Tag: rabbitmq exchange

使用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); } } 有没有办法在MassTransit中使用routingkey配置直接或主题交换?