0

我正在尝试订阅控制主题。当我订阅时，mqtt 适配器显示以下日志记录：

14:28:47.933 [vert.x-eventloop-thread-0] DEBUG o.e.h.a.m.i.VertxBasedMqttProtocolAdapter - created subscription [tenant: tenant_aloxy, device: device-aloxy, filter: control/tenant_aloxy/device-aloxy/req/#, requested QoS: AT_MOST_ONCE, granted QoS: AT_MOST_ONCE]

当我将消息发布到 control/tenant_aloxy/device-aloxy/req//alp 时，设备没有收到消息，并且我没有在 hono mqtt 适配器中记录任何错误。但是，当我使用以下命令自己订阅该主题时：qb message receive control/tenant_aloxy/device-aloxy/req/# -b amqp://user:secret@hostname:5672，我收到了消息。知道在哪里看吗？

我目前使用的 Hono 版本来自提交https://github.com/eclipse/hono/commit/78979346212446dc6cf8b8b3255f048e19e81210

更新
我将 Hono 更新到版本 0.9-M2 并且仍然有同样的问题。订阅时的日志记录如下：

12:21:02.407 [vert.x-eventloop-thread-0] INFO  o.e.h.s.m.LoggingConnectionEventProducer -    Connected - ID: device_interface_client_b24704c9-ed11-41af-a0e0-ba90264a7362, Protocol Adapter: hono-mqtt, Device: device [device-id: device-aloxy, tenant-id: tenant_aloxy], Data: null
12:21:02.515 [vert.x-eventloop-thread-0] DEBUG o.e.h.client.impl.AbstractHonoClient - receiver open [source: control/tenant_aloxy/device-aloxy]
12:21:02.515 [vert.x-eventloop-thread-0] DEBUG o.e.hono.client.CommandConsumer - successfully created command consumer [control/tenant_aloxy/device-aloxy]
12:21:02.517 [vert.x-eventloop-thread-0] DEBUG o.e.h.a.m.i.VertxBasedMqttProtocolAdapter - created subscription [tenant: tenant_aloxy, device: device-aloxy, filter: control/+/+/req/#, requested QoS: AT_MOST_ONCE, granted QoS: AT_MOST_ONCE]

我将消息发布到队列控制/tenant_aloxy/device-aloxy/req//alp

更新 2
我发现了一些奇怪的东西。以下屏幕截图从整体角度显示了指标： Enmasse 连接视图

它显示有多条消息已发布到队列，但已被 Hono MQTT 适配器拒绝。但是，尽管 SPRINT_PROFILE "dev" 已激活，但我在控制台中看不到这些消息的任何日志记录。

4

2 回答 2

0

经过身份验证的设备必须使用主题过滤器control/+/+/req/#来订阅命令。如果设备未经身份验证，则control/${tenant-id}/{device-id}/req/#可以使用。

如果设备device-aloxy已通过身份验证，则订阅主题control/+/+/req/#并尝试发送命令。

于 2019-01-25T16:30:57.937 回答
0

我认为您发布到错误的地址。另请记住，发送命令的应用程序不会发布到主题（即 MQTT parlais），而是将 AMQP 消息发送到由地址标识的远程节点。

也就是说，您的应用程序应通过目标地址为的发送方链接发送命令（请参阅https://www.eclipse.org/hono/api/command-and-control-api/#send-a-onecontrol/tenant_aloxy/device-aloxy的前提条件-方式命令）。请注意，目标地址与设备订阅的 MQTT 主题名称不同。

如果您期待响应，那么您还需要打开一个接收者链接，并在命令消息中包含接收者链接的源地址作为回复属性的值（如https://www.eclipse.org/hono中所述/api/command-and-control-api/#send-a-request-response-command）。

于 2019-01-28T13:27:10.313 回答