php socket程式設計：使用socket_recv而不是socket_read
阿新 • • 發佈：2020-08-15
socket_recv和socket_read都可以用於讀取socket資料，不過二者有差別，推薦使用socket_recv。
原因如下：
1.socket_recv支援多種flag，用於不同場景
2.socket_recv可以檢測socket關閉的情況(例如對端關閉了socket)
返回值：$return_value=socket_recv(...)
含義： >0 表示接收到的位元組數；
===0, 發生了錯誤，socket closed；
===false，無資料，socket not closed。
socket_read不能判斷socket是否已經斷開。
測試流程：
啟動server端，再啟動client端：可以正常通訊。
測試程式碼如下:
file: bug1_server.php
<?php /** * file: bug1_server.php * socket server * 基於php socket函式族 * IO模型：同步阻塞 * 粘包處理：固定長度 * 連線數：1個socket連線 * * 測試目標：模擬client crash時，server無法判斷socket是否斷開 * 測試結果：kill殺掉client程序後，server程序socket_last_error()返回為0，無法判斷socket是否關閉 * * @author davidyanxw * @date 2018.04.27*/ set_time_limit(0); //建立服務端的socket套接流,net協議為IPv4，protocol協議為TCP $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); // reuse address socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1); /*繫結接收的套接流主機和埠,與客戶端相對應*/ if (socket_bind($socket, '127.0.0.1', 8801) == false) { echo 'server bind fail:' . socket_strerror(socket_last_error()); }//監聽套接流 if (socket_listen($socket, 4) == false) { echo 'server listen fail:' . socket_strerror(socket_last_error()); } $accept_resource = socket_accept($socket); if($accept_resource === false) { echo "accept connection failed".PHP_EOL; exit; } // 讀寫超時時間:0.8s socket_set_option($accept_resource, SOL_SOCKET, SO_RCVTIMEO, array("sec" => 0, "usec" => 800000)); socket_set_option($accept_resource, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 0, "usec" => 800000)); // stream固定長度 $len = 100; //讓伺服器不停獲取客戶端傳過來的資訊 while (true) { $string_read = socket_read($accept_resource, $len); if($string_read === false) { echo "socket error:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL; break; } elseif($string_read == '') { if(in_array(socket_last_error(), [SOCKET_EPIPE, SOCKET_ECONNRESET])) { echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL; break; } if(in_array(socket_last_error(), [SOCKET_EAGAIN])) { // EAGAIN, retry later usleep(500); continue; } echo "server receive empty:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL; } else { $string = trim($string_read); echo 'server receive success,msg:['.$string.'],time:' . microtime(true) . PHP_EOL; } } ; // 先shutdown，後close @socket_shutdown($accept_resource); socket_close($accept_resource); @socket_shutdown($socket); socket_close($socket); /** * 生成php隨機串 * @param $length * @return string */ function randomkeys($length){ $output=''; for ($a = 0; $a<$length; $a++) { $output .= chr(mt_rand(33, 126)); } return $output; } ?>
file:bug1_client.php
<?php /** * file:bug1_client.php * socket client * 基於php socket函式族 * IO模型：同步阻塞 * 粘包處理：固定長度 * 連線數：1個socket連線 * * @author davidyanxw * @date 2018.04.27 */ set_time_limit(0); //建立一個socket套接流 $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //接收套接流的最大超時時間(800ms) //傳送套接流的最大超時時間(800ms) socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array("sec" => 0, "usec" => 800000)); socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 0, "usec" => 800000)); $len = 100; //連線服務端的套接流，這一步就是使客戶端與伺服器端的套接流建立聯絡 if (socket_connect($socket, '127.0.0.1', 8801) == false) { echo 'connect fail massege:' . socket_strerror(socket_last_error()); } else { while(1){ $ori_msg = 'Hello, server!'.randomkeys(8); $message_write = str_pad($ori_msg, $len); //向服務端寫入字串資訊 $sent = @socket_write($socket, $message_write, $len); if ($sent === false) { if(in_array(socket_last_error(), [SOCKET_EPIPE, SOCKET_ECONNRESET])) { echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL; break; } echo "socket error:".socket_last_error().",error msg:".socket_strerror(socket_last_error()).PHP_EOL; } else{ echo 'client write success,msg:['.$ori_msg.'],time:' . microtime(true).PHP_EOL; } // break; } } @socket_shutdown($socket); socket_close($socket); /** * 生成php隨機串 * @param $length * @return string */ function randomkeys($length){ $output=''; for ($a = 0; $a<$length; $a++) { $output .= chr(mt_rand(33, 126)); } return $output; } ?>
正確的程式碼是：(file: debug1_server.php)
<?php /** * file: debug1_server.php * socket server * 基於php socket函式族 * IO模型：同步阻塞 * 粘包處理：固定長度 * 連線數：1個socket連線 * * 測試目標：模擬client crash時，server無法判斷socket是否斷開 * 測試結果：kill殺掉client程序後，server程序socket_last_error()返回為0，無法判斷socket是否關閉 * * @author davidyanxw * @date 2018.04.27 */ set_time_limit(0); //建立服務端的socket套接流,net協議為IPv4，protocol協議為TCP $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); // reuse address socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1); /*繫結接收的套接流主機和埠,與客戶端相對應*/ if (socket_bind($socket, '127.0.0.1', 8801) == false) { echo 'server bind fail:' . socket_strerror(socket_last_error()); } //監聽套接流 if (socket_listen($socket, 4) == false) { echo 'server listen fail:' . socket_strerror(socket_last_error()); } $accept_resource = socket_accept($socket); if($accept_resource === false) { echo "accept connection failed".PHP_EOL; exit; } // 讀寫超時時間:0.8s socket_set_option($accept_resource, SOL_SOCKET, SO_RCVTIMEO, array("sec" => 0, "usec" => 800000)); socket_set_option($accept_resource, SOL_SOCKET, SO_SNDTIMEO, array("sec" => 0, "usec" => 800000)); // stream固定長度 $len = 100; //讓伺服器不停獲取客戶端傳過來的資訊 while (true) { /* 使用socket_recv */ $len_read = socket_recv($accept_resource, $string_read, $len, 0); if ($len_read === false) { // no data echo "no data".PHP_EOL; continue; } elseif($len_read === 0 ) { // socket closed echo "socket error:" . socket_last_error() . ",error msg:" . socket_strerror(socket_last_error()) . PHP_EOL; break; } else { $string = trim($string_read); echo 'server receive success,msg:['.$string.'],time:' . microtime(true) . PHP_EOL; } } ; // 先shutdown，後close @socket_shutdown($accept_resource); socket_close($accept_resource); @socket_shutdown($socket); socket_close($socket); /** * 生成php隨機串 * @param $length * @return string */ function randomkeys($length){ $output=''; for ($a = 0; $a<$length; $a++) { $output .= chr(mt_rand(33, 126)); } return $output; } ?>
https://www.jianshu.com/p/fb20c931920f