关于使用GCDAsyncSocket
GCDAsyncSocket是什么？
GCDAsyncSocket是一个封装了<sys/socket.h>的第三方库。
而我们平时说的最多的socket是什么呢，实际上socket是对TCP/IP协议的封装，Socket本身并不是协议，而是一个调用接口（API），通过Socket，我们能使用TCP/IP协议。实际上，Socket跟TCP/IP协议没有必然的联系。Socket编程接口在设计的时候，就希望也能适应其他的网络协议。所以说，Socket的出现只是使得程序员更方便地使用TCP/IP协议栈而已，是对TCP/IP协议的抽象，从而形成了我们知道的一些最基本的函数接口，比如create、listen、connect、accept、send、read和write等等。
GCDAsyncSocket的作用？
建立Socket连接至少需要一对套接字，其中一个运行于客户端，称为ClientSocket ，另一个运行于服务器端，称为ServerSocket 。
套接字之间的连接过程分为三个步骤：服务器监听，客户端请求，连接确认。
1。服务器监听：服务器端套接字并不定位具体的客户端套接字，而是处于等待连接的状态，实时监控网络状态，等待客户端的连接请求。
2。客户端请求：指客户端的套接字提出连接请求，要连接的目标是服务器端的套接字。为此，客户端的套接字必须首先描述它要连接的服务器的套接字，指出服务器端套接字的地址和端口号，然后就向服务器端套接字提出连接请求。
3。连接确认：当服务器端套接字监听到或者说接收到客户端套接字的连接请求时，就响应客户端套接字的请求，建立一个新的线程，把服务器端套接字的描述发给客户端，一旦客户端确认了此描述，双方就正式建立连接。而服务器端套接字继续处于监听状态，继续接收其他客户端套接字的连接请求。
GCDAsyncSocket的使用？
客户端(client)
连接服务器
clientSocket = GCDAsyncSocket()
clientSocket.delegate = self
clientSocket.delegateQueue = DispatchQueue.global()
do {
try clientSocket.connect(toHost: inputIPTF.text!, onPort: 8080)
} catch {
print("error")
}
连接服务器成功后的回调
func socket(_ sock: GCDAsyncSocket, didConnectToHost host: String, port: UInt16) {
//链接成功
print("链接成功->端口:" + host + " port:" + String(port))
clientSocket.readData(withTimeout: -1, tag: 0)
}
服务端发来信息时触发回调
func socket(_ sock: GCDAsyncSocket, didRead data: Data, withTag tag: Int) {
//获取客户端发来的数据
let readClientDataString: NSString? = NSString.init(data: data, encoding: String.Encoding.utf8.rawValue)
print(readClientDataString ?? "nil")
DispatchQueue.main.async {
guard let str = readClientDataString else{
self.msgLB.text = ""
return
}
self.msgLB.text = String(str)
}
self.sendMsgWithString(msg: "OK")
}
服务端(server)
链接服务端
@IBAction func connetnServer(_ sender: UIButton) {
if (inputPortTF.text?.isEmpty)! == false && inputIPTF.text?.isEmpty == false{
clientSocket = GCDAsyncSocket()
clientSocket.delegate = self
clientSocket.delegateQueue = DispatchQueue.global()
do {
try clientSocket.connect(toHost: inputIPTF.text!, onPort: 8080)
} catch {
print("error")
}
}else{
msgLB.text = "端口或IP不能为空"
}
}
有客户端的socket连接到服务器时的回调，把newSocket保存起来。
///MARK - Delegate
/*
* 有客户端的socket连接到服务器
*/
func socket(_ sock: GCDAsyncSocket, didAcceptNewSocket newSocket: GCDAsyncSocket) {
if clientSockets.contains(newSocket) {
print("已经存在！")
return
}else{
clientSockets.append(newSocket)
}
let serviceStr:NSMutableString = NSMutableString()
serviceStr.append("login successful\n")
newSocket.write(serviceStr.data(using: String.Encoding.utf8.rawValue)!, withTimeout: -1, tag: 0)
// 3.监听客户端有没有数据上传
//timeout -1 代表不超时
//tag 标识作用，现在不用，就写0
newSocket.readData(withTimeout: -1, tag:2)
}
连接服务器后的回调
func socket(_ sock: GCDAsyncSocket, didConnectToHost host: String, port: UInt16) {
//链接成功
print("链接成功->端口:" + host + " port:" + String(port))
clientSocket.readData(withTimeout: -1, tag: 0)
}
func socketDidDisconnect(_ sock: GCDAsyncSocket, withError err: Error?) {
//与服务器断开
print("断开服务器")
}
func socket(_ sock: GCDAsyncSocket, didRead data: Data, withTag tag: Int) {
//获取客户端发来的数据
let readClientDataString: NSString? = NSString.init(data: data, encoding: String.Encoding.utf8.rawValue)
print(readClientDataString ?? "nil")
DispatchQueue.main.async {
guard let str = readClientDataString else{
self.msgLB.text = ""
return
}
self.msgLB.text = String(str)
}
self.sendMsgWithString(msg: "OK")
}
可以下载一个叫网络助手的app来测试socket。
