这篇文章主要介绍“Springboot中RocketMQ怎么实现广播消息”，在日常操作中，相信很多人在Springboot中RocketMQ怎么实现广播消息问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Springboot中RocketMQ怎么实现广播消息”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！RocketMQ消息模式主要有两种：广播模式、集群模式（负载均衡模式）广播模式是每个消费者，都会消费消息；负载均衡模式是每一个消费只会被某一个消费者消费一次；我们业务上一般用的是负载均衡模式，当然一些特殊场景需要用到广播模式，比如发送一个信息到邮箱，手机，站内提示；我们可以通过@RocketMQMessageListener的messageModel属性值来设置，MessageModel.BROADCASTING是广播模式，MessageModel.CLUSTERING是默认集群负载均衡模式下面来介绍下 springboot+rockermq 整合实现 广播消息创建Springboot项目，添加rockermq 依赖配置rocketmq# 端口
server:
port: 8083# 配置 rocketmq
rocketmq:
name-server: 127.0.0.1:9876
#生产者
producer:
#生产者组名，规定在一个应用里面必须唯一
group: group1
#消息发送的超时时间 默认3000ms
send-message-timeout: 3000
#消息达到4096字节的时候，消息就会被压缩。默认 4096
compress-message-body-threshold: 4096
#最大的消息限制，默认为128K
max-message-size: 4194304
#同步消息发送失败重试次数
retry-times-when-send-failed: 3
#在内部发送失败时是否重试其他代理，这个参数在有多个broker时才生效
retry-next-server: true
#异步消息发送失败重试的次数
retry-times-when-send-async-failed: 3生产端：新建一个 controller 来做消息发送生产端按正常发送逻辑发送消息即可创建两个消费者来消费消息我们先集群负载均衡测试，加上messageModel=MessageModel.免费云主机域名CLUSTERING消费者1：消费者2： 与消费者1在 同一个consumerGroup 和 topic启动服务，测试 集群模式消费集群模式测试： 两个消费者平摊 消息把上面两个消费者的 messageModel 属性值修改成 广播模式消费者1：消费者2： 与消费者1在 同一个consumerGroup 和 topic重启服务，测试 广播模式消费到此，关于“Springboot中RocketMQ怎么实现广播消息”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注百云主机网站，小编会继续努力为大家带来更多实用的文章！
这篇文章主要介绍了设计API接口时要注意什么的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇设计API接口时要注意什么文章都会有所收获，下面我们一起来看看吧。 为了防止API接口中的数据被篡改，很多时候我们需要对API接口做签名。接…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
