大家好,我是指北君。
今天指北君带领大家接着学习RabbitMQ,了解RabbitMQ的五大通信模型之一的发布订阅模型;接下来还会有关于RabbitMQ的系列教程,对你有帮助的话记得关注哦~
发布订阅模型
上一篇文章中,简单的介绍了一下RabbitMQ的work模型。这篇文章来学习一下RabbitMQ中的发布订阅模型。
发布订阅模型(Publish/Subscribe):简单的说就是队列里面的消息会被多个消费者同时接受到,消费者接收到的信息一致。
发布订阅模型适合于做模块之间的异步通信。
适用场景
1、发送并记录日志信息
2、springcloud的config组件里面通知配置自动更新
3、缓存同步
4、微信订阅号
演示
生产者
消费者
测试
先启动2个消费者,再启动生产者
可以看出来消费者1和消费者2接收到的消息是一模一样的,每个消费者都收到了生产者发送的消息;
发布订阅模型,用到了一个新的东西-交换机,这里也解释一下相关方法的参数:
小结
本文到这里就结束了,介绍了RabbitMQ通信模型中的发布订阅模型,适合于做模块之间的异步通信。