使用 MQTT 在 Java 中将命令发布到 IBM IoT 中的设备

Question

我目前正在尝试使用 Java Web 应用程序将命令发布到 IBM IoT Foundation MQTT Broker 中的特定主题。我的应用程序已经能够侦听设备事件并对其执行操作，但是将命令发布到设备是一个问题。我确定我的设备正在侦听命令的正确主题，那么可能有什么问题？更具体地说，这是我调用的用于发布到主题的命令（从我的 Java 应用程序）：

publish("iot-2/cmd/" + MQTTUtil.getDefaultCmdId() + "/fmt/json", rawJSONCommand, false, 0); 
System.out.println("Finished sending command!"); 

其中"发布"方法定义如下：

public void publish(String topic, String message, boolean retained, int qos) { // check if client is connected
if (isMqttConnected()) 
{
// create a new MqttMessage from the message string 
MqttMessage mqttMsg = new MqttMessage(message.getBytes()); 
// set retained flag 
mqttMsg.setRetained(retained); 
// set quality of service 
mqttMsg.setQos(qos);
try { 
System.out.println("About to send!"); 
client.publish(topic, mqttMsg); 
System.out.println("Finished sending!"); } 
catch (MqttPersistenceException e)
{ e.printStackTrace(); } 
catch (MqttException e)
{ e.printStackTrace(); } }
else {
System.out.println("Connection lost!"); connectionLost(null); 
} }

发生的所有事情是我输入方法，按照代码指定在我的控制台上打印"即将发送！"，然后实际的"client.publish（topic，mqttMsg）"调用无限期地阻止我的程序。最终，在阻止一段时间后，我收到以下错误：

org.eclipse.paho.client.mqttv3.internal.ClientState checkForActivity SEVERE: a:2uwqwc:<MY_APP_NAME>: Timed out as no write activity, keepAlive=60,000 lastOutboundActivity=1,452,646,209,624 lastInboundActivity=1,452,646,149,303 time=1,452,646,329,628 lastPing=0

感谢您的帮助！

Answer 1

如果要从应用程序发布，是否指定设备类型和设备 ID？

myAppClient.publishCommand(deviceType, deviceId, "stop", data);

请参阅文档中有关将命令发布到连接设备的部分。https://docs.internetofthings.ibmcloud.com/java/java_cli_app.html