Rabbit MQ的广播模式是什么意思


本篇内容主要讲解“Rabbit MQ的广播模式是什么意思”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Rabbit MQ的广播模式是什么意思”吧!最近做了一个需求,需要一个接口,可以给3万多人发消息,因为人数较多,用一条线程同步发送肯定是不行的,如果是一条线程,同步发送的话,哪怕有一条数据出现了问题,都会导致本次发送的失败,所以,想到了用Rabbit MQ的广播模式来做。 广播模式其实就是将你要发送的消息放到“交换机”中,然后对应的队列去交换机中获取消息给消费者(接收消息的一端)消费。如下图所示:(emmm 图片是我在网上找的,自己画的太丑了)在上述过程中,主线程执行到第一步之后就可以返回了,这是一个异步的过程,不需要等待队列去交换机中 香港云主机取完数据,“主线程返回“和“队列取数据给消费者”这两个过程是同时进行的。这样的话,发送消息的时候就不必等到3万多条消息都发送完成才能继续进行下一步了。功能大概介绍了一下,接下来就是代码了,我只做一个简单的记录首先是一个配置类上边这个用来创建交换机和队列,并将队列和交换机进行绑定下边这个是消息生产者再添加一个辅助类,存常量(别问为啥,大家都是这么做的哈哈哈哈)最后是消息的消费者到此就完事了,只需要在你的业务中调用生产者就行了,消息会被队列自动接收,而接收到的消息需要怎么处理,就是业务逻辑的事了。上边只是一个最简单的例子,也只用了一个队列,如果想要添加多个队列,需要在配置类中进行声明,并进行绑定,此外,在调用生产者的时候,需要将rabbitTemplate.convertAndSend()方法的第二个参数去掉。ok!到此,相信大家对“Rabbit MQ的广播模式是什么意思”有了更深的了解,不妨来实际操作一番吧!这里是开发云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

相关推荐: Docker中怎么配置nacos

Docker中怎么配置nacos,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这 香港云主机篇文章希望你能解决这个问题。正文拉取镜像到本地docker新建nacos容器其中env参数是指定容器所处环境,这里是指建立单机版的na…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 07/29 21:20
下一篇 07/29 21:20

相关推荐