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

Posted 2021-01-15 li-mzx

对于RibbitMQ  消息队列

使用：

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

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

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

 

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

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

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

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

 

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

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

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