1-21 ------

xinda-server/mqtt-broker/src/main/java/com/xinda/mqtt/handler/MqttPublish.java

@@ -58,16 +58,31 @@ public class MqttPublish implements MqttHandler {
 
     @Override
     public void handler(ChannelHandlerContext ctx, MqttMessage message) {
+
+        JSONObject jsonObject = JSON.parseObject((String) message.payload());
+
+        System.out.println(jsonObject);
+
+//        查看消息
         MqttPublishMessage publishMessage = (MqttPublishMessage) message;
         /*获取客户端id*/
         String clientId = AttributeUtils.getClientId(ctx.channel());
         String topicName = publishMessage.variableHeader().topicName();
         log.debug("=>***客户端[{}],主题[{}],推送消息[{}]", clientId, topicName,
                 ByteBufUtil.hexDump(publishMessage.content()));
+
         // 以get结尾是模拟客户端数据,只转发消息
         if (topicName.endsWith(XinDaConstant.MQTT.PROPERTY_GET_SIMULATE)) {
             sendTestToMQ(publishMessage);
-        } else {
+        }
+//        else if (topicName.contains("/function/get/")) {
+////            改成订阅主题   进行保存
+//            System.out.println("改成订阅主题");
+//        } else if (topicName.contains("/info/get/")) {
+//            //发布主题   推送的消息进行保存
+//            System.out.println("发布主题");
+//        }
+        else {
             /*获取客户端session*/
             Session session = AttributeUtils.getSession(ctx.channel());
             //平台检测session是否同步