嵌入式Linux应用项目----智能网关

sudo apt-get install mosquitto

sudo apt-get install mosquitto-clients

ps -ef | grep mosq

lsof -i | grep mosquitto

# 无密码mosquitto_sub -t test# 有密码mosquitto_sub -u user -P 123456 -t test

# 无密码mosquitto_pub -t test -m "发布的内容"# 有密码mosquitto_pub -u user -P 123456 -t test -m "发布的内容"

sudo apt-get install libssl-devgit clone https://github.com/eclipse/paho.mqtt.c.gitcd paho.mqtt.cmakesudo make install

-lpaho-mqtt3c

tar -zxf curl-7.60.0.tar.gz cd curl-7.60.0/./configuresudo make install

LDFLAGS += -lpthread

LDFLAGS += -lrt

ldd   --version

strings  libcrypto.so.50  | grep 'GLIBC_'

objdump  -T  libcrypto.so.50  | grep 'GLIBC_'

import http.serverimport socketserverimport jsonimport osclass OTARequestHandler(http.server.SimpleHTTPRequestHandler):    # 固件版本信息    FIRMWARE_VERSION = "1.2.5"    FIRMWARE_FILENAME = "firmware"  # 实际存储的文件名    def do_GET(self):        """处理GET请求"""        # 处理版本查询请求        if self.path == "/version":            self.send_version_response()        # 处理固件下载请求        elif self.path == "/firmware":            self.serve_firmware()        else:            # 其他请求返回简单响应            self.send_response(200)            self.send_header('Content-type', 'text/plain')            self.end_headers()            self.wfile.write(b"OTA Server is running")    def send_version_response(self):        """返回版本信息JSON响应"""        try:            version_parts = self.FIRMWARE_VERSION.split('.')            version_data = {                "major": int(version_parts[0]),                "minor": int(version_parts[1]),                "patch": int(version_parts[2])            }        except (IndexError, ValueError):            version_data = {"major": 0, "minor": 0, "patch": 0}        self.send_response(200)        self.send_header('Content-type', 'application/json')        self.end_headers()        self.wfile.write(json.dumps(version_data).encode('utf-8'))    def serve_firmware(self):        """提供固件文件下载"""        try:            # 获取固件文件完整路径            firmware_path = os.path.join(os.getcwd(), self.FIRMWARE_FILENAME)            # 检查文件是否存在            if not os.path.exists(firmware_path):                raise FileNotFoundError            # 获取文件大小            file_size = os.path.getsize(firmware_path)            # 设置HTTP响应头            self.send_response(200)            self.send_header('Content-type', 'application/octet-stream')            self.send_header('Content-Disposition',                             f'attachment; filename="firmware_{self.FIRMWARE_VERSION}"')            self.send_header('Content-Length', str(file_size))            self.end_headers()            # 流式传输文件内容            with open(firmware_path, 'rb') as f:                while True:                    chunk = f.read(8192)  # 8KB chunk                    if not chunk:                        break                    self.wfile.write(chunk)        except FileNotFoundError:            self.send_error(404, "Firmware file not found")        except Exception as e:            self.send_error(500, f"Server error: {str(e)}")def run_ota_server(ip='0.0.0.0', port=80):    """启动OTA服务器"""    with socketserver.TCPServer((ip, port), OTARequestHandler) as httpd:        print(f"OTA server running on http://{ip}:{port}")        print(f"Version endpoint: http://{ip}:{port}/version")        print(f"Firmware endpoint: http://{ip}:{port}/firmware")        print(f"Make sure '{OTARequestHandler.FIRMWARE_FILENAME}' exists in current directory")        httpd.serve_forever()if __name__ == "__main__":    # 需要sudo权限运行（80端口）    run_ota_server()