RabbitMQ怎样能实现多个队列由一个消费者来接收消息
2016-09-05 · 知道合伙人互联网行家
护肤达人IT宅族
知道合伙人互联网行家
采纳数：5637
获赞数：17441
毕业于曲阜师范大学，学士学位。互联网行业2年从业经验，读过SEO相关书籍。现任爱家网SEO优化专员。
向TA提问 私信TA
关注
![]()
展开全部
1、笨拙点方法，就是轮循，consume的阻塞监听可以设置timeout，通过设置一个较小的timeout，可以轮流监听几个channel，变相实现监听多个queue，对性能要求不是很高，可以使用这种方法
2、还有个办法就是先取出一个队列的消息数，然后循环的都读出后，转去读另一个队列，所有队列如果都没有消息了，就这样循环等待着
3、还有一个专业人士的回答，但是我还没有完全理解：
消费者（consumer）这是个业务层的概念，而消费或者说订阅（也就是 consume）是 AMQP 协议层的东西，所以，你问一个消费者能否订阅多个queue，答案是当然可以。方案也就一种，按照协议的流程分别向不同的 queue 进行 consume。至于是使用多线程方式来处理，还是使用事件驱动的方式（单线程）来处理这就取决于实现了。
如果对多线程控制能力不是很强，建议不要用这种方式，太专业了
4、这个问题后来我仔细想过，也许可以在应用层进行一下重新设计，可以用线程池作为多个consumer只读取出消息，不进行处理，然后publish进另一个队列，然后用由一个consumer来处理消息
2、还有个办法就是先取出一个队列的消息数，然后循环的都读出后，转去读另一个队列，所有队列如果都没有消息了，就这样循环等待着
3、还有一个专业人士的回答，但是我还没有完全理解：
消费者（consumer）这是个业务层的概念，而消费或者说订阅（也就是 consume）是 AMQP 协议层的东西，所以，你问一个消费者能否订阅多个queue，答案是当然可以。方案也就一种，按照协议的流程分别向不同的 queue 进行 consume。至于是使用多线程方式来处理，还是使用事件驱动的方式（单线程）来处理这就取决于实现了。
如果对多线程控制能力不是很强，建议不要用这种方式，太专业了
4、这个问题后来我仔细想过，也许可以在应用层进行一下重新设计，可以用线程池作为多个consumer只读取出消息，不进行处理，然后publish进另一个队列，然后用由一个consumer来处理消息
已赞过
已踩过<
评论
收起
你对这个回答的评价是？
网易云信
2023-12-06 广告
很高兴能回答您的问题。以下是一段针对“一对一消息组件”的描述，字数在200字左右：该组件支持用户之间的私密交流，让沟通更加直接和高效。通过它，您可以向特定对象发送消息，并实时查看消息状态，包括对方是否已读或未读。同时，该组件还支持富文本消息...
点击进入详情页
本回答由网易云信提供
展开全部
创建多个队列
消费者创建同等个数的channel同时绑定到消息队列上
使用消息模式处理各个通道上的消息
关键在于一个消费者创建N个channel绑定，实现多个通道消息的异步处理
已赞过
已踩过<
评论
收起
你对这个回答的评价是？
推荐律师服务：
若未解决您的问题，请您详细描述您的问题，通过百度律临进行免费专业咨询
