eclipse paho java_Eclipse paho学习笔记

Eclipse Paho

java 支持java和android

两个客户端异步和同步， MqttAsyncClient,MqttClient

其中 后者是前者的包装同步器，特效除了5.0都支持

有两个版本可以相互替换

org.eclipse.paho

org.eclipse.paho.client.mqttv3

%VERSION%

下面是简单同步的例子：

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.MqttMessage;

import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;public classMqttPublishSample {public static voidmain(String[] args) {

String topic= “MQTT Examples”;

String content= “Message from MqttPublishSample”;int qos = 2;

String broker= “tcp://iot.eclipse.org:1883”;

String clientId= “JavaSample”;

MemoryPersistence persistence= newMemoryPersistence();try{

MqttClient sampleClient= newMqttClient(broker, clientId, persistence);

MqttConnectOptions connOpts= newMqttConnectOptions();

connOpts.setCleanSession(true);

System.out.println(“Connecting to broker:”+broker);

sampleClient.connect(connOpts);

System.out.println(“Connected”);

System.out.println(“Publishing message:”+content);

MqttMessage message= newMqttMessage(content.getBytes());

message.setQos(qos);

sampleClient.publish(topic, message);

System.out.println(“Message published”);

sampleClient.disconnect();

System.out.println(“Disconnected”);

System.exit(0);

}catch(MqttException me) {

System.out.println(“reason”+me.getReasonCode());

System.out.println(“msg”+me.getMessage());

System.out.println(“loc”+me.getLocalizedMessage());

System.out.println(“cause”+me.getCause());

System.out.println(“excep”+me);

me.printStackTrace();

}

}

}

下面是异步处理三个例子

https://github.com/eclipse/paho.mqtt.java/tree/master/org.eclipse.paho.sample.mqttv3app/src/main/java/org/eclipse/paho/sample/mqttv3app

最新的java的同步例子有四个类

https://github.com/eclipse/paho.mqtt.java/tree/master/org.eclipse.paho.sample.mqttclient/src/main/java/org/eclipse/paho/sample/mqttclient/mqttv3

发布订阅 连接执行

执行了4种发布的数据，有文件和消息