如何从 MQTT 生产并在 ActiveMQ 中作为 MQTT 和 JMS 消费答案

【问题标题】：How to Produce from MQTT and consume as MQTT and JMS in ActiveMQ如何从 MQTT 生产并在 ActiveMQ 中作为 MQTT 和 JMS 消费
【发布时间】：2015-08-23 17:48:00
【问题描述】：

我有一个设置，其中消息作为 MQTT 生成到 ActiveMQ。我有两个消费者，一个是 JMS，另一个是 MQTT。

当我将消息作为 JMS 消息发布到主题“foo”时，我在 JMS 和 MQTT 消费者处都接收到消息，但是当我在同一主题上作为 MQTT 发布时，我仅在 MQTT 消费者和JMS 消费者什么也没有收到。

在发布为 MQTT 时，我是否需要专门做一些事情才能像 MQTT 和 JMS 一样使用。

请帮忙。

更新：

JMS Consumer
JMS Producer
MQTT Publisher
MQTT Subscriber
activemq.xml

【问题讨论】：

您应该检查 MQTT 客户端用于发布到所有的主题名称是否会导致您的 JMS 客户端订阅的内容。
我将主题名称用作 JMS 和 MQTT 发布者和订阅者的“foo”。主题名称对我来说似乎不是问题。
我认为任何人都无法在不查看 ActiveMQ WebConsole 的代码和视图的情况下做出回答，以了解正在创建哪些目标。还可以使用最新的 ActiveMQ 版本来修复所有错误。
嗨，我已经添加了代码和截图。我正在使用 ActiveMQ 5.11.1

标签： jms activemq mqtt

【解决方案1】：

您的问题看起来是您的 JMS 使用者期望消息以 TextMessage 形式到达，这是在处理 MQTT 生成的消息时的错误假设。

MQTT 消息是二进制的，没有内容类型信息或标头来定义有效负载。出于这个原因，代理将始终将它们解释为 BytesMessage 并按原样发送它们。您将需要针对该事实编写代码并同时使用 BytesMessage，然后将有效负载作为字符串读取。

【讨论】：