分类：消息发布

2021
07-02

C#用RabbitMQ实现消息订阅与发布

目录Fanout交换机模型RabbitMQ控制台操作新增两个队列绑定fanout交换机示例效果图核心代码消息发布消息订阅Fanout交换机模型扇形交换机，采用广播模式，根据绑定的交换机，路由到与之对应的所有队列。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。Fanout交换机转发消息是最快的。RabbitMQ控制台操作新增两个队列在同一个Virtualhost下新增两个队列Q1,Q... 继续阅读 >
2021
03-02

C# 基于消息发布订阅模型的示例(下)

一背景在上面的一篇文章中我们介绍了一个完整地基于消息发布和订阅的模型，这篇文章我将介绍一种简单的基于消息的发布和订阅模型，在这个模型中我们将通过构建一个Publisher类来完成对特定的事件和事件订阅进行封装，这个是一个更加轻量级别的方式，使用这个的主要目的是降低类之间彼此的耦合程度，从而方便代码的扩展和访问，最终使代码结构更加合理。我们首先来看看具体的Publisher类的构成，后面我们将会对这个类做一... 继续阅读 >
2021
03-02

C# 基于消息发布订阅模型的示例(上)

在我们的开发过程中，我们经常会遇到这样的场景就是一个对象的其中的一些状态依赖于另外的一个对象的状态，而且这两个对象之间彼此是没有关联的，及两者之间的耦合性非常低，特别是在这种基于容器模型的开发中遇到的会非常多，比如Prism框架或者MEF这种框架中，而我们会发现在这样的系统中我们经常使用一种Publish和Subscribe的模式来进行交互，这种交互有什么好处呢？基于带着这些问题的思考，我们来一步步来剖析！首先第... 继续阅读 >