消息中间件MQ(三)ActiveMQ

一、request-Respoinse模式

消息中间件MQ(三)ActiveMQ

request-Respoinse模式生产者

给生产者配置一个监听器

消息中间件MQ(三)ActiveMQ

生产者接受代码

消息中间件MQ(三)ActiveMQ

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

消息中间件MQ(三)ActiveMQ

request-Respoinse模式-消费者

消费者配置

消息中间件MQ(三)ActiveMQ

消费者响应代码

消息中间件MQ(三)ActiveMQ

消息中间件MQ(三)ActiveMQ

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

消费者

消息中间件MQ(三)ActiveMQ

生成者

消息中间件MQ(三)ActiveMQ

二、嵌入式MQ

消息中间件MQ(三)ActiveMQ

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

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

消息中间件MQ(三)ActiveMQ

消息中间件MQ(三)ActiveMQ

消息中间件MQ(三)ActiveMQ
说明1:activemq_acks 订阅关系

说明2:activemq_lock 与集群有关

说明3:activemq_msgs 队列消息内容

消息持久订阅

生产者不需要改动(下图这个要关掉)

消息中间件MQ(三)ActiveMQ

消费者

消息中间件MQ(三)ActiveMQ

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

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

消息可靠性

生产者 与 MQ 可靠性

 消息中间件MQ(三)ActiveMQ

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

消息中间件MQ(三)ActiveMQ

消费者 与 MQ 可靠性

应答模式1 - 自动应答

消息中间件MQ(三)ActiveMQ

应答模式2 - 手动应答

消息中间件MQ(三)ActiveMQ

应答模式3-批量应答

消息中间件MQ(三)ActiveMQ

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

应答模式4-事务模式

消息中间件MQ(三)ActiveMQ

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

上一篇:zabbix使用ipv6地址监控agent客户端


下一篇:[springboot2-4] 拦截器和文件上传