本文只是针对iOS中使用MQTT做推送消息的简单实用做一个说明,深入的知识点由于最近赶项目没时间研究,有大神手滑路过了,还请多多指点,互相交流下
MQTT的简介:(这个简介百度上面有的,里面比较重要的是qos,消息的发布质量)
- MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twitter让房屋联网）的通信协议。
- MQTT协议是为大量计算能力有限，且工作在低带宽、不可靠的网络的远程传感器和控制设备通讯而设计的协议，它具有以下主要的几项特性：
1、使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序耦合；
2、对负载内容屏蔽的消息传输；
3、使用 TCP/IP 提供网络连接；
4、有三种消息发布服务质量：qos
“至多一次”，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。
“至少一次”，确保消息到达，但消息重复可能会发生。
“只有一次”，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果。
5、小型传输，开销很小（固定长度的头部是 2 字节），协议交换最小化，以降低网络流量；
6、使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制；
使用cocoapods导入MQTT
platform :ios, "7.0"
pod "MQTTClient"
pod 'MQTTClient/Websocket'
pod 'SocketRocket'
// 导入头文件
#import <MQTTClient/MQTTClient.h>
- 具体用法
// 创建一个传输对象
MQTTCFSocketTransport *transport = [[MQTTCFSocketTransport alloc] init];
// IP
transport.host = TFHOST;
// 端口
transport.port = TFPORT;
// 会话
MQTTSession *session = [[MQTTSession alloc] init];
self.session = session;
session.transport = transport;
session.delegate = self;
// 设置终端ID(可以根据后台的详细详情进行设置)
session.clientId = uid;
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
// 会话链接并设置超时时间
[session connectAndWaitTimeout:30];
dispatch_async(dispatch_get_main_queue(), ^{
// 订阅主题, qosLevel是一个枚举值,指的是消息的发布质量
// 注意:订阅主题不能放到子线程进行,否则block不会回调
[session subscribeToTopic:topic atLevel:MQTTQosLevelAtMostOnce subscribeHandler:^(NSError *error, NSArray<NSNumber *> *gQoss) {
if (error) {
TFLog(@"连接失败 = %@", error.localizedDescription);
}else{
TFLog(@"链接成功 = %@", gQoss);
}
}];
});
});
- MQTT的别的操作,这些操作是对MQTT做了简单的封装
/**
* 断开链接
*/
- (void)disconnect{
if (self.session) {
[self.session disconnect];
}
}
/**
* 关闭
*/
- (void)close{
if (self.session) {
[self.session close];
}
}
/**
* 关闭断开链接会话后的回调
*/
- (void)closeWithDisconnect{
if (self.session) {
[self.session closeWithDisconnectHandler:^(NSError *error) {
if (error) {
TFLog(@"close error = %@", error.localizedDescription);
}else{
TFLog(@"close session");
}
}];
}
}
/**
* 发布数据
*
* @param data 二进制数据
*/
- (void)publishAndWaitData:(NSData *)data{
if (self.session) {
[self.session publishAndWaitData:data onTopic:topic retain:NO qos:MQTTQosLevelAtMostOnce];
}
}
/**
* 发布数据
*
* @param dic 字典数据
*/
- (void)publishAndWaitDic:(NSDictionary *)dic{
NSError *error = nil;
NSData *data = [NSJSONSerialization dataWithJSONObject:dic options:NSJSONWritingPrettyPrinted error:&error];
[self publishAndWaitData:data];
}
- MQTT连接后事件的处理是在代理中回调的.
// 接收到新的消息后的回调,接受到服务器的消息后会回调这个代理方法
- (void)newMessage:(MQTTSession *)session data:(NSData *)data onTopic:(NSString *)topic qos:(MQTTQosLevel)qos retained:(BOOL)retained mid:(unsigned int)mid{
}
