ActiveMq总结思维导图思维导图模板_ProcessOn思维导图、流程图

1.入门概述

前言

为什么要引入消息中间件

什么场景引入消息中间件

。。。

从生活case到实际生产案例

上述问题产生的背景

系统之间直接调用实际工程落地和存在的问题

系统间的接口耦合比较严重

面对大流量时容易被冲垮

等待同步存在性能问题

如何解决

需要有东西来解决上述问题？？

是什么

定义

特点

采用异步处理模式

应用系统间的解耦

发送者和接收者不必了解对方，只需要确认消息

发送者和接收者不必同时在线

具体业务

能干嘛

去哪里下

怎么玩

最主要的功能

实现高可用，高性能，可伸缩，易用和安全的企业级面向消息服务的系统

异步消息的消费和处理

控制消息的消费顺序

可以和spring与springboot 整合简化编码

配置集群容错的mq集群

。。。

2.ActiveMQ的安装和控制台

3.Java编码实现ActiveMQ通信

IDEA建立maven工程

POM.xml

JMS编码总体架构

对比回忆以前基础课程JDBC的编码套路

粗说目的地distination队列和主题

两大模式特性

在点对点的消息传递域中，目的地被称为队列（queue）

上手案例

消息生产者

代码

控制台

控制台说明

消息消费者

方式一：同步阻塞方式receive()

方式二：设置监听方式

编码小总结

JMS开发的基本步骤

两种消费方法

在发布订阅消息传递域中，目的地被称为主题（topic）

上手案例

发布主题生产者

订阅主题消费者

先启动消费者后启动生产者，不然发送的消息是废消息

控制台

小总结

两个模式的特性

两大模式的比较

4.JMS规范和落地产品

是什么

JavaEE

JMS

分支主题

MQ中间件的其他落地产品

消息队列的详细对比

JMS的组成和特点

JMS privider

实现JMS接口与规范的消息中间件，也就是我们的MQ服务器

JMS producer

消息生产者，创建与发送JMS消息的客户端应用

JMS consumer

消息的消费者，接受与处理JMS消息的客户端应用

JMS message

消息头

JMSdesination

消息发送的目的地，主要是指Queue与Topic

JMSDeliveryMode

JMSExpiration

JMSPriority

JMSMessageID

唯一识别每个消息的表示，由MQ产生

消息体

封装具体消息的数据

五种消息体的格式

分支主题

TextMessage

普通的字符串消息，包含一个string

MapMessage

一个map类型的消息，key为stirng类型，而value 为java的基本类型

BytesMessage

二进制数组消息，包含一个byte[]

StreamMessage

java数据流消息，用标准流操作来顺序的填充或读取

ObjectMessage

对象消息，包含一个可序列化的java对象

发送和接受的消息体类型必须是一致对应的

消息属性

如果需要使用消息头以外的值，那么可以使用消息属性///一种加强型的api

识别/去重/重点标注等操作非常有用的方法

是什么

JMS的可靠性

persistent：持久性

参数设置说明

非持久

持久

默认是持久化的

持久的queue

演示

结论

持久的topic

代码

先启动订阅在启动生产

持久的发布主题生产者

持久的订阅主题消费者

控制台

类似微信公众号的订阅发布

非持久的topic 没有意义，因为发布订阅模式是先启动订阅在启动生成，消息已经被消费了。如果先启动生产者后启动订阅者，消息会被当作废消息

transaction:事务

producer提交时的事务

false

只要执行send就进入到队列中

关闭事务，那第2个签收参数的设置需要有效

true

先执行send再执行commit，消息才被真正的提交到队列中

消息需要批量发送，需要缓存区处理

事务偏生产者/签收偏消费者

Acknowledge:签收

非事务

自动签收（默认）

Session.AUTO_ACKNOWLEDGE

手动签收

客户端调用acknowledge方法手动签收

Session.CLIENT_ACKNOWLEDGE

允许重复消息

Session.DUPS_OK_ACKNOWLEDGE

事务

消费者事务开启，只有commit后才能将全部消息变为已消费，写ack没有作用，即使写了签收也不会签收出队

消息生产者

代码

控制台

消息消费者

代码

控制台

签收与事务的关系

在事务性会话中，当一个事务被成功提交则消息被自动签收。如果事务回滚，则消息会被再次传送

非事务会话中，消息何时被确认取决于创建会话时的应答模式（acknowledgement）

JMS的点对点模式总结

JMS的发布订阅模式总结

非持久订阅

持久订阅

用那个

当所有消息必须被接受，则用持久订阅。当丢失消息能够被容忍，则用非持久订阅

5.ActiveMQ的Broker

是什么

回忆阳哥之前讲解过的redis，不同的conf配置文件模拟不同的实例

嵌入式的Broker

pom.xml

EmbedBroker

队列验证

6.Spring整合ActiveMQ

1.maven修改，需要添加spring支持的jms的包

pom.xml

2.spring配置文件

3.队列

生产者

消费者

4.主题

Spring配置文件，新增主题topic

applicationContext.xml

生产者

同队列代码不变

消费者

同队列代码不变

5.在spring中里边实现消费者不启动，直接通过配置监听完成

说明

spring配置文件

applicationContext.xml

需要写一个类来实现监听

只需要启动生产者，不需要启动消费者，自动完成监听记录

7.SpringBoot整合ActiveMQ

队列

队列生产者

1.新建maven工程并设置包名类名

工程名

包名

2.pom.xml

3.application.yum

4.配置bean

类似Spring框架的applicationContext.xml文件

5.Queue_Produce

6.主启动类MainApp_Produce

7.测试单元

8.新需求：要求每隔3秒往MQ推送消息，以下定时发送case,案例修改

修改Queue_Produce新增定时投递方法

修改主启动类

直接开始主启动类，间隔发消息OK

队列消费者

1.新建maven工程并设置包名类名

2.pom.xml

3.application.yml

4.Queue_Consumer

5.主启动类

发布订阅

Topic生产者

1.新建maven工程并设置包名类名

工程名

包名

2.pom.xml

3.application.yum

4.配置bean

类似Spring框架的applicationContext.xml文件

5.Topic_Produce

6.主启动类MainApp_Produce

Topic消费者

1.新建maven工程并设置包名类名

2.pom.xml

3.application.yml

4.Topic_Consumer

5.主启动类

模拟两个消费者

8.ActiveMQ传输协议

面试题

默认的61616端口怎么修改

你生产上的链接协议如何配置的？使用TCP么？

官网

分支主题

各种主要协议

是什么

有那些

1.TCP默认的

2.NIO

3.AMQP协议

4.stomp协议

5.SSL

6.mqtt协议

扩展Github

7.ws协议

8.小总结

NIO案例演示

官网

http://activemq.apache.org/configuring-transports

说明

修改配置文件activemq.xml

生产与消费两端的协议代码修改

分支主题

运行验证

NIO案例演示增强

上述NIO性能不错了，如何进一步优化？

问题

UPI格式头以“nio”开头，表示这个端口使用以TCP为基础的NIO网络IO模型但是这样的设置方式，只能使这个端口支持openwire协议。

那么我们怎么即让这个端口支持NIO网络io模型，又让它支持多个协议呢？

解决

使用auto关键字

使用“+”符号来为端口设置多种特性

如果我们即需要某一个端口支持NIO网络io模型，又需要它支持多种协议

9.ActiveMQ的消息存储与持久化

官网

http://activemq.apache.org/persistence

是什么

面试题

ActiveMQ持久化机制

回忆阳哥讲的redis持久化机制

说明

一句话，MQ服务器宕机，消息不会丢失的机制

有哪些

ActiveMQ Message Store (了解)

基于文件的存储方式，是以前的默认消息存储，现在不用了

KahaDB 消息存储（默认）

基于日志文件，从ActiveMQ5.4开始默认的持久化插件

官网

kahaDB官网

验证

说明

http://activemq.apache.org/kahadb

kahaDB的存储原理

JDBC 消息存储

消息基于JDBC存储的

LevelDB消息存储（了解）

JDBC Message store with ActiveMQ Journal

JDBC消息存储

1.MQ+Mysql

2.添加mysql数据库的驱动包到lib文件夹

3.jdbcPersistanceAdapter配置

4.数据库连接池配置

5.建库建表说明

建一个名为activemq的数据库

三张表的说明

activemq_msgs

activemq_acks

activemq_lock

如果新建数据库OK+上述配置OK+代码运行OK，三张表会自动建立

万一情况，手动建表sql如果配置不好需要手动，应急

6.代码运行验证

一定要开启持久化

producer.setDeliveryMode(DeliveryMode.PERSISTENT);

队列

生产者

消费者

topic

生产者

消费者

7.数据库情况

一旦运行生产code

点对点

发布订阅

mysql

queue

在运行消费看看表msgs数据的变化情况

topic

先启动消费者订阅在运行生产者，看acks

8.小总结

9.开发有坑

JDBC Message store with ActiveMQ Journal

是什么

说明

配置

重启配置文件激活

运行

ActiveMQ持久化机制小总结

10.ActiveMQ多节点集群

面试题

引入消息队列之后该如何保证其高可用

是什么

基于zookeeper和leveldb搭建activemq集群集群仅提供主备方式的高可用集群功能，避免单点故障

zookeeper+replicated-leveldb-store的主从集群

三种集群方式的对比

基于共享文件系统kahadb默认

基于JDBC

基于可复制的LevelDB

本次案例采用zk+levelDB

共享文件系统

是什么

http://activemq.apache.org/replicated-leveldb-store

官网集群原理图

解释

部署规划和步骤

1.环境和版本

2.关闭防火墙并保证win可以ping通过activemq服务器

3.要求具备zk集群并可以成功启动

参考阳哥之前讲解过的zookeeper??没看过

4.集群部署规划列表

5.创建3台集群目录

6.修改管理控制台端口

7.hostname名字映射

8.activemq集群配置

01/02/03路径

3个节点的BrokerName要求完全一致

3个节点的持久化配置

9.修改各个节点的消息端口

10.按照顺序启动3个ActiveMQ节点，到这步前题是zk集群已经成功启动运行

分支主题

11.zk集群的节点状态说明

3台zk集群连接任意一台

查看master

集群可用性测试

干掉一台Activemq，它会自动切换到另一个活着的

代码

11.高级特性和大厂长考重点

1.引入消息队列之后该如何保证其高可用性

2.异步投递Async Sends

异步投递

分支主题

说明

对于一个slow consumer ，使用同步发送消息可能出现producer堵塞等情况，慢消费者适合使用异步发送

是什么

官网配置

面试追问

异步发送如何确认发送成功？

分支主题

3.延时投递和定时投递

分支主题

官网说明

四大属性

粗说cron

案例演示

分支主题

代码

分支主题

4.分发策略（没讲）

5.Activemq消费重试机制

生产案例面试题

具体那些情况会引起消息重发

请说说消息的重发时间间隔和重发次数么

有毒消息PoisonACK谈谈你的理解

记得和学生讲解2次，上述回答

官网

分支主题

属性说明

案例验证与讲解

分支主题

整合Spring后如何使用，假如工作中需要

6.死信队列

分支主题

是什么

死信队列的使用：处理失败的消息

activemq死信队列的配置介绍

分支主题

配置案例

自动删除过期消息

存放非持久消息到死队列中

7.如何保证消息不被重复消费呢？幂等性问题？