最近敲项目中需要用到cocoaMQTT，这个第三方的库。
//简单的来说这个mqtt需要以下的几步
1.cocpods中导入cocoaMqtt的第三方
2.注册mqtt的账号
3.遵循mqtt的协议。（在做的过程中，我并没有去遵循mqtt的协议。因为是用swift去写的。cocoaMQTT中有闭包。所以使用的是闭包的方式去写）
4.在连接上的闭包中去写需要订阅的主题都有那一些
（ public var didConnectAck: (CocoaMQTT, CocoaMQTTConnAck) -> Void = { _, _ in }）
5.在mqtt连接状态有所改变的闭包中去写入连接。（也就是mqtt的状态变成断开连接的时候）
6.还有一些其他的闭包：发送消息的回调、接收到订阅的主题发送过来的消息、取消订阅主题。
7.发送消息出去的方式是：需要发送出去的主题+（你需要发送的消息）
8.mqtt中发送出去主题的消息有两种形式 ： string 或者 [UInt8]数组的方式
9.比方A。发送消息给B。这个时候A发送的时候通过主题的方式去吧消息发送出去。
A并不会去管发送给了谁。只要是B订阅了主题。就会接受到这个消息（两个人的账号 ip + 端口号等都是一致的）（如果C也订阅了相同的主题就会接收到A发送出去的主题）
10.MQTT发送出去的消息是实时性的。
let clientID = ”*******“
//server
mqtt = CocoaMQTT(clientID: clientID, host: mqttIp, port: ****)
//账号
mqtt?.username = "*****"
//密码
mqtt?.password = "******************"
//保持时间
mqtt?.keepAlive = 60
_ = mqtt?.connect()
（这个是注册账号的方式）
--------------------------------------------------------------------
//可以使用闭包代替协议 接受到订阅的主题
mqtt?.didReceiveMessage = { mqtt, message, id in
//（在这儿能够接收到他人通知主题 的方式发送过来的消息）
//接收到他人发送过来的消息进行相对应的解析他人发送的消息内容具体是什么东西
}
///发送消息的回调
mqtt?.didPublishMessage = { mqtt, message, id in
}
//mqttDidDisconnect
mqtt?.didDisconnect = { mqtt, erroe in
}
//取消订阅主题的信息是什么
mqtt?.didUnsubscribeTopic = { mqtt, topic in
}
mqtt?.didSubscribeTopic = { mqtt, topics in
}
mqtt?.didPublishAck = { mqtt, id in
}
mqtt?.didChangeState = { mqtt, state in
//断开链接时
switch mqtt.connState {
case .connecting:
break
case .connected:
break
case .disconnected:
_ = mqtt.connect()
break
default:
break
}
}
mqtt?.didConnectAck = { mqtt, ack in
/**链接上了
ack == accept时候在此之中去订阅需要订阅的主题
订阅的主题
*/
if ack == .accept {
//（在这儿订阅的主题信息是什么）
mqtt.ping()
}
}
mqtt?.didReceivePong = { mqtt in
}
mqtt?.didPing = { mqtt in
}
--------------------------------------------------
//发送的主题
let mqttTopic: String = "主题是什么"
let message = CocoaMQTTMessage(topic: mqttTopic, payload: [UInt8], qos: .qos0, retained: false, dup: false)
//发送出去
mqtt?.publish(message)
//个人建议，因为我在做的过程中发送出去的主题都是[uint8]一个类型的数组发送出去的。在写的过程中。发现用[uint8]能够传送出去更多的东西。以上就是本人简单的一些小总结。后期回去完善以上的文章。欢迎大家和我交流。一起共同进步。谢谢
mqtt在断网的时候发送主题会失败，不知道其他人使用mqtt的用途主要是那一个方面的。个人建议是在断网的时候记录一下数据将数据记录到数据库中。iOS中可以有判断网络链接上的通知。我在项目中遇到的一个问题就是需要在网络断开之后去记录有那一些的数据需要在重新链接到网络之后在次发送到云端。这个做起来也是比较简单的。
～～～～～～～～
.qos等级
- 0代表“至多一次”，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。
- 1代表“至少一次”，确保消息到达，但消息重复可能会发生。
- 2代表“只有一次”，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果。 备注：由于服务端采用Mosca实现，Mosca目前只支持到QoS 1
-先这些吧。后期再遇到些什么东西在继续做一些补充。
网友评论