8 SpringBoot整合RocketMQ实现消费者广播模式和负载均衡模式

梦里梦外; 2021-09-09 14:28 371阅读 0赞

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_20_color_FFFFFF_t_70_g_se_x_16]

如上图，假如我们有多个消费者，消息生产者发送的消息，是每一个消费者都消费一次呢？还是通过一些机制，比如轮询机制，每个消息只被某一个消费者消费一次呢？

这里涉及到消费者的消费模式，一种是广播模式，还有一种是负载均衡模式；

**广播模式是每个消费者，都会消费消息；**

**负载均衡模式是每一个消费只会被某一个消费者消费一次；**

我们业务上一般用的是负载均衡模式，当然一些特殊场景需要用到广播模式，比如发送一个信息到邮箱，手机，站内提示；

我们可以通过`@RocketMQMessageListener`的`messageModel`属性值来设置，`MessageModel.BROADCASTING`是广播模式，`MessageModel.CLUSTERING`是默认集群负载均衡模式；

我们先集群负载均衡测试，加上`messageModel=MessageModel.CLUSTERING`

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pJU7vtRJ-1630718197196)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826143726996.png)\]][img-pJU7vtRJ-1630718197196_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826143726996.png]

我们启动两个实例，先启动一个RocketmqConsumer消费者实例，端口8084

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_20_color_FFFFFF_t_70_g_se_x_16 1]

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-KhJ7qXkH-1630718197201)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144503441.png)\]][img-KhJ7qXkH-1630718197201_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144503441.png]

编辑配置，

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-gkYvQ9bX-1630718197202)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144534662.png)\]][img-gkYvQ9bX-1630718197202_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144534662.png]

把`Single instance only`的勾选去掉，然后点OK按钮；

然后修改代码，启动端口改成`8085`

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-oAu2vHu0-1630718197203)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144703314.png)\]][img-oAu2vHu0-1630718197203_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144703314.png]

消费者输出信息改下；

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ZSmJQDv2-1630718197203)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144718993.png)\]][img-ZSmJQDv2-1630718197203_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144718993.png]

最后我们再启动一个消费者实例；

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-RHjmAsuy-1630718197204)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144825339.png)\]][img-RHjmAsuy-1630718197204_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144825339.png]

我们启动消息生产者测试：

启动后，两个消费者控制台分别输出：

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-fGuL0uTA-1630718197204)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144922059.png)\]][img-fGuL0uTA-1630718197204_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144922059.png]

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-K1rio054-1630718197205)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826144930076.png)\]][img-K1rio054-1630718197205_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144930076.png]

根据实验，我们发现消息被两个消费者负载均衡随机消费掉了。

我们再来测试下广播模式；修改`messageModel=MessageModel.BROADCASTING`

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-medAWvti-1630718197206)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826150836810.png)\]][img-medAWvti-1630718197206_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826150836810.png]

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-0jxmVwqf-1630718197207)(C:\\Users\\java1234\\Desktop\\RocketMQ\\课件\\RocketMQ分布式消息队列课件.assets\\image-20210826150846427.png)\]][img-0jxmVwqf-1630718197207_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826150846427.png]

测试发现，两个消费者客户端把消息都各自消费了一遍。广播模式测试OK；

> 微信搜一搜公众号【java1234】关注这个放荡不羁的程序员，关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20210907/1312dacc786748cbaad6f0ff4019cc9f.png
[img-pJU7vtRJ-1630718197196_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826143726996.png]: /images/20210907/799e3963ee1a432ca366b59083568d41.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20210907/dbfa172641914493a7b2fcd76ad47d65.png
[img-KhJ7qXkH-1630718197201_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144503441.png]: /images/20210907/d40bcb3f1b1d499d9b46309a38881952.png
[img-gkYvQ9bX-1630718197202_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144534662.png]: /images/20210907/fe3f7298fc9746af843c7b74ec06ca32.png
[img-oAu2vHu0-1630718197203_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144703314.png]: /images/20210907/5992feef8b91463e9ec138e867a4bee7.png
[img-ZSmJQDv2-1630718197203_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144718993.png]: /images/20210907/f6e575499b514f999d59e058875a8937.png
[img-RHjmAsuy-1630718197204_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144825339.png]: /images/20210907/224da13c0aab49dfaa41580ad1aeb201.png
[img-fGuL0uTA-1630718197204_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144922059.png]: /images/20210907/348686594e9a4573b22ed3857cbb82b3.png
[img-K1rio054-1630718197205_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826144930076.png]: /images/20210907/8f137eddd76348d19fc79ad59152383e.png
[img-medAWvti-1630718197206_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826150836810.png]: /images/20210907/02ca521f1a884bb58b4d62bf9fab5fbc.png
[img-0jxmVwqf-1630718197207_C_Users_java1234_Desktop_RocketMQ_RocketMQ_.assets_image-20210826150846427.png]: /images/20210907/340f9d07a7fe457babe38db998e166ab.png