资源简介
一个关于MQTT的简单java实现
代码片段和文件信息
/**
*
* Description:
* @author admin
* 2017年2月10日下午17:50:15
*/
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 ClientMQTT {
public static final String HOST = “tcp://localhost:1883“;
public static final String TOPIC = “topic11“;
private static final String clientid = “client11“;
private MqttClient client;
private MqttConnectOptions options;
private String userName = “admin“;
private String passWord = “password“;
private ScheduledExecutorService scheduler;
private void start() {
try {
// host为主机名,clientid即连接MQTT的客户端ID,一般以唯一标识符表示,MemoryPersistence设置clientid的保存形式,默认为以内存保存
client = new MqttClient(HOST clientid new MemoryPersistence());
// MQTT的连接设置
options = new MqttConnectOptions();
// 设置是否清空session这里如果设置为false表示服务器会保留客户端的连接记录,这里设置为true表示每次连接到服务器都以新的身份连接
options.setCleanSession(true);
// 设置连接的用户名
options.setUserName(userName);
// 设置连接的密码
options.setPassword(passWord.toCharArray());
// 设置超时时间 单位为秒
options.setConnectionTimeout(10);
// 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线,但这个方法并没有重连的机制
options.setKeepAliveInterval(20);
// 设置回调
client.setCallback(new PushCallback());
MqttTopic topic = client.getTopic(TOPIC);
//setWill方法,如果项目中需要知道客户端是否掉线可以调用该方法。设置最终端口的通知消息
options.setWill(topic “close“.getBytes() 2 true);
client.connect(options);
//订阅消息
int[] Qos = {1};
String[] topic1 = {TOPIC};
client.subscribe(topic1 Qos);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws MqttException {
ClientMQTT client = new ClientMQTT();
client.start();
}
}
属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
目录 0 2017-02-10 13:06 MQTT\
目录 0 2017-02-13 13:06 MQTT\.idea\
文件 4 2017-02-10 10:53 MQTT\.idea\.name
文件 1144 2017-02-10 10:53 MQTT\.idea\compiler.xm
目录 0 2017-02-10 10:53 MQTT\.idea\copyright\
文件 115 2017-02-10 10:53 MQTT\.idea\copyright\profiles_settings.xm
文件 171 2017-02-10 10:53 MQTT\.idea\encodings.xm
目录 0 2017-02-10 12:49 MQTT\.idea\libraries\
文件 693 2017-02-10 12:49 MQTT\.idea\libraries\Maven__org_eclipse_paho_org_eclipse_paho_client_mqttv3_1_0_2.xm
文件 793 2017-02-10 12:43 MQTT\.idea\misc.xm
文件 259 2017-02-10 10:53 MQTT\.idea\modules.xm
目录 0 2017-02-10 10:53 MQTT\.idea\scopes\
文件 143 2017-02-10 10:53 MQTT\.idea\scopes\scope_settings.xm
文件 176 2017-02-10 10:53 MQTT\.idea\vcs.xm
文件 46877 2017-02-13 13:06 MQTT\.idea\workspace.xm
文件 974 2017-02-10 12:49 MQTT\MQTT.iml
文件 647 2017-02-10 12:48 MQTT\pom.xm
目录 0 2017-02-10 10:53 MQTT\src\
目录 0 2017-02-10 10:53 MQTT\src\main\
目录 0 2017-02-10 17:48 MQTT\src\main\java\
文件 2726 2017-02-10 17:48 MQTT\src\main\java\ClientMQTT.java
文件 1811 2017-02-10 17:43 MQTT\src\main\java\PushCallback.java
文件 3242 2017-02-10 17:46 MQTT\src\main\java\ServerMQTT.java
目录 0 2017-02-10 10:53 MQTT\src\main\resources\
目录 0 2017-02-10 10:53 MQTT\src\test\
目录 0 2017-02-10 10:53 MQTT\src\test\java\
目录 0 2017-02-10 13:06 MQTT\target\
目录 0 2017-02-10 17:38 MQTT\target\classes\
文件 2469 2017-02-10 15:25 MQTT\target\classes\ClientMQTT.class
文件 1832 2017-02-10 13:06 MQTT\target\classes\PushCallback.class
文件 3537 2017-02-10 17:38 MQTT\target\classes\ServerMQTT.class
............此处省略2个文件信息
- 上一篇:AutoItX4Java
- 下一篇:android酒店管理系统
相关资源
- AutoItX4Java
- 使用java语言实现的QQ聊天软件
- 用java实现基于文件的图书管理系统
- Java实现分词正向最大匹配和逆向最大
- java 公式计算汇总,直接调用其方法即
- java sqlserver 酒店管理系统 源码
- 基于jspjava的毕业设计源码
- 毕业设计_java+sql2000员工管理系统
- java语言解决八数码问题完整版
- 带有界面的基于UDP通信的多人聊天代
- java程序设计之网络编程第二版课后习
- jsp+servlet+javabean实现简单购物车
- log4j-1.2.15-sources.jar
- java 坦克大战 ppt 和 源码
- java+oracle实现学生管理系
- JAVA画2叉树
- goldengate for java
- Java中国象棋单机版186025
- jsp 宠物管理系统
- java网络聊天室课程设计报告内
- java实现excel表格文件的复制
- java加密文件,可自定义密钥
- 二维矩形装箱算法--二叉树--java实现
- Java 2 实用教程第五版课本代码
- 编译原理 电梯模拟程序java版
- Java 电子相片管理程序
- opentsdb-java-client-master.zip
- 基于java web的作业提交与批阅系统
- 基于javaweb的在线图书销售系统JavaWe
- JavaWeb设计五子棋游戏设计与开发系统
评论
共有 条评论