通过 Rebus 2 订阅 rabbitmq 队列

Question

在我的应用程序中，我正在尝试根据您使用下一个代码的建议在“Rebus”主题交换中订阅“MyQueue”队列，该队列已绑定到它：

    async void InitializeBus()
    {

    var busConfigurer = Configure.With(new CastleWindsorContainerAdapter(_container))
            .Logging(l => l.Log4Net())
            .Transport(t => t.UseRabbitMq(_connectionString, "MyQueue")
                .Declarations(false, false, false)
                    .ExchangeNames("RebusDirect", "Rebus")
                        .Prefetch(5))
            .Options(o => {
                o.SimpleRetryStrategy(_errorQueue);
                if (_enableLegacyCompatibility)
                {
                    o.EnableLegacyCompatibility();
                }
            })
            .Serialization(s => s.Decorate(c => new XmlMessageSerializer()));

        var bus = busConfigurer.Start();`
        await bus.Advanced.Topics.Subscribe("MyQueue");
    }

结果我有一个例外

AMQP 操作被中断：AMQP 关闭原因，由 对等体，code=404，text="NOT_FOUND - vhost '/' 中没有队列 'MyQueue'"， classId=50, methodId=20, cause=

虽然队列存在。

如果我删除 .Declarations(false, false, false) 并等待 bus.Advanced.Topics.Subscribe("MyQ​​ueue");它将在 RebusDirect 交换中的 rabbit 中创建新的 MyQueue 并开始收听它。 rabbit的连接字符串是正确的。

问题可能出在哪里？配置不当还是订阅方式不正确？

提前致谢。

Answer 1

第一件事 - 如果您是 Rebus 和 RabbitMQ 专家用户并且想要实现一些不寻常的事情，您可能应该只跳过自动声明。

Declarations 部分应该是.Declarations(true, true, true)（或者干脆省略，因为默认始终确保自动声明交换、队列和绑定）。

接下来的事情——生产线

await bus.Advanced.Topics.Subscribe("MyQueue");

表示你在混淆事物，因为MyQueue是一个队列，但是当你Subscribe某事物时，你订阅了一个TOPIC。

“主题”基本上只是一个任意字符串，例如“东西”。发布者可以使用该主题发布内容，如下所示：

await bus.Advanced.Topics.Publish("thingamabob", new GizmoDoodle());

然后将GizmoDoodle 消息传递到当前绑定到该主题的队列。

为了“绑定话题”，你

await bus.Advanced.Topics.Subscribe("thingamabob");

在 RabbitMQ 中建立绑定。

我建议您从头开始（无需以任何方式自定义 Rebus 对 RabbitMQ 的使用）并查看 Rebus 在 RabbitMQ 中创建了什么以使其工作。如果你还没有这样做，你绝对应该去启用RabbitMQ Management Plugin。