StompJS向MQTT代理发消息时遇“Unknown Destination”错误

问题分析 #

你遇到的问题本质是STOMP协议与MQTT代理的地址解析规则不匹配：

• 使用/test作为destination时，MQTT代理无法识别无前缀的绝对路径格式，因此返回Unknown destination错误；
• 使用test作为destination时，代理默认启用了自动前缀映射规则，将无前缀地址自动补全为/queue/test，但这不符合你的需求。

解决方案 #

针对不同的MQTT代理（如EMQX、ActiveMQ等），可以通过以下方式解决：

1. 修改代理的STOMP插件配置

大多数MQTT代理的STOMP插件支持自定义destination映射规则，以EMQX为例：

• 找到STOMP插件配置文件（通常为emqx.conf或stomp.conf）；
• 添加或修改stomp.destination_mapping配置，指定/test直接映射到MQTT主题test：

  stomp.destination_mapping = "/test" => "test"
  

  保存配置后重启代理，此时使用/test作为destination即可正常发送消息。

2. 调整STOMP消息的Destination格式

如果代理不允许修改映射规则，可根据代理的默认映射逻辑调整destination：

• 若代理支持/topic/前缀映射到MQTT主题（自动去掉前缀），则将destination设为/topic/test，代理会自动转换为MQTT主题test；
• 部分代理支持直接使用test作为destination，但需要关闭自动添加/queue/前缀的功能，具体需查阅对应代理的官方文档。

3. 关闭代理的自动前缀添加规则

有些代理默认会给所有无前缀的STOMP destination添加/queue/或/topic/前缀，需找到对应配置项关闭该功能。例如在ActiveMQ中，修改activemq.xml里的STOMP连接器配置：

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?autoCreateQueues=false&amp;autoCreateTopics=false&amp;destinationPrefix=" />

清空destinationPrefix的默认值，即可禁用自动前缀添加。

验证代码示例 #

配置完成后，使用原代码即可正常发送：

stompClient.publish({
     destination: `/test`,
     binaryBody: data, 
     headers: {
        contentType: 'application/octet-stream',
     }
})

内容的提问来源于stack exchange，提问作者Rusty