消息中间件之ActiveMQ
2021-04-11 23:21:19 14 举报AI智能生成
登录查看完整内容
为你推荐
查看更多
消息中间件之ActiveMQ学习和总结大纲
作者其他创作
大纲/内容
ActiveMQ
1.入门概述
ActiveMQ官网
消息服务作用
解耦
削峰
异步
ActiveMQ是什么
定义
特点
采用异步处理模式
应用系统之间解耦合
发送者和接受者不必了解对方，只需要确认消息
发送者和接受者不必同时在线
整体架构
怎么玩
最重要的功能
实现高可用，高性能，可伸缩，易用和安全的企业级面向消息服务的系统
异步消息的消费和处理
控制消息的消费顺序
可以和Spring或者SpringBoot整合简化代码
配置集群容错的MQ集群
从生活Case到实际生产案例
上述问题引出的产生背景
系统之间直接调用实际工程落地和存在的问题
系统之间接口耦合比较严重
面对大流量并发时，容易被冲垮
等待同步存在性能问题
你如何解决
需要有一种东东能摆平上述情况
2.ActiveMQ安装和控制台
官网下载
Linux安装
普通启动
默认端口为61616
普通关闭
带日志启动
Apache ActiveMQ控制台
http://127.0.0.1:8161/admin
默认的pwd是admin/admin
ActiveMQ采用61616端口提供JMS服务
ActiveMQ采用8161端口提供管理控制台服务
3.Java编码实现ActiveMQ通讯
POM.xml文件
JMS编码总体架构
回忆一下以前的JDBC编码套路
上手案例
消息生产者
代码
控制台
控制台说明
消息消费者
代码1-阻塞式消费者
代码2-异步监听式消费者
编码小总结
JMS开发的基本步骤
两种消费方式
备注
先启动生产者，再启动消费者
1个消费者（A）
消费者A消费队列中所有信息
2个消费者（A、B）
消费者A消费掉所有信息，消费者B没得信息可消费
N个消费者同两个消费者
先启动消费者，后启动生产者
N个消费者
N个消费者平均轮流进行消费
生产者启动后，再启动其他的消费者
所有消费者平均轮流进行消费
发布主题生产者
订阅主题消费者
小总结
两大模式特效
两大模式比较
4.JMS规范
什么是Java消息服务
JavaEE
JMS
Java Message Service(Java消息服务是JavaEE中的一个技术
MQ中间件的其他落地产品
消息队列的详细比较
JMS的组成结构和特点
JMS Provider
实现JMS接口和规范的消息中间件，也就是我们说的MQ服务器
JMS Producer
消息生产者，创建和发送JMS消息的客户端应用
JMS Consumer
消息消费者，接收和处理JMS消息的客户端应用
JSM Message
消息头
JMSDestination
消息发送的目的地，主要是指Queue和Topic
JMSDeliveryMode
持久模式：应该被传送一次且被消费一次
非持久模式：最多会传递一次
JMSExpiration
JMSPriority
JMSMessageID
唯一标识每个消息的标识由MQ产生。
消息体
5种消息格式
TxtMessage
普通字符串消息，包含一个String
MapMessage
一个Map类型的消息，key为Strng类型，而值为Java基本类型
BytesMessage
二进制数组消息，包含一个byte[]
StreamMessage
Java数据流消息，用标准流操作来顺序填充和读取
ObjectMessage
对象消息，包含一个可序列化的Java对象
消息属性
可以将属性是为消息头的扩展，属性指定一些消息头没有包括的附加信息，比如可以在属性里指定消息选择器。
它们还用于暴露消息选择器在消息过滤时使用的数据。
JMS的可靠性
持久性：Persistent
参数设置说明
非持久
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT)
非持久化：当服务器宕机，消息不存在。
持久
messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT)
持久化：当服务器宕机，消息依然存在。
持久的Queue
Queue默认是持久
演示
结论
持久的Topic
事务：Transaction
producer提交时的事务
false
1.只要执行send，就进入到Pending Messages2.关闭事务，那第2个签收参数的设置需要有效Session.AUTO_ACKNOWLEDGE
true
先执行send再执行commit，消息才被真正提交到到队列中Pending Messages
consumer提交时的事务
1.只要执行receive，就会进入Messages Dequeue2.关闭事务，那第2个签收参数的设置需要有效Session.AUTO_ACKNOWLEDGE
先执行receive再执行commit，消息才被真正提交到队列中Messages Dequeue
生产者
消费者
签收机制：Acknowledge
签收方式
自动签收
手动签收
允许重复消息
事务下的签收
签收和事务的关系
1.在事务性回话中，当一个事务被成功提交则消息被自动签收。如果事务回滚，则消息会被再次传送。2.事务优先于签收，开始事务后，签收机制不再起任何作用。
非事务性会话中，消息何时被确认取决于创建会话时的应答模式（acknowledgement mode）
生产事务开启，只有commit后才能将全部消息变为已消费
事务偏向生产者，签收偏向消费者。也就是说，生产者使用事务更好点，消费者使用签收机制更好点。
JMS的点对点总结
JMS的发布订阅总结
非持久订阅
持久订阅
用哪个?
当所有的消息必须被接收，则用持久订阅。当消息丢失能够被容忍，则用非持久订阅
5.ActiveMQ的Broker
Broker是什么
启动broker时指定配置文件
嵌入式Broker
6.ActiveMQ的传输协议
面试题
默认的61616端口如何更改
你生产上的连接协议如何配置的？使用tcp吗？
官网
http://activemq.apache.org/configuring-version-5-transports.html
是什么
有哪些
1.Transmission Control Protocol(TCP)默认
2.New I/O API Protocol(NIO)
3.AMQP协议
4.Stomp协议
5.Secure Sockets Layer Protocol(SSL)
6.MQTT协议
扩展Github
7.WS协议(websocket)
8.小总结
nio案例演示
修改配置文件
生产和消费两端协议代码修改
运行验证
nio案例演示增强
上诉NIO性能不错了，如何进一步优化？
问题
URI格式以\"nio\"开头，代表这个端口使用TCP协议为基础的NIO网络模型。但是这样的设置方式，只能使这个端口支持Openwire协议。
我们怎么能够让这个端口既支持NIO网络模型，又让他支持多个协议呢？
解决
使用auto关键字
使用\"+\"符号来为端口设置多种特性
7.ActiveMQ的消息存储和持久化
http://activemq.apache.org/persistence
ActiveMQ持久化机制
回忆Redis持久化机制有几种
RDB
AOF
说明
一句话：ActiveMQ宕机了，消息不会丢失的机制。
AMQ Mesage Store(了解）
基于文件的存储方式，是以前的默认消息存储，现在不用了
KahaDB消息存储(默认)
基于日志文件，从ActiveMQ5.4开始默认的持久化插件
kahaDB
验证
http://activemq.aache.org/kahadb
KahaDB的存储原理
JDBC消息存储
消息基于JDBC存储的
LevelDB消息存储(了解)
JDBC Message Store with ActiveMQ Journal
JDBC存储消息
1.MQ+MySQL
2.添加mysql数据库的驱动包到lib文件夹
3.jdbcPersistenceAdapter配置
4.数据库连接池配置
如果不使用默认的数据库连接池（dbcp2），则也需要引入对应的jar
5.建库SQL和创表说明
建一个名为activemq的数据库
三张表的说明
ACTIVEMQ_MSGS
ACTIVEMQ_ACKS
ACTIVEMQ_LOCK
如果新建数据库ok，上述配置ok，代码运行ok，3张表会自动生成
如果表没生成，可能需要自己创建
6.代码运行验证
一定要开启持久化
messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);
队列
主题
7.数据库情况
一旦运行生产code
点到点
发布/订阅
mysql
queue
topic
9.开发有坑
JDBC Message store with ActiveMQ Journal
配置
图
以前是实时写入mysql，在使用了journal后，数据会被journal处理，如果在一定时间内journal处理（消费）完了，就不写入mysql，如果没消费完，就写入mysql，起到一个缓存的作用
ActiveMQ持久化机制小总结
8.ActiveMQ的多节点集群
引入消息中间件后如何保证其高可用
基于zookeeper和LevelDB搭建ActiveMQ集群。集群仅提供主备方式的高可用集群功能，避免单点故障。
zookeeper+replicated-leveldb-store的主从集群
三种集群方式对比
基于shareFileSystem共享文件系统（KahaDB）
基于JDBC
基于可复制的LevelDB
本次案例采用ZK+Replicated LevelDB Store
ShareFileSystem
http://activemq.apache.org/replicated-leveldb-store
官网集群原理图
解释
部署规划和步骤
1.环境和版本
2.关闭防火墙并保证各个服务器能够ping通
3.要求具备zk集群并可以成功启动
配置集群教程
4.集群部署规划列表
5.创建3台集群目录
就是一台电脑复制三份ActiveMQ
6.修改管理控制台端口
就是ActiveMQ后台管理页面的访问端口
7.hostname名字映射(如果不映射只需要吧mq配置文件的hostname改成当前主机ip)
8.ActiveMQ集群配置
配置文件里面的BrokerName要全部一致
持久化配置(必须)
9.修改各个节点的消息端口
真实的三台机器不用管
先启动Zk 在启动ActiveMQ
11.zk集群节点状态说明
3台Zk连接任意一台验证三台ActiveMQ是否注册上了Zookeeper
查看Master
集群可用性测试
9.高级特性和大厂常考重点
异步投递Async Sends
异步投递是什么
官网配置
代码实现
异步发送如何确认发送成功
延迟投递和定时投递
官网说明
四个属性
修改配置文件并重启
消息重试机制
官网文档
属性说明
死信队列
死信队列的使用：处理失败的消息
死信队列的配置
SharedDeadLetterStrategy
IndividualDeadLetterStragy
配置案例：存放非持久消息到死信队列
自动删除过期消息
保证消息不被重复消费
数据库的唯一约束
消费记录，记录关键的key标识
10.性能优化
生产者发送效率、产出率低
收藏
0 条评论
回复 删除
下一页
