publish订阅者模式
2022-03-17 / 1 min read
订阅者模式中,我们加入了一个交换机,然后这个交换机会把消息转发给所有的消费者,所有的消费者拿到的消息都是一样的。
消息发送
在这个模式中,我们首先要创建一个exchange,和simple模式不同的地方,在simple模式中我们创建的是队列
然后是对消息的发送也有不同的地方,在simple模式中,我们的key是队列名称。
消息处理
在消息处理的时候,我们首先还是要先创建交换机,然后再进行后面的处理。
然后我们创建一个队列
这里我们可以创建出一个队列q,然后这个队列是没有名称的,然后在下面的信息处理中,进行处理。这里我们可以看到绑定到了交换机中,然后进行消息的消费。
对于这个模式来说,我们消费者和生产者都是通过exchange交换机进行绑定传输消息的。
上面就是对订阅者模式的讲解