小编Sye*_*yed的帖子

使用 MassTransit 使用交换和路由密钥发布消息

我已经关注 MassTransit 几个星期了,我对各种可能性很好奇。但是,我似乎无法完全正确地理解这些概念。

预期行为 我想将消息发布到“直接”交换与路由键绑定到两个不同的队列以执行其他活动。

当我使用 MassTransit 尝试相同的逻辑以获得更好的可扩展性时。我发现 MassTransit 根据带有扇出类型的队列名称创建自己的交换。

通过交换和路由密钥发布消息的经典代码

using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                channel.ExchangeDeclare(exchange, "direct");

                var body = Encoding.UTF8.GetBytes(message);

                channel.BasicPublish(exchange, routingKey, null, body);
                Console.WriteLine(" [x] Sent {0}", message);
            }
        }
Run Code Online (Sandbox Code Playgroud)

有没有办法在 MassTransit 中使用路由密钥配置直接或主题交换?

c# masstransit message-queue rabbitmq-exchange

9
推荐指数
2
解决办法
9349
查看次数