EasyNetQ支持的最简单的消息传递模式是发布/ 订阅。这种模式是消除消费者信息提供者的绝佳方式。出版商简单地向全世界说,“这已经发生了”或“我现在有了这些信息”。它不关心是否有人正在倾听,他们可能是谁或他们所在的位置。我们可以添加和删除特定消息类型的订阅者,而无需重新配置发布者。我们还可以让许多发布商发布相同的消息,再次添加和删除发布者,而无需重新配置任何其他发布者或订阅者。
要使用EasyNetQ发布(假设您已经创建了IBus实例):
- 创建消息的实例,它可以是任何可序列化的.NET类型。
- 在IBus上调用Publish方法,将其传递给您的消息实例。
这是代码......
var message = new MyMessage { Text = "Hello Rabbit" };
bus.Publish(message);
为确保邮件传递,请使用Publisher确认。
一个警告
发布/订阅模式中的参与者彼此无知。出版商只是简单地向全世界说'这已发生',订阅者告诉全世界'我关心这个'。在这个模型中,没有人关心特定事件是好的。消息可能有一个订阅者,可能有200个订阅者,或者可能没有订阅者。出版商不应该在意。EasyNetQ实现了这种模式。如果您开始发布并且没有订阅者从未启动过,那么您的消息就会消失。这是设计的。