我已经花了几个星期的时间研究 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中配置直接或主题交换并使用路由键?