websocket连接mqtt实现发布及订阅主题
环境：linux（ubuntu、Centos7），websocket，mosquitto-1.4.10，libwebsockets-master
说明：如果安装过程中出现问题，请看六中的解决办法。可能会解决你遇到的问题。
⼀、安装相应的功能libwebsockets
2.解压，我下载的是zip的，利⽤xftp上传到服务器上⾯的。
3.进⼊⽬录 cd libwebsockets-master
4.创建⼀个build⽂件夹 mkdir build
5.进⼊build  cd build
6.安装如果希望使⽤64位库⽂件，添加参数如下cmake .. -DLIB_SUFFIX=64
7.编译make
8. 安装make install
⼆、安装mqtt服务器
2.解压 tar zxfvmosquitto-1.4.
3.进⼊⽬录  cd mosquitto-1.
4.10
4.配置⽂件  vim config.mk （WITH_WEBSOCKETS:=yes）
5.编译make
6.安装make install
三、配置mqtt服务器
1.到/etc/f，如果没有该⽂件则进⼊你安装的mosquitto位置执⾏ f
/etc/f
2.编辑f  f
3.在Default Listenter 添加⼀下内容
port 1883
listener 19211
protocol websockets
注意：这⾥19211是websocket连接端⼝
4.运⾏ mosquitto -c  /etc/f  （这⾥⼀定运⾏这个，不然websocket连接不上mqtt服务器。）
四、测试mqtt服务器
websocket和socket
1.启动mqtt服务器 mosquitto -v
2.订阅主题 mosquitto_sub -v -t 主题名
3.发布消息 mosquitto_pub -t 主题名 -m 消息内容
如果订阅主题的客户端收到发布的消息，则说明成功。
1.引⼊<script src="cdnjs.cloudflare/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascript"></script>
2. // 创建client
client = new Paho.MQTT.Client(location.hostname, Number(location.port), "clientId");
// 设置回调
// 连接mqtt服务器
//回调⽅法
function onConnect() {
console.log("onConnect");
//订阅主图
client.subscribe("World");
//发布消息
message = new Paho.MQTT.Message("Hello");
message.destinationName = "World";
client.send(message);
}
// 连接失败的回调
function onConnectionLost(responseObject) {
if (Code !== 0) {
console.log("onConnectionLost:"+Message);
}
}
// 接收到消息的回调
function onMessageArrived(message) {
console.log("onMessageArrived:"+message.payloadString);
}
六、遇到的问题
1.编译不到cmake
解决办法：安装cmake
sudo apt-get install libssl-dev
< while loading shared libraries: libmosquitto.so.1: cannot open shared object file: No such file or directory 解决办法：
# 创建链接
sudo ln -s /usr/local/lib/libmosquitto.so.1 /usr/lib/libmosquitto.so.1
# 更新动态链接库
sudo ldconfig
3.编译不到openssl/ssl.h
解决办法：安装openssl
sudo apt-get install libssl-dev
4.编译过程不到ares.h
解决办法：sudo apt-get install libc-ares-dev
5.编译过程不到uuid/uuid.h
sudo apt-get install uuid-dev
6.最后启动了，就是远程连接不上，考虑是防⽕墙的问题
关闭防⽕墙systemctl stop firewalld.service
具体的解决办法我猜测应该是配置防⽕墙，配置开放端⼝，⽽不是关闭防⽕墙，这个⽅法我还没来的及验证。
< while loading shared libraries: libwebsockets.so.9: cannot open shared object file: No such file or directory 解决办法：sudo ln -s /usr/local/lib64/libwebsockets.so.9 /usr/lib/libwebsockets.so.9
sudo ldconfig
8.websocket连接报错Failed to connect: AMQJS0007E Socket error:undefined.
如果配置的websocket正常启动成功，问题可能出现在SSL上⾯。
解决⽅法：关闭ssl的⽀持
卸载mqtt：make uninstall
配置config.mk  WITH_TLS:=no  WITH_TLS_PSK:=no
安装 make install

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。