PHP SOCKET編程詳解

2020-03-22 20:16:36

字體：大中小

供稿：網(wǎng)友

1. 預(yù)備知識一直以來很少看到有多少人使用php的socket模塊來做一些事情，大概大家都把它定位在腳本語言的范疇內(nèi)吧，但是其實php的socket模塊可以做很多事情，包括做ftplist,http post提交，smtp提交，組包并進(jìn)行特殊報文的交互（如smpp協(xié)議），whois查詢。這些都是比較常見的查詢。特別是php的socket擴(kuò)展庫可以做的事情簡直不會比c差多少。php的socket連接函數(shù)1、集成于內(nèi)核的socket這個系列的函數(shù)僅僅只能做主動連接無法實現(xiàn)端口監(jiān)聽相關(guān)的功能。而且在4.3.0之前所有socket連接只能工作在阻塞模式下。
此系列函數(shù)包括
fsockopen，pfsockopen
這兩個函數(shù)的具體信息可以查詢php.net的用戶手冊
他們均會返回一個資源編號對于這個資源可以使用幾乎所有對文件操作的函數(shù)對其進(jìn)行操作如fgets(),fwrite(), fclose()等單注意的是所有函數(shù)遵循這些函數(shù)面對網(wǎng)絡(luò)信息流時的規(guī)律，例如：
fread() 從文件指針 handle 讀取最多 length 個字節(jié)。該函數(shù)在讀取完 length 個字節(jié)數(shù)，或到達(dá) EOF 的時候，或（對于網(wǎng)絡(luò)流）當(dāng)一個包可用時就會停止讀取文件，視乎先碰到哪種情況。
可以看出對于網(wǎng)絡(luò)流就必須注意取到的是一個完整的包就停止。2、php擴(kuò)展模塊帶有的socket功能。php4.x 以后有這么一個模塊extension=php_sockets.dll，Linux上是一個extension=php_sockets.so。
當(dāng)打開這個此模塊以后就意味著php擁有了強(qiáng)大的socket功能，包括listen端口，阻塞及非阻塞模式的切換，multi-client 交互式處理等
這個系列的函數(shù)列表參看http://www.php.net/manual/en/ref.sockets.php
看過這個列表覺得是不是非常豐富呢？不過非常遺憾這個模塊還非常年輕還有很多地方不成熟，相關(guān)的參考文檔也非常少：（
我也正在研究中，因此暫時不具體討論它，僅給大家一個參考文章http://www.zend.com/pecl/tutorials/sockets.php2. 使用PHP socket擴(kuò)展服務(wù)器端代碼： php * File name server.php * 服務(wù)器端代碼 * @author guisu.huang * @since 2012-04-11 //確保在連接客戶端時不會超時 set_time_limit(0); //設(shè)置IP和端口號 $address = "127.0.0.1"; $port = 2046; //調(diào)試的時候，可以多換端口來測試程序！ * 創(chuàng)建一個SOCKET * AF_INET=是ipv4 如果用ipv6，則參數(shù)為 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"); //開始監(jiān)聽 $result = socket_listen($sock, 4) or die("socket_listen() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n"); echo "OK/nBinding the socket on $address:$port ... "; echo "OK/nNow ready to accept connections./nListening on the socket ... /n"; do { // never stop the daemon //它接收連接請求并調(diào)用一個子連接Socket來處理客戶端和服務(wù)器間的信息 $msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n"); //讀取客戶端數(shù)據(jù) echo "Read client data /n"; //socket_read函數(shù)會一直讀取客戶端數(shù)據(jù),直到遇見/n,/t或者/0字符.PHP腳本把這寫字符看做是輸入的結(jié)束符. $buf = socket_read($msgsock, 8192); echo "Received msg: $buf /n"; //數(shù)據(jù)傳送向客戶端寫入返回結(jié)果 $msg = "welcome /n"; socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n"); //一旦輸出被返回到客戶端,父/子socket都應(yīng)通過socket_close($msgsock)函數(shù)來終止 socket_close($msgsock); } while (true); socket_close($sock); 客戶端代碼： 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 socket/n"); // 創(chuàng)建一個Socket $connection = socket_connect($socket, $host, $port) or die("Could not connet server/n"); // 連接 socket_write($socket, "hello socket") or die("Write failed/n"); // 數(shù)據(jù)傳送向服務(wù)器發(fā)送消息 while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) { echo("Response was:" . $buff . "/n"); socket_close($socket); 使用cli方式啟動server：php server.php這里注意socket_read函數(shù)：
可選的類型參數(shù)是一個命名的常數(shù)：
PHP_BINARY_READ - 使用系統(tǒng)recv（）函數(shù)。用于讀取二進(jìn)制數(shù)據(jù)的安全。（在PHP “默認(rèn)= 4.1.0）
PHP_NORMAL_READ - 讀停在/ n或/r（在PHP = 4.0.6默認(rèn)）針對參數(shù)PHP_NORMAL_READ ，如果服務(wù)器的響應(yīng)結(jié)果沒有/ n。造成socket_read(): unable to read from socket3. PHP socket內(nèi)部源碼從PHP內(nèi)部源碼來看，PHP提供的socket編程是在socket，bind,listen等函數(shù)外添加了一個層，讓其更加簡單和方便調(diào)用。但是一些業(yè)務(wù)邏輯的程序還是需要程序員自己去實現(xiàn)。
下面我們以socket_create的源碼實現(xiàn)來說明PHP的內(nèi)部實現(xiàn)。
前面我們有說到php的socket是以擴(kuò)展的方式實現(xiàn)的。在源碼的ext目錄，我們找到sockets目錄。這個目錄存放了PHP對于socket的實現(xiàn)。直接搜索PHP_FUNCTION(socket_create)，在sockets.c文件中找到了此函數(shù)的實現(xiàn)。如下所示代碼：
/* {{{ 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_html' target='_blank'>value, php_sock, le_socket); } Zend API實際對c函數(shù)socket做了包裝，供PHP使用。而在c的socket編程中，我們使用如下方式初始化socket。//初始化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函數(shù)函數(shù)名描述
socket_accept() 接受一個Socket連接
socket_bind() 把socket綁定在一個IP地址和端口上
socket_clear_error() 清除socket的錯誤或最后的錯誤代碼
socket_close() 關(guān)閉一個socket資源
socket_connect() 開始一個socket連接
socket_create_listen() 在指定端口打開一個socket監(jiān)聽
socket_create_pair() 產(chǎn)生一對沒有差別的socket到一個數(shù)組里
socket_create() 產(chǎn)生一個socket，相當(dāng)于產(chǎn)生一個socket的數(shù)據(jù)結(jié)構(gòu)
socket_get_option() 獲取socket選項
socket_getpeername() 獲取遠(yuǎn)程類似主機(jī)的ip地址
socket_getsockname() 獲取本地socket的ip地址
socket_iovec_add() 添加一個新的向量到一個分散/聚合的數(shù)組
socket_iovec_alloc() 這個函數(shù)創(chuàng)建一個能夠發(fā)送接收讀寫的iovec數(shù)據(jù)結(jié)構(gòu)
socket_iovec_delete() 刪除一個已分配的iovec
socket_iovec_fetch() 返回指定的iovec資源的數(shù)據(jù)
socket_iovec_free() 釋放一個iovec資源
socket_iovec_set() 設(shè)置iovec的數(shù)據(jù)新值
socket_last_error() 獲取當(dāng)前socket的最后錯誤代碼
socket_listen() 監(jiān)聽由指定socket的所有連接
socket_read() 讀取指定長度的數(shù)據(jù)
socket_readv() 讀取從分散/聚合數(shù)組過來的數(shù)據(jù)
socket_recv() 從socket里結(jié)束數(shù)據(jù)到緩存
socket_recvfrom() 接受數(shù)據(jù)從指定的socket，如果沒有指定則默認(rèn)當(dāng)前socket
socket_recvmsg() 從iovec里接受消息
socket_select() 多路選擇
socket_send() 這個函數(shù)發(fā)送數(shù)據(jù)到已連接的socket
socket_sendmsg() 發(fā)送消息到socket
socket_sendto() 發(fā)送消息到指定地址的socket
socket_set_block() 在socket里設(shè)置為塊模式
socket_set_nonblock() socket里設(shè)置為非塊模式
socket_set_option() 設(shè)置socket選項
socket_shutdown() 這個函數(shù)允許你關(guān)閉讀、寫、或指定的socket
socket_strerror() 返回指定錯誤號的周詳錯誤
socket_write() 寫數(shù)據(jù)到socket緩存
socket_writev() 寫數(shù)據(jù)到分散/聚合數(shù)組5. PHP Socket模擬請求我們使用stream_socket來模擬： * @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 .= "/r/n"; $ddd = $header . $post; $fp = stream_socket_client("tcp://localhost:80", $errno, $errstr, 30); $response = ''; if (!$fp) { echo "$errstr ($errno) br / } else { fwrite($fp, $ddd); $i = 1; while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; //處理這一行 fclose($fp); return $response; } 注意，以上程序可能會進(jìn)入死循環(huán)；這個PHP的feof($fp) 需要注意的地方了，我們來分析為什么進(jìn)入死循環(huán)。while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; 實際上，feof是可靠的，但是結(jié)合fgets函數(shù)一塊使用的時候，必須要小心了。一個常見的做法是：$fp = fopen("myfile.txt", "r"); while (!feof($fp)) { $current_line = fgets($fp); //對結(jié)果做進(jìn)一步處理,防止進(jìn)入死循環(huán) 當(dāng)處理純文本的時候，fgets獲取最后一行字符后，foef函數(shù)返回的結(jié)果并不是TRUE。實際的運(yùn)算過程如下：1) while（）繼續(xù)循環(huán)。2) fgets 獲取倒數(shù)第二行的字符串3) feof返回false，進(jìn)入下一次循環(huán)4）fgets獲取最后一行數(shù)據(jù)5) 一旦fegets函數(shù)被調(diào)用，feof函數(shù)仍然返回的是false。所以繼續(xù)執(zhí)行循環(huán)6) fget試圖獲取另外一行，但實際結(jié)果是空的。實際代碼沒有意識到這一點(diǎn)，試圖處理另外根本不存在的一行，但fgets被調(diào)用了，feof放回的結(jié)果仍然是false7) .....8) 進(jìn)入死循環(huán)PHP教程

鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請第一時間聯(lián)系我們修改或刪除，多謝。

上一篇：PHP中的stdClass是什么？如何使用？(代碼示例）

下一篇：CodeIgniter配置之database.php用法實例分析