MassTransit：如何在Request Client中指定队列名称？

解决方法 #

你需要在请求客户端的配置中明确指定目标Worker队列的地址，以下是两种常用的配置方式：

方式一：直接在AddRequestClient中指定目标队列 #

修改发送端的AddMassTransit配置，在注册请求客户端时传入目标队列的Uri，确保和Worker端配置的QueueName完全一致：

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Durable = false;
        cfg.AutoDelete = true;
        cfg.SetQueueArgument("x-expires", null);

        // 配置和Worker端一致的RabbitMQ Host及SSL参数
        cfg.Host("<Address>", 5671, "/", h =>
        {
            h.UseSsl(s =>
            {
                s.CertificatePath = rabbitMqOptions.CurrentValue.CertificatePath;
                s.UseCertificateAsAuthenticationIdentity = true;
                s.ServerName = rabbitMqOptions.CurrentValue.ServerName;
                s.Protocol = System.Security.Authentication.SslProtocols.Tls12;
                s.AllowPolicyErrors(SslPolicyErrors.RemoteCertificateNameMismatch);
                s.CertificatePassphrase = "";
            });
        });
    });

    // 指定请求发送到的目标队列地址
    x.AddRequestClient<Worker_Request>(
        new Uri($"rabbitmqs://<Address>/{massTransitOptions.CurrentValue.QueueName}"), 
        configure =>
        {
            configure.Timeout = TimeSpan.FromSeconds(30); // 根据业务需求设置超时时间
        });
});

注意：Uri要使用rabbitmqs协议（和Worker端的SSL配置匹配），地址和队列名必须和Worker端的QueueName保持一致。

方式二：全局配置请求客户端的默认目标地址 #

如果有多个请求客户端需要指向同一个队列，可以在RabbitMQ的全局配置中设置默认地址：

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Durable = false;
        cfg.AutoDelete = true;
        cfg.SetQueueArgument("x-expires", null);

        cfg.Host("<Address>", 5671, "/", h =>
        {
            // 同Worker端的SSL配置
        });

        // 为Worker_Request类型的请求指定默认目标队列
        cfg.SetRequestClientDefaultAddress<Worker_Request>(
            new Uri($"rabbitmqs://<Address>/{massTransitOptions.CurrentValue.QueueName}"));
    });

    // 注册请求客户端，会自动使用上面配置的默认地址
    x.AddRequestClient<Worker_Request>();
});

核心说明 #

你之前看到的临时队列（temporary=true）是因为没有指定目标队列时，MassTransit的默认行为——创建临时队列来处理请求。配置指定队列后，请求会被发送到你设定的Worker队列，所有监听该队列的Worker实例都会参与消费，实现多Worker共享RabbitMQ实例的需求。

内容的提问来源于stack exchange，提问作者user621713