消息队列-ActiveMQ-白红宇

消息队列-ActiveMQ

阅读量：6278 次

发布时间：2019-06-22

本文共 2356 字，大约阅读时间需要 7 分钟。

1 业务需求描述

　　举例描述：

　　　　再警情通报的业务时通过发送消息界面可以选择

　　　　警情联络，和船情通报两种消息

　　发送方式可分为

　　　　一对一发送：部门对部门、个人对个人

　　　　一对多发送：部门对多部门、个人对多人

2 功能实现设计

　　基于上述需求描述，在消息传输功能实现上选用activemq进行警情联络消息传输功能的实现。

1. 基础概念

　　ActiveMQ：是Apache出品，最流行的，能力强劲的开源消息总线。是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。

　　JMS（Java消息服务）：是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。

2. JMS消息模式

　　1) 点对点或队列模式

　　每个消息只能有一个消费者。消息的生产者和消费者之间没有时间上的相关性，无论消费者在生产者发送消息的时候是否处于运行状态，它都可以提取消息。

　　2) Pub/Sub 发布/订阅模式

　　每个消息可以有多个消费者。生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。（基于我们的需求选用pub/sub）

3. Broker节点

　　代表一个运行MQ的节点。

4. Transport传输方式

　　ActiveMQ目前支持的Transport有：VM Transport、TCP Transport、NIO Transport、SSL Transport、Peer Transport、UDP Transport、Multicast Transport、HTTP and HTTPS Transport、WebSockets Transport、Failover Transport、Fanout Transport、Discovery Transport、ZeroConf Transport等。

　　1) VM Transport：允许客户端和Broker直接在VM内部通信，采用的连接不是Socket连接，而是直接的方法调用，从而避免了网络传输的开销。应用场景也仅限于Broker和客户端在同一JVM环境下。

　　2) TCP Transport：客户端通过TCP Socket连接到远程Broker。配置语法：

tcp://hostname:port?transportOptions

　　3) HTTP and HTTPS Transport：允许客户端使用REST或者Ajax的方式进行连接。这意味着可以直接使用Javascript向ActiveMQ发送消息。

　　4) WebSockets Transport：允许客户端通过HTML5标准的WebSockets方式连接到Broker。

　　5) Failover Transport：青龙系统MQ采用的就是这种连接方式。这种方式具备自动重新连接的机制，工作在其他Transport的上层，用于建立可靠的传输。允许配置任意多个的URI，该机制将会自动选择其中的一个URI来尝试连接。配置语法：

　　failover:(tcp://localhost:61616,tcp://localhost:61617,.....)?transportOptions

　　6) Fanout Transport：主要适用于生产消息发向多个代理。如果多个代理出现环路，可能造成消费者接收重复的消息。所以，使用该协议时，最好将消息发送给多个不相连接的代理。

5. Persistence持久化存储

　　1) AMQ Message Store

　　ActiveMQ 5.0 的缺省持久化存储方式。

　　2) Kaha Persistence