+(instancetype)shared;

typedef NS_ENUM(NSUInteger,WebSocketConnectType){  WebSocketDefault = 0,  //初始狀態(tài),未連接,不需要重新連接  WebSocketConnect,    //已連接  WebSocketDisconnect  //連接后斷開(kāi),需要重新連接};

//建立長(zhǎng)連接- (void)connectServer;

-(void)webSocketDidOpen:(RMWebSocket *)webSocket; //連接成功回調(diào)

- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error;//連接失敗回調(diào)

///接收消息回調(diào),需要提前和后臺(tái)約定好消息格式.- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessageWithString:(nonnull NSString *)string

- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean;///關(guān)閉連接回調(diào)的代理

#import <foundation foundation="" h=""> #import "RMWebSocket.h"typedef NS_ENUM(NSUInteger,WebSocketConnectType){  WebSocketDefault = 0, //初始狀態(tài),未連接  WebSocketConnect,   //已連接  WebSocketDisconnect  //連接后斷開(kāi)};@class WebSocketManager;@protocol WebSocketManagerDelegate  <nsobject> - (void)webSocketManagerDidReceiveMessageWithString:(NSString *)string;@endNS_ASSUME_NONNULL_BEGIN@interface WebSocketManager : NSObject@property (nonatomic, strong) RMWebSocket *webSocket;@property(nonatomic,weak) id <websocketmanagerdelegate nbsp="">  delegate;@property (nonatomic, assign)  BOOL isConnect; //是否連接@property (nonatomic, assign)  WebSocketConnectType connectType;+(instancetype)shared;- (void)connectServer;//建立長(zhǎng)連接- (void)reConnectServer;//重新連接- (void)RMWebSocketClose;//關(guān)閉長(zhǎng)連接- (void)sendDataToServer:(NSString *)data;//發(fā)送數(shù)據(jù)給服務(wù)器@endNS_ASSUME_NONNULL_END </websocketmanagerdelegate> </nsobject></foundation>

#import "WebSocketManager.h"@interface WebSocketManager ()<rmwebsocketdelegate> @property (nonatomic, strong) NSTimer *heartBeatTimer; //心跳定時(shí)器@property (nonatomic, strong) NSTimer *netWorkTestingTimer; //沒(méi)有網(wǎng)絡(luò)的時(shí)候檢測(cè)網(wǎng)絡(luò)定時(shí)器@property (nonatomic, assign) NSTimeInterval reConnectTime; //重連時(shí)間@property (nonatomic, strong) NSMutableArray *sendDataArray; //存儲(chǔ)要發(fā)送給服務(wù)端的數(shù)據(jù)@property (nonatomic, assign) BOOL isActivelyClose;  //用于判斷是否主動(dòng)關(guān)閉長(zhǎng)連接，如果是主動(dòng)斷開(kāi)連接，連接失敗的代理中，就不用執(zhí)行 重新連接方法@end@implementation WebSocketManager+(instancetype)shared{  static WebSocketManager *_instance = nil;  static dispatch_once_t onceToken;  dispatch_once(&onceToken, ^{    _instance = [[self alloc]init];  });  return _instance;}- (instancetype)init{  self = [super init];  if(self){    self.reConnectTime = 0;    self.isActivelyClose = NO;        self.sendDataArray = [[NSMutableArray alloc] init];  }  return self;}//建立長(zhǎng)連接- (void)connectServer{  self.isActivelyClose = NO;    self.webSocket.delegate = nil;  [self.webSocket close];  _webSocket = nil;//  self.webSocket = [[RMWebSocket alloc] initWithURL:[NSURL URLWithString:@"https://dev-im-gateway.runxsports.com/ws/token=88888888"]];  self.webSocket = [[RMWebSocket alloc] initWithURL:[NSURL URLWithString:@"ws://chat.workerman.net:7272"]];  self.webSocket.delegate = self;  [self.webSocket open];}- (void)sendPing:(id)sender{  [self.webSocket sendPing:nil error:NULL];}#pragma mark --------------------------------------------------#pragma mark - socket delegate///開(kāi)始連接-(void)webSocketDidOpen:(RMWebSocket *)webSocket{    NSLog(@"socket 開(kāi)始連接");  self.isConnect = YES;  self.connectType = WebSocketConnect;  [self initHeartBeat];///開(kāi)始心跳  }///連接失敗-(void)webSocket:(RMWebSocket *)webSocket didFailWithError:(NSError *)error{  NSLog(@"連接失敗");  self.isConnect = NO;  self.connectType = WebSocketDisconnect;  DLog(@"連接失敗，這里可以實(shí)現(xiàn)掉線自動(dòng)重連，要注意以下幾點(diǎn)");  DLog(@"1.判斷當(dāng)前網(wǎng)絡(luò)環(huán)境，如果斷網(wǎng)了就不要連了，等待網(wǎng)絡(luò)到來(lái)，在發(fā)起重連");  DLog(@"3.連接次數(shù)限制，如果連接失敗了，重試10次左右就可以了");    //判斷網(wǎng)絡(luò)環(huán)境  if (AFNetworkReachabilityManager.sharedManager.networkReachabilityStatus == AFNetworkReachabilityStatusNotReachable){ //沒(méi)有網(wǎng)絡(luò)      [self noNetWorkStartTestingTimer];//開(kāi)啟網(wǎng)絡(luò)檢測(cè)定時(shí)器  }else{ //有網(wǎng)絡(luò)      [self reConnectServer];//連接失敗就重連  }}///接收消息-(void)webSocket:(RMWebSocket *)webSocket didReceiveMessageWithString:(NSString *)string{    NSLog(@"接收消息---- %@",string);  if ([self.delegate respondsToSelector:@selector(webSocketManagerDidReceiveMessageWithString:)]) {    [self.delegate webSocketManagerDidReceiveMessageWithString:string];  }}///關(guān)閉連接-(void)webSocket:(RMWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean{    self.isConnect = NO;  if(self.isActivelyClose){    self.connectType = WebSocketDefault;    return;  }else{    self.connectType = WebSocketDisconnect;  }    DLog(@"被關(guān)閉連接，code:%ld,reason:%@,wasClean:%d",code,reason,wasClean);    [self destoryHeartBeat]; //斷開(kāi)連接時(shí)銷毀心跳    //判斷網(wǎng)絡(luò)環(huán)境  if (AFNetworkReachabilityManager.sharedManager.networkReachabilityStatus == AFNetworkReachabilityStatusNotReachable){ //沒(méi)有網(wǎng)絡(luò)    [self noNetWorkStartTestingTimer];//開(kāi)啟網(wǎng)絡(luò)檢測(cè)  }else{ //有網(wǎng)絡(luò)    NSLog(@"關(guān)閉連接");    _webSocket = nil;    [self reConnectServer];//連接失敗就重連  }}///ping-(void)webSocket:(RMWebSocket *)webSocket didReceivePong:(NSData *)pongData{  NSLog(@"接受pong數(shù)據(jù)--> %@",pongData);}#pragma mark - NSTimer//初始化心跳- (void)initHeartBeat{  //心跳沒(méi)有被關(guān)閉  if(self.heartBeatTimer) {    return;  }  [self destoryHeartBeat];  dispatch_main_async_safe(^{    self.heartBeatTimer = [NSTimer timerWithTimeInterval:10 target:self selector:@selector(senderheartBeat) userInfo:nil repeats:true];    [[NSRunLoop currentRunLoop]addTimer:self.heartBeatTimer forMode:NSRunLoopCommonModes];  })  }//重新連接- (void)reConnectServer{  if(self.webSocket.readyState == RM_OPEN){    return;  }    if(self.reConnectTime > 1024){ //重連10次 2^10 = 1024    self.reConnectTime = 0;    return;  }    WS(weakSelf);  dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(self.reConnectTime *NSEC_PER_SEC)), dispatch_get_main_queue(), ^{        if(weakSelf.webSocket.readyState == RM_OPEN && weakSelf.webSocket.readyState == RM_CONNECTING) {      return;    }        [weakSelf connectServer];    //    CTHLog(@"正在重連......");        if(weakSelf.reConnectTime == 0){ //重連時(shí)間2的指數(shù)級(jí)增長(zhǎng)      weakSelf.reConnectTime = 2;    }else{      weakSelf.reConnectTime *= 2;    }  });  }//發(fā)送心跳- (void)senderheartBeat{  //和服務(wù)端約定好發(fā)送什么作為心跳標(biāo)識(shí)，盡可能的減小心跳包大小  WS(weakSelf);  dispatch_main_async_safe(^{    if(weakSelf.webSocket.readyState == RM_OPEN){      [weakSelf sendPing:nil];    }  });}//沒(méi)有網(wǎng)絡(luò)的時(shí)候開(kāi)始定時(shí) -- 用于網(wǎng)絡(luò)檢測(cè)- (void)noNetWorkStartTestingTimer{  WS(weakSelf);  dispatch_main_async_safe(^{    weakSelf.netWorkTestingTimer = [NSTimer scheduledTimerWithTimeInterval:1.0 target:weakSelf selector:@selector(noNetWorkStartTesting) userInfo:nil repeats:YES];    [[NSRunLoop currentRunLoop] addTimer:weakSelf.netWorkTestingTimer forMode:NSDefaultRunLoopMode];  });}//定時(shí)檢測(cè)網(wǎng)絡(luò)- (void)noNetWorkStartTesting{  //有網(wǎng)絡(luò)  if(AFNetworkReachabilityManager.sharedManager.networkReachabilityStatus != AFNetworkReachabilityStatusNotReachable)  {    //關(guān)閉網(wǎng)絡(luò)檢測(cè)定時(shí)器    [self destoryNetWorkStartTesting];    //開(kāi)始重連    [self reConnectServer];  }}//取消網(wǎng)絡(luò)檢測(cè)- (void)destoryNetWorkStartTesting{  WS(weakSelf);  dispatch_main_async_safe(^{    if(weakSelf.netWorkTestingTimer)    {      [weakSelf.netWorkTestingTimer invalidate];      weakSelf.netWorkTestingTimer = nil;    }  });}//取消心跳- (void)destoryHeartBeat{  WS(weakSelf);  dispatch_main_async_safe(^{    if(weakSelf.heartBeatTimer)    {      [weakSelf.heartBeatTimer invalidate];      weakSelf.heartBeatTimer = nil;    }  });}//關(guān)閉長(zhǎng)連接- (void)RMWebSocketClose{  self.isActivelyClose = YES;  self.isConnect = NO;  self.connectType = WebSocketDefault;  if(self.webSocket)  {    [self.webSocket close];    _webSocket = nil;  }    //關(guān)閉心跳定時(shí)器  [self destoryHeartBeat];    //關(guān)閉網(wǎng)絡(luò)檢測(cè)定時(shí)器  [self destoryNetWorkStartTesting];}//發(fā)送數(shù)據(jù)給服務(wù)器- (void)sendDataToServer:(NSString *)data{  [self.sendDataArray addObject:data];    //[_webSocket sendString:data error:NULL];    //沒(méi)有網(wǎng)絡(luò)  if (AFNetworkReachabilityManager.sharedManager.networkReachabilityStatus == AFNetworkReachabilityStatusNotReachable)  {    //開(kāi)啟網(wǎng)絡(luò)檢測(cè)定時(shí)器    [self noNetWorkStartTestingTimer];  }  else //有網(wǎng)絡(luò)  {    if(self.webSocket != nil)    {      // 只有長(zhǎng)連接OPEN開(kāi)啟狀態(tài)才能調(diào) send 方法，不然會(huì)Crash      if(self.webSocket.readyState == RM_OPEN)      {//        if (self.sendDataArray.count > 0)//        {//          NSString *data = self.sendDataArray[0];          [_webSocket sendString:data error:NULL]; //發(fā)送數(shù)據(jù)//          [self.sendDataArray removeObjectAtIndex:0];////        }      }      else if (self.webSocket.readyState == RM_CONNECTING) //正在連接      {        DLog(@"正在連接中，重連后會(huì)去自動(dòng)同步數(shù)據(jù)");      }      else if (self.webSocket.readyState == RM_CLOSING || self.webSocket.readyState == RM_CLOSED) //斷開(kāi)連接      {        //調(diào)用 reConnectServer 方法重連,連接成功后 繼續(xù)發(fā)送數(shù)據(jù)        [self reConnectServer];      }    }    else    {      [self connectServer]; //連接服務(wù)器    }  }}@end</rmwebsocketdelegate>

- (void)applicationDidBecomeActive:(UIApplication *)application {  // Restart any tasks that were paused (or not yet started) while the application was inactive. If the application was previously in the background, optionally refresh the user interface.  if ([WebSocketManager shared].connectType == WebSocketDisconnect) {    [[WebSocketManager shared] connectServer];      }}