Реализация протокола Swift MQTT с использованием mosquitto api в ios - PullRequest
Новая
       17

Реализация протокола Swift MQTT с использованием mosquitto api в ios

0 голосов
/ 07 января 2020

Я пытаюсь реализовать протокол MQTT для обновлений местоположения в реальном времени, используя mosquitto api. Я уже настроил локальный сервер и в терминале отправляю и получаю сообщение, а также не получаю в моем проекте. Вот мой код. И я делюсь коротким экраном терминала.

введите описание изображения здесь 

import UIKit
import CocoaMQTT



    func mqttSetUp()
    {
        let clientID = "mosq-irTRTw6KH28CzBbUPC" //+ "tutzqscv"//String(ProcessInfo().processIdentifier)
        let mqtt = CocoaMQTT(clientID: clientID, host: "/usr/local/etc/mosquitto/mosquitto.conf", port: 1883)
        mqtt.username = "p2"
        mqtt.password = "c1"
        mqtt.willMessage = CocoaMQTTWill(topic: "/will", message: "dieout")
        mqtt.keepAlive = 60
        mqtt.delegate = self
        mqtt.disconnect()
        mqtt.connect()
    }

    func TRACE(_ message: String = "", fun: String = #function) {
        let names = fun.components(separatedBy: ":")
        var prettyName: String
        if names.count == 2 {
            prettyName = names[0]
        } else {
            prettyName = names[1]
        }

        if fun == "mqttDidDisconnect(_:withError:)" {
            prettyName = "didDisconect"
        }
        print("[TRACE] [\(prettyName)]: \(message)")
    }
}
extension ViewController: CocoaMQTTDelegate
{
    func mqtt(_ mqtt: CocoaMQTT, didUnsubscribeTopic topic: String)
    {
        print("topic==>\(topic)")
    }


    // Optional ssl CocoaMQTTDelegate
    func mqtt(_ mqtt: CocoaMQTT, didReceive trust: SecTrust, completionHandler: @escaping (Bool) -> Void) {
        TRACE("trust: \(trust)")

        completionHandler(true)
    }

    func mqtt(_ mqtt: CocoaMQTT, didConnectAck ack: CocoaMQTTConnAck) {
        TRACE("ack: \(ack)")

        if ack == .accept {
            mqtt.subscribe("chat/room/animals/client/+", qos: CocoaMQTTQOS.qos1)
        }
    }

    func mqtt(_ mqtt: CocoaMQTT, didStateChangeTo state: CocoaMQTTConnState) {
        TRACE("new state: \(state)")
    }

    func mqtt(_ mqtt: CocoaMQTT, didPublishMessage message: CocoaMQTTMessage, id: UInt16) {
        TRACE("message: \(message.string!.description), id: \(id)")
    }

    func mqtt(_ mqtt: CocoaMQTT, didPublishAck id: UInt16) {
        TRACE("id: \(id)")
    }

    func mqtt(_ mqtt: CocoaMQTT, didReceiveMessage message: CocoaMQTTMessage, id: UInt16 ) {
        TRACE("message: \(message.string!.description), id: \(id)")

        let name = NSNotification.Name(rawValue: "MQTTMessageNotification")
        NotificationCenter.default.post(name: name, object: self, userInfo: ["message": message.string!, "topic": message.topic])
    }

    func mqtt(_ mqtt: CocoaMQTT, didSubscribeTopics success: NSDictionary, failed: [String]) {
        TRACE("subscribed: \(success), failed: \(failed)")
    }

    func mqtt(_ mqtt: CocoaMQTT, didSubscribeTopic topics: [String]) {
        TRACE("topic: \(topics)")
    }

    func mqttDidPing(_ mqtt: CocoaMQTT) {
        TRACE()
    }

    func mqttDidReceivePong(_ mqtt: CocoaMQTT) {
        TRACE()
    }

    func mqttDidDisconnect(_ mqtt: CocoaMQTT, withError err: Error?) {
        TRACE("\(err.debugDescription)")
    }
}

1 Ответ

0 голосов
/ 07 января 2020

Создать класс Mqtt Siglton 

import UIKit
import CocoaMQTT

class MQTT {

    var objMQTTClient : CocoaMQTT?

    static let shared = MQTT()
    private init() {}
}

. Пожалуйста, создайте dicPayload для передачи в MQTT 

func publishMQTTMessage() {

      var dicPayload = [String : Any]()
      dicPayload["sender_id"] = <Pass Sender Id>
      dicPayload["recv_id"] = <Pass reciver Id>
      dicPayload["message"] = <message>
      dicPayload["chat_type"] = <userChatType>
      dicPayload["message_type"] = <messageType>

      MQTT.shared.MQTTPublishWithTopic(dicPayload, appDelegate.loginUser.userId, CMQTTUSERTOPIC)

 }

publi sh сообщение с MQTT Topi c

func MQTTPublishWithTopic(_ payload:[String : Any], _ id:Any?, _ topic : String?)
{
    let jsonData = try? JSONSerialization.data(withJSONObject: payload, options: [])
    let jsonString = String(data: jsonData!, encoding: .utf8)
    objMQTTClient?.publish(topic!, withString: jsonString!)
    print("message publish")

}
...