mqtt接收数据并保存

使用java语言，接收mqtt传输来的数据，并进行保存，里面包含所需的jar包

package com.jinzhong;  
  
 import java.util.concurrent.ScheduledExecutorService;  
 import org.eclipse.paho.client.mqttv3.MqttClient;  
 import org.eclipse.paho.client.mqttv3.MqttConnectOptions;  
 import org.eclipse.paho.client.mqttv3.MqttException;  
 import org.eclipse.paho.client.mqttv3.MqttTopic;  
 import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
   
 public class Client {  
   
     public static final String HOST = “tcp://127.0.0.1:1883“;  
     public static final String TOPIC = “toclient/111/#“;  
     private static final String clientid = “client“;  
     private MqttClient client;  
     private MqttConnectOptions options;  
     private String userName = “admin“;
     private String passWord = “password“;
   
     private ScheduledExecutorS

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        2633  2018-01-04 16:51  mqtt接收数据并保存\Client.java
     文件        2914  2018-01-04 16:52  mqtt接收数据并保存\PushCallback.java
     目录           0  2018-01-04 16:54  mqtt接收数据并保存\jar\
     文件      190418  2018-01-03 11:37  mqtt接收数据并保存\jar\gson-2.2.4.jar
     文件      279402  2018-01-03 17:14  mqtt接收数据并保存\jar\mqtt-client-1.7-uber.jar
     文件      313438  2018-01-03 11:37  mqtt接收数据并保存\jar\org.eclipse.paho.client.mqttv3-1.0.2.jar
     文件       48593  2018-01-03 11:37  mqtt接收数据并保存\jar\wmqtt.jar
     目录           0  2018-01-04 16:54  mqtt接收数据并保存\