ActiveMQ(四)---连接器connector
1. 什么是连接器
在ActiveMQ中有3个重要的角色：Broker、Producer、Consumer。
Broker为消息代理，它是ActiveMQ服务端角色，接受客户端的连接并提供消息通信的核心服务。
Producer是消息生产者，客户端角色。
Consumer是消息消费者，客户端角色。
客户端怎样和服务端通信，该选择哪种网络协议？ActiveMQ定义的连接器(connector)就是用来约定ActiveMQ的节点之间如何通信。
2. 连接器分类
在ActiveMQ中，连接器(connector)共分为以下两类：
- 传输连接器(
transport connector)：用于客户端和服务端之间( client-to-broker)的通信。 - 网络连接器(
network connector)：用户集群中多个服务端之间(broker-to-broker)的通信。
2.1 传输连接器
传输连接器提供了很多连接协议供使用者来选择，ActiveMQ 的5.15版本包括以下协议：
- tcp，默认使用的协议，符合大多数的使用场景。
- udp，客户端使用udp协议和服务端通信，当客户端和服务端之间存在防火墙可以考虑使用udp协议。
- vm，当客户端和服务端在同一个JVM中可以考虑使用。直接使用虚拟机本地方法调用，从而避免网络通信的开销。
- nio，本质上还是tcp，只是使用了java NIO包，某些场景下可能性能更好。
- ssl，基于tcp提供安全的通信。
- http/https，允许客户端使用REST或Ajax的方式进行连接，可以通过JS给ActiveMQ发送消息。
- multicast，客户端使用组播的方式连接到服务端。
- websocket，可以通过HTML5中的websocket技术连接服务端。
- amqp，高级消息队列协议，很多消息中间件都支持该协议。ActiveMQ5.8版本开始支持。
- mqtt，MQTT是一个基于客户端-服务器的消息发布/订阅传输协议，主要应用在loT(物联网)。
- stomp，STOMP是在WebSocket之上提供了一个基于帧的线路格式（frame-based wire format）层，用来定义消息的语义，就像HTTP在TCP套接字之上添加了请求-响应模型层一样。ActiveMQ5.6版本开始支持
用户可以根据自己应用的特点来选择不同的协议。上面介绍的是客户端和服务端之间通信的一些基本协议，除了这些基本协议之外，ActiveMQ还提供了客户端和服务器端通信高可用的配置。
- failover，为客户端提供重连服务端的逻辑，允许配置多个上面介绍的不同协议的连接配置，并随机的从其中选择一个进行连接，如果失败则继续选择其他服务重试。failover的配置格式：
failover:(tcp://ip1:61616,tcp://ip2:61616)?initialReconnectDelay=100。 - fanout，采用复制的方式将消息发送给多个服务端，配置格式为：
fanout:(tcp://localhost:61629,udp://localhost:61639,tcp://localhost:61649)
fanout
2.2 网络连接器
网络连接器用来将多个消息服务器连接在一起形成集群，作为一个整体对外提供服务。
broker集群
ActiveMQ中的网络连接器，常用的有如下两种：
- static，静态协议，用于已知多个服务器的IP地址。
- multicast，广播协议，用于服务器之间实现动态识别。
3. 连接器的配置及使用
服务端的连接器配置可以配置在ActiveMQ的配置文件%ActiveMQ_home%\conf\activemq.xml中（当然ActiveMQ启动时，可以指定配置文件）。在activemq.xml文件中，可以看到如下配置：
<transportConnectors>
<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
这段配置的含义是，这个ActiveMQ服务对外提供tcp\amqp\stomp\ws\mqtt协议，以便客户端连接。
以TCP为例，可以看到配置语法都是形如：
tcp://hostname:port?key=value
具体各个协议具体怎么配置、支持哪些参数请参考官方文档：
URI Protocols
Configuring Transports
指定单独的配置文件
ActiveMQ服务默认的配置文件为：%ActiveMQ_home%\conf\activemq.xml。我们可以根据应用的需求对此默认的配置文件进行修改，有时我们不想改动此文件，而是指定另外一个单独的文件作为ActiveMQ的配置。针对这种情况，ActiveMQ提供了xbean支持，具体用法如下所示：
activemq start xbean:examples/conf/myactivemq.xml
xbean支持相对路径和绝对路径，下面的演示环境是windows cmd
1.相对路径
D:\app\apache-activemq-5.15.8\bin> activemq start xbean:../examples/conf/activemq.xml
2.绝对路径
D:\app\apache-activemq-5.15.8\bin> activemq start xbean:/D:/app/apache-activemq-5.15.8/examples/conf/activemq-demo.xml
客户端指定连接协议
那么客户端如何指定连接的协议呢？可以在创建ConnectionFactory对象时，指定使用什么协议和消息服务端进行通信。如下所示：
String brokerURL = "tcp://localhost:61616";
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURL);
和服务端一样，客户端也支持在url后面带一些参数，用来配置属性。
参考资料/扩展阅读
[1]：深入理解AMQP协议
[2]：《ActiveMQ In Action》
[3]：消息队列之 ActiveMQ
[4]：Networks of Brokers
