ActiveMQ学习教程（三）——连接配置

这节介绍MQ的连接配置

在MQ目录/conf/activemq-demo.xml中可看到如下配置

<transportConnectors> 
<transportConnector name="openwire" uri="tcp://localhost:61616" 
discoveryUri="multicast://default"/>
<transportConnector name="ssl"  uri="ssl://localhost:61617"/> 
<transportConnector name="stomp" uri="stomp://localhost:61613"/> 
<transportConnector name="xmpp"  uri="xmpp://localhost:61222"/>
</transportConnectors>

可以看到在MQ中可配置个连接，并且还可以配置多种协议的连接。
MQ中支持的网络协议有TCP、NIO、UDP、SSL、HTTP(S)、VM等。
下面对其中常用的几种进行一下说明。

TCP：
MQ默认使用的协议，开放性、高效性、可靠性是其主要特点，这个协议可满足一般应用的大部分需求，因此在项目中还是比较常用的。第一节中的例子用到的就是TCP协议。

NIO：
NIO的概念是在JAVASE1.4首先提出来的，这是一种新的JAVA IO模型，是对底层IO的一种封装，让程序员们可以更方便的对IO进行操作。
这种协议下，网络消息的传播效率非常的高。因此，当系统存在高用户量、高并发或网络堵塞时，可考虑用此协议。
配置示例如下：

<transportConnector name="nio" uri="nio:localhost:61618" />

SSL:
安全套接层协议，这种协议比较重要，因此本教程将对SSL协议连接方式作重点介绍。
在MQ目录/conf/activemq.xml文件中修改以下配置

<sslContext> 
    <sslContext keyStore="file:${activemq.base}/conf/broker.ks" keyStorePassword="password"/> 
</sslContext>
<transportConnectors>
    <transportConnector name="ssl" uri="ssl://localhost:61617"/>
</transportConnectors>

broker.ks是MQ的默认证书，默认密码为password
启动activemq.bat
可发现MQ已经以SSL方式启动，端口为61617

将第一节中Consumer.java与Publisher.java的以下代码

protected static String brokerURL = "tcp://localhost:61616";

修改为

protected static String brokerURL = "ssl://localhost:61617";

在Consumer.java和Publisher的VM arguments 里输入
-Djavax.net.ssl.keyStore=MQ目录\conf\client.ks
-Djavax.net.ssl.keyStorePassword=password
-Djavax.net.ssl.trustStore=MQ目录\conf\client.ts
设置Consumer.java和Publisher的Program arguments为 ORCL

启动Consumer.java和Publisher，将看到和第一节示例一样的结果，只不过这里的连接协议改为了SSL。

由于本例中用到的证书是MQ自带的，正式环境中不可能用默认证书，否则SSL将形同虚设。因此，我们必须生成自己的证书，以保证其安全性。

在命令行中输入
keytool -genkey -alias broker -keyalg RSA -keystore mybroker.ks
按提示输入密码（本例子的密码为test123）和其它信息，可以看到在当前目录下生成了一个mybroker.ks文件，接着在命令行输入keytool -export -alias broker -keystore mybroker.ks -file mybroker_cert，输入刚才的密码test123，生成mybroker_cert。
接成生成客户端keystore，输入keytool -genkey -alias client -keyalg RSA -keystore myclient.ks，输入客户端密码和其它信息，生成myclient.ks，接着输入keytool -import -alias broker -keystore myclient.ts -file mybroker_cert，生成myclient.ts。
证书生成的工作就完成了。
接着把刚刚生成的证书复制到MQ目录\conf下，将activemq.xml的sslContext节点修改为

<sslContext> 
    <sslContext keyStore="file:${activemq.base}/conf/mybroker.ks" keyStorePassword="test123"/> 
</sslContext>

重启MQ，修改Consumer.java和Publisher.java和VM参数为
-Djavax.net.ssl.keyStore＝MQ目录\conf\myclient.ks
-Djavax.net.ssl.keyStorePassword=test123
-Djavax.net.ssl.trustStore=MQ目录\conf\myclient.ts
启动Consumer.java和Publisher.java
到此，我们把我们自己生成的证书用到了SSL协议上。
其它诸如HTTP(S)/UDP(不可靠性)/VM(用于虚拟机内应用程序间的通信)等协议，在实际中用的并不多，本教程就不介绍了。

评论

5 楼 jrocket 2014-07-17  

谢谢，很实用

4 楼 zhengyong7232 2013-07-02  

单向的试过吗  我搞了两天，不好使

3 楼 wl59138528 2013-05-31  

     good

2 楼 wuzhengxuan 2012-07-17  

讲解得很不错的说，对我们这类入门级别的很有帮助

1 楼 Ahua772 2011-12-20  

非常感谢，谢谢了