iOS開發--淺談CocoaAsyncSocket編程


Socket就是一種特殊的文件。它是一個連接了兩個用戶的文件,任何一個用戶向Socket里寫數據,另一個用戶都能看得到,不管這兩個用戶分布在世界上相距多么遙遠的角落,感覺就像坐在一起傳紙條一樣。

這么講Socket應該更容易理解吧?這種抽象是非常重要的,因為它屏蔽了更底層的東西,我就想寫個程序發送下數據,為什么要關系物理層怎么傳輸呢,對吧。

所以有了Socket的概念之后,我們在兩個客戶端之間發送消息可能就是這樣的:

指定對方的地址

打開一個和對方連接的Socket

把Socket當成普通的文件,往里寫數據

要是發現Socket里有數據,就讀出來,那必然是對方發過來的

這樣的話,網絡編程是不是就非常簡單了呢?

那么我們就開始吧

首先呢, 大家先搭配環境,CocoaAsyncSocket是一個三方類庫 ,大家需要去guthub上下載或者終端直接安裝這里就不過多介紹了。

搭配好框架后我們需要引入 CFNetwork.framework 框架 , 它是xcode本省的框架直接引用就行。

好啦環境搭配好了 讓我們封裝一個類來操作socket

1. socket 連接

即時通訊最大的特點就是實時性,基本感覺不到延時或是掉線,所以必須對socket的連接進行監視與檢測,在斷線時進行重新連接,如果用戶退出登錄,要將socket手動關閉,否則對服務器會造成一定的負荷。

一般來說,一個用戶(對於ios來說也就是我們的項目中)只能有一個正在連接的socket,所以這個socket變量必須是全局的,這里可以考慮使用單例或是AppDelegate進行數據共享,本文使用單例。如果對一個已經連接的socket對象再次進行連接操作,會拋出異常(不可對已經連接的socket進行連接)程序崩潰,所以在連接socket之前要對socket對象的連接狀態進行判斷

使用socket進行即時通訊還有一個必須的操作,即對服務器發送心跳包,每隔一段時間對服務器發送長連接指令(指令不唯一,由服務器端指定,包括使用socket發送消息,發送的數據和格式都是由服務器指定),如果沒有收到服務器的返回消息,AsyncSocket會得到失去連接的消息,我們可以在失去連接的回調方法里進行重新連接。

先創建一個單例,命名為Singleton

Singleton.h

// Singleton.h

#import "AsyncSocket.h"

#define DEFINE_SHARED_INSTANCE_USING_BLOCK(block) \

static dispatch_once_t onceToken = 0; \

__strong static id sharedInstance = nil; \

dispatch_once(&onceToken, ^{ \

sharedInstance = block(); \

}); \

return sharedInstance; \

@interface Singleton : NSObject

創建單例方法

+ (Singleton *)sharedInstance;

@end

Singleton.m

+(Singleton *) sharedInstance{

static Singleton *sharedInstace = nil;

static dispatch_once_t onceToken;

dispatch_once(&onceToken, ^{

sharedInstace = [[self alloc] init];

});

return sharedInstace;

}

下面是連接,心跳,失去連接后重連連接(長連接)在.h文件中聲明方法,並聲明代理

<AsyncSocketDelegate>

-(void)socketConnectHost;// socket連接

在.m中實現,連接時host與port都是由服務器指定,如果不是自己寫的服務器,請與服務器端開發人員交流

// socket連接

-(void)socketConnectHost{

self.socket    = [[AsyncSocket alloc] initWithDelegate:self];

NSError *error = nil;

[self.socket connectToHost:self.socketHost onPort:self.socketPort withTimeout:3 error:&error];

}

心跳

心跳通過計時器來實現

在singleton.h中聲明一個定時器

@property (nonatomic, retain) NSTimer        *connectTimer; // 計時器

在.m中實現連接成功回調方法,並在此方法中初始化定時器,發送心跳在后文向服務器發送數據時說明

#pragma mark  - 連接成功回調

-(void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString  *)host port:(UInt16)port

{

NSLog(@"socket連接成功");

// 每隔30s像服務器發送心跳包

self.connectTimer = [NSTimer scheduledTimerWithTimeInterval:30 target:self selector:@selector(longConnectToSocket) userInfo:nil repeats:YES];// 在longConnectToSocket方法中進行長連接需要向服務器發送的訊息

[self.connectTimer fire];

}

2. socket 斷開連接與重連

斷開連接

失去連接有幾種情況,服務器斷開,用戶主動cut,還可能有如QQ其他設備登錄被掉線的情況,不管那種情況,我們都能收到socket回調方法返回給我們的訊息,如果是用戶退出登錄或是程序退出而需要手動cut,我們在cut前對socket的userData賦予一個值來標記為用戶退出,這樣我們可以在收到斷開信息時判斷究竟是什么原因導致的掉線

在.h文件中聲明一個枚舉類型

enum{

SocketOfflineByServer,// 服務器掉線,默認為0

SocketOfflineByUser,  // 用戶主動cut

};

聲明斷開連接方法

-(void)cutOffSocket; // 斷開socket連接

.m

// 切斷socket

-(void)cutOffSocket{

self.socket.userData = SocketOfflineByUser;// 聲明是由用戶主動切斷

[self.connectTimer invalidate];

[self.socket disconnect];

}

重連

實現代理方法

-(void)onSocketDidDisconnect:(AsyncSocket *)sock{

NSLog(@"sorry the connect is failure %ld",sock.userData);

if (sock.userData == SocketOfflineByServer) {

// 服務器掉線,重連

[self socketConnectHost];

}else if (sock.userData == SocketOfflineByUser) {

// 如果由用戶斷開,不進行重連

return;

}

}

 

 

3. socket 發送與接收數據

發送數據

我們補充上文心跳連接未完成的方法

// 心跳連接

-(void)longConnectToSocket{

// 根據服務器要求發送固定格式的數據,假設為指令@"longConnect",但是一般不會是這么簡單的指令

NSString *longConnect = @"longConnect";

NSData  *dataStream  = [longConnect dataUsingEncoding:NSUTF8StringEncoding];

[self.socket writeData:dataStream withTimeout:1 tag:1];

}

socket發送數據是以棧的形式存放,所有數據放在一個棧中,存取時會出現粘包的現象,所以很多時候服務器在收發數據時是以先發送內容字節長度,再發送內容的形式,得到數據時也是先得到一個長度,再根據這個長度在棧中讀取這個長度的字節流,如果是這種情況,發送數據時只需在發送內容前發送一個長度,發送方法與發送內容一樣,假設長度為8

NSData  *dataStream  = [@8 dataUsingEncoding:NSUTF8StringEncoding];

[self.socket writeData:dataStream withTimeout:1 tag:1];

接收數據

為了能時刻接收到socket的消息,我們在長連接方法中進行讀取數據

[self.socket readDataWithTimeout:30 tag:0];

如果得到數據,會調用回調方法

-(void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag

{

// 對得到的data值進行解析與轉換即可

[self.socket readDataWithTimeout:30 tag:0];

}

4. 簡單使用說明

我們在用戶登錄后的第一個界面進行socket的初始化連接操作,在得到數據后,將所需要顯示的數據放在singleton中,對變量進行監聽后做出相應的操作即可,延伸起來比較復雜,

[Singleton sharedInstance].socketHost = @"192.186.100.21";// host設定

[Singleton sharedInstance].socketPort = 10045;// port設定

// 在連接前先進行手動斷開

[Singleton sharedInstance].socket.userData = SocketOfflineByUser;

[[Singleton sharedInstance] cutOffSocket];

// 確保斷開后再連,如果對一個正處於連接狀態的socket進行連接,會出現崩潰

[Singleton sharedInstance].socket.userData = SocketOfflineByServer;

[[Singleton sharedInstance] socketConnectHost];

好了以后再給大家分享吧



文/張洪國(簡書作者)
原文鏈接:http://www.jianshu.com/p/a678a59830e5
著作權歸作者所有,轉載請聯系作者獲得授權,並標注“簡書作者”。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM