js连接mqtt进行通信

1.html头部引入mqtt.js

<script src="https://unpkg.com/mqtt/dist/mqtt.js"></script>

2.连接已打开的mqttServer，若无mqtt服务端，点击下载https://www.emqx.io/zh/downloads

<script>// 连接选项const options = {clean: true, // true: 清除会话, false: 保留会话connectTimeout: 4000, // 超时时间// 认证信息clientId: 'test',    //客户端IDusername: 'admin', //连接用户名password: 'public',//连接密码，默认为public,新版本登录后台界面会让你修改密码// 心跳时间keepalive: 60,}// 连接字符串, 通过协议指定使用的连接方式const connectUrl = 'ws://127.0.0.1:8083/mqtt' //连接服务端地址，注意查看ws协议对应的端口号const client = mqtt.connect(connectUrl, options)client.on('connect', () => {console.log('连接成功')// 订阅多个主题client.subscribe(['tourist_enter', 'message_arrived'], //主题{ qos: 1 },  (err) => {console.log(err || '订阅成功')},);// 发布消息client.publish('tourist_enter', 'Hello EMQ X', (err) => {console.log(err || '发布成功')})})//失败重连client.on('reconnect', (error) => {console.log('正在重连:', error)})//连接失败client.on('error', (error) => {console.log('连接失败:', error)})//接收消息client.on('message', (topic, message) => {console.log('收到消息：', topic, message.toString())})
</script>

想要查看或者修改不同协议对应的端口号需要到配置文件(~安装目录/etc/emqx.conf)中查看，部分协议如下：

//tcp协议（连接地址为 tcp://127.0.0.1:1883）
listeners.tcp.default {
bind = “0.0.0.0:1883”
max_connections = 1024000
}

//ssl（连接地址为 ssl://127.0.0.1:8883）
listeners.ssl.default {
bind = “0.0.0.0:8883”
max_connections = 512000
ssl_options {
keyfile = “etc/certs/key.pem”
certfile = “etc/certs/cert.pem”
cacertfile = “etc/certs/cacert.pem”
}
}

//ws协议（连接地址为 ws://127.0.0.1:8083/mqtt）
listeners.ws.default {
bind = “0.0.0.0:8083”
max_connections = 1024000
websocket.mqtt_path = “/mqtt”
}

//wss协议（连接地址为 wss://127.0.0.1:8084/mqtt）
listeners.wss.default {
bind = “0.0.0.0:8084”
max_connections = 512000
websocket.mqtt_path = “/mqtt”
ssl_options {
keyfile = “etc/certs/key.pem”
certfile = “etc/certs/cert.pem”
cacertfile = “etc/certs/cacert.pem”
}
}

js连接mqtt进行通信相关推荐

HTML5网页APP连接MQTT,使用js连接mqtt
使用js连接mqtt 使用js连接mqtt 描述:使用javascript连接mqtt 代码: ehz-app {{ message }} var app = new Vue({ el: '#app' ...
JS 连接MQTT的方法（mqtt.js的使用方法）
本文章是介绍 mqtt.js 的使用方法一.说明本文章使用的版本是 4.1.x ,没用最新版的原因是 4.2.x 以上版本会报错,具体报错可以看我的另一篇文章,点击查看. 使用的 4.1.x 版本 ...
前端websocket连接mqtt服务器（Paho-mqtt,mqttws31.js）以及断开重连
项目需求,java端连接C#,想在前台处理订阅消息,用了websocket和mqtt,查了一上午,因为本机没有node.js,关于paho-mqtt.js的例子连接不了,比如301错误码.什么二进制数 ...
【阿里云】物联网平台配置ESP8266真实设备AT串口连接，支持MQTT协议通信
文章目录 1 阿里云物联网平台 2 MQTT.fx虚拟设备连接 2.1 配置设备连接(建立连接) 2.2 配置订阅和发布(数据通信) 3 ESP8266真实设备连接 3.1 配置设备连接(建立连接) ...
websocket连接mqtt实现发布及订阅主题
2019独角兽企业重金招聘Python工程师标准>>> 环境:linux(ubuntu.Centos7),websocket,mosquitto-1.4.10,libwebsocke ...
MQTT-Eclipse paho mqtt源码分析-连接MQTT Broker
Eclipse paho mqtt源码分析 MQTT paho mqtt 源码分析 org.eclipse.paho.client.mqttv3.MqttClient MQTT MQTT(消息队列遥测 ...
WebRTC实时通信系列教程8 打通P2P连接和信令通信
[转载请注明出处: http://blog.csdn.net/leytton/article/details/76836265] PS:如果本文对您有帮助,请点个赞让我知道哦~ <WebRTC ...
java连接MQTT服务器(Springboot整合MQTT)
一.业务场景硬件采集的数据传入EMQX平台(采用MQTT协议),java通过代码连接MQTT服务器,进行采集数据接收.解析.业务处理.存储入库.数据展示. MQTT 是基于发布(Publish)/ ...
云服务器部署mqtt协议通信,云服务器部署mqtt协议通信
云服务器部署mqtt协议通信内容精选换一换虚拟IP(Virtual IP Address,简称VIP)是一个未分配给真实弹性云服务器网卡的IP地址.弹性云服务器除了拥有私有IP地址外,还可以拥有 ...

js连接mqtt进行通信

js连接mqtt进行通信相关推荐

最新文章

热门文章