资源简介
vert.x结合springboot开发mqtt服务端,直接启动主类。
代码片段和文件信息
package com.yumg.vertx_mqtt;
import io.netty.handler.codec.mqtt.MqttQoS;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.mqtt.MqttServer;
import io.vertx.mqtt.MqttTopicSubscription;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import javax.annotation.PostConstruct;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;
@SpringBootApplication
public class VertxMqttApplication {
public static void main(String[] args) {
SpringApplication.run(VertxMqttApplication.class args);
}
@PostConstruct
public void init(){
Vertx vertx = Vertx.vertx();
MqttServer mqttServer = MqttServer.create(vertx);
mqttServer.endpointHandler(endpoint -> {
// shows main connect info
System.out.println(“MQTT client [“ + endpoint.clientIdentifier() + “] request to connect clean session = “ + endpoint.isCleanSession());
if (endpoint.auth() != null) {
System.out.println(“[username = “ + endpoint.auth().userName() + “ password = “ + endpoint.auth().password() + “]“);
}
if (endpoint.will() != null) {
System.out.println(“[will topic = “ + endpoint.will().willTopic() + “ msg = “ + endpoint.will().willMessage() +
“ QoS = “ + endpoint.will().willQos() + “ isRetain = “ + endpoint.will().isWillRetain() + “]“);
}
endpoint.disconnectHandler(v->{
System.out.println(“disconnect from client...“);
});
System.out.println(“[keep alive timeout = “ + endpoint.keepAliveTimeSeconds() + “]“);
endpoint.subscribeHandler(subscribe->{
List grantedQosLevels = new ArrayList();
for (MqttTopicSubscription s: subscribe.topicSubscriptions()) {
System.out.println(“Subscription for “ + s.topicName() + “ with QoS “ + s.qualityOfService());
grantedQosLevels.add(s.qualityOfService());
}
// ack the subscriptions request
endpoint.subscribeAcknowledge(subscribe.messageId() grantedQosLevels);
});
endpoint.unsubscribeHandler(unsubscribe -> {
for (String t: unsubscribe.topics()) {
System.out.println(“Unsubscription for “ + t);
}
// ack the subscriptions request
endpoint.unsubscribeAcknowledge(unsubscribe.messageId());
});
endpoint.publishHandler(message -> {
System.out.println(“Just received message [“ + message.payload().toString(Charset.defaultCharset()) + “] with QoS [“ + message.qosLevel() + “]“);
if (message.qosLevel() == MqttQoS.AT_LEAST_ONCE) {
endpoint.publishAcknowledge(message.messageId());
} else
属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
文件 268 2018-10-18 09:29 vertx_mqtt\.gitignore
文件 647 2018-10-18 09:29 vertx_mqtt\.idea\compiler.xm
文件 177 2018-10-18 09:29 vertx_mqtt\.idea\encodings.xm
文件 568 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__ch_qos_logback_logback_classic_1_2_3.xm
文件 547 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__ch_qos_logback_logback_core_1_2_3.xm
文件 522 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 644 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 595 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 623 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 674 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 688 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 729 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_fasterxm
文件 546 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_jayway_jsonpath_json_path_2_4_0.xm
文件 700 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xm
文件 572 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_buffer_4_1_29_Final.xm
文件 565 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_4_1_29_Final.xm
文件 593 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_dns_4_1_29_Final.xm
文件 607 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_http2_4_1_29_Final.xm
文件 600 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_http_4_1_29_Final.xm
文件 600 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_mqtt_4_1_29_Final.xm
文件 607 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_codec_socks_4_1_29_Final.xm
文件 572 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_common_4_1_29_Final.xm
文件 579 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_handler_4_1_29_Final.xm
文件 621 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_handler_proxy_4_1_29_Final.xm
文件 586 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_resolver_4_1_29_Final.xm
文件 614 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_resolver_dns_4_1_29_Final.xm
文件 593 2018-10-18 09:33 vertx_mqtt\.idea\libraries\Maven__io_netty_netty_transport_4_1_29_Final.xm
文件 509 2018-10-18 11:01 vertx_mqtt\.idea\libraries\Maven__io_vertx_vertx_core_3_4_2.xm
文件 558 2018-10-18 11:01 vertx_mqtt\.idea\libraries\Maven__io_vertx_vertx_mqtt_server_3_4_2.xm
文件 611 2018-10-18 09:29 vertx_mqtt\.idea\libraries\Maven__javax_annotation_javax_annotation_api_1_3_2.xm
............此处省略118个文件信息
- 上一篇:Unity相机画面渲染序列帧插件
- 下一篇:FPGA简易频率计
相关资源
- 在各城市的窄带物联网中传感器起到
- 物联网家居系统中基于单片机的多路
- 物联网中无线传感器节点和RFID数据融
- 有关面向工业物联网的无线传感器网
- 物联网无线传感器网络的7大特点
- EMCP物联网云平台操作手册
- 电信物联网NB-lot上传编解码插件检测
- 物联网云平台设备管理和相关页面
- MQTT_3.1protocol_Specific中文版
- 中国移动NB-IoT安全白皮书.pdf
- 智能网联汽车信息安全白皮书
- 物联网行业新突破:UWB人员定位技术
- 开放充电协议标准2.0 OCPP 2.0
- 物联网智能家居平台DIY:ARDUINO 物联网
- MQTTv3.1中文版
- mt7628 mqtt功能 放到packet下面就可以使
-
Symli
nk XR1020--工业物联网智能网关规 - 矿山物联网网络技术发展趋势与关键
- 矿山物联网云计算与平台技术
- FCS技术在矿山物联网感知层的应用
- 论感知矿山物联网与矿山综合自动化
- 论矿山物联网的结构性平台与服务性
- 物联网与感知矿山专题讲座之三&mda
- 感知矿山物联网云计算应用探索
- MQTT-1.zip
- 07-5123-07-ZigbeeClusterLibrary_Revision_7.pdf
- 物联网行业深度分析报告:NB-IOT开启
- 仓储物联网管理系统开发项目流程中
- 单片机通过ESP8266上传温湿度数据
- 智能门锁安全分析报告.pdf
评论
共有 条评论