KURA：如何更改 MQTT 消息格式

Question

KURA MQTT 云客户端根据以下公式 (more details) 发布消息：

#account-name/#client-id/#API-ID/topic

我想用自己的格式发送 MQTT 消息，我不想在 MQTT 消息中发送账户名和客户端 ID。

我该怎么做？ 我已经尝试在 KURA Web 界面 -> MQTTData 传输中更改配置，并删除了“lwt.topic”的内容，但没有成功。

Answer 1

直接使用DataService。让 OSGi 将实例注入到您的组件中。
在组件类中使用的示例代码：

public class MyComponent {
    private DataService m_dataService;

    public void setDataService(DataService dataService) {
        m_dataService = dataService;
    }

    public void unsetDataService(DataService dataService) {
        m_dataService = null;
    }

    // activate() deactivate() and all required methods

    public void publish() {
        String topic = "your/topic";
        String payload = "Hello!";
        int qos = 0;
        boolean retain = false;
        try {
            m_dataService.publish(topic, payload.getBytes(), qos, retain, 2);
            s_logger.info("Publish ok");
        } catch (Exception e) {
            s_logger.error("Error while publishing", e);
        }
    }
}

在你的组件中OSGI-INF/mycomponent.xml通过添加以下内容告诉OSGi调用哪些方法来注入DataService

<reference name="DataService"
    interface="org.eclipse.kura.data.DataService"
    bind="setDataService"
    unbind="unsetDataService"
    cardinality="1..1"
    policy="static" />

然后你可以将你需要的主题传递给DataService.publish(...)。有效负载必须转换为 byte[] 数组。