发布订阅和生产者消费者模型的区别？

订阅或者消费者都是通过 poll 轮询去检查 MQ 中是否有消息的吗？主流的 MQ（Kafaka、rabbitMQ、RocketMQ），从 MQ 中取任务是的 API 是阻塞的还是非阻塞的？

参考文章：
消息队列及常见消息队列介绍

kafka rabbitmq rocketmq 消息队列设计模式

阅读 2.2k

撰写回答

你尚未登录，登录后可以

和开发者交流问题的细节
关注并接收问题和回答的更新提醒
参与内容的编辑和改进，让解决方法与时俱进

推荐问题

使用rabbitMQ作为vue项目获取数据的方法，每次调用后都会残留队列缓存在服务器上，这该怎么处理？
最开始进入页面就有6个接口，每次进主页都残留一些队列，使用channel.deleteQueue(replyToQueueInfo.queue)在responsePromise后删除队列，程序就没有数据了剩下的接口也会卡住，加上定时器也没什么用。在其后的finally{}里面删除队列，有些删了有些还留在后台。
1 回答1.3k 阅读✓ 已解决
Spring Boot 3.2.2 连接 RocketMQ 5.1.2 报错如何解决？
Started container failed. DefaultRocketMQListenerContainer{consumerGroup='topic_02_CONSUMER', namespace='', namespaceV2='', nameServer='192.168.50.20:9876', topic='topic_02', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='*', messageModel=CLUSTERING', tlsEnable=false, instanceNam...
1 回答731 阅读✓ 已解决
如何在RabbitMQ中处理验证码发送达到上限后的无限重复消费问题？
想用rabbitmq完成验证码发送业务但是超过设置的上限后就开始无限重复消费!问过gemini和智谱之类的ai，都是原地改来改去，改了一天现在人已经晕了。 {代码...}
1 回答1.1k 阅读
请问如何设计一个有大量输入参数和快速反应输出结果功能的函数？
请问：1、我觉得这样的场景历史上肯定有遇到过，请问是否有比较成功的经验借鉴呢？2、是否有好的设计模式来进行设计此功能呢？3、推荐使用什么语言实现此功能呢？除了C/C++，是否还有其他的语言推荐呢？
1 回答1.3k 阅读

相似问题

rocketmq队列和消费者关系
1 回答8.9k 阅读
消费者监听消息队列
3 回答4.9k 阅读
kafka的consumer是否可以订阅nsq的消息？
1 回答3.4k 阅读✓ 已解决
rabbitmq 和 kafka 都不支持生产者批量插入消息吗？
2 回答2.5k 阅读
spring 消息队列如何根据消费者负载进行消息调度
1 回答3.9k 阅读✓ 已解决

找不到问题？创建新问题

发布订阅和生产者消费者模型的区别？

你尚未登录，登录后可以

使用rabbitMQ作为vue项目获取数据的方法，每次调用后都会残留队列缓存在服务器上，这该怎么处理？

Spring Boot 3.2.2 连接 RocketMQ 5.1.2 报错如何解决？

如何在RabbitMQ中处理验证码发送达到上限后的无限重复消费问题？

请问如何设计一个有大量输入参数和快速反应输出结果功能的函数？