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

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
1
2
3
4
5
6
7
8
9
10
11
12

• 本机IP地址
  

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

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

• 在设备中，可以找到clientId，username，passwd，mqttHostUrl等信息
  

• 在日志服务中，可以看到设备的行为信息。
  

• 关于MQTT参数的解释
  
  

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

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

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

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

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

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

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

  function obj = mqtt(varargin)
  
  try
      obj = mqttio.Mqtt(varargin{:});
  catch errExp
      throwAsCaller(errExp);
  end
  1
  2
  3
  4
  5
  6
  7

• 然后，未定义变量 “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")
  1
  2
  3

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")
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22

• 经测试，可以发送消息到服务器。
  

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

参考资料：
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);

1
2
3
4
5
6
7
8
9
10
11
12
13