欢迎光临朱凯的个人博客!
朱凯,a3.work

webSocket使用

 发布时间: 2016-12-21 15:50      原创:  朱凯      评论: .       .人查看

项目需要,后台搭建了webSocket,这里说一下如何跟后台对接的

这里我们使用的是SocketRocket框架 (https://github.com/facebook/SocketRocket)

用法:

@property (nonatomic,strong) SRWebSocket *webSocket;
- (void)viewWillAppear:(BOOL)animated{
    [super viewWillAppear:animated];
    // 发送webSocket
    self.webSocket.delegate = nil;
    [self.webSocket close];
    self.webSocket = [[SRWebSocket alloc] initWithURLRequest:[NSURLRequest requestWithURL:[NSURL URLWithString:[NSString stringWithFormat:@"ws:ip地址:端口"]]]];
    self.webSocket.delegate =self;
    [self.webSocket open];
}

遵守 <SRWebSocketDelegate> 代理

- (void)webSocketDidOpen:(SRWebSocket *)webSocket;{
    NSLog(@"连接成功,可以登录后台服务器,开启心跳");
}
- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error;{
    NSLog(@"webSocket连接错误:- %@",error);
    NSLog(@"这里可以实现掉线自动重连,要注意以下几点");
    NSLog(@"1.判断当前网络环境,如果断网了就不要连了,等待网络到来,再发起重连");
    NSLog(@"2.判断调用层是否需要连接,例如用户都没在聊天界面,连接上去浪费流量");
    NSLog(@"3.连接次数限制,如果连接失败了,重试10次左右就可以了,不然就死循环了。");
}
- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message;{
    NSLog(@"收到消息:- %@",message);
}
- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean;{
    NSLog(@"连接断开,清空socket对象,清空该清空的东西,还有关闭心跳!");
}

向服务器发送消息

发送的时候可能断网,可能socket还在连接,要判断一些情况

发送逻辑是,我有一个 socketQueue 的串行队列,发送请求会加到这个队列里,然后一个一个发出去,如果掉线了,重连连上后继续发送,对调用层透明,调用层不需要知道网络断开了

- (void)sendData:(id)data {
    WEAKSELF(ws);
    dispatch_async(self.socketQueue, ^{
        if (ws.socket != nil) {
            // 只有 SR_OPEN 开启状态才能调 send 方法啊,不然会崩
            if (ws.socket.readyState == SR_OPEN) {
                [ws.socket send:data];    // 发送数据
            } else if (ws.socket.readyState == SR_CONNECTING) {
                NSLog(@"正在连接中,重连后其他方法会去自动同步数据");
                // 每隔2秒检测一次 socket.readyState 状态,检测 10 次左右
                // 只要有一次状态是 SR_OPEN 的就调用 [ws.socket send:data] 发送数据
                // 如果 10 次都还是没连上的,那这个发送请求就丢失了,这种情况是服务器的问题了,小概率的
                // 代码有点长,我就写个逻辑在这里好了
            } else if (ws.socket.readyState == SR_CLOSING || ws.socket.readyState == SR_CLOSED) {
                // websocket 断开了,调用 reConnect 方法重连
                [ws reConnect:^{
                    NSLog(@"重连成功,继续发送刚刚的数据");
                    [ws.socket send:data];
                }];
            }
        } else {
            NSLog(@"没网络,发送失败,一旦断网 socket 会被我设置 nil 的");
            NSLog(@"其实最好是发送前判断一下网络状态比较好,我写的有点晦涩,socket==nil来表示断网");
        }
    });
}

心跳机制

心跳机制就不难了,开个定时器,问下后台要每隔多少秒发送一次心跳请求就好了。然后注意,断网了或者socket断开的时候把心跳关一下,省资源,不然都断网了,还在循环发心跳,浪费CPU和电量。

注: 

因为跟后台对接时,会出现扯皮状况 (后台说代码没错,前台我们检查后也没发现错误,但就是连不通), 这里分享给大家一个测试的地址:  ws://echo.websocket.org,可以连接,可以发送消息(会有回复的哟)

转载请注明来源:   webSocket使用  - 朱凯博客

分享是一种快乐,也是一种美德:
¥打开支付宝,扫码领红包¥ 红包

支付宝 aliPay

微信 wxPay