关于java:消息中间件之ActiveMQ

49次阅读

共计 3856 个字符，预计需要花费 10 分钟才能阅读完成。

1、JMS（Java Message Service，Java 音讯服务）

1.1 定义

Java 音讯服务（Java Message Service, 即 JMS）利用程序接口是一个 Java 平台中对于面向消息中间件(MOM) 的 API, 用于在两个应用程序之间，或分布式系统中发送音讯，进行异步通信。Java 音讯服务是一个与具体平台无关的 APl。

1.2 JMS 的对象模型

名称 形容
ConnectionFactory 连贯工厂
Connection 连贯
Session 会话
Destination 目标
MessageProducer 生产者
MessageConsumer 消费者
Message 音讯
Broker 消息中间件的实例(ActiveMQ)

1.3 JMS 音讯模型

  1. Point-to-Point (P2P) / 点对点

  2. Publish/Subscribe (Pub/Sub) / 主题(公布订阅)

1.4 JMS 的音讯构造

音讯头、音讯属性、音讯体

  1. 音讯头

  2. 音讯属性：能够了解为音讯的附加音讯头，属性名能够自定义

  3. 音讯体

2、ActiveMQ 概念

2.1 定义

ActiveMQ 是 Apache 出品，最风行的，能力强劲的开源音讯总线。

ActiveMQ 是一个齐全反对 JMS1.1 和 J2EE 1.4 标准的 JMS Provider 实现，只管 JMS 标准出台曾经是很久的事件了，然而 JMS 在当今的 J2EE 利用两头依然扮演着非凡的位置。

2.2 个性

  1. 反对多种编程语言
  2. 反对多种传输协定
  3. 有多种长久化形式

2.3 ActiveMQ 反对哪些协定

  1. ActiveMQ 反对多种协定传输和传输方式，容许客户端应用多种协定连贯。
  2. ActiveMQ 反对的协定: AUTO、OpenWire、AMQP、Stomp、MQTT 等。
  3. ActiveMQ 反对的根底传输方式: VM、TCP、SSL、UDP、Peer、Multicast、HTTP(S)等，以及更高级的 Failover、Fanout、Discovery、ZeroConf 形式。

2.4 OpenWire 协定

2.4.1 OpenWire 协定是什么

OpenWire 是 Apache 的一种跨语言的协定，容许从不同的语言和平台拜访 ActiveMQ, 是 ActiveMQ 4.x 当前的版本默认的传输协定。

2.4.2 OpenWire 协定如何应用

OpenWire 反对 TCP、SSL、NIO、UDP、VM 等传输方式，间接配置这些连贯，就是应用的 OpenWire 协定，OpenWire 有 本人的配置参数，客户端和服务器端配置的参数名都通过缀“wireFormat.”示意。

示例

OpenWire 的配置参数阐明

属性 默认值 形容
stackTraceEnabled true 是否应该把曾经产生并且跟踪到的堆栈异样, 通过 Broker 发送到客户端
tcpNoDelayEnabled true socket 的 NoDelay 参数
cacheEnabled true 如果一直反复的值进行缓存，以便少编组 (马上要进行的发送) 产生
tightEncodingEnabled true 依据 CPU 应用状况，主动调整传输内容大小(压缩比例)
prefixPacketSize true 在每个包被编组前(马上要被发送)，每个包的大小是否应该作为前缀连贯的最大闲暇工夫, 以毫秒为单位。
maxInactivityDuration 30000 broker 服务会依据配置敞开超时的连贯。同时也能够通过心跳机制来放弃连贯。值 <= 0 则禁用流动连贯的监测。
maxlnactivityDurationInitalDelay 10000 连贯建设之后，多久开始进行超时检测
cacheSize 1024 如果能被缓存，那么这个规定了缓存的最大数量。此属性中在 ActiveMQ 的 4.1 中开始增加应用可发送最大帧大小
maxFrameSize MAX_ LONG 能够帮忙避免 OOM DOS 攻打

2.5 为什么应用 MQTT 协定

MQTT 的构造简略，绝对于其它音讯协定，它更加轻量级。适宜在计算能力无限、低带宽、不牢靠的网络环境应用。

2.5.1 MQTT 的公布订阅模型

2.5.2 MQTT 服务质量

服务质量(QoS) 级别是一种对于发送者和接收者之间信息投递的保障协定。MQTT 中有三种 QoS 级别:

  1. 至少一次(0)
  2. 至多一次(1)
  3. 只有一次(2)

QoS 是 MQTT 的一个次要性能，它使得在不牢靠的网络下进行通信变得更为简略，因为即使是在十分不牢靠的网络下，协定也能够掌控是否须要重发消息并保障音讯达到。它也能帮忙客户端依据网络环境和程序逻辑来自由选择 QoS.

2.5.3 ActiveMQ 中如何应用 MQTT 协定

ActiveMQ 服务器端配置

<transportConnectors>
    <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize= 104857600"/>
</transportConnectors>

MQTT 配置参数阐明

属性 默认值 形容
maxFrameSize 268435456 (v5.12.0)能够发送的最大帧大小。协定限度为 256MB, 其值不能设置得更高。能够帮忙避免 OOM DOS 攻打

配置示例

<transportConnector name="mqtt" uri="mtt://localhost:1883?wireFormat.maxFrameSize=100000"/>

MQTT 应用 NIO

<transportConnector name="mgtt+nio" uri="mtt+nio://localhost:1883"/>

MQTT 应用 NIO + SSL

<transportConnector name="mqtt+nio" uri="mqtt+niossl://localhost:1883"/>

2.5.4 Spring 应用 MQTT

Spring Integration 提供了 MQTT 协定的反对，通过 Maven 增加依赖即可应用。

<dependency>
    <groupld>org.springframework.integration</groupld>
    <artifactld>spring-integration-mqtt</artifactld>
    <version>5.1.1.RELEASE</version>
</dependency>

2.6 AUTO 协定是什么

AUTO 自动检测协定从 ActiveMQ 5.13.0 开始，ActiveMQ 开始反对协定格局检测，能够自动检测 OpenWire、STOMP、AMQP 和 MQTT。容许这 4 种类型的客户端共享一个传输

AUTO 应用 TCP

<transportConnector name="auto" uri="auto://localhost:5671"/>

AUTO 应用 SSL

<transportConnector name="auto+ssl" uri="autssl://localhost:5671"/>

AUTO 应用 NIO

<transportConnector name="auto+nio" uri="auto+nio://localhost:5671"/>

AUTO 应用 NIO+SSL

<transportConnector name="auto+nio+ssl" uri="auto+nioss://localhost:5671"/>

3、ActiveMQ 高可用集群计划

3.1 ActiveMQ 有哪些集群部署形式

Master-Slave 部署形式 Broker-Cluster 部署形式 Master-Slave 与 Broker-Cluster 相结合的部署形式

3.2 Master-Slave 部署形式

共享同一个文件系统

共享同一个数据库

3.3 Broker-Cluster 部署形式

3.4 Master-Slave 与 Broker-Cluster 相结合的部署形式

4、ActiveMQ 长久化机制

4.1 Queue 类型的长久化机制

4.2 Topic 类型的长久化机制

4.3 存储形式

4.3.1 JDBC 形式

将音讯存储到数据库中，例如: Mysql、SQL Server、Oracle、DB2 等

长处 毛病
方便管理 性能低
能够反对强一致性 /

4.3.2 AMQ 形式

基于文件的存储形式，它具备写入速度快和容易复原的特点，然而因为其重建索引工夫过长，而且索引文件占用磁盘空间过大，所以曾经不举荐应用。

长处 毛病
性能高于 JDBC 索引占用磁盘空间量大
/ 重建索引速度十分慢

4.3.3 LevelDB 形式

LevelDB 是 Google 开发的一套用于长久化数据的高性能类库.LevelDB 并不是一 - 种服务，用户须要自行实现 Server。是单过程的服务，可能解决十亿级别规模 Key-Value 型数据，占用内存小。

特点

  1. 基于 K - V 存储
  2. Key 值有序存储
  3. 操作接口简略
  4. 反对数据快照
  5. 反对数据压缩

L evelDB 的构造

ActiveMQ 配置 LevelDB：批改配置文件 ${ACTIVEMQ_ HOME}/conf/activemq.xml

<persistenceAdapter>
    <levelDB directory="${activemq.data}/activemq-data"/>
</persistenceAdapter>

5、ActiveMQ 事务实现机制

ActiveMQ 事务实现的是最终一致性

生产者端实现机制如下：

消费者端实现机制如下：

正文完
java
发表至： java
2022-02-21
 0
关于java:云监控系统-HertzBeat-v110-发布一条命令开启监控之旅
关于java:Java基础一一设计模式单例模式的运用
HttpServletRequest对象
InfluxDB入门第一篇安装