iOS开发者福音：iOS项目也能支持MQTT5.0啦！

2017 年 8 月，OASIS MQTT Technical Committee 正式发布了用于 Public Review 的 MQTT 5.0 草案。2018 年，MQTT 5.0 正式发布。

然而到目前为止，苹果生态里仍没有完整支持 MQTT 5.0 的客户端 SDK。

• Broker: broker-cn.emqx.io

• TCP Port: 1883

• Websocket Port: 8083

• TCP/TLS 端口: 8883

• Websocket/TLS 端口:8084

///MQTT 5.0
let clientID = "CocoaMQTT-" + String(ProcessInfo().processIdentifier)
let mqtt5 = CocoaMQTT5(clientID: clientID, host: "broker-cn.emqx.io", port: 1883)


let cOnnectProperties= MqttConnectProperties()
connectProperties.topicAliasMaximum = 0
connectProperties.sessiOnExpiryInterval= 0
connectProperties.receiveMaximum = 100
connectProperties.maximumPacketSize = 500
mqtt5.cOnnectProperties= connectProperties


mqtt5.username = "test"
mqtt5.password = "public"
mqtt5.willMessage = CocoaMQTTWill(topic: "/will", message: "dieout")
mqtt5.keepAlive = 60
mqtt5.delegate = self
mqtt5.connect()


///MQTT 3.1.1
let clientID = "CocoaMQTT-" + String(ProcessInfo().processIdentifier)
let mqtt = CocoaMQTT(clientID: clientID, host: "broker-cn.emqx.io", port: 1883)
mqtt.username = "test"
mqtt.password = "public"
mqtt.willMessage = CocoaMQTTWill(topic: "/will", message: "dieout")
mqtt.keepAlive = 60
mqtt.delegate = self
mqtt.connect()



▍订阅主题

///MQTT 5.0
mqtt5.subscribe("chat/room/animals/client/+", qos: CocoaMQTTQoS.qos1)
//or
//let subscriptions : [MqttSubscription] = [MqttSubscription(topic: "chat/room/animals/client/+"),MqttSubscription(topic: "chat/room/foods/client/+"),MqttSubscription(topic: "chat/room/trees/client/+")]
//mqtt.subscribe(subscriptions)


///MQTT 3.1.1
mqtt.subscribe("chat/room/animals/client/+", qos: CocoaMQTTQoS.qos1)
//or
//let subscriptions : [(String, CocoaMQTTQoS)] = [("chat/room/animals/client/+", qos: CocoaMQTTQoS.qos1),("chat/room/foods/client/+", qos: CocoaMQTTQoS.qos1),("chat/room/trees/client/+", qos: CocoaMQTTQoS.qos1)]
//mqtt.subscribe(subscriptions)



▍发布主题

///MQTT 5.0
mqtt5!.publish("chat/room/animals/client/" + animal!, withString: message!, qos: .qos1, DUP: false, retained: false, properties: publishProperties)


///MQTT 3.1.1
mqtt!.publish("chat/room/animals/client/" + animal!, withString: message!, qos: .qos1)



///MQTT 5.0
mqtt5!.autoRecOnnect= true


///MQTT 3.1.1
mqtt!.autoRecOnnect= true



▍单双向 SSL 连接

///MQTT 5.0
mqtt5!.enableSSL = true


///MQTT 3.1.1
mqtt!.enableSSL = true


let clientCertArray = getClientCertFromP12File(certName: "client-keycert", certPassword: "MySecretPassword")
var sslSettings: [String: NSObject] = [:]
sslSettings[kCFStreamSSLCertificates as String] = clientCertArray


///MQTT 5.0
mqtt5!.sslSettings = sslSettings


///MQTT 3.1.1
mqtt!.sslSettings = sslSettings



openssl pkcs12 -export -clcerts -in client-cert.pem -inkey client-key.pem -out client.p12

///MQTT 5.0
let lastWillMessage = CocoaMQTTMessage(topic: "/chat/room/animals/client/Sheep", string: "dieout")
lastWillMessage.retained = true
lastWillMessage.qos = .qos1
mqtt5!.willMessage = lastWillMessage


///MQTT 3.1.1
mqtt!.willMessage = CocoaMQTTMessage(topic: "/will", string: "dieout")



 let authProperties = MqttAuthProperties()
       mqtt5!.auth(reasonCode: CocoaMQTTAUTHReasonCode.continueAuthentication, authProperties: authProperties)



至此，我们完成了使用 CocoaMQTT 客户端连接到公共 MQTT 服务器，并实现了客户端与 MQTT 服务器的连接、消息发布和订阅。

EMQ 致力于帮助用户轻松便捷地使用 MQTT 开展物联网业务，我们的一系列客户端 SDK 均在持续开发中，敬请关注。

We are hiring! Join us and Code the Future together.

► EMQ 2021 全球招聘季

简历投递邮箱：hr@emqx.io

EMQ HR

点击"阅读原文" ，了解 CocoaMQTT

↓↓↓