一、前提条件

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质量,连接地址等信息。

  //cientId的生成必须遵循GroupID@@@前缀,且需要保证全局唯一
 NSString *deviceID = [UIDevice currentDevice].identifierForVendor.UUIDString;
 self.clientId = [NSString stringWithFormat:@"%@@@@%@",self.groupId,deviceID];

 //初始化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.mqttSettings[@"host"]
   port:[self.mqttSettings[@"port"] intValue]
   tls:[self.mqttSettings[@"tls"] boolValue]
   keepalive:60  //心跳间隔不得大于120s
   clean:true
   auth:true
   user:userName
   pass:token
   will:false
   willTopic:nil
   willMsg:nil
   willQos:0
   willRetainFlag:FALSE
   withClientId:self.clientId];


4、订阅【subscribe】

【订阅主题】

当客户端成功连接环信MQTT消息云后,通过设置subscriptions参数值实现订阅主题与取消订阅主题 。当subscriptions非空时,订阅主题;当subscriptions为空时,取消订阅主题;

/**
订阅主题
格式为 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消息云服务中,有任何疑问和建议,欢迎您联系我们