這篇文章主要介紹了PHP SOCKET編程詳解,需要的朋友可以參考下
1. 預備知識
一直以來很少看到有多少人使用php的socket模塊來做一些事情，大概大家都把它定位在腳本語言的范疇內吧，但是其實php的socket模塊可以做很多事情，包括做ftplist,http post提交，smtp提交，組包並進行特殊報文的交互(如smpp協議)，whois查詢。這些都是比較常見的查詢。
特別是php的socket擴展庫可以做的事情簡直不會比c差多少。
php的socket連接函數
1、集成於內核的socket
這個系列的函數僅僅只能做主動連接無法實現端口監聽相關的功能。而且在4.3.0之前所有socket連接只能工作在阻塞模式下。
此系列函數包括
fsockopen，pfsockopen
這兩個函數的具體信息可以查詢php.net的用戶手冊
他們均會返回一個資源編號對於這個資源可以使用幾乎所有對文件操作的函數對其進行操作如fgets(),fwrite(), fclose()等單注意的是所有函數遵循這些函數面對網絡信息流時的規律，例如：
fread() 從文件指針 handle 讀取最多 length 個字節。 該函數在讀取完 length 個字節數，或到達 EOF 的時候，或(對於網絡流)當一個包可用時就會停止讀取文件，視乎先碰到哪種情況。
可以看出對於網絡流就必須注意取到的是一個完整的包就停止。
2、php擴展模塊帶有的socket功能。
php4.x 以後有這麼一個模塊extension=php_sockets.dll，Linux上是一個extension=php_sockets.so。
當打開這個此模塊以後就意味著php擁有了強大的socket功能，包括listen端口，阻塞及非阻塞模式的切換，multi-client 交互式處理等
這個系列的函數列表參看http://www.php.net/manual/en/ref.sockets.php
看過這個列表覺得是不是非常豐富呢?不過非常遺憾這個模塊還非常年輕還有很多地方不成熟，相關的參考文檔也非常少：(
我也正在研究中，因此暫時不具體討論它，僅給大家一個參考文章
http://www.zend.com/pecl/tutorials/sockets.php
2. 使用PHP socket擴展
服務器端代碼：
?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 <?php /** * File name server.php * 服務器端代碼 * * @author guisu.huang * @since 2012-04-11 * */ //確保在連接客戶端時不會超時 set_time_limit(0); //設置IP和端口號 $address = "127.0.0.1"; $port = 2046; //調試的時候，可以多換端口來測試程序！ /** * 創建一個SOCKET * AF_INET=是ipv4 如果用ipv6，則參數為 AF_INET6 * SOCK_STREAM為socket的tcp類型，如果是UDP則使用SOCK_DGRAM */ $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n"); //阻塞模式 socket_set_block($sock) or die("socket_set_block() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n"); //綁定到socket端口 $result = socket_bind($sock, $address, $port) or die("socket_bind() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n"); //開始監聽 $result = socket_listen($sock, 4) or die("socket_listen() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n"); echo "OKnBinding the socket on $address:$port ... "; echo "OKnNow ready to accept connections.nListening on the socket ... n"; do { // never stop the daemon //它接收連接請求並調用一個子連接Socket來處理客戶端和服務器間的信息 $msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n"); //讀取客戶端數據 echo "Read client data n"; //socket_read函數會一直讀取客戶端數據,直到遇見n,t或者 字符.PHP腳本把這寫字符看做是輸入的結束符. $buf = socket_read($msgsock, 8192); echo "Received msg: $buf n"; //數據傳送 向客戶端寫入返回結果 $msg = "welcome n"; socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n"); //一旦輸出被返回到客戶端,父/子socket都應通過socket_close($msgsock)函數來終止 socket_close($msgsock); } while (true); socket_close($sock);客戶端代碼：
?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 <?php /** * File name:client.php * 客戶端代碼 * * @author guisu.huang * @since 2012-04-11 */ set_time_limit(0); $host = "127.0.0.1"; $port = 2046; $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create socketn"); // 創建一個Socket $connection = socket_connect($socket, $host, $port) or die("Could not connet servern"); // 連接 socket_write($socket, "hello socket") or die("Write failedn"); // 數據傳送 向服務器發送消息 while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) { echo("Response was:" . $buff . "n"); } socket_close($socket);使用cli方式啟動server：
php server.php
這裡注意socket_read函數：
可選的類型參數是一個命名的常數：
PHP_BINARY_READ - 使用系統recv()函數。用於讀取二進制數據的安全。 (在PHP>“默認= 4.1.0)
PHP_NORMAL_READ - 讀停在 n或r(在PHP <= 4.0.6默認)
針對參數PHP_NORMAL_READ ，如果服務器的響應結果沒有 n。造成socket_read(): unable to read from socket
3. PHP socket內部源碼
從PHP內部源碼來看，PHP提供的socket編程是在socket，bind,listen等函數外添加了一個層，讓其更加簡單和方便調用。但是一些業務邏輯的程序還是需要程序員自己去實現。
下面我們以socket_create的源碼實現來說明PHP的內部實現。
前面我們有說到php的socket是以擴展的方式實現的。在源碼的ext目錄，我們找到sockets目錄。這個目錄存放了PHP對於socket的實現。直接搜索PHP_FUNCTION(socket_create)，在sockets.c文件中找到了此函數的實現。如下所示代碼：
?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 /* {{{ proto resource socket_create(int domain, int type, int protocol) U Creates an endpoint for communication in the domain specified by domain, of type specified by type */ PHP_FUNCTION(socket_create) { long arg1, arg2, arg3; php_socket *php_sock = (php_socket*)emalloc(sizeof(php_socket)); if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "lll", &arg1, &arg2, &arg3) == FAILURE) { efree(php_sock); return; } if (arg1 != AF_UNIX #if HAVE_IPV6 && arg1 != AF_INET6 #endif && arg1 != AF_INET) { php_error_docref(NULL TSRMLS_CC, E_WARNING, "invalid socket domain [%ld] specified for argument 1, assuming AF_INET", arg1); arg1 = AF_INET; } if (arg2 > 10) { php_error_docref(NULL TSRMLS_CC, E_WARNING, "invalid socket type [%ld] specified for argument 2, assuming SOCK_STREAM", arg2); arg2 = SOCK_STREAM; } php_sock->bsd_socket = socket(arg1, arg2, arg3); php_sock->type = arg1; if (IS_INVALID_SOCKET(php_sock)) { SOCKETS_G(last_error) = errno; php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to create socket [%d]: %s", errno, php_strerror(errno TSRMLS_CC)); efree(php_sock); RETURN_FALSE; } php_sock->error = 0; php_sock->blocking = 1; 1257,1-8 61% ZEND_REGISTER_RESOURCE(return_value, php_sock, le_socket); }Zend API實際對c函數socket做了包裝，供PHP使用。 而在c的socket編程中，我們使用如下方式初始化socket。
?
1 2 3 4 5 //初始化Socket if( (socket_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){ printf("create socket error: %s(errno: %d)n",strerror(errno),errno); exit(0); }4. socket函數
函數名 描述
socket_accept() 接受一個Socket連接
socket_bind() 把socket綁定在一個IP地址和端口上
socket_clear_error() 清除socket的錯誤或最後的錯誤代碼
socket_close() 關閉一個socket資源
socket_connect() 開始一個socket連接
socket_create_listen() 在指定端口打開一個socket監聽
socket_create_pair() 產生一對沒有差別的socket到一個數組裡
socket_create() 產生一個socket，相當於產生一個socket的數據結構
socket_get_option() 獲取socket選項
socket_getpeername() 獲取遠程類似主機的ip地址
socket_getsockname() 獲取本地socket的ip地址
socket_iovec_add() 添加一個新的向量到一個分散/聚合的數組
socket_iovec_alloc() 這個函數創建一個能夠發送接收讀寫的iovec數據結構
socket_iovec_delete() 刪除一個已分配的iovec
socket_iovec_fetch() 返回指定的iovec資源的數據
socket_iovec_free() 釋放一個iovec資源
socket_iovec_set() 設置iovec的數據新值
socket_last_error() 獲取當前socket的最後錯誤代碼
socket_listen() 監聽由指定socket的所有連接
socket_read() 讀取指定長度的數據
socket_readv() 讀取從分散/聚合數組過來的數據
socket_recv() 從socket裡結束數據到緩存
socket_recvfrom() 接受數據從指定的socket，如果沒有指定則默認當前socket
socket_recvmsg() 從iovec裡接受消息
socket_select() 多路選擇
socket_send() 這個函數發送數據到已連接的socket
socket_sendmsg() 發送消息到socket
socket_sendto() 發送消息到指定地址的socket
socket_set_block() 在socket裡設置為塊模式
socket_set_nonblock() socket裡設置為非塊模式
socket_set_option() 設置socket選項
socket_shutdown() 這個函數允許你關閉讀、寫、或指定的socket
socket_strerror() 返回指定錯誤號的周詳錯誤
socket_write() 寫數據到socket緩存
socket_writev() 寫數據到分散/聚合數組
5. PHP Socket模擬請求
我們使用stream_socket來模擬：
?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 /** * * @param $data= array=array('key'=>value) */ function post_contents($data = array()) { $post = $data ? http_build_query($data) : ''; $header = "POST /test/ HTTP/1.1" . "n"; $header .= "User-Agent: Mozilla/4.0+(compatible;+MSIE+6.0;+Windows+NT+5.1;+SV1)" . "n"; $header .= "Host: localhost" . "n"; $header .= "Accept: */*" . "n"; $header .= "Referer: http://localhost/test/" . "n"; $header .= "Content-Length: ". strlen($post) . "n"; $header .= "Content-Type: application/x-www-form-urlencoded" . "n"; $header .= "rn"; $ddd = $header . $post; $fp = stream_socket_client("tcp://localhost:80", $errno, $errstr, 30); $response = ''; if (!$fp) { echo "$errstr ($errno)<br />n"; } else { fwrite($fp, $ddd); $i = 1; while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; //處理這一行 } } fclose($fp); return $response; }注意，以上程序可能會進入死循環;
這個PHP的feof($fp) 需要注意的地方了，我們來分析為什麼進入死循環。
?
1 2 3 4 while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; }實際上，feof是可靠的，但是結合fgets函數一塊使用的時候，必須要小心了。一個常見的做法是：
?
1 2 3 4 5 $fp = fopen("myfile.txt", "r"); while (!feof($fp)) { $current_line = fgets($fp); //對結果做進一步處理,防止進入死循環 }當處理純文本的時候，fgets獲取最後一行字符後，foef函數返回的結果並不是TRUE。實際的運算過程如下：
1) while()繼續循環。
2) fgets 獲取倒數第二行的字符串
3) feof返回false，進入下一次循環
4)fgets獲取最後一行數據
5) 一旦fegets函數被調用，feof函數仍然返回的是false。所以繼續執行循環
6) fget試圖獲取另外一行，但實際結果是空的。實際代碼沒有意識到這一點，試圖處理另外根本不存在的一行，但fgets被調用了，feof放回的結果仍然是false
7) .....
8) 進入死循環
