做好每一件事,读好每一本书,天道酬勤
publish订阅者模式
2022-03-17 / 1 min read


订阅者模式中,我们加入了一个交换机,然后这个交换机会把消息转发给所有的消费者,所有的消费者拿到的消息都是一样的。

消息发送

在这个模式中,我们首先要创建一个exchange,和simple模式不同的地方,在simple模式中我们创建的是队列

然后是对消息的发送也有不同的地方,在simple模式中,我们的key是队列名称。

消息处理

在消息处理的时候,我们首先还是要先创建交换机,然后再进行后面的处理。
然后我们创建一个队列

这里我们可以创建出一个队列q,然后这个队列是没有名称的,然后在下面的信息处理中,进行处理。这里我们可以看到绑定到了交换机中,然后进行消息的消费。

对于这个模式来说,我们消费者和生产者都是通过exchange交换机进行绑定传输消息的。
上面就是对订阅者模式的讲解