首页 > 其他 > 详细

ActivityMQ消息中间件【待完成】

时间:2019-09-15 16:29:10      阅读:104      评论:0      收藏:0      [点我收藏+]

1,MQ的引入

使用场景,将耗时的通知业务交给消息中间件【业务逻辑进行解耦】

技术分享图片技术分享图片

 

使用消息中间件的逻辑交互

技术分享图片

 

 2,MQ的应用场景

首先消息中间件是一个异步处理

有两个关键点:①耗时;②业务的耦合度

案例1:注册某网站会员成功,短信通知成功,这个就可以直接交给消息中间件

案例2:注册某网站会员,需要使用手机验证码,这个就不能使用消息中间件,业务必须使用【原因:消息中间件是异步执行的,可能导致收不到验证码】

3,MQ的消费类型

技术分享图片

 

4,消息中间件类型

redis、ActivityMQ、RocketMQ(nameSrv)【阿里巴巴使用】、Kafka【zookeeper】、RabbitMQ、ZerOMQ

技术分享图片

5,ActivityMQ安装与使用

http://activemq.apache.org/components/classic/download/

技术分享图片

 

技术分享图片

 

 在浏览器中登录localhost:8161 初始账号:admin,密码:admin

 技术分享图片

 

 查看端口:8161;消息服务端口:61616

6,MQ点对点通信

7,MQ发布订阅

8,MQ的签收模式

自动签收、手动签收【massage.acknowledge()】、事务签收【session.commit()】、

9,SpringBoot操作ActiveMQ

10,ActiveMQ冥等性

防止信息重复消费

11,注意事项

①消费者代码不要抛出异常,否则activeMQ默认有重试机制;

②如果代码发生异常,需要发布版本才可以解决问题,不要使用重试机制,采用日志记录方式,定时Job进行补偿;

③如果不需要发布版本解决的问题,可以采用重试机制进行补偿。

 

参考链接:https://www.bilibili.com/video/av45541255/?p=11

ActivityMQ消息中间件【待完成】

原文:https://www.cnblogs.com/Mufasa/p/11521982.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!