rpc sub

apq-pc-client/src/main/java/com/priusis/client/service/core/MqttServiceImpl.java

@@ -70,7 +70,8 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
 
     private static final String DEVICE_TELEMETRY_TOPIC = "devices/telemetry";
     private static final String DEVICE_ATTRIBUTES_TOPIC = "devices/attrs";
-    private static final String DEVICE_RPC_TOPIC = "devices/rpc";
+    private static final String DEVICE_RPC_RES_TOPIC = "devices/rpc/req";
+    private static final String DEVICE_RPC_TOPIC = DEVICE_RPC_RES_TOPIC + "/+";
     private static final String DEVICE_EVENT_TOPIC = "devices/event";
     private static final String DEVICE_GET_ATTRIBUTES_REQUEST_TOPIC = "devices/attrs/req/1";
     private static final String DEVICE_GET_ATTRIBUTES_RESPONSE_PLUS_TOPIC = "devices/attrs/res/+";
@@ -303,15 +304,15 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
                     onAttributesUpdate(message);
                 } else if (topic.equals(DEVICE_GET_ATTRIBUTES_RESPONSE_PLUS_TOPIC)) {
                     onDeviceAttributesResponse(message);
-                } else if (topic.equals(DEVICE_RPC_TOPIC)) {
+                } else if (topic.startsWith(DEVICE_RPC_RES_TOPIC)) {
                     onRpcCommand(message);
-                } else if (topic.equals(DEVICE_ATTRIBUTES_TOPIC)) {
+                } else if (topic.startsWith(DEVICE_ATTRIBUTES_TOPIC)) {
                     onGatewayAttributesUpdate(message);
                 } else if (topic.equals(DEVICE_GET_ATTRIBUTES_RESPONSE_TOPIC)) {
                     onGatewayAttributesGet(message);
                 }
             } catch (Exception e) {
-                log.warn("Failed to process arrived message!", message);
+                log.warn("Failed to process arrived message：{}!", message, e);
             }
         });
 
@@ -677,9 +678,9 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
         } catch (Exception e) {
             log.error("获取Mac地址注册设备信息异常", e);
         }
-        //MqttClientSecurityConfiguration mqttClientSecurityConfiguration = new MqttClientSecurityConfiguration();
-        //mqttClientSecurityConfiguration.setAccessToken("D6qjl0xNnDMtgSPMczGt");
-        //return mqttClientSecurityConfiguration;
+        MqttClientSecurityConfiguration mqttClientSecurityConfiguration = new MqttClientSecurityConfiguration();
+        mqttClientSecurityConfiguration.setAccessToken("D6qjl0xNnDMtgSPMczGt");
+        return mqttClientSecurityConfiguration;
         //return null;
     }
 

apq-pc-client/src/main/resources/application-dev.yml

 apq:
-  iot-gateway: 192.168.124.29:7002
+  iot-gateway: 192.168.124.19:7002
 PC_HOST: 192.168.124.29