package mqtt;

import org.eclipse.paho.client.mqttv3.*;

public class MqttClientCalendarExample {

 public static void main(String[] args) {
 /**
 * mqtt.host=tcp://124.223.72.93:1883
 * mqtt.username=admin
 * mqtt.password=admin@123
 * mqtt.topic=user/DEVICEID/smart
 * mqtt.clientId=client_XXX
 */
 String broker = "tcp://124.223.72.93:1883";
 String userName = "admin";
 String password = "admin@123";
 String DEVICEID = "test333";
 String clientId = "client_" + DEVICEID;
 String topic = "user/" + DEVICEID + "/smart";//发布
 //订阅
 String topicFilter = "test/ddqqbb";//订阅
 try {
 MqttClient client = new MqttClient(broker, clientId);
 MqttConnectOptions connOpts = new MqttConnectOptions();
 connOpts.setUserName(userName);
 connOpts.setPassword(password.toCharArray());
 connOpts.setCleanSession(true);

 client.connect(connOpts);
 String message = "IDEA-publish message";
 MqttMessage mqttMessage = new MqttMessage(message.getBytes());
 mqttMessage.setQos(0);
 client.publish(topic, mqttMessage);
// client.disconnect();
 client.subscribe(topicFilter);
 client.setCallback(new MqttCallback() {
 @Override
 public void connectionLost(Throwable cause) {
 System.out.println("connectionLost:" + cause.getMessage());
 }

 @Override
 public void messageArrived(String topic, MqttMessage message) throws Exception {
 System.out.println("messageArrived:" + message);
// messageArrived:{"deviceid":"test333","pushBody":"{\"content\":{\"person\":\"[徐总]\",\"location\":\"[]\",\"time\":\"[明天中午12点]\"},\"desc\":\"\",\"result\":0,\"type\":\"normal\"}","pushType":"1"}
// messageArrived:{"deviceid":"test333","pushBody":"{\"desc\":\"\",\"items\":[{\"x\":0,\"y\":0,\"cell\":\"TIME\"},{\"x\":0,\"y\":1,\"cell\":\"周一/Mon\"},{\"x\":0,\"y\":2,\"cell\":\"周二/Tue\"},{\"x\":0,\"y\":3,\"cell\":\"周三/Wed\"},{\"x\":0,\"y\":4,\"cell\":\"周四/Thu\"},{\"x\":0,\"y\":5,\"cell\":\"周五/Fri\"},{\"x\":0,\"y\":6,\"cell\":\"TIME\"},{\"x\":0,\"y\":7,\"cell\":\"周六/Sat\"},{\"x\":0,\"y\":8,\"cell\":\"周日/Sun\"},{\"x\":1,\"y\":0,\"cell\":\"08:30-09:30\"},{\"x\":1,\"y\":1,\"cell\":\"小蜜腰塑形\\nSera\"},{\"x\":1,\"y\":2,\"cell\":\"\"},{\"x\":1,\"y\":3,\"cell\":\"翘臀瘦腿\\nLucy\"},{\"x\":1,\"y\":4,\"cell\":\"\"},{\"x\":1,\"y\":5,\"cell\":\"美背塑胸\\nLiz\"},{\"x\":1,\"y\":6,\"cell\":\"10:30-11:30\"},{\"x\":1,\"y\":7,\"cell\":\"\"},{\"x\":1,\"y\":8,\"cell\":\"能量塔架\\nAngel\"},{\"x\":2,\"y\":0,\"cell\":\"10:30-11:30\"},{\"x\":2,\"y\":1,\"cell\":\"翘臀瘦腿\\nSera\"},{\"x\":2,\"y\":2,\"cell\":\"美背塑胸\\nYIYI\"},{\"x\":2,\"y\":3,\"cell\":\"维密训练\\nLucy\"},{\"x\":2,\"y\":4,\"cell\":\"小蜜腰塑形\\nSunny\"},{\"x\":2,\"y\":5,\"cell\":\"能量塔架\\nLiz\"},{\"x\":2,\"y\":6,\"cell\":\"11:00-12:00\"},{\"x\":2,\"y\":7,\"cell\":\"极速塑形\\nSunny\"},{\"x\":2,\"y\":8,\"cell\":\"\"},{\"x\":3,\"y\":0,\"cell\":\"11:45-12:45\"},{\"x\":3,\"y\":1,\"cell\":\"维密训练\\nSera\"},{\"x\":3,\"y\":2,\"cell\":\"脊柱保养\\nYIYI\"},{\"x\":3,\"y\":3,\"cell\":\"小蛮腰塑形\\nLucy\"},{\"x\":3,\"y\":4,\"cell\":\"能量塔架\\nSunny\"},{\"x\":3,\"y\":5,\"cell\":\"极速型形\\nLiz\"},{\"x\":3,\"y\":6,\"cell\":\"13:00-14:00\"},{\"x\":3,\"y\":7,\"cell\":\"\\nSunny\"},{\"x\":3,\"y\":8,\"cell\":\"美背型胸\\nAngel\"},{\"x\":4,\"y\":0,\"cell\":\"13:00-14:00\"},{\"x\":4,\"y\":1,\"cell\":\"\"},{\"x\":4,\"y\":2,\"cell\":\"能量塔架\\nYIYI\"},{\"x\":4,\"y\":3,\"cell\":\"\"},{\"x\":4,\"y\":4,\"cell\":\"美背塑胸\\nSunny\"},{\"x\":4,\"y\":5,\"cell\":\"\"},{\"x\":4,\"y\":6,\"cell\":\"14:30-15:30\"},{\"x\":4,\"y\":7,\"cell\":\"维密训练\\nSunny\"},{\"x\":4,\"y\":8,\"cell\":\"脊柱保养\\nAngel\"},{\"x\":5,\"y\":0,\"cell\":\"18:15-19:15\"},{\"x\":5,\"y\":1,\"cell\":\"\"},{\"x\":5,\"y\":2,\"cell\":\"小蛮腰塑形\\nRunning\"},{\"x\":5,\"y\":3,\"cell\":\"\"},{\"x\":5,\"y\":4,\"cell\":\"翅臀瘦腿\\n兰兰\"},{\"x\":5,\"y\":5,\"cell\":\"\"},{\"x\":5,\"y\":6,\"cell\":\"18:00-19:00\"},{\"x\":5,\"y\":7,\"cell\":\"美背塑胸\\nNini\"},{\"x\":5,\"y\":8,\"cell\":\"\"},{\"x\":6,\"y\":0,\"cell\":\"18:30-19:30\"},{\"x\":6,\"y\":1,\"cell\":\"能量��架\\nLiz\"},{\"x\":6,\"y\":2,\"cell\":\"\"},{\"x\":6,\"y\":3,\"cell\":\"美背塑胸\\nSera\"},{\"x\":6,\"y\":4,\"cell\":\"\"},{\"x\":6,\"y\":5,\"cell\":\"脊柱保养\\nSera\"},{\"x\":6,\"y\":6,\"cell\":\"18:15-19:15\"},{\"x\":6,\"y\":7,\"cell\":\"\"},{\"x\":6,\"y\":8,\"cell\":\"极速塑形\\nSunny\"},{\"x\":7,\"y\":0,\"cell\":\"19:30-20:30\"},{\"x\":7,\"y\":1,\"cell\":\"\"},{\"x\":7,\"y\":2,\"cell\":\"翘臀瘦腿\\nRunning\"},{\"x\":7,\"y\":3,\"cell\":\"\"},{\"x\":7,\"y\":4,\"cell\":\"维密训练\\n兰兰\"},{\"x\":7,\"y\":5,\"cell\":\"\"},{\"x\":7,\"y\":6,\"cell\":\"19:15-20:15\"},{\"x\":7,\"y\":7,\"cell\":\"能量塔架\\nNini\"},{\"x\":7,\"y\":8,\"cell\":\"\"},{\"x\":8,\"y\":0,\"cell\":\"20:00-21:00\"},{\"x\":8,\"y\":1,\"cell\":\"美背塑胸\\nLiz\"},{\"x\":8,\"y\":2,\"cell\":\"\"},{\"x\":8,\"y\":3,\"cell\":\"极速塑形\\nSera\"},{\"x\":8,\"y\":4,\"cell\":\"\"},{\"x\":8,\"y\":5,\"cell\":\"翅臂腹腿\\nSera\"},{\"x\":8,\"y\":6,\"cell\":\"19:30-20:30\"},{\"x\":8,\"y\":7,\"cell\":\"\"},{\"x\":8,\"y\":8,\"cell\":\"小蜜腰型形\\nSunny\"}],\"result\":0,\"type\":\"excel\"}","pushType":"1"}
 }

 @Override
 public void deliveryComplete(IMqttDeliveryToken token) {
 System.out.println("deliveryComplete:" + token);
 }
 });
 } catch (MqttException me) {
 System.out.println("Error: " + me.getMessage());
 }
 }
}