iOS MQTT 接入示例(MQTT 物联套件)

前言

需要是倒端连着抱MQTT,点击按钮利用MQTT给门禁上的设施发送信息;
流动:门禁设备(Android系统并了MQTT和叫硬件信息发送指令的包)
症结未缓解:
1.门最终开没起来成,硬件是未曾给举报的,门禁设备也未晓;
2.移动装备消息发送了,指定的门禁设备是否收取信息,移动端还无亮堂;

该文介绍的凡采取阿里底MQTT接抱ios的证明
因为吃的demo里没有参数说明,看简单说明作为了解;

MQTT协议中文版

MQTT是一个客户端服务端架构的披露/订阅模式之音讯传协议。它的设计思想是轻飘、开放、简单、规范,易于落实。
这些特征令它对广大面貌吧都是挺好的选,特别是对于受限的条件要机器和机具的通信(M2M)以及物联网环境(IoT)
商讨传送门:https://mcxiaoke.gitbooks.io/mqtt-cn/content/

MQTT应用场景

屏幕快照.png

MQTT 物联套件

介绍 MQTT 协议基本概念,阿里巴巴 MQ 提供的 MQTT 服务的重要性原理和 MQTT
协议要的运用场景
地点如下:
https://help.aliyun.com/document\_detail/42419.html?spm=5176.doc47755.6.560.dcabYu

MQTT iOS 接入示例

介绍如何采取 iOS 客户端收发 MQTT 消息地址如下:
https://help.aliyun.com/document\_detail/47755.html?spm=5176.doc44711.6.633.pN8AIa

iOS接抱 非CocoaPods 安装配置

滑到示例地址的底层: 下载demo
拿到路pods下的MQTTClient下的MQTTClient导入工程;
并非将LICENSE文件为导入进程序

切莫是CocoaPods安装,需要拿如下面文件改成为双料引号””
#import <MQTTClient/MQTTSession.h>
#import <MQTTClient/MQTTSessionLegacy.h>
#import <MQTTClient/MQTTSessionSynchron.h>
#import <MQTTClient/MQTTMessage.h>
#import <MQTTClient/MQTTTransport.h>
#import <MQTTClient/MQTTCFSocketTransport.h>
#import <MQTTClient/MQTTCoreDataPersistence.h>
#import <MQTTClient/MQTTSSLSecurityPolicyTransport.h>

#import "MQTTSession.h"
#import "MQTTSessionLegacy.h"
#import "MQTTSessionSynchron.h"
#import "MQTTMessage.h"
#import "MQTTTransport.h"
#import "MQTTCFSocketTransport.h"
#import "MQTTCoreDataPersistence.h"
#import "MQTTSSLSecurityPolicyTransport.h"
以待实现的地方导入头文件;
/*
 * MQTTClient: imports
 * MQTTSessionManager.h is optional
 */
#import "MQTTClient.h"
#import "MQTTSessionManager.h"

/*
 * MQTTClient: using your main view controller as the MQTTSessionManagerDelegate
 */

#import <CommonCrypto/CommonHMAC.h>
加上代办:
MQTTSessionManagerDelegate

/*
 * MQTTClient: keep a strong reference to your MQTTSessionManager here
 */
@property (strong, nonatomic) MQTTSessionManager *manager;

@property (strong, nonatomic) NSDictionary *mqttSettings;
@property (strong, nonatomic) NSString *rootTopic;
@property (strong, nonatomic) NSString *accessKey;
@property (strong, nonatomic) NSString *secretKey;
@property (strong, nonatomic) NSString *groupId;
@property (strong, nonatomic) NSString *clientId;
@property (assign, nonatomic) NSInteger qos;

@property (strong, nonatomic) NSMutableArray *chat;
初始化客户端连接到host
 MQTT-Client-FrameWork 包提供的客户端类有 MQTTSession 和 MQTTSessionManager,
 建议使用后者维持静态资源,而且已经封装好自动重连等逻辑。
 初始化时需要传入相关的网络参数

参数在阿里提供的demo里发生一个plist文件,如下:

屏幕快照 2017.png

参数如何布置请查看:
https://help.aliyun.com/document\_detail/29536.html?spm=5176.doc29535.6.551.OrrVHX

从部署文件导入相关属性,发起连接

本人的需要是才出一个地方采取,进至这页面的时候,我才发起连接,
点击按钮给门禁上之java程序发送开门消息,连接方式调用如下方法:

-(void)initMQTT{

    NSURL *bundleURL = [[NSBundle mainBundle] bundleURL];
    NSURL *mqttPlistUrl = [bundleURL URLByAppendingPathComponent:@"mqtt.plist"];
    self.mqttSettings = [NSDictionary dictionaryWithContentsOfURL:mqttPlistUrl];
    self.rootTopic = self.mqttSettings[@"rootTopic"];
    self.accessKey = self.mqttSettings[@"accessKey"];
    self.secretKey = self.mqttSettings[@"secretKey"];
    self.groupId = self.mqttSettings[@"groupId"];
    self.qos =[self.mqttSettings[@"qos"] integerValue];

    //clientId的生成必须遵循GroupID@@@前缀,且需要保证全局唯一
    /*为了保证全局唯一,ios可以获取CFUUID,每次获取都是不一样的,
       想保证一个设备一样,需要存本地一份;
        但是我这里需要每次使用的时候,每次连击所以为了保证clientid全局唯一,
        我每次都获取一次CFUUID,去掉中间的分隔线" - "代码如下,
    */
    CFUUIDRef cfuuid = CFUUIDCreate(kCFAllocatorDefault);
    NSString* cfuuidString = (NSString*)CFBridgingRelease(CFUUIDCreateString(kCFAllocatorDefault, cfuuid));
    NSString* tempstr = [cfuuidString stringByReplacingOccurrencesOfString:@"-" withString:@""];
    cfuuidString = tempstr;

    self.clientId=[NSString stringWithFormat:@"%@@@@%@%@",self.groupId,@"",cfuuidString];

    self.chat = [[NSMutableArray alloc] init];
    /*
     * MQTTClient: create an instance of MQTTSessionManager once and connect
     * will is set to let the broker indicate to other subscribers if the connection is lost
     */
    if (!self.manager) {
        self.manager = [[MQTTSessionManager alloc] init];
        self.manager.delegate = self;

        self.manager.subscriptions = [NSDictionary dictionaryWithObject:
                                      [NSNumber numberWithLong:self.qos]forKey:
                                      [NSString stringWithFormat:@"%@/#", self.rootTopic]];

        //password的计算方式是,使用secretkey对groupId做hmac签名算法,具体实现参考macSignWithText方法
        NSString *passWord = [[self class] macSignWithText:self.groupId secretKey:self.secretKey];
          /*
          此处从配置文件导入的Host即为MQTT的接入点,该接入点获取方式请参考资源申请章节文档,
           在控制台上申请MQTT实例,每个实例会分配一个接入点域名
          */
        [self.manager connectTo:self.mqttSettings[@"host"]
                           port:[self.mqttSettings[@"port"] intValue]
                            tls:[self.mqttSettings[@"tls"] boolValue]
                      keepalive:60  //心跳间隔不得大于120s
                          clean:true
                           auth:true
                           user:self.accessKey
                           pass:passWord
                           will:false
                      willTopic:nil
                        willMsg:nil
                        willQos:0
                 willRetainFlag:FALSE
                   withClientId:self.clientId];

    } else {
        [self.manager connectToLast];
    }
 }

/*
 userName 和 passWord 的设置

 由于服务端需要对客户端进行鉴权,因此需要传入合法的 userName 和 passWord。
 userName 设置为当前用户的 AccessKey,
 password 则设置为 MQTT 客户端 GroupID 的签名字符串,
 签名计算方式是使用 SecretKey 对 GroupID 做 HmacSHA1 散列加密。
 具体方法请参考 👇 中的 macSignWithText 函数。
 */
+ (NSString *)macSignWithText:(NSString *)text secretKey:(NSString *)secretKey
{
    NSData *saltData = [secretKey dataUsingEncoding:NSUTF8StringEncoding];
    NSData *paramData = [text dataUsingEncoding:NSUTF8StringEncoding];
    NSMutableData* hash = [NSMutableData dataWithLength:CC_SHA1_DIGEST_LENGTH ];
    CCHmac(kCCHmacAlgSHA1, saltData.bytes, saltData.length, paramData.bytes, paramData.length, hash.mutableBytes);
    NSString *base64Hash = [hash base64EncodedStringWithOptions:0];

    return base64Hash;
}
connectTo方法里之参数说明:
  • tls:false
    //是否以tls协议,mosca是支撑tls的,如果运用了一旦装成true
  • clean:false
    //session是否清除,这个得专注,如果是false,代表保持登录,
    比方客户端离线了重登录就可以接纳及离线消息。注意:QoS为1以及QoS为2,并要订阅和发送一致
  • auth:true //是否采用登录验证,和底的user和pass参数组合使用
  • user:_userName //用户名
  • pass:_passwd //密码
  • willTopic:@”” //下面四独参数用来安如果客户端好离线发送的消息,
    此时此刻参数是哪个topic用来传异常离线消息,这里的要命离线消息都负的凡客户端掉线后发送的掉线消息
  • will:@”” //异常离线消息体。自定义之很离线消息,约定好格式就得了
  • willQos:0 //接收离线消息的级别 0、1、2
  • willRetainFlag:false //只有在吗true时,Will Qos和Will
    Retain才见面吃读取,此时信息体payload中
    若是起Will Topic和Will Message具体内容,否则,Will QoS和Will
    Retain值会被忽略掉
  • withClientId:nil];
    //客户端id,需要特别指出的凡者id需要全局唯一,因为服务端是因是来区分不同的客户端的,
    默认情况下一个id登录后,假如有另外的接连为之id登录,上一个一连会叫踢下线;

出殡信息(当点击按钮的时节,发送信息方法如下:)

  [self.manager sendData:[self.scanDic.mj_JSONString dataUsingEncoding:NSUTF8StringEncoding]
                     topic:[NSString stringWithFormat:@"%@",
                            self.rootTopic]//此处设置多级子topic
                       qos:self.qos
                    retain:FALSE];
出殡方注意topic的安

以下为安卓代码中的注解示例:
ios的demo中从未这个美学原理说明
信发送至某某主题Topic,所有订阅者Topic的设施都能接收这消息。
按照MQTT的通告订阅规范,Topic也堪是系列Topic。
此安装了发送至二级topic如下:
sampleClient.publish(topic+”/notice/”, message);
唯独发送P2P音讯,二级Topic必须是“p2p”,三级topic是目标的ClientID
此间安装的三级topic需要是接收方的ClientID如下:
string p2pTopic =topic+”/p2p/”+consumerClientId;

qos:消息之传输方式

QoS说明如下:

  • 0 代表“至多一致坏”,消息公布了依赖底层 TCP/IP
    网络。会有信息丢失或重复。
    立马同级别可用于如下情况,环境传感器数据,丢失一破读记录无所谓,因为快晚还见面产生次赖发送。
  • 1 代表“至少一不好”,确保信息到达,但消息还或会见生。
  • 2
    代表“只发生相同糟糕”,确保信息到达一蹩脚。这无异级别可用以如下情况,在计费系统受到,消息再度或掉会造成未得法的结果。
  • 备考:由于服务端采用Mosca实现,Mosca目前单纯支持及QoS 1
  • 万一发送的凡临时的音信,例如:给某topic所有在线的设备发送一漫漫消息,丢失的言语也不在乎,0就得了
    (客户端登录的时候如果指明支持的QoS级别,同时发送信息之时节呢要指明这条消息支持之QoS级别)
  • 若果急需客户端保证会接受信息,需要指定QoS为1,如果以需要加入客户端不在线也要力所能及接至信息,
    那么客户端登录的时候如果指定session的得力,接收离线消息需要指定服务端要保存客户端的session状态。

接到发送信息之回调

/*
 * MQTTSessionManagerDelegate
 */
- (void)handleMessage:(NSData *)data onTopic:(NSString *)topic retained:(BOOL)retained {
    /*
     * MQTTClient: process received message
     */
    NSString *dataString = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
    [self.chat insertObject:[NSString stringWithFormat:@"RecvMsg from Topic: %@\nBody: %@", topic, dataString] atIndex:0];    
}