ActiveMQ 无法识别 Stomp : Transport scheme NOT recognized: [stomp+ssl]

Question

我正在尝试在 puppetmaster(开源 puppet )上设置 mcollective/activemq。我遇到了 ActiveMQ 无法识别 Stomp 协议(protocol)的问题。这是我的 /etc/activemq/instances-enabled/activemq/activemq.xml 文件中应该启用 stomp+ssl 的相关片段:

<transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
            <transportConnector name="stomp+ssl" uri="stomp+ssl://0.0.0.0:61614?needClientAuth=true&amp;transport.enabledProtocols=TLSv1,TLSv1.1,TLSv1.2"/>
</transportConnectors>

当我通过 service activemq start 启动 ActiveMQ 时，我注意到守护进程并没有结束运行(我不认为它是一个进程)。然后我尝试运行 service activemq console activemq，看起来问题是它找不到 stomp 传输方案。这是我在输出中看到的第一个错误(错误在整个输出过程中一直存在):

ERROR | Failed to start Apache ActiveMQ ([localhost, ID:my-servers-hostname.example.com-40447-1475514312306-0:1], java.io.IOException: Transport Connector could not be registered in JMX: java.io.IOException: Transport scheme NOT recognized: [stomp+ssl])

ActiveMQ 可以很好地识别 openwire。仅使用 openwire+ssl 而不使用 stomp+ssl 时，ActiveMQ 守护进程可以正常启动，没有错误。但是，当我尝试运行 mco find 时，出现错误，因为 mco 似乎仍在尝试使用 stomp+ssl(而 ActiveMQ 仅启用了 openwire+ssl):

error 2016/10/03 17:26:59: activemq.rb:149:in `on_ssl_connectfail' SSL session creation with stomp+ssl://mcollective@localhost:61614 failed: Connection refused - connect(2) for "localhost" port 61614

也许我需要调整我的 mco 配置以使用 openwire 而不是 stomp？我不确定该配置位于何处或位于哪个文件中。不确定为什么它不能识别 stomp，但我想知道我在这里有什么选择。是否甚至可以仅使用 openwire+ssl 来使用 MCollective/ActiveMQ，或者如果我想使用 mco，是否需要使用 stomp？我认为这不是端口问题，因为我相信相关端口在服务器上是打开的。

以下是我机器上安装的相关包/版本:

OS: Ubuntu 16.04 (xenial)
puppet: 4.7.0
ActiveMQ: 5.13.2
ruby-stomp: 1.3.5-1
MCollective (mco) version: 2.9.0

Answer 1

我在项目中的嵌入式 ActiveMQ 服务器遇到了同样的问题。结果我需要将以下依赖项添加到我的 pom。

    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-stomp</artifactId>
        <version>5.15.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-kahadb-store</artifactId>
        <version>5.15.0</version>
    </dependency>

在您的情况下，我认为您需要获取这 2 个 jar 并将它们添加到您的 ActiveMQ 安装中。