新增mqtt相关功能

张世豪

2 天以前 c9b1d33979b3972fe6a82fa427b4ba9a20989112

 src/Mqttmessage/Client.java

@@ -4,6 +4,9 @@
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;

import set.Setsys;
import user.Usrdell;

/**
 * MQTT客户端工具类
 * 用于连接MQTT服务器并订阅主题
@@ -94,12 +97,12 @@
     * 示例用法
     */

    public static void test()  {
    public static void lianjiemqqt()  {
        try {
            String host = "tcp://39.99.43.227:1883";
            String deiveID="6258";
            String clientId = "hxzkMQTT";
            String clientId2 = "hxzkMQTT2";
            String deiveID=Setsys.getMowerIdValue();
            String clientId =Usrdell.getUserEmail()+"mower";
            String clientId2 =Usrdell.getUserEmail()+"response";
            String topic = "mower/"+deiveID+"/gps";
            String topic2 = "mower/"+deiveID+"/response";
            Client mqttClient = new Client(host, topic, clientId);