时间戳

首页 > 解决方案 > 在 SwiftUI iOS 应用程序中订阅 MQTT 主题

ios - 在 SwiftUI iOS 应用程序中订阅 MQTT 主题

问题描述

我正在编写一个小型 iOS 应用程序来将 MQTT 消息发送到托管在我的四轴飞行器上的 Raspberry Pi 伴侣计算机上的代理。在 iOS 应用程序主视图中，应用程序将连接到 MQTT 代理（检查），发送与多个按钮相关的消息（检查），并监控各种四轴飞行器遥测数据，例如模式、距离和纬度/经度。iPhone 应用程序将在地图上显示无人机位置和用户位置（检查）。

我目前遇到的问题是让应用程序保持对主题的持续订阅，然后更新代码中的几个变量。目前，下面的代码包含按钮视图内的订阅行和“确实收到消息”代码，该代码仅在按下该按钮时暂时起作用。

我尝试将此代码粘贴到内容视图中的各个位置，但均未成功；诚然，我是一名新手编码员，Swift/iOS 对我来说非常陌生。理想情况下，当无人机发布某些主题时，该应用程序将持续监控某些主题并更新几个变量以等于消息。

import MapKit
import SwiftUI
import CocoaMQTT


struct Drone {
    var coordinate: CLLocationCoordinate2D
    var distance: UInt8
    var direction: UInt8
}

//
struct ContentView: View {
    @State public var region = MKCoordinateRegion(center: CLLocationCoordinate2D(latitude: 34.0000, longitude: -86.0000), span: MKCoordinateSpan(latitudeDelta: 0.001, longitudeDelta: 0.001))
    
    @State private var trackingMode = MapUserTrackingMode.follow
    
    @State private var safety = false
    
    @State private var showingSheet = false
    
    @State public var Connection:Bool = false
    
    var Bee: Drone = Drone(coordinate: .init(latitude: 34.0010, longitude: -86.0010), distance: 10, direction: 180)
    
    
    let mqttClient = CocoaMQTT(clientID: "swift", host: "mqtt.eclipse.org", port: 1883)
    
    var body: some View {
        
        
        VStack {
            HStack{
                Text("Beer Bee")
                
                Spacer()
                Button(action: {
                    self.mqttClient.username="user"
                    self.mqttClient.password="password"
                    self.mqttClient.keepAlive=60
                    self.mqttClient.connect()
                    self.Connection.toggle()
                    
                    }, label: {
                        Text(Connection ? "Disconnect":"Connect")
                    })
            }

            
            Map(coordinateRegion: $region, interactionModes: .zoom, showsUserLocation: true, userTrackingMode: $trackingMode)
            HStack {
                Text("Flight Mode")
                Spacer()
                Text("Distance")
                Spacer()
                Text("Position Accuracy")
            }
            HStack(alignment: .center) {
                Toggle(isOn: $safety) {
                    //action here
                }
                .toggleStyle(SwitchToggleStyle(tint: Color.red))

                Button("Main") {
                    self.mqttClient.publish("topic/dronetest", withString: "hello world!")
                }
                Spacer()
            }
            
            Button("Hold") {
                self.mqttClient.subscribe("topic/dronetest")
                self.mqttClient.didReceiveMessage = { mqtt, message, id in
                    print("Message received in topic \(message.topic) with payload \(message.string!)")
                }
            }
             Spacer()
            Button("Manual Control") {
                self.showingSheet.toggle()
            }
            .sheet(isPresented: $showingSheet) {
                SecondView()//region: self.region, Connection: self.Connection)
            }
            Spacer()
        }
        .background(/*@START_MENU_TOKEN@*//*@PLACEHOLDER=View@*/Color.yellow/*@END_MENU_TOKEN@*/)
        
       
    }
}

标签： iosswiftxcodeswiftuimqtt

解决方案

这是我在 StackOverflow 中的第一个答案，我也是新手。我遇到了同样的问题，但我可以通过为 mqttClient 声明“didConnectAck”来解决它；订阅仍然存在。只需将以下缺少的行添加到您的代码中：

self.mqttClient.didConnectAck = { mqtt, ack in
   self.mqttClient.subscribe("topic/dronetest")
   self.mqttClient.didReceiveMessage = { mqtt, message, id in
      print("Message received in topic \(message.topic) with payload \(message.string!)")
   }
}

此外，（也许？）在您的第一个按钮中添加以下行可能很有用：

self.mqttClient.autoReconnect = true

我希望我能帮助你回答这个问题。祝你好运。

推荐阅读