一、Socket簡介
1、socket只不過是一種數據結構
2、使用這個socket數據結構去開始一個客戶端和服務器之間的會話
3、服務器是一直在監聽准備產生一個新的會話。當一個客戶端連接服務端,它就打開服務器正在進行監聽的一個端口進行會話
4、服務器端接受客戶端的鏈接請求,那么就進行一次循環。現在這個客戶端就能夠發送信息到服務器,服務器也能發送信息給客戶端。
二、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
四、使用說明
確認打開socket方法
A、編輯php.ini文件,去掉extension=php_sockets.dll前面的注釋
B、代碼來加載擴展庫
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打開');
}
五、socket編程
1、服務器端
功能:
A、初始化一個socket並且打開一個緩存收發數據
B、等待連接,一旦產生一個連接,它將打印”Socket connected”在服務器端的屏幕上
C、服務器檢查緩存區,如果緩存區里有數據,它將把數據發送到連接過來的計算機。
D、連接關閉后,服務器又開始處理下一次連接
// 獲取協議
$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");
}
2、客戶端
功能:
A、客戶端連接到服務器,客戶端讀取數據
B、如果這是第一時間到達這個循環的首次連接,這個服務器將發送”NO DATA”返回給客戶端。如果情況發生了,這個客戶端在連接之上
C、客戶端發送它的數據到服務器,如果發送給服務器,客戶端等待響應。一旦接受響應,那么它將響應寫到屏幕上
// 創建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");