本文介绍iOS版MQTT 客户端，如何连接环信MQTT消息云快速实现消息的自收自发。

一、前提条件

1.部署iOS开发环境

下载安装 Xcode。

下载安装cocoapods，本文以cocoapods为例。

2.导入项目依赖

 在项目的podfile文件中设置如下：

  source 'https://github.com/CocoaPods/Specs.git'
  platform :ios, '10.0'
  pod 'MQTTClient'
  pod 'AFNetworking'
  pod 'MBProgressHUD'
  pod 'Masonry'
  pod 'MJRefresh'
  pod 'YYModel'
  target 'MQTTChat' do
end

二、实现流程

1、获取鉴权

     为保障客户安全性需求，环信MQTT消息云服务为客户提供【token+clientID】方式实现鉴权认证，其中AppID(clientID中的关键字段)及token标识获取流程如下:

【登录console】
    欢迎您登录环信云console控制台，在此控制台中，为您提供应用列表、解决方案、DEMO体验以及常见问题等功能。
     在应用列表中，若您未在APP中开通MQTT业务，可参见APP  MQTT开通流程
     若APP已开通MQTT业务，可在应用列表中选中Appname，点击【查看】操作，进入应用详情。

【获取AppID及连接地址】 
      进入【查看】后，点击左侧菜单栏【MQTT】->【服务概览】，在下图红色方框内获取当前AppID及服务器连接地址。

【获取token】
     为实现对用户管控及接入安全性，环信云console提供用户认证功能，支持对用户账户的增、删、改、查以及为每个用户账户分配唯一token标识，获取token标识可选择以下两种形式。
  形式一：console控制台获取（管理员视角）
  * 点击左侧菜单栏【应用概览】->【用户认证】页面，点击【创建IM用户】按钮，增添新的账户信息（包  括用户名及密码）。
  * 创建成功后，在【用户ID】列表中选中账户，点击【查看token】按钮获取当前账户token信息。

  形式二：客户端代码获取（客户端视角）
  * 获取域名：点击左侧菜单栏【即时通讯】->【服务概览】页面，查看下图中token域名、org_name、app_name。

  * 拼接URL：获取token URL格式为：http:/ /token域名/org_name/app_name/token。 
  * 用户名/密码：使用【用户ID】列表中已有账户的用户名及密码，例“用户名：test/密码：test123”。

客户端获取token代码示例如下：

- (void)getTokenWithUsername:(NSString *)username password:(NSString *)password completion:(void (^)(NSString *token))response {

NSString *urlString = getToken_url;
//初始化一个AFHTTPSessionManager
AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
//设置请求体数据为json类型
manager.requestSerializer = [AFJSONRequestSerializer serializer];
//设置响应体数据为json类型
manager.responseSerializer = [AFJSONResponseSerializer serializer];
//请求体，参数（NSDictionary 类型）

NSDictionary *parameters = @{@"grant_type":@"password",
@"username":username,
@"password":password
};
__block NSString *token = @"";

[manager POST:urlString parameters:parameters progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {

NSError *error = nil;
NSData *jsonData = [NSJSONSerialization dataWithJSONObject:responseObject options:NSJSONWritingPrettyPrinted error:&error];
NSDictionary *jsonDic = [NSJSONSerialization JSONObjectWithData:jsonData options:NSJSONReadingMutableContainers error:&error];
NSLog(@"%s jsonDic:%@",__func__,jsonDic);
token = jsonDic[@"access_token"];

response(token);
} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
NSLog(@"%s error:%@",__func__,error.debugDescription);
response(token);
}];
}

2、初始化

      在cocoapods工程中创建MQTT客户端，客户端初始配置包括创建clientID，topic名称，QoS质量，连接地址等信息。

  NSString *deviceID = [UIDevice currentDevice].identifierForVendor.UUIDString;

self.clientId = [NSString stringWithFormat:@"%@@%@",deviceID,self.appId];

//初始化manager
self.manager = [[MQTTSessionManager alloc] init];
self.manager.delegate = self;

//订阅的主题 格式为 xxx/xxx/xxx 可以为多级话题
self.manager.subscriptions = @{[NSString stringWithFormat:@"%@/IOS", self.rootTopic]:@(self.qos),[NSString stringWithFormat:@"%@/IOS_TestToic", self.rootTopic]:@(1)};

3、连接服务器

    配置连接密码、cleansession标志、心跳间隔、超时时间等信息，调用connect（）函数连接至环信MQTT消息云。

//此处从配置文件导入的Host即为MQTT的接入点，该接入点获取方式请参考资源申请章节文档，在控制台上申请MQTT实例，每个实例会分配一个接入点域名
[self.manager connectTo:self.host

port:self.port
tls:self.tls
keepalive:60
clean:true
auth:true
user:userName
pass:token
will:false
willTopic:nil
willMsg:nil
willQos:0
willRetainFlag:FALSE
withClientId:self.clientId];

4、订阅【subscribe】

【订阅主题】

/**
 订阅主题
 格式为 xxx/xxx/xxx 可以为多级话题 @{@"xxx/xxx/xxx...":@(1)}
 qos定义{ 0: 最多一次，1:至少一次 2:仅一次}
*/
self.manager.subscriptions = @{[NSString stringWithFormat:@"%@/IOS", self.rootTopic]:@(self.qos),[NSString stringWithFormat:@"%@/IOS_TestToic", self.rootTopic]:@(1)};

【取消订阅】

self.manager.subscriptions = @{};

【接收消息】

    从环信MQTT消息云接收订阅消息。

  /*
   * MQTTSessionManagerDelegate
   */
 - (void)handleMessage:(NSData *)data onTopic:(NSString *)topic retained:(BOOL)retained {
/*
    * MQTTClient: process received message
    */

NSString *dataString = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
  [self.receiveMsgs insertObject:[NSString stringWithFormat:@"RecvMsg from Topic: %@ Body: %@", topic, dataString] atIndex:0];
  [self.tableView reloadData];
}

5、发布【publish】

   向环信MQTT消息云中指定topic发送消息。

- (void)send {
/*
   * MQTTClient: send data to broker
   */

  [self.manager sendData:[self.messageTextField.text dataUsingEncoding:NSUTF8StringEncoding]
  topic:[NSString stringWithFormat:@"%@/%@",
self.rootTopic,
@"IOS"]//此处设置多级子topic
  qos:self.qos
  retain:FALSE];
}

6、断开连接

  MQTT client向环信MQTT消息云发送断开连接请求。

  /*
   * 断开连接
   */
 - (void)disConnect {
   [self.manager disconnect];
self.manager.subscriptions = @{};
 }

7、重新连接

 MQTT client向环信MQTT消息云发送重新连接请求。

/*
 * 重新连接
*/
- (void)connect {
[self.manager connectToLast];
}

三、更多信息

  * 完整demo示例，请参见demo下载。

  * 目前MQTT客户端支持多种语言，请参见 SDK下载。
  * 如果您在使用环信MQTT消息云服务中，有任何疑问和建议，欢迎您联系我们。