什么是MQTT

MQTT（消息队列遥测传输），基于发布/订阅的消息协议。
MQTT工作在TCP/IP协议族上，是为硬件性能低下的远程设备及网络糟糕的情况下设计的发布/订阅型的消息协议。
在移动消息，物联网，车联网，智能设备等领域有着广泛的应用

MQTT特点

• 使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序的耦合。
• 使用TCP/IP提供网络连接
• 有三种消息发布服务质量
  1.至多一次：消息发送可能会丢失或者重复，这一级别情况下，丢失一次数据无所谓，不久后会第二次发送。
  2.至少一次：确保消息到达，但是可能会出现消息重复。
  3.只有一次：确保消息达到一次。
• 小型传输，开销很小（固定长度的头部是2字节），协议交换最小化，降低网络流量
• 使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制
  Last Will 定义客户端出现网络异常导致连接中断的情况下，服务器需要做的一些措施。
  Last Will（遗嘱），就是有客户端预先定义好的主题和对应消息，附加在头部信息，在连接异常的情况下由服务器主动发布此消息。

MQTTClient使用

MQTTClient是比较优秀的github 针对MQTT封装的开源项目
传送门 MQTT-Client-Framework

初始化 Session

    MQTTSession *mqttSession = [[MQTTSession alloc] init];
    // 设置签名， 签名唯一性 //MQTT_NAME 为自己配制的字符串
 //  NSString *clientID = [NSString stringWithFormat:@"iOS-%@", MQTT_NAME];
    mqttSession.clientId = @"上面的 clientID"; // clientID
    
    // 订阅主题
    MQTTCFSocketTransport *transport = [[MQTTCFSocketTransport alloc] init];
    transport.host = @"ip 地址";
    transport.port = 8080; //端口号
    // 给 session 对象设置基本信息
    mqttSession.transport = transport;
    // 设置代理 回调信息
    mqttSession.delegate = self;
    // 设置用户名称
    mqttSession.userName = @"用户名称";
    // 设置用户密码
    mqttSession.password = @"用户密码";
    // 设置会话链接超时时间
    [mqttSession connectAndWaitTimeout:3];

SessionMangerDelegate 回调 在连接成功后订阅主题

#pragma mark - MQTTSession Delegate
/**
 订阅主题回调
 */
- (void)connected:(MQTTSession *)session {
    
    // MQTT连接成功，进行订阅主题 设置主题 服务质量
    [session subscribeToTopic:@"主题名称" atLevel:MQTTQosLevelAtMostOnce];
    
}
/**
 订阅主题失败
 */
- (void)connectionError:(MQTTSession *)session error:(NSError *)error {
    

}
/**
 连接状态回调
 */
- (void)handleEvent:(MQTTSession *)session event:(MQTTSessionEvent)eventCode error:(NSError *)error {
    
    NSDictionary *events = @{
                             @(MQTTSessionEventConnected): @"连接成功",
                             @(MQTTSessionEventConnectionRefused): @"连接被拒绝",
                             @(MQTTSessionEventConnectionClosed): @"连接关闭",
                             @(MQTTSessionEventConnectionError): @"连接错误",
                             @(MQTTSessionEventProtocolError): @"协议不被接受/协议错误",
                             @(MQTTSessionEventConnectionClosedByBroker): @"其余错误"
                             };
    
}

/**
 收到消息
 */
- (void)newMessage:(MQTTSession *)session data:(NSData *)data onTopic:(NSString *)topic qos:(MQTTQosLevel)qos retained:(BOOL)retained mid:(unsigned int)mid {
    
    NSDictionary *dic = [NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:nil];
    
    // 进行下一步操作
    
}

给主题发送消息

    //发送消息
    [mqttSession publishData:[NSData data] onTopic:@"所订阅的主题" retain:NO qos:MQTTQosLevelAtMostOnce publishHandler:^(NSError *error) {
        
        if (error) {

            // 发送失败则 重新登录 mqtt 进行重发
         //   [self getMQTTServerAnew];
            
        }else {
            //主题发送成功
            NSLog(@"主题 %@ 发送成功", @"所订阅的主题");
        }
        
    }];

End

如有疑问或者错误处，欢迎探讨和指正。