PHP SOCKET編程詳解
1. 預(yù)備知識(shí)
一直以來很少看到有多少人使用php的socket模塊來做一些事情,大概大家都把它定位在腳本語言的范疇內(nèi)吧,但是其實(shí)php的socket模塊可以做很多事情,包括做ftplist,http post提交,smtp提交,組包并進(jìn)行特殊報(bào)文的交互(如smpp協(xié)議),whois查詢。這些都是比較常見的查詢。
特別是php的socket擴(kuò)展庫可以做的事情簡直不會(huì)比c差多少。
php的socket連接函數(shù)
1、集成于內(nèi)核的socket
這個(gè)系列的函數(shù)僅僅只能做主動(dòng)連接無法實(shí)現(xiàn)端口監(jiān)聽相關(guān)的功能。而且在4.3.0之前所有socket連接只能工作在阻塞模式下。
此系列函數(shù)包括
fsockopen,pfsockopen
這兩個(gè)函數(shù)的具體信息可以查詢php.net的用戶手冊(cè)
他們均會(huì)返回一個(gè)資源編號(hào)對(duì)于這個(gè)資源可以使用幾乎所有對(duì)文件操作的函數(shù)對(duì)其進(jìn)行操作如fgets(),fwrite(), fclose()等單注意的是所有函數(shù)遵循這些函數(shù)面對(duì)網(wǎng)絡(luò)信息流時(shí)的規(guī)律,例如:
fread() 從文件指針 handle 讀取最多 length 個(gè)字節(jié)。 該函數(shù)在讀取完 length 個(gè)字節(jié)數(shù),或到達(dá) EOF 的時(shí)候,或(對(duì)于網(wǎng)絡(luò)流)當(dāng)一個(gè)包可用時(shí)就會(huì)停止讀取文件,視乎先碰到哪種情況。
可以看出對(duì)于網(wǎng)絡(luò)流就必須注意取到的是一個(gè)完整的包就停止。
2、php擴(kuò)展模塊帶有的socket功能。
php4.x 以后有這么一個(gè)模塊extension=php_sockets.dll,Linux上是一個(gè)extension=php_sockets.so。
當(dāng)打開這個(gè)此模塊以后就意味著php擁有了強(qiáng)大的socket功能,包括listen端口,阻塞及非阻塞模式的切換,multi-client 交互式處理等
這個(gè)系列的函數(shù)列表參看http://www.php.net/manual/en/ref.sockets.php
看過這個(gè)列表覺得是不是非常豐富呢?不過非常遺憾這個(gè)模塊還非常年輕還有很多地方不成熟,相關(guān)的參考文檔也非常少:(
我也正在研究中,因此暫時(shí)不具體討論它,僅給大家一個(gè)參考文章
http://www.zend.com/pecl/tutorials/sockets.php
2. 使用PHP socket擴(kuò)展
服務(wù)器端代碼:
<?php /** * File name server.php * 服務(wù)器端代碼 * * @author guisu.huang * @since 2012-04-11 * */ //確保在連接客戶端時(shí)不會(huì)超時(shí) set_time_limit(0); //設(shè)置IP和端口號(hào) $address = "127.0.0.1"; $port = 2046; //調(diào)試的時(shí)候,可以多換端口來測試程序! /** * 創(chuàng)建一個(gè)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 //它接收連接請(qǐng)求并調(diào)用一個(gè)子連接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ù)會(huì)一直讀取客戶端數(shù)據(jù),直到遇見\n,\t或者\(yùn)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)建一個(gè)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方式啟動(dòng)server:
php server.php
這里注意socket_read函數(shù):
可選的類型參數(shù)是一個(gè)命名的常數(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))
針對(duì)參數(shù)PHP_NORMAL_READ ,如果服務(wù)器的響應(yīng)結(jié)果沒有\(zhòng) n。造成socket_read(): unable to read from socket
3. PHP socket內(nèi)部源碼
從PHP內(nèi)部源碼來看,PHP提供的socket編程是在socket,bind,listen等函數(shù)外添加了一個(gè)層,讓其更加簡單和方便調(diào)用。但是一些業(yè)務(wù)邏輯的程序還是需要程序員自己去實(shí)現(xiàn)。
下面我們以socket_create的源碼實(shí)現(xiàn)來說明PHP的內(nèi)部實(shí)現(xiàn)。
前面我們有說到php的socket是以擴(kuò)展的方式實(shí)現(xiàn)的。在源碼的ext目錄,我們找到sockets目錄。這個(gè)目錄存放了PHP對(duì)于socket的實(shí)現(xiàn)。直接搜索PHP_FUNCTION(socket_create),在sockets.c文件中找到了此函數(shù)的實(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_value, php_sock, le_socket); }
Zend API實(shí)際對(duì)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() 接受一個(gè)Socket連接
socket_bind() 把socket綁定在一個(gè)IP地址和端口上
socket_clear_error() 清除socket的錯(cuò)誤或最后的錯(cuò)誤代碼
socket_close() 關(guān)閉一個(gè)socket資源
socket_connect() 開始一個(gè)socket連接
socket_create_listen() 在指定端口打開一個(gè)socket監(jiān)聽
socket_create_pair() 產(chǎn)生一對(duì)沒有差別的socket到一個(gè)數(shù)組里
socket_create() 產(chǎn)生一個(gè)socket,相當(dāng)于產(chǎn)生一個(gè)socket的數(shù)據(jù)結(jié)構(gòu)
socket_get_option() 獲取socket選項(xiàng)
socket_getpeername() 獲取遠(yuǎn)程類似主機(jī)的ip地址
socket_getsockname() 獲取本地socket的ip地址
socket_iovec_add() 添加一個(gè)新的向量到一個(gè)分散/聚合的數(shù)組
socket_iovec_alloc() 這個(gè)函數(shù)創(chuàng)建一個(gè)能夠發(fā)送接收讀寫的iovec數(shù)據(jù)結(jié)構(gòu)
socket_iovec_delete() 刪除一個(gè)已分配的iovec
socket_iovec_fetch() 返回指定的iovec資源的數(shù)據(jù)
socket_iovec_free() 釋放一個(gè)iovec資源
socket_iovec_set() 設(shè)置iovec的數(shù)據(jù)新值
socket_last_error() 獲取當(dāng)前socket的最后錯(cuò)誤代碼
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() 這個(gè)函數(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選項(xiàng)
socket_shutdown() 這個(gè)函數(shù)允許你關(guān)閉讀、寫、或指定的socket
socket_strerror() 返回指定錯(cuò)誤號(hào)的周詳錯(cuò)誤
socket_write() 寫數(shù)據(jù)到socket緩存
socket_writev() 寫數(shù)據(jù)到分散/聚合數(shù)組
5. PHP Socket模擬請(qǐng)求
我們使用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 />\n"; } else { fwrite($fp, $ddd); $i = 1; while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; //處理這一行 } } fclose($fp); return $response; }
注意,以上程序可能會(huì)進(jìn)入死循環(huán);
這個(gè)PHP的feof($fp) 需要注意的地方了,我們來分析為什么進(jìn)入死循環(huán)。
while ( !feof($fp) ) { $r = fgets($fp, 1024); $response .= $r; }
實(shí)際上,feof是可靠的,但是結(jié)合fgets函數(shù)一塊使用的時(shí)候,必須要小心了。一個(gè)常見的做法是:
$fp = fopen("myfile.txt", "r"); while (!feof($fp)) { $current_line = fgets($fp); //對(duì)結(jié)果做進(jìn)一步處理,防止進(jìn)入死循環(huán) }
當(dāng)處理純文本的時(shí)候,fgets獲取最后一行字符后,foef函數(shù)返回的結(jié)果并不是TRUE。實(shí)際的運(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試圖獲取另外一行,但實(shí)際結(jié)果是空的。實(shí)際代碼沒有意識(shí)到這一點(diǎn),試圖處理另外根本不存在的一行,但fgets被調(diào)用了,feof放回的結(jié)果仍然是false
7) .....
8) 進(jìn)入死循環(huán)
相關(guān)文章
Mysql中l(wèi)imit的用法方法詳解與注意事項(xiàng)
mysql的數(shù)據(jù)一般都是用limit控制數(shù)量,它的使用方法也是需要注意的。2008-04-04PHP學(xué)習(xí)筆記(一):基本語法之標(biāo)記、空白、和注釋
這篇文章主要介紹了PHP學(xué)習(xí)筆記(一):基本語法,本文講解了PHP 標(biāo)記、PHP 注釋、PHP 空白三個(gè)最基本的語法,需要的朋友可以參考下2015-04-04Ping服務(wù)的php實(shí)現(xiàn)方法,讓網(wǎng)站快速被收錄
這篇博文繼續(xù)說說這個(gè)ping服務(wù)的問題,首先歸納和總結(jié)以下資料2012-02-02Thinkphp事件機(jī)制兩種實(shí)現(xiàn)方式詳解
根據(jù)官方文檔thinkphp6的事件機(jī)制涉及三個(gè)類:事件類(event)、監(jiān)聽類(listener)、訂閱類(subscribe)。官方的文檔以及官方的視頻都沒把事件機(jī)制講清楚。下面我以單應(yīng)用為例用另一種方式給大家總結(jié)一下2022-09-09PHP在獲取指定目錄下的目錄,在獲取的目錄下面再創(chuàng)建文件,多平臺(tái)
PHP在獲取指定目錄下的目錄,在獲取的目錄下面再創(chuàng)建文件,多平臺(tái),需要的朋友可以參考下。2011-08-08PHP入門教程之使用Mysqli操作數(shù)據(jù)庫的方法(連接,查詢,事務(wù)回滾等)
這篇文章主要介紹了PHP入門教程之使用Mysqli操作數(shù)據(jù)庫的方法,涉及php+mysqli操作數(shù)據(jù)庫的基本連接、編碼設(shè)置、查詢、修改、事務(wù)回滾等操作技巧,需要的朋友可以參考下2016-09-09