1

我对此有点陌生，所以我可能错过了显而易见的事情。

我有一个带 jboss 保险丝的 openshift 齿轮。我已经启动了一个带有 mqtt 连接器的 ActiveMQ 代理，并创建了一个骆驼路线（使用 OSGi 蓝图），从同一个 openshift 设备上的 ActiveMQ mqtt 连接器消费。当我使用 ip-address:port 到 mqtt 连接器时，一切正常，但这不是我想要做的。我想要一些其他解决方案（解析器），它不需要我在 mqtt 端点中指出一个特定的 IP 地址，这样我就可以在骆驼路由中移动而无需重新配置它。

ActiveMQ 连接器配置：

   <transportConnectors>
        <transportConnector name="openwire" publishedAddressPolicy="#addressPolicy" uri="tcp://${OPENSHIFT_FUSE_IP}:${OPENSHIFT_FUSE_AMQ_PORT}"/>
        <transportConnector name="mqtt"     publishedAddressPolicy="#addressPolicy" uri="mqtt://${OPENSHIFT_FUSE_IP}:1883"/>
    </transportConnectors>

骆驼路线工作时：

<camelContext trace="false" id="blueprintContext" xmlns="http://camel.apache.org/schema/blueprint">
  <route id="mqttToLog">
    <from uri="mqtt:iot?host=tcp://127.4.22.139:1883&amp;subscribeTopicName=mytesttopic&amp;userName=admin&amp;password=xxxxxxx" id="iot_endpoint">
      <description>The MQTT endpoint for consuming data sent from the devices.</description>
    </from>
    <log message="The message contains ${body}" loggingLevel="INFO" id="iot_log">
      <description>Logs all the incoming MQTT messages. This is just for verification purpouses.</description>
    </log>
    <to uri="mock:result" id="iot_mock">
      <description>Final sink for the MQTT message flow. Kept for verification.</description>
    </to>
  </route>
</camelContext>

我的骆驼路线配置文件将功能骆驼作为父级，并具有骆驼和骆驼-mqtt。

那么我如何摆脱实际上必须在端点中指定主机，例如使用 mq 组或其他一些注册表（结构）或类似的？

谢谢，

托马斯

4

1 回答 1

0

如果您正在运行一个结构，那么 ActiveMQ 集群功能的工作方式如下：代理是所谓的“代理组”的一部分。默认代理是“默认”组的一部分，这意味着有一个名为mq-client-default. 此配置文件将在 OSGi 服务注册表中注册一个预先配置的 ActiveMQ ConnectionFactory。它配置为连接到您的代理所在的任何位置，并将自动故障转移到同一组中的其他代理。

要在 Fuse 6.1 中使用上述内容，请执行以下操作：

  • 创建一个新的子容器
  • 将 mq-client-default 配置文件添加到它
  • 将特性“mq-fabric-camel”添加到 mq-client-default 配置文件。这将安装一个名为“amq”的骆驼组件，该组件自动使用 mq-client-default 配置文件中的 connectionFactory。
  • 像下面这样部署骆驼路线，见证 JBoss Fuse 的精彩:)

<camelContext xmlns="http://camel.apache.org/schema/blueprint"> <route id="myRoute"> <from uri="timer://foo?fixedRate=true&amp;period=5000"/> <setBody> <simple>Hello from Camel route to ActiveMQ</simple> </setBody> <to uri="amq:queue:timermessages"/> </route> </camelContext>

无论broker在哪里，或者camel route在哪里，这条路由产生的消息都会最终到达broker。

祝你好运！

PS amq 组件使用 openwire 与代理通信，但任何其他客户端都可以使用您启用的任何协议来消费或生成消息到您的队列。

于 2015-03-10T13:22:04.077 回答