1.**CocoaAsyncSocket介紹 **

CocoaAsyncSocket 是適用于 Mac 和 iOS 的異步套接字網(wǎng)絡(luò)庫川队，支持 tcp 和 udp。其中：
AsyncSocket 類是支持TCP的
AsyncUdpSocket 是支持UDP的

2.**本地集成CocoaAsyncSocket **

下載通道

3.pod集成

  pod 'CocoaAsyncSocket'

4.代碼

HGFCTCPSocketServe.h

#import <Foundation/Foundation.h>
#import <GCDAsyncSocket.h>



@interface HGFCTCPSocketServe : NSObject <GCDAsyncSocketDelegate>
{
    GCDAsyncSocket *_asyncSocket;
    int reConnectCount;
    
    dispatch_source_t _connectTimer;
    dispatch_queue_t _connectQueue;
    BOOL connectInterrupt;
    
}

+ (instancetype)sharedInstance;

@property(nonatomic,copy) NSString * connectStatusStr;    //打印連接狀態(tài)




/** 是否連接 */
- (BOOL)isFCDisConnect;

@property (nonatomic, assign) BOOL isFCConnect;

- (void)writeToFCTCPWithData:(NSData *)data;
/**
 * 開啟HGFCTCPSocketServe
 */
-(void)start;
/**
 * 關(guān)閉HGFCTCPSocketServe
 */
-(void)stop;

- (void)disconnect;

@end

HGFCTCPSocketServe.m

#import <UIKit/UIKit.h>
#import "HGFCTCPSocketServe.h"

#define kTcpFCPort  5000
#define kTCPIP @"192.168.1.1"
@interface HGFCTCPSocketServe ()
@end

@implementation HGFCTCPSocketServe
static HGFCTCPSocketServe *hgFcTcpsocket = nil;
static dispatch_once_t onceToken;
+ (instancetype)sharedInstance {
    dispatch_once(&onceToken, ^{
        hgFcTcpsocket = [[self alloc] init];
    });
    return hgFcTcpsocket;
}//初始化
- (instancetype)init
{
    if (self = [super init]) {
        _asyncSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
        hgFCConnectTool=[HGFCConnectTool sharedInstance];
        
  
    }
    return self;
}
/**
 * 開啟HGFCTCPSocketServe
 */
-(void)start{
    reConnectCount=0;
    [self connectWithHost:kTCPIP port:kTcpFCPort];
    
}
/**
 * 關(guān)閉HGFCTCPSocketServe
 */
-(void)stop{

    if(_connectTimer!=nil)
    {
        dispatch_source_cancel(_connectTimer);
        _connectTimer = nil;
    }
    [self disconnect];
    
}

//連接socket 地址 端口號(hào)
- (void)connectWithHost:(NSString *)hostName port:(int)port
{
    NSError *error = nil;
    if ([self isFCDisConnect])
    {
        [_asyncSocket connectToHost:hostName onPort:port withTimeout:4.0 error:&error];
        NSLog(@"%@",[NSString stringWithFormat:@"開始連接:%d",port]);
    }
    if (error) {
         NSLog(@"%@",[NSString stringWithFormat:@"5000連接錯(cuò)誤:%@",error]);
   
            [self reConnect];
     
    }
}
//斷開連接
- (void)disconnect
{
    [_asyncSocket disconnect];
}

//是否連接
- (BOOL)isFCDisConnect
{
    return [_asyncSocket isDisconnected];
}

//讀
- (void)readDataWithTimeout:(NSTimeInterval)timeout tag:(long)tag
{
    [_asyncSocket readDataWithTimeout:-1 tag:tag];
}

//寫
- (void)writeToFCTCPWithData:(NSData *)data;
{
 
    [_asyncSocket writeData:data withTimeout:-1 tag:kTcpFCPort];
    
}

#pragma mark GCDAsyncSocketDelegate method
//斷開連接代理
- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err
{
    NSLog(@"5000 斷開");


     reConnectCount++;
       [self reConnect];
   
}
//連接成功代理
- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port {

    NSLog(@"5000 端口連接成功");

    if(_connectTimer!=nil)
    {
        dispatch_source_cancel(_connectTimer);
        _connectTimer = nil;
    }
    
    
    [sock readDataWithTimeout:-1 tag:kTcpFCPort];
}

//讀數(shù)據(jù)成功代理
- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag {

    
    [sock readDataWithTimeout:-1 tag:tag];
}
///發(fā)送消息成功之后回調(diào)
- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag {
    
    [sock readDataWithTimeout:-1 tag:kTcpFCPort];
}

//斷開重連方法
-(void)fcConnectTimerStart{
   
    @autoreleasepool {
        dispatch_async(dispatch_get_main_queue(), ^{
            NSLog(@"5000 重新連接");
            [self connectWithHost:kTCPIP port:kTcpFCPort];
        });
    }
}


//重連線程
-(void)reConnect{
    if(_connectTimer!=nil)
    {
        dispatch_source_cancel(_connectTimer);
        _connectTimer = nil;
    }
    if(reConnectCount>6){
        reConnectCount=6;
    }
    
    _connectQueue = dispatch_queue_create("_reConnectFCQueue", NULL);
    _connectTimer= dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, _connectQueue);
    //開始時(shí)間
    dispatch_time_t start = dispatch_time(DISPATCH_TIME_NOW, 3.0 * NSEC_PER_SEC);
    //間隔時(shí)間
    uint64_t interval = NSEC_PER_SEC * reConnectCount;
    dispatch_source_set_timer(_connectTimer, start, interval, 0);
    //設(shè)置回調(diào)
    __weak __typeof__(self) weakSelf = self;
    dispatch_source_set_event_handler(_connectTimer, ^{
        [weakSelf fcConnectTimerStart];
    });
    //啟動(dòng)timer
    dispatch_resume(_connectTimer);
}

-(void)Dealloc
{
    [_asyncSocket disconnect];
    _asyncSocket.delegate=nil;
    _asyncSocket=nil;
    [[NSNotificationCenter defaultCenter] removeObserver:self];
    NSLog(@"Dealloc  hgfctcpsocket");
    hgFcTcpsocket=nil;
    onceToken=0;
}