消息队列-ActiveMQ

Posted 2021-01-30

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了消息队列-ActiveMQ相关的知识，希望对你有一定的参考价值。

1 业务需求描述

举例描述：

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

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

发送方式可分为

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

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

2 功能实现设计

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

基础概念

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

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

JMS消息模式

1) 点对点或队列模式

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

技术分享图片

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

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

Broker节点

代表一个运行MQ的节点。

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