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

文章目录

1、MQTT服务器：本地Ubuntu搭建
2、MQTT服务器：阿里云平台搭建
3、设备：MQTT.fx虚拟设备（通信测试成功√）
4、设备：MATLAB虚拟设备（正式连接）
- 4.1 使用MATLAB与本地服务器建立连接（成功）
- 4.2 使用MATLAB与阿里云服务器建立连接（失败）

1、MQTT服务器：本地Ubuntu搭建

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

本机IP地址

参考资料：
https://blog.csdn.net/qq_33406883/article/details/107492604

2、MQTT服务器：阿里云平台搭建

在设备中，可以找到clientId，username，passwd，mqttHostUrl等信息
在日志服务中，可以看到设备的行为信息。
关于MQTT参数的解释

3、设备：MQTT.fx虚拟设备（通信测试成功√）

#mermaid-svg-1exBzWMQ3nzeXAgZ {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .error-icon{fill:#552222;}#mermaid-svg-1exBzWMQ3nzeXAgZ .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-1exBzWMQ3nzeXAgZ .marker{fill:#333333;stroke:#333333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .marker.cross{stroke:#333333;}#mermaid-svg-1exBzWMQ3nzeXAgZ svg{font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .label{font-family:"trebuchet ms",verdana,arial,sans-serif;color:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .cluster-label text{fill:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .cluster-label span{color:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .label text,#mermaid-svg-1exBzWMQ3nzeXAgZ span{fill:#333;color:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .node rect,#mermaid-svg-1exBzWMQ3nzeXAgZ .node circle,#mermaid-svg-1exBzWMQ3nzeXAgZ .node ellipse,#mermaid-svg-1exBzWMQ3nzeXAgZ .node polygon,#mermaid-svg-1exBzWMQ3nzeXAgZ .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .node .label{text-align:center;}#mermaid-svg-1exBzWMQ3nzeXAgZ .node.clickable{cursor:pointer;}#mermaid-svg-1exBzWMQ3nzeXAgZ .arrowheadPath{fill:#333333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-1exBzWMQ3nzeXAgZ .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-1exBzWMQ3nzeXAgZ .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-1exBzWMQ3nzeXAgZ .cluster text{fill:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ .cluster span{color:#333;}#mermaid-svg-1exBzWMQ3nzeXAgZ div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-1exBzWMQ3nzeXAgZ :root{--mermaid-font-family:"trebuchet ms",verdana,arial,sans-serif;}

成功

设备MQTT.fx

连接Ubuntu服务器

连接阿里云服务器

填写信息，点击Connect连接即可。
具体可以参考之前的：https://gwj1314.blog.csdn.net/article/details/124575451
经过测试可以发现，连接云端时，阿里云设备在线，且可以互发消息。
连接本地Ubuntu服务器时，一样显示设备在线，且可以互相发消息。

4、设备：MATLAB虚拟设备（正式连接）

#mermaid-svg-pF9niENJGmMLhhoA {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-pF9niENJGmMLhhoA .error-icon{fill:#552222;}#mermaid-svg-pF9niENJGmMLhhoA .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-pF9niENJGmMLhhoA .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-pF9niENJGmMLhhoA .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-pF9niENJGmMLhhoA .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-pF9niENJGmMLhhoA .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-pF9niENJGmMLhhoA .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-pF9niENJGmMLhhoA .marker{fill:#333333;stroke:#333333;}#mermaid-svg-pF9niENJGmMLhhoA .marker.cross{stroke:#333333;}#mermaid-svg-pF9niENJGmMLhhoA svg{font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-pF9niENJGmMLhhoA .label{font-family:"trebuchet ms",verdana,arial,sans-serif;color:#333;}#mermaid-svg-pF9niENJGmMLhhoA .cluster-label text{fill:#333;}#mermaid-svg-pF9niENJGmMLhhoA .cluster-label span{color:#333;}#mermaid-svg-pF9niENJGmMLhhoA .label text,#mermaid-svg-pF9niENJGmMLhhoA span{fill:#333;color:#333;}#mermaid-svg-pF9niENJGmMLhhoA .node rect,#mermaid-svg-pF9niENJGmMLhhoA .node circle,#mermaid-svg-pF9niENJGmMLhhoA .node ellipse,#mermaid-svg-pF9niENJGmMLhhoA .node polygon,#mermaid-svg-pF9niENJGmMLhhoA .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-pF9niENJGmMLhhoA .node .label{text-align:center;}#mermaid-svg-pF9niENJGmMLhhoA .node.clickable{cursor:pointer;}#mermaid-svg-pF9niENJGmMLhhoA .arrowheadPath{fill:#333333;}#mermaid-svg-pF9niENJGmMLhhoA .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-pF9niENJGmMLhhoA .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-pF9niENJGmMLhhoA .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-pF9niENJGmMLhhoA .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-pF9niENJGmMLhhoA .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-pF9niENJGmMLhhoA .cluster text{fill:#333;}#mermaid-svg-pF9niENJGmMLhhoA .cluster span{color:#333;}#mermaid-svg-pF9niENJGmMLhhoA div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-pF9niENJGmMLhhoA :root{--mermaid-font-family:"trebuchet ms",verdana,arial,sans-serif;}

成功

失败

设备MATLAB

连接Ubuntu服务器

连接阿里云服务器

地址错误

首先需要下载 MQTT in MATLAB ，放在matlab目录下。
（链接：https://www.mathworks.com/matlabcentral/fileexchange/64303-mqtt-in-matlab）
确保包含以下文件

文件内容如下（mqtt内容：mqtt.m）

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

然后，未定义变量 “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与本地服务器建立连接（成功）

连接文件test.m

% 建立连接
port = 1883;
myMQTT= mqtt("tcp://10.10.21.94", "ClientID", "d06e83e7eba941299a224b47eabd00cf", 'Port', port);% 发送消息
% 虚拟机ubuntu发布：mosquitto_pub -t nihao -m helloworld
topic = "GoGoGo";
message =  '{ "id": "123","version": "1.0","params": {    "isAlarm": { "value": true}  }} ' ;
publish(myMQTT, topic, message);% 订阅消息
Topic2 = 'nihao';
mySub = subscribe(myMQTT,Topic2,'callback',@showMessage,'Qos',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")

经测试，可以发送消息到服务器。
也可以从服务器接受消息。

参考资料：
https://blog.csdn.net/weixin_47545780/article/details/117398202
https://blog.csdn.net/liu_text/article/details/122073119

4.2 使用MATLAB与阿里云服务器建立连接（失败）

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

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