代码中未指定交易所的 MassTransit ACCESS_REFUSED

Question

我正在使用一个非常基本的示例来测试我的 MassTransit 通过 C# 与 rabbitMq 的连接。每当我运行此代码以连接到我的 rabbitMq 端点时，只要我将通配符设置为权限，它就可以正常工作。但是，当我在 rabbitMq admin 中添加权限以仅允许此用户访问 test 事件时，此代码将失败。

由于某种原因，它会首先尝试连接到我猜想是由 MassTransit 生成的交换名称：

RabbitMQ.Client.Exceptions.OperationInterruptedException: 'The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=403, text="ACCESS_REFUSED - access to exchange '*ComputerName*_dotnet_bus_73451gfsgerqwrefxfddgf' in vhost '/' refused for user 'user'", classId=40, methodId=10, cause='

所以交换*ComputerName*_dotnet_bus_73451gfsgerqwrefxfddgf，之后它将尝试连接到test交换。当然，我可以将ComputerName.... 交换添加到权限中，但是对于每台尝试运行此代码的计算机都需要这样做。为什么 MassTransit 试图连接到这个交易所？代码不正确还是这正是 MassTransit 的工作原理？

这是测试应用程序的代码（我稍微修改了一下，所以它可能无法立即运行，但总的来说代码运行良好）：

using System;
using MassTransit;

namespace Test
{
    public class Testing
    {
        public string Id { get; set; }
    }
}

namespace Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
            {
                var host = sbc.Host(new Uri("rabbitmq://servername"), h =>
                {
                    h.Username("user");
                    h.Password("user");
                });

                sbc.ReceiveEndpoint(host, "test", ep =>
                {
                    ep.Handler<Testing>(context =>
                    {
                        return Console.Out.WriteLineAsync($"Received: {context.Message.Id}");
                    });
                });
            });

            bus.Start();

            // For testing purposes, we send a message ourselves.
            bus.Publish(new Testing { Id = "X" });

            Console.WriteLine("Waiting for messages. Press any key to exit");
            Console.ReadKey();

            bus.Stop();
        }
    }
}

rabbitMq admin 用户权限的图片：

Answer 1

代码不正确还是这正是 MassTransit 的工作原理？

这很可能就是 MassTransit 的运作方式。请参阅另一个问题：Prevent MassTransit from creating a RabbitMQ exchange for a consumer host

奇怪的是，我在 MassTransit 文档中的任何地方都找不到此信息。

您必须授予 configure 权限才能使用包含字符串 dotnet_bus 的交换。很可能需要其他权限，例如 read 和 write。

---

_{注意：RabbitMQ 团队会监控 rabbitmq-users mailing list，并且有时只回答 StackOverflow 上的问题。}