标签：消费者 生产者 应答 request 模式 MQ 消息中间件 ActiveMQ

一、request-Respoinse模式

request-Respoinse模式生产者

给生产者配置一个监听器

生产者接受代码

生成者发送消息时，需要告诉消费者如何应答

request-Respoinse模式-消费者

消费者配置

消费者响应代码

spring boot 集成request-Respoinse模式生产者

消费者

生成者

二、嵌入式MQ

说明：生产者和消费者使用方式代码都一样。

三、消息存储的持久化机制

说明1：activemq_acks 订阅关系

说明2：activemq_lock 与集群有关

说明3：activemq_msgs 队列消息内容

消息持久订阅

生产者不需要改动（下图这个要关掉）

消费者

条件1：消息本身是一个持久化信息

条件2：消费者需要是一个持久化消费者

消息可靠性

生产者 与 MQ 可靠性

 

说明：这种模  式下，发送一个，产生一条队列

消费者 与 MQ 可靠性

应答模式1 - 自动应答

应答模式2 - 手动应答

应答模式3-批量应答

说明：这种模式会出现重复消息的问题（已经处理了三条还没提交，这个时候执行第四条，报错了。这个时候MQ会重新发前三条消息）

应答模式4-事务模式

说明：跟生产者的事务模式使用方式一样的。

标签：消费者,生产者,应答,request,模式,MQ,消息中间件,ActiveMQ
来源： https://blog.csdn.net/qq_38377190/article/details/112307165

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。