MQTT

MQTTSessionManager *sessionManager = [[MQTTSessionManager alloc] init];
 [sessionManager connectTo:@“192.168.1.4” //服务器地址
                      port:1883  //服务端端口号
                       tls:false //是否使用tls协议，mosca是支持tls的，如果使用了要设置成true
                 keepalive:60    //心跳时间，单位秒，每隔固定时间发送心跳包
                     clean:false //session是否清除，这个需要注意，如果味false，代表保持登录，如果客户端离线了再次登录就可以接收到离线消息
                      auth:true //是否使用登录验证，和下面的user和pass参数组合使用
                      user:_userName //用户名
                      pass:_passwd //密码
                 willTopic:@""  //下面四个参数用来设置如果客户端离线发送给其它客户端消息，当前参数是哪个topic用来传输离线消息，这里的离线消息都指的是客户端掉线后发送的掉线消息
                      will:@"" //自定义的离线消息，约定好格式就可以了
                   willQos:0  //接收离线消息的级别
            willRetainFlag:false 
              withClientId:]; //客户端id，需要特别指出的是这个id需要全局唯一，因为服务端是根据这个来区分不同的客户端的，默认情况下一个id登录后，假如有另外的连接以这个id登录，上一个连接会被踢下线

//订阅topic
sessionManager.subscriptions = [[NSMutableDictionary alloc] init];
[sessionManager.subscriptions setObject:[NSNumber numberWithInt:1]
                                                                     forKey:_topic];
//发送消息,返回值msgid大于0代表发送成功
UInt16 msgid = [sessionManager sendData:[msg dataUsingEncoding:NSUTF8StringEncoding] //要发送的消息体
                                                                          topic:topic  //要往哪个topic发送消息                                                                        
                                                                            qos:1 //消息级别
                                                                         retain:false];

- (void)handleMessage:(NSData *)data onTopic:(NSString *)topic retained:(BOOL)retained;

//注册观察者，记得在离开页面时移除观察者
- (void)viewWillAppear:(BOOL)animated {
    [super viewWillAppear:animated];
    
    [sessionManager addObserver:self
                    forKeyPath:@"state"
                       options:NSKeyValueObservingOptionInitial | NSKeyValueObservingOptionNew
                       context:nil];
}


- (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context {
    switch (sessionManager.state) {
        case MQTTSessionManagerStateClosed: //连接已经关闭
            break;
        case MQTTSessionManagerStateClosing: //连接正在关闭
            break;
        case MQTTSessionManagerStateConnected: //已经连接
            break;
        case MQTTSessionManagerStateConnecting: //正在连接中
            break;
        case MQTTSessionManagerStateError: //异常
            break;
        case MQTTSessionManagerStateStarting: //开始连接
        default:
            break;
    }
}