KURA：如何更改MQTT消息格式

1 回答

• 4

  直接使用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[] 数组 .

  回复于 2024-05-05T09:39:41+08:00