mq消息队列阻塞怎么办 RabbitMQ怎样能实现多个队列由一个消费者来接收消息?
RabbitMQ怎样能实现多个队列由一个消费者来接收消息?
1. 笨拙的方法是循环。消耗的阻塞监视可以设置超时。通过设置较小的超时,可以依次监视多个通道,也可以变相监视多个队列。性能要求不是很高,所以可以采用这种方法
2。另一种方法是先取出一个队列中的消息数,然后在循环中读出消息,然后切换到另一个队列如果所有队列中都没有消息,它们将在此循环中等待
3。有专业人士的回答,但我还没有完全理解:
消费者是业务层的概念,消费或订阅是AMQP,因此,如果你问消费者是否可以订阅多个队列,答案当然是。解决方案也是一种,根据协议的进程,分别向不同的队列进行查询。是使用多线程还是事件驱动(单线程)取决于实现。
如果控制多线程的能力不是很强,建议不要使用这种方法,这太专业了
4。后来我仔细考虑了这个问题。也许我可以在应用层重新设计它。我可以将线程池用作只读消息的多个使用者,而不处理它们。然后将它们发布到另一个队列中,并使用一个使用者来处理消息
PS-Ef | grep rabbit查看rabbit进程并根据进程判断安装路径
/usr/lib/rabbit MQ/lib/rabbit MQ_uuserver-3.6.13
输入rabbit的安装路径,文件列表结构如下进入SBIN目录
输入命令rabbitmqctl list超过20000个数据
关闭应用程序
rabbitmqctl stop应用程序
执行清除命令
rabbitmqctl reset
7
启动应用程序
rabbitmqctl start应用程序
8
验证rabbitmqctl list队列
mq消息队列阻塞怎么办 rabbitmq查看队列内容 rabbitmq阻塞
版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。