这是更新后的代码，我仍然没有添加@Solowalker建议的更改，但如果你把所有这些放在一起，你就可以得到完整的答案。我会尝试更新代码，一旦一切都是工作。

import os
from locust import task, TaskSet, User, run_single_user
from locust.clients import HttpSession
from kombu import Connection, Exchange, Queue

class KombuClient(HttpSession):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.connection = Connection(
            hostname=os.getenv(
                "LOCUST_AMQP_CONFIG", "amqp://guest:guest@localhost:5672//"
            ),
        )
        self.channel = self.connection.channel()

    def send_message(self, message):
        exchange = Exchange(
            name=os.getenv("LOCUST_AMQP_EXCHANGE", "test_exchange"),
            type="direct",
        )
        queue = Queue(
            name=os.getenv("LOCUST_AMQP_QUEUE", "test_queue"),
            exchange=exchange,
            routing_key=os.getenv("LOCUST_AMQP_KEY", "test_key"),
        )
        queue.maybe_bind(self.connection)
        queue.declare()

        producer = self.connection.Producer(
            exchange=exchange,
            routing_key=os.getenv("LOCUST_AMQP_KEY", "test_key"),
        )
        producer.publish(message)
        print("INFO: Sent message: '{}'".format(message))

    def close_connection(self):
        self.connection.release()

class UserBehavior(TaskSet):
    @task
    def send_hello_message(self):
        self.client.send_message(message="Hello World!")

class RabbitMQUser(User):
    host = "http://localhost"
    tasks = [UserBehavior]
    min_wait = 5000
    max_wait = 9000
    abstract = True

    def __init__(self, environment):
        super().__init__(environment)
        self.client = KombuClient(self.host, user=self, request_event=environment.events.request)

if __name__ == "__main__":
    run_single_user(RabbitMQUser)

这个问题在Locust常见问题解答中有介绍，示例可以在in the docs中找到。您需要做的是触发包含所有请求信息和统计信息的request事件。您使用的是HttpUser，但覆盖了client，所以您将它变成了一个普通的User，它不知道您在做什么，您需要告诉它记录什么以及何时记录。
示例取自gRPC场景的文档：

self.environment.events.request.fire(
        request_type="grpc",
        name=call_details.method,
        response_time=(time.perf_counter() - start_perf_counter) * 1000,
        response_length=response_length,
        response=response,
        context=None,
        exception=exception,
    )

用你自己的统计数据来打电话。请参阅链接文档页面以了解参数的含义，但由于您正在做一个自定义用户，您可以使它们成为并意味着任何您想要的。