码迷,mamicode.com
首页 > 其他好文 > 详细

RibbitMQ 大数据分布式下的消息队列思

时间:2018-10-25 12:10:46      阅读:244      评论:0      收藏:0      [点我收藏+]

标签:nbsp   一个   服务启动   开启   情况下   分布   lin   多个   消息队列   

对于RibbitMQ  消息队列

使用:

定义一个队列,作为消息队列

生产者,生产消息添加入队列

消费者,监听到消息队列中有消息后,取出消息处理消息

 

每台服务器也可以配置多个消费者去处理消息

此处向Handler中,增加的消费者对象,类似于观察者模式

那是不是可以改为, Handler 中,持有消费者对象,改为持有消费者对象工厂或者池

在启动消费者线程去执行任务时, 主线程或开启监听线程,来监听消息处理的速度, 根据消息处理的速度,调用消费者工厂,生成更多的消费者去处理任务

 

同理,如果是服务器集群,在当今微服务盛行的情况下, 微服务启动非常快,

也可以配置一个监听服务器,用来监听每个消息队列处理的任务的速度,

然后根据消息处理的速度,启动更多的服务器去处理任务

 

RibbitMQ 大数据分布式下的消息队列思

标签:nbsp   一个   服务启动   开启   情况下   分布   lin   多个   消息队列   

原文地址:https://www.cnblogs.com/li-mzx/p/9848654.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!