如何在主要方法Eclipse Paho中访问回调方法（messageArrived）到达的消息的有效负载？

问题描述：

问题陈述： - 我试图自动化MQTT流程，因为我需要按顺序发布和订阅多个主题。技巧部分是从第一次发布接收到的消息具有一些值，将在下一个子/ pub命令中传递。如何在主要方法Eclipse Paho中访问回调方法（messageArrived）到达的消息的有效负载？

例如，

子到topicA/ABC
酒吧到topicA/ABC上topicA/ABC接收
消息为xyz
子主题topicA/XYZ
酒馆主题topicA/XYZ

我能够接收关于第一个主题的消息，但我没有得到如何访问主方法中接收到的消息的有效载荷，并将其传递并附加到下一个主题为下一个子。

有没有办法将messageArrived回调方法的消息有效载荷从客户端实例创建的主方法获取？

注意： - 我正在使用单个客户端进行发布和订阅。

请帮助我，因为我已经用尽了选择和方法。

编辑： -

代码片断

主要类

public class MqttOverSSL { 
String deviceId; 
MqttClient client = null; 

public MqttOverSSL() { 

} 

public MqttOverSSL(String deviceId) throws MqttException, InterruptedException { 
    this.deviceId = deviceId; 
    MqttConnection mqttConObj = new MqttConnection(); 
    this.client = mqttConObj.mqttConnection(); 
} 

public void getLinkCodeMethod() throws MqttException, InterruptedException { 

    client.subscribe("abc/multi/" + deviceId + "/linkcode", 0); 
    publish(client, "abc/multi/" + deviceId + "/getlinkcode", 0, "".getBytes()); 


} 

}

MQTT Claback IMPL： -

public class SimpleMqttCallBack implements MqttCallback { 

    String arrivedMessage; 

    @Override 
    public void connectionLost(Throwable throwable) { 
    System.out.println("Connection to MQTT broker lost!"); 
    } 

    @Override 
    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { 

    arrivedMessage = mqttMessage.toString(); 

    System.out.println("Message received:\t" + arrivedMessage); 

    linkCode(arrivedMessage); 
    } 

    @Override 
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { 
    System.out.println("Delivery complete callback: Publish Completed "+ Arrays.toString(iMqttDeliveryToken.getTopics())); 
    } 


    public void linkCode(String arrivedMessage) throws MqttException { 
    System.out.println("String is "+ arrivedMessage); 
    Gson g = new Gson(); 
    GetCode code = g.fromJson(arrivedMessage, GetCode.class); 
    System.out.println(code.getLinkCode()); 
    } 

}

Publisher类： -

public class Publisher { 
    public static void publish(MqttClient client, String topicName, int qos, byte[] payload) throws MqttException { 

     String time = new Timestamp(System.currentTimeMillis()).toString(); 
     log("Publishing at: "+time+ " to topic \""+topicName+"\" qos "+qos); 

     // Create and configure a message 
     MqttMessage message = new MqttMessage(payload); 
     message.setQos(qos); 

     // Send the message to the server, control is not returned until 
     // it has been delivered to the server meeting the specified 
     // quality of service. 
     client.publish(topicName, message); 
    } 

    static private void log(String message) { 
     boolean quietMode = false; 
     if (!quietMode) { 
      System.out.println(message); 
     } 
    } 
}

没有与我们共享任何代码，我们真的不能帮助 – hardillb

嗨hardilib，在原来的帖子中添加了相同的内容。请看看。 –

答

好的，现在你要做的更清楚一点。

简短回答不，你不能将值传递回“主要方法”。 MQTT是异步的，意味着您不知道消息何时到达您订阅的主题。

您需要更新代码来检查传入消息主题是什么，然后处理在messageArrived()处理程序中执行的任何操作。如果你有一系列的任务需要完成，那么你可能需要实现所谓的状态机，以便跟踪你在序列中的位置。

如何在主要方法Eclipse Paho中访问回调方法（messageArrived）到达的消息的有效负载？

相关推荐