iOS之MQTT简单使用

本文只是针对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{
 
}