php實現socket簡單的例子
一、Socket簡介
1、socket只不過是一種數據結構
2、使用這個socket數據結構去開始一個客戶端和服務器之間的會話
3、服務器是一直在監聽準備產生一個新的會話。當一個客戶端連接服務端,它就打開服務器正在進行監聽的一個端口進行會話
4、服務器端接受客戶端的鏈接請求,那麽就進行一次循環。現在這個客戶端就能夠發送信息到服務器,服務器也能發送信息給客戶端。【重點】
雖然如此,遊戲服務端依舊不用php,而是用lua或c++,因為php有瓶頸,且很快到達瓶頸。
二、Socket變量
產生一個socket,你需要三個變量:一個是協議,一個socket類型和一個公共協議類型。
1、協議
AF_INET//產生socket的協議,使用TCP或UDP來傳輸,使用IPV4的地址
AF_INET6//產生socket的協議,使用TCP或UDP來傳輸,用在IPV6的地址
AF_UNIX//本地協議,使用在unix和linux系統上,它很少使用,一般都是當客戶端和服務器在同一臺機器上的時候使用
2、Socket類型
SOCK_STREAM//這個協議是按照順序的、可靠的、數據完整的基於字節流的鏈接。這是一個使用最多的socket類型,這個socket是使用TCP來進行傳輸。
SOCK_DGRAM//這個協議是無連接的、固定長度的傳輸調用。該協議是不可靠的,使用UDP來進行它的鏈接。
SOCK_SEQPACKET//這個協議是雙線路的、可靠的鏈接,發送固定長度的數據包進行傳輸。必須把這個包完整的接受才能進行讀取。
SOCK_RAW//這個socket類型提供單一的網絡訪問,這個socket類型使用ICMP協議。
SOCK_RDM//這個類型是很少使用的,在大部分的操作系統上沒有實現,它是提供數據鏈路層使用,不保證數據包順序。
3、公共協議
ICMP//互聯網控制消息協議,主要使用在網關和主機上,在檢查網絡狀態和報告錯誤信息
UDP//用戶數據報文協議,它是一個無連接,不可靠的傳輸協議
TCP//傳輸控制協議,這是一個使用最多的可靠的公共協議,他能保證數據包能夠到達接管者那兒,如果在傳輸過程中發生錯誤,那麽它將重新發送出錯數據包
三、Socket函數
1、socket_create
作用:產生一個socket,相當於產生一個socket的數據結構
用法:socket_create(int domain,int type,int protocol)
參數:domai--協議,type--類型,protoco--公共協議
返回:sockets resource on success or false on error
2、socket_bind
作用:把socket綁定在一個IP地址和端口上
用法:socket_bind(resource socket,string address [,int port])
參數:socket--socket resource,address--ip地址,port--端口
返回:boolean
3、socket_accept
作用:接受一個socket連接
用法:socket_accept(resource socket)
參數:socket--socket resource
返回:return a new socket resource on success or false on error
4、socket_connect
作用:開始一個socket連接
用法:socket_connect(resource socket,string address [,int port])
參數:socket--socket resource,address--ip地址,port--端口
返回:boolean
5、socket_listen
作用:監聽由指定socket的所有連接
用法:socket_listen(resource socket [,int backlog])
參數:socket--socket resource
返回:boolean
6、socket_read
作用:讀取指定長度的數據
用法:socket_read(resource socket,int length [,int type])
參數:socket--socket resource,length--字符長度,type--PHP_BINARY_READ|PHP_NORMAL_READ
返回:string
7、socket_write
作用:寫數據到socket
用法:socket_write(resource socket,string buffer [,int length])
參數:socket--socket resource,buffer--字符,length--字符長度
返回:boolean
8、socket_send
作用:這個函數發送數據到已連接的socket
用法:socket_send(resource socket,string buffer,int length,int flags)
參數:socket--socket resource,buffer--字符,length--字符長度
返回:boolean
9、socket_last_error
作用:獲取當前socket的最後錯誤代碼
用法:socket_last_error([resource socket])
參數:socket--socket resource
返回:int
10、socket_strerror
作用:返回指定錯誤號的詳細錯誤
用法:socket_strerror(int errno)
參數:errno--socket_last_error
返回:string
11、socket_close
作用:關閉一個socket資源
用法:socket_close([resource socket])
參數:socket--socket resource
返回:null
四、php開啟
確認打開socket方法
編輯php.ini文件,去掉extension=php_sockets.dll前面的註釋
或
<?php header("Content-type:text/html;charset=utf-8"); if(!extension_loaded(‘sockets‘)){ if(strtoupper(substr(PHP_OS,0,3)) == ‘WIN‘){ dl(‘php_sockets.dll‘); printf(‘php_sockets.dll‘); }else{ dl(‘sockets.so‘); printf(‘sockets.so‘); } }else{ printf(‘通過編輯php.ini打開‘); }
五、服務端開啟【以下是一個簡單的例子,真實與服務器交互情況比此復雜一些】
功能:
A、初始化一個socket並且打開一個緩存收發數據
B、等待連接,一旦產生一個連接,它將打印”Socket connected”在服務器端的屏幕上
C、服務器檢查緩存區,如果緩存區裏有數據,它將把數據發送到連接過來的計算機。
D、連接關閉後,服務器又開始處理下一次連接
<?php //獲取協議 $commonProtocol = getprotobyname(‘tcp‘); //產生一個socket $socket = socket_create(AF_INET, SOCK_STREAM, $commonProtocol); //把socket綁定在一個IP地址和端口上 socket_bind($socket, ‘localhost‘,1337); //監聽由指定socket的所有連接 socket_listen($socket); //初始化buffer $buffer = "NO DATA"; while(true){ //接受一個socket連接 $connection = socket_accept($socket); printf("Socket connected\r\n"); //檢測buffer if($buffer != ""){ printf("Something is in the buffer...sending data...\r\n"); //寫數據到socket緩存 socket_write($connection, $buffer."\r\n"); printf("Wrote to socket\r\n"); }else{ printf("No Data in the buffer\r\n"); } //讀取指定長度的數據 while($data = socket_read($connection, 1024,PHP_NORMAL_READ)){ $buffer = $data; //寫數據到socket緩存 socket_write($connection, $buffer."\r\n"); printf("Buffer: " . $buffer . "\r\n"); } //關閉一個socket資源 socket_close($connection); printf("Closed the socket\r\n\r\n"); }
六、客戶端交互
功能:
A、客戶端連接到服務器,客戶端讀取數據
<?php //創建socket $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //連接socket $connection = socket_connect($socket, ‘localhost‘,1337); //讀取指定長度的數據 while($buffer = socket_read($socket, 1024,PHP_BINARY_READ)){ if($buffer == "NO DATA"){ printf("NO DATA"); break; }else{ //輸出buffer printf("Buffer Data: " . $buffer . ""); } } printf("Writing to Socket"); //寫數據到socket緩存 if(!socket_write($socket, "SOME DATA\r\n")){ printf("Write failed"); } //讀取指定長度的數據 while($buffer = socket_read($socket, 1024,PHP_NORMAL_READ)){ printf("Data sent was: SOME DATA Response was:" . $buffer . ""); } printf("Done Reading from Socket");
php實現socket簡單的例子