New file |
| | |
| | | package com.ruoyi.jianguan.mqtt.client; |
| | | |
| | | |
| | | import com.ruoyi.jianguan.mqtt.callback.PushCallback; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.eclipse.paho.client.mqttv3.IMqttToken; |
| | | import org.eclipse.paho.client.mqttv3.MqttClient; |
| | | import org.eclipse.paho.client.mqttv3.MqttConnectOptions; |
| | | import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; |
| | | import org.springframework.context.annotation.Bean; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | @Slf4j |
| | | @Component |
| | | public class ClientMQTT { |
| | | private final static String HOST = "tcp://127.0.0.1:9882"; |
| | | private final static String USER_NAME = "admin"; |
| | | private final static String PASS_WORD = "mingxingdianli123"; |
| | | private static final String CLIENT_ID = String.valueOf(System.currentTimeMillis()); |
| | | private static final Integer TIME_OUT = 30000; |
| | | private static final Integer KEEP_ALIVE = 30000; |
| | | private MqttClient client; |
| | | private MqttConnectOptions options; |
| | | private void start() { |
| | | try { |
| | | // host为主机名,clientid即连接MQTT的客户端ID,一般以唯一标识符表示,MemoryPersistence设置clientid的保存形式,默认为以内存保存 |
| | | client = new MqttClient(HOST, CLIENT_ID, new MemoryPersistence()); |
| | | // MQTT的连接设置 |
| | | options = new MqttConnectOptions(); |
| | | // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录,这里设置为true表示每次连接到服务器都以新的身份连接 |
| | | options.setCleanSession(false); |
| | | // 设置连接的用户名 |
| | | options.setUserName(USER_NAME); |
| | | // 设置连接的密码 |
| | | options.setPassword(PASS_WORD.toCharArray()); |
| | | // 设置超时时间 单位为秒 |
| | | options.setConnectionTimeout(TIME_OUT); |
| | | // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线,但这个方法并没有重连的机制 |
| | | options.setKeepAliveInterval(KEEP_ALIVE); |
| | | // automaticReconnect 为 true 表示断线自动重连,但仅仅只是重新连接,并不订阅主题;在 connectComplete 回调函数重新订阅 |
| | | options.setAutomaticReconnect(true); |
| | | // 设置回调 |
| | | // 设置回调 |
| | | client.setCallback(new PushCallback()); |
| | | |
| | | IMqttToken iMqttToken = client.connectWithResult(options); |
| | | boolean complete = iMqttToken.isComplete(); |
| | | System.err.println("MQTT连接" + (complete ? "成功" : "失败")); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 连接至mqtt服务器,获取mqtt连接 |
| | | * |
| | | * @return |
| | | */ |
| | | // @Bean |
| | | // public ClientMQTT getMqttPushClient() { |
| | | // //连接至mqtt服务器,获取mqtt连接 |
| | | // this.start(); |
| | | // return this; |
| | | // } |
| | | } |
| | | |