物联网项目记录（1）服务器配置（MQTT）

最近在移植之前物联网的竞赛项目的时候，重新整理了一下并记录。以便后面再次移植或者传给后人（）。

需要：云服务器*1，镜像Ubuntu系统。

配置上，项目最初部署在华为云上，内存8G，带宽10M/s，硬盘120G（硬盘一般用不满，主要是内存和带宽）。

图传想要达到较好的质量，实测带宽10M/s是至少的，这样传递QQVGA的图像才能不明显卡顿。但是实际上图像处理可以放在边缘处理，就可以降低带宽需求。内存是考虑到运行深度学习模型需要的，但是也可以通过优化算法来降低需求。因此后期移植，我考虑的一个新的配置是内存4G，带宽6M/s，硬盘70G。

开发环境搭建#

远程连接服务器的推荐用Finalshell，集成了FTP和shell，非常好用。具体过程略。可以参考这篇文章，这个。

这一步主要搭建EMQX，所以没什么代码量。后面面对前后端处理的HTTP服务器搭建时，就可以考虑用vscode的远程资源管理器来写代码。

EMQX配置#

命令行按行逐个运行下列指令。

1
curl -s https://assets.emqx.com/scripts/install-emqx-deb.sh | sudo bash
2
sudo apt-get install emqx
3
sudo systemctl start emqx

如果你的端口已经全部开放，这时候浏览器输入<服务器ip>：18083就可以进入EMQX的后台管理系统。但是大部分云服务器是默认不打开这些端口的，需要在安全组配置。

EMQX需要哪些端口？服务器输入：

1
sudo lsof -i

找到所有是EMQX使用的端口：

这些就是我们需要在云服务器厂商的后台开放的端口。进入云服务器厂商的后台，以腾讯云为例，找到“防火墙”（大概这个意思，华为云我记得是叫安全组）。

点击添加规则，添加上述我们查询得知需要的端口。（为了图方便把所有端口都打开也行，但是不推荐）。

现在浏览器输入<服务器ip>：18083，就可以看见后台了：

如果浏览器进不了这个网页后台，要么是服务器端口没有放开（上一步有问题），要么是浏览器自动解析成了https，而EMQX默认是http，这时候在浏览器输入<服务器ip>：18083，然后手动改成http就可以了。

初始时，用户名是admin，密码是public。

简单测试#

在手头没有嵌入式设备的情况下，简单用python测试一下是否可行。

在本地电脑上新建一个项目文件夹（叫什么可以，我叫mqtt_tester），新建三个文件，config.yaml，sender.py，listener.py，分别用来存储一些服务器和客户端配置文本、运行时负责模拟发送、运行时模拟接收。

预先需要pip一些包：

1
pip install paho-mqtt
2
pip install pyyaml

下面是config.yaml：

1
server:
2
  address: "<服务器ip>"              # MQTT服务器地址
3
  port: 1883                        # MQTT服务器端口
4
  topics:                           # 可订阅主题
5
    - "mqtt/test"                       # 测试主题
6

7
client:
8
  name: "mqtt_tester"

1
"""
2
    sender.py
3
    模拟客户端，测试MQTT服务器收发消息
4
"""
5

6
import os
7
import paho.mqtt.client as mqtt
8
import yaml
9

10
# 获取当前脚本文件的绝对路径，然后获取同目录下的config.yaml文件的路径
11
current_dir = os.path.dirname(os.path.abspath(__file__))
12
config_path = os.path.join(current_dir, 'config.yaml')
13
with open(config_path, 'r', encoding='utf-8') as file:
14
    config = yaml.safe_load(file)
15
broker_address = config['server']['address']
16
broker_port = config['server']['port']
17

18
def on_connect(client, userdata, flags, rc):
19
    print(f"Connected with result code {rc}")
20

21
client = mqtt.Client()
22
client.on_connect = on_connect
23
client.username_pw_set(config['client']['name'])
24
client.connect(broker_address, broker_port, 60)
25

26
client.loop_start()
27

28
while True:
29
    topic = input("请输入主题: ")
30
    message = input("请输入消息内容: ")#.encode('gbk') #后面可以选编码格式，简单测试不需要
31
    client.publish(topic, message)

1
"""
2
  listener.py
3
  测试MQTT监听程序
4
"""
5

6
import os
7
import paho.mqtt.client as mqtt
8
import yaml
9

10
current_dir = os.path.dirname(os.path.abspath(__file__))
11
config_path = os.path.join(current_dir, 'config.yaml')
12

13
with open('config.yaml', 'r', encoding='utf-8') as file:
14
    config = yaml.safe_load(file)
15
MQTT_SERVER = config['server']['address']
16
MQTT_PORT = config['server']['port']
17
MQTT_TOPIC = config['server']['topics']
18

19
def on_message(client, userdata, msg):
20
    try:
21
        message = msg.payload.decode('utf-8')  # 尝试用UTF-8解码
22
    except UnicodeDecodeError:
23
        message = msg.payload.decode('gbk')  # 如果失败，改用GBK解码
24
    topic = msg.topic
25
    print(f"Received message '{message}' on topic '{topic}'")
26

27
def on_connect(client, userdata, flags, rc):
28
    print("Connected with result code "+str(rc))
29
    for topic in MQTT_TOPIC:
30
        client.subscribe(topic)
31

32
if __name__ == '__main__':
33
    client = mqtt.Client()
34
    client.on_connect = on_connect
35
    client.on_message = on_message
36

37
    client.username_pw_set(config['client']['name'])
38
    client.connect(MQTT_SERVER, MQTT_PORT, 60)
39

40
    client.loop_forever()

同时运行上述两个sender.py和listener.py，在前者的控制台中输入主题和消息内容，切换到后者的控制台，就可以看见已经收到了消息：

不要关闭控制台，打开前面的EMQX后台网页，进入客户端，可以看见两个连接的客户端。