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

如何解决在SwiftUI iOS应用程序中订阅MQTT主题

我正在编写一个小型iOS应用程序，以将MQTT消息发送给代理，该代理托管在我的四轴飞行器的Raspberry Pi伴侣计算机上。在iOS应用主视图中，该应用将连接到MQTT Broker（检查），发送与多个按钮关联的消息（检查），并监视各种四轴飞行器遥测度，例如模式，距离和纬度/经度。 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@*/)
        
       
    }
}

解决方法

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

tf.keras.layers.AdditiveAttention

（也许？）在第一个按钮中添加以下行可能会很有用：

tf.keras.layers.AdditiveAttention

我希望我能为您提供答案。祝你好运。