4.2传输连接器

4.2传输连接器

为了交换信息，生产者和消费者必须连接到代理器。客户端到代理器的连接是通过传输连接器来实现的。ActiveMQ提供了一些客户端协议，可以用来交换信息。ActiveMQ用户对连接的要求是多种多样的。一些用户关注性能，一些用户关注安全或其它指标。ActiveMQ尝试满足所有这些要求，并对每一种使用场景提供一种连接器。

    在这一节，你将学会在ActiveMQ配置文件中配置传输连接器，然后修改股票投资例子来演示这些连接器。接下来的章节，我们将讨论网络连接器可用协议，并介绍内嵌代理器和虚拟机协议。这两个概念使得代理器可以在你的应用中运行，这个主题将在第七章继续讨论。

 

4.2.1配置传输连接器

对于代理器来说，传输连接器是用来接受和监听客户端连接的。如果你看一看ActiveMQ演示例子的配置文件（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>

你可以看到传输连接器定义在<transportConnectors>元素之间。你通过<transport-Connector>元素定义特定的连接器。ActiveMQ可以不同的端口上设置不同协议的连接器。一个连接器必须有自己唯一的名字和URI属性。在这个例子中，URI定义了网络协议和可选参数，通过它们，ActiveMQ将被曝露出来给客户端连接。discoveryUri属性是可选的，这个属性将在4.3.1节讲解。

    上面的片段定义了4个传输连接器。当你通过使用这样的配置文件启动ActiveMQ，你将看到如下日志：

INFO TransportServerThreadSupport - Listening for connections at:
tcp://localhost:61616

INFO TransportConnector - Connector openwire Started
INFO TransportServerThreadSupport - Listening for connections at:
ssl://localhost:61617
INFO TransportConnector - Connector ssl Started
INFO TransportServerThreadSupport - Listening for connections at:
stomp://localhost:61613
INFO TransportConnector - Connector stomp Started
INFO TransportServerThreadSupport - Listening for connections at:
xmpp://localhost:61222
INFO TransportConnector - Connector xmpp Started

 

从客户端角度，传输连接器是一个连接，通过它可以向代理器发送和接收消息。发送和接收消息的内容放在第七章。下面的代码展示了java应用如何使用传输连接器URIs。

ActiveMQConnectionFactory factory =
    new ActiveMQConnectionFactory("tcp://localhost:61616 ");
Connection connection = factory.createConnection();
connection.start();
Session session =
    connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

我们可以看到，在配置文件里定义的URI被客户端用来创建连接。在这个例子中，TCP传输URI将被使用。

注：我们可以在客户端和服务器端是用URI的query部分。通常地，这些参数对于客户端和服务器端都有用，但其中的一些只能用在某一部分。所以，在使用这些特定查询参数前请先查看文档说明。

理解了基本的传输连接器配置之后，我们应该了解ActiveMQ提供了哪些类型的传输连接器。不过在我们讲解特定传输连接器之前，我们先修改股票投资例子，让它使用不同的传输连接器。

 

4.2.2修改股票投资例子

第三章引入了一个股票投资例子，它用ActiveMQ来发布和消费股票交易消息。当时，我们使用标准的连接器URI，因为我们想让这个例子看起来尽量简单。这一章，我们将介绍所有的协议并同意股票投资例子来使用它们。所以，我们要修改该例子，让它使用任意的协议工作。

    列表4.1是main（）一个修改后的版本。

Listing 4.1 Modifying stock portfolio publisher to support various connector URIs

 前面的代码保证连接器URI作为第一个参数被传递，并且剩下的参数是额外的目标的名称。现在，生产者可以通过下面的命令来运行：

$ mvn exec:java -Dexec.mainClass=org.apache.activemq.book.ch4.Publisher \
-Dexec.args="tcp://localhost:61616 CSCO ORCL"
...
Sending: {price=65.713356601409, stock=JAVA, offer=65.779069958011,
up=true}
on destination: topic://STOCKS.JAVA
Sending: {price=66.071605671946, stock=JAVA, offer=66.137677277617,
up=true}
on destination: topic://STOCKS.JAVA
Sending: {price=65.929035001620, stock=JAVA, offer=65.994964036622,
up=false}
on destination: topic://STOCKS.JAVA
...

注意到现在有三个参数被传送给生产者。我们也可以用相同的方法来修改消费者。在下面的列表中，被修改后的消费者把第一个参数作为URI来使用。

Listing 4.2 Modifying stock portfolio consumer to support various connector URIs

 为了达到和第三章相同的功能，你必须提供一个额外的URI参数。下面的例子展示了如何做：

$ mvn exec:java -Dexec.mainClass=org.apache.activemq.book.ch4.Consumer \
-Dexec.args="tcp://localhost:61616 CSCO ORCL"
...
ORCL 65.71 65.78 up
ORCL 66.07 66.14 up
ORCL 65.93 65.99 down
CSCO 23.30 23.33 up
...

注意，消息在生产者和消费者之间的流动是和原始例子一样。通过这些修改，现在这个例子可以使用各种协议运行了。现在我们应该深入到特定的连接器里面了。下面的部分你将看到你通过网络连接代理器有什么选择。