【物联网】MATLAB通过MQTT与阿里云和本地服务器建立连接

1、MQTT服务器&＃xff1a;本地Ubuntu搭建

# 安装服务器
sudo apt install mosquitto
sudo apt install mosquitto_pub # 运行mqtt服务器
mosquitto -v# 发布名称为nihao的订阅&＃xff0c;信息内容为helloworld
mosquitto_pub -t nihao -m helloworld# 查看ubuntu本机ip地址
ifconfig


• 本机IP地址
  

参考资料&＃xff1a;
https://blog.csdn.net/qq_33406883/article/details/107492604

2、MQTT服务器&＃xff1a;阿里云平台搭建

• 在设备中&＃xff0c;可以找到clientId&＃xff0c;username&＃xff0c;passwd&＃xff0c;mqttHostUrl等信息
  

• 在日志服务中&＃xff0c;可以看到设备的行为信息。
  

• 关于MQTT参数的解释
  
  

3、设备&＃xff1a;MQTT.fx虚拟设备&＃xff08;通信测试成功√&＃xff09;

• 填写信息&＃xff0c;点击Connect连接即可。
  具体可以参考之前的&＃xff1a;https://gwj1314.blog.csdn.net/article/details/124575451
  

• 经过测试可以发现&＃xff0c;连接云端时&＃xff0c;阿里云设备在线&＃xff0c;且可以互发消息。
  

• 连接本地Ubuntu服务器时&＃xff0c;一样显示设备在线&＃xff0c;且可以互相发消息。
  
  

4、设备&＃xff1a;MATLAB虚拟设备&＃xff08;正式连接&＃xff09;

• 首先需要下载 MQTT in MATLAB &＃xff0c;放在matlab目录下。
  &＃xff08;链接&＃xff1a;https://www.mathworks.com/matlabcentral/fileexchange/64303-mqtt-in-matlab&＃xff09;
  确保包含以下文件
  

• 文件内容如下&＃xff08;mqtt内容&＃xff1a;mqtt.m&＃xff09;

  function obj &＃61; mqtt(varargin)tryobj &＃61; mqttio.Mqtt(varargin{:});
catch errExpthrowAsCaller(errExp);
end


• 然后&＃xff0c;未定义变量 “com” 或类 “com.mathworks.mqttclient.client.Client”
  需要执行以下命令。

  % 未定义"com” 或类“com.mathworks.mqttclient.client.Client” 报错解决方案
% javaaddpath("C:\Program Files\MATLAB\R2022a\toolbox\MQTT in Matlab\matlab mqtt\jar\org.eclipse.paho.client.mqttv3-1.1.0.jar")
% javaaddpath("C:\Program Files\MATLAB\R2022a\toolbox\MQTT in Matlab\matlab mqtt\mqttasync.jar")


4.1 使用MATLAB与本地服务器建立连接&＃xff08;成功&＃xff09;

• 连接文件test.m
  

  % 建立连接
port &＃61; 1883;
myMQTT&＃61; mqtt("tcp://10.10.21.94", "ClientID", "d06e83e7eba941299a224b47eabd00cf", &＃39;Port&＃39;, port);% 发送消息
% 虚拟机ubuntu发布&＃xff1a;mosquitto_pub -t nihao -m helloworld
topic &＃61; "GoGoGo";
message &＃61; &＃39;{ "id": "123","version": "1.0","params": { "isAlarm": { "value": true} }} &＃39; ;
publish(myMQTT, topic, message);% 订阅消息
Topic2 &＃61; &＃39;nihao&＃39;;
mySub &＃61; subscribe(myMQTT,Topic2,&＃39;callback&＃39;,&＃64;showMessage,&＃39;Qos&＃39;,0);% 每次收到新消息时显示主题和消息的回调函数
function showMessage(topic,data)disp(data);
end% 未定义"com” 或类“com.mathworks.mqttclient.client.Client” 报错解决方案
% javaaddpath("C:\Program Files\MATLAB\R2022a\toolbox\MQTT in Matlab\matlab mqtt\jar\org.eclipse.paho.client.mqttv3-1.1.0.jar")
% javaaddpath("C:\Program Files\MATLAB\R2022a\toolbox\MQTT in Matlab\matlab mqtt\mqttasync.jar")


• 经测试&＃xff0c;可以发送消息到服务器。
  

• 也可以从服务器接受消息。
  

参考资料&＃xff1a;
https://blog.csdn.net/weixin_47545780/article/details/117398202
https://blog.csdn.net/liu_text/article/details/122073119

4.2 使用MATLAB与阿里云服务器建立连接&＃xff08;失败&＃xff09;

• 如图&＃xff0c;将mqtt函数对应的参数修改为阿里云的参数。
  运行后得到Unable to establish connection with broker. 无法与代理建立连接。
  
  

clc;
clear all;
close all;% D001
brokerAddress &＃61; &＃39;tcp://xxxx&＃39;;
port &＃61; 1883;
clientID &＃61; &＃39;xxx&＃39;;
username &＃61; &＃39;xxxxx&＃39;;% 建立连接
myMQTT&＃61; mqtt(brokerAddress, "ClientID", clientID, &＃39;Port&＃39;, port, &＃39;Username&＃39;, username, "Password", password);