中间件1.2.2-ActiveMQ支持的消息协议讲解

Activemq支持协议:

1)Activemq支持多种协议传输和传输方式,允许客户端使用多种协议连接。

2)Activemq支持的协议:AUTO、 OpenWire、AMQP、 Stomp、MQTT等

3)Activemq支持的基础传输方式:WM、TCP、SSL、UDP、Peer、Multicast、HTTP(S)等,以及更高级的 Failover、 Fanout、 Discovery、ZeroConf方式。

Active MQI的协议连接配置

在${ACTIVEMQ_ HOME}/conf/ activemq.xml中,通过配置<transportConnectors>就可以使用多种传输方式。

Activemq常用的传输方式及配置

TCP

由于TCP具有可靠传输的特性,它在 Activemq中也是最常使用的一种协议。在默认的配置中,TCP连接的端口为61616

TCP配置格式: tcp://hostname:port?key=value

TCP配置参数说明

在服务器端配置时,参数要以“ transport.”开头

在客户端连接时,参数省略“ transport.前缀

服务器端配置示例:

tcp://localhost:61616?transport.threadName&transport.trace=false&transport.soTimeout=60000

客户端配置示例:

tcp://localhost:61616?threadName&trace=false&soTimeout=60000

TCP配置参数说明:

SSL

需要一个安全连接的时候可以考虑使用SSL,适用于 client和 broker在公网的情况,如使用aws云平台等

http://activemq.apache.org/ssl-transport-reference.html

SSL配置格式,可配置参数和TCP相同

ssl: //localhost: 61616

SSL客户端配置

JMS客户端需要使用 Activemqsslconnectionfactory类创建连接, brokerurll以ssl://开头,以下是 Spring配置示例

<bean id="AMQJMSConnectionFactory" class="org.apache.activemq.ActiveMQSslConnectionFactory">...</bean>

SSL主机名验证

从 Activemq5.15.6开始, Activemq开始支持TLS主机名验证,默认情况下客户端启用了该验证,而服务器端没有启用。

服务器端配置

ssl://localhost:61616?transport.verifyHostName=true

客户端配置

ssl://localhost:61616?socket.verifyHostName=false

或

ssl://localhost:61616?verifyHostName=false

NIO(默认BIO)

使用Java的NIO方式对连接进行改进,因为NIO使用线程池,可以复用线程,所以可以用更少的线程维持更多的连接。如果有大量的客户端,或者性能瓶颈在网络传输上,可以考虑使用NIO的连接方式。

NIO配置格式,可配置参数和TCP相同

nio://hostname:port?key=value

NIO是 Openwire协议的传输方式,其它协议,像AMQP、MQTT、 Stomp,也有NIO的现,通常在协议前缀中加“+nio”来区分。示例: 

mgtt+nio://localhost:1883

NIO传输线程使用情况配置

从5.15.0开始, Active MQ支持调整NO的传输线程,可以设置以下属性

NIO传输线程使用情况配置

属性可以在${ACTⅣEMQ_HOME}/bin/env中配置

NIO SSL

从 Activemq5.6版本开始,NO可以支持和SsL搭配使用的传输连接

NIO+SSL配置格式,可配置参数和TCP相同

nio+ssl://1.0.0.0:61616

UDP

与面向连接,可靠的字节流服务的TCP不同,UDP是一个面向数据的简单传输连接,没有TCP的三次握手,所以性能大大强于TCP,但是是以牺牲可靠性为前提。适用于丢失也无所谓的消息。

UDP配置格式

udp://localhost:8123

UDP配置参数说明

HTTP(S)

需要穿越防火墙,可以考虑使用HTTP(S),但由于HTTP(S)是短连接,每次创建连接的成本较高,所以性能最差。通过XML传输数据。

HTTP配置格式

http://localhost:8080?param1=val1&param2=val2

HTTPS配置格式

https://localhost:8080?param1=val1&param2=val2

VM

虚拟机协议(方法直调),使用场景是 client和 broker在同一个Java虚拟机内嵌的情况,无需网络通信的开销。

VM配置格式

vm://brokerName?marshal=false&broker.persistent=false

VM配置参数说明

OpenWire协议是什么

OpenWire是 Apache的一种跨语言的协议,允许从不同的语言和平台访问Activemq,是 Active MQ4.x以后的版本默认的传输协议。

http://activemq.apache.org/openwire-version-2-specification.html

http://activemq.apache.org/wire-protocol.html

OpenWire协议如何使用

OpenWire支持TCP、SSL、NIO、UDP、VM等传输方式,直接配置这些连接,就是使用的 OpenWire协议, Openwire有自己的配置参数,客户端和服务器端配置的参数名都通过前缀“ wireFormat.”表示。

http://activemq.apache.org/configuring-wire-formats.htm

示例

tcp://localhost:61616?wireFormat.cacheEnabled=false&wireFormat.tightEncodingEnabled=false

OpenWire配置参数说明

MQTT协议是什么

MQTT( Message Queuing Telemetry Transport)消息队列遥测传输是IBM开发的一个即时通讯协议,已成为物联网通信的标准。

为什么使用MQTT协议

MQTT的结构简单,相对于其它消息协议,它更加轻量级。适合在计算能力有限、低带宽、不可靠的网络环境使用。

MQTT服务质量

什么是服务质量

服务质量(QoS)级别是一种关于发送者和接收者之间信息投递的保证协议。

MQTT中有三种QS级别:

至多一次(0)

至少一次(1)

只有一次(2)

为什么要有服务质量

QoS是MQTT的一个主要功能,它使得在不可靠的网络下进行通信变得更为简单,因为即便是在非常不可靠的网络下,协议也可以掌控是否需要重发消息并保证消息到达。它也能帮助客户端根据网络环境和程序逻辑来自由选择QoS。

它是怎样工作的-- Qos level 0~2