iOS Swift MQTT无法向Raspberry Pi发布消息求助

问题概况 #

iOS SwiftUI应用通过MQTT连接树莓派成功（树莓派终端显示subscribing/subscribed），但点击前进、后退等已实现publish的方向按钮时，树莓派无任何响应。以下是两端代码的排查与修复建议：

树莓派Python代码问题排查与修复 #

1. 回调实例一致性问题

原代码connectionStatus函数使用全局mqttClient订阅主题，若回调传入的client实例与全局实例不一致，会导致订阅失效。应改为使用回调参数中的client：

def connectionStatus(client, userdata, flags, rc):
    print("subscribing")
    # 使用传入的client实例订阅，避免全局实例不一致
    client.subscribe("robot/move")
    print("subscribed")

2. 添加消息接收调试

在messageDecoder开头添加消息打印，确认树莓派是否真的收到iOS发送的消息，同时去除消息首尾可能存在的空格/换行：

def messageDecoder(client, userdata, msg):
    # 去除首尾空白字符，避免iOS端发送的消息带隐藏格式
    message = msg.payload.decode(encoding='UTF-8').strip()
    # 打印完整信息，排查是否收到消息及内容是否正确
    print(f"Received message on topic [{msg.topic}]: '{message}'")
    
    if message == "f":
        forward()
        print("^^^ forward! ^^^")
    elif message == "b":
        backward()
        print("\/ backward \/")
    # ... 其余分支保持不变 ...

iOS SwiftUI代码问题排查与修复 #

1. 避免客户端ID冲突

若iOS和树莓派使用相同的clientID: "Robot"，会导致MQTT服务器踢掉重复连接。修改iOS端客户端ID为唯一值：

// 修改clientID为唯一标识，避免与树莓派端冲突
let mqttClient = CocoaMQTT(clientID: "Robot-iOS", host: "raspberrypi.local", port: 1883)

2. 监听连接状态并校验

添加MQTT代理监听连接状态，确保点击按钮发送消息时客户端处于在线状态：

struct ContentView: View {
    @State private var isMQTTConnected = false
    
    var body: some View {
        ZStack {
            // ... 原有视图布局 ...
        }
        .onAppear {
            mqttClient.delegate = self
        }
    }
}

// 实现CocoaMQTTDelegate监听连接状态
extension ContentView: CocoaMQTTDelegate {
    func mqttDidConnect(_ mqtt: CocoaMQTT, ack: CocoaMQTTConnAck) {
        isMQTTConnected = true
        print("MQTT连接成功")
    }
    
    func mqttDidDisconnect(_ mqtt: CocoaMQTT, withError err: Error?) {
        isMQTTConnected = false
        print("MQTT断开连接：\(err?.localizedDescription ?? "未知错误")")
    }
    
    func mqtt(_ mqtt: CocoaMQTT, didPublishMessage message: CocoaMQTTMessage, id: UInt16) {
        print("消息发送成功：\(message.string ?? "")")
    }
}

3. 按钮发送前校验连接状态

修改按钮的action逻辑，先检查MQTT连接状态，再执行发送：

// 以Forward按钮为例
struct Forward: View {
    var body: some View {
        Button {
            guard mqttClient.isConnected else {
                print("未连接到MQTT，无法发送消息")
                return
            }
            // 设置QoS为1，确保消息至少送达一次
            let publishResult = mqttClient.publish("robot/move", withString: "f", qos: .qos1)
            print("发送前进指令，结果：\(publishResult)")
        } label: {
            Image(systemName: "arrow.right.square")
                .renderingMode(.template)
                .resizable()
                .aspectRatio(contentMode: .fit)
                .frame(width: 100, height: 100)
                .foregroundColor(.white)
        }
    }
}

4. 补充未实现publish的按钮

部分按钮（如BackwardLeft、ForwardRight等）仅打印日志，未实现MQTT发送，需补充mqttClient.publish逻辑，例如：

struct BackwardLeft: View {
    var body: some View {
        Button {
            guard mqttClient.isConnected else {
                print("未连接到MQTT，无法发送消息")
                return
            }
            mqttClient.publish("robot/move", withString: "bl")
            print("Move back left")
        } label: {
            Image(systemName: "arrow.up.left.square")
                .renderingMode(.template)
                .resizable()
                .aspectRatio(contentMode: .fit)
                .frame(width: 100, height: 100)
                .foregroundColor(.white)
        }
    }
}

额外检查项 #

1. 确认树莓派MQTT服务器（如Mosquitto）运行正常，端口1883未被防火墙拦截
2. 验证iOS设备与树莓派处于同一局域网，raspberrypi.local能正常解析到树莓派IP
3. 检查树莓派端forward()、backward()等电机控制函数是否能独立正常运行

内容的提问来源于stack exchange，提问作者ankar