|
|
經(jīng)常有朋友會對php的socket應用充滿疑惑，本文就以實例代碼作一講解，希望能對初學php的朋友起到一點幫助作用
具體代碼如下：
1.服務器端代碼:
<?phpclass SocketServer{ private $_port='9000'; private $_address='127.0.0.1'; private $_client_socket_list=array(); public function __set($name,$val){ $this--->$name=$val; } private function _showError($error){ exit($error); } /** * 開始進行socket服務器端監(jiān)聽端口 */ public function start(){ // 創(chuàng)建端口 if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) { $this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () )); } // 綁定 if (socket_bind ( $sock, $this->_address, $this->_port ) === false) { $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) )); } // 監(jiān)聽 if (socket_listen ( $sock, 5 ) === false) { $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) ); } do { //當有一個客戶端連接的時候 if ($client_socket=socket_accept ( $sock )) { $count = count ( $this->_client_socket_list ) + 1; //把新來的用戶加入 客戶端數(shù)組里 $this->_client_socket_list[]=$client_socket; echo "new connection:/r/n";//服務器端輸出當前正在連接的客戶端數(shù)量 echo "current connection:{$count}/r/n"; //接受客戶端傳過來的字符串 $msg=$this->read($client_socket); echo "client:{$msg}/r/n"; //服務器向客戶端傳值 $my_msg="I am fine,think you/r/n"; $this->send($client_socket,$my_msg); } /** * 這段代碼給你參考,用來判斷是否有客戶端主動失去連接 else{ foreach ( $this->_client_socket_list as $socket ) { $len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接 if ($len < 7) { //這里寫是去連接的客戶端業(yè)務 } } } */ }while(true); } /** * 發(fā)送數(shù)據(jù)給客戶端 */ public function send($client_socket,$str){ return socket_write ( $client_socket,$str, strlen ( $str ) ); } /** * 從客戶端接受數(shù)據(jù) */ public function read($client_socket){ return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關(guān)系,會自動識別 }}$socket_server =new SocketServer();$socket_server->start();//開始監(jiān)聽
2.客戶端代碼:
<?phpclass SocketServer{ private $_port='9000'; private $_address='127.0.0.1'; private $_client_socket_list=array(); public function __set($name,$val){ $this--->$name=$val; } private function _showError($error){ exit($error); } /** * 開始進行socket服務器端監(jiān)聽端口 */ public function start(){ // 創(chuàng)建端口 if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) { $this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () )); } // 綁定 if (socket_bind ( $sock, $this->_address, $this->_port ) === false) { $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) )); } // 監(jiān)聽 if (socket_listen ( $sock, 5 ) === false) { $this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) ); } do { //當有一個客戶端連接的時候 if ($client_socket=socket_accept ( $sock )) { $count = count ( $this->_client_socket_list ) + 1; //把新來的用戶加入 客戶端數(shù)組里 $this->_client_socket_list[]=$client_socket; echo "new connection:/r/n";//服務器端輸出當前正在連接的客戶端數(shù)量 echo "current connection:{$count}/r/n"; //接受客戶端傳過來的字符串 $msg=$this->read($client_socket); echo "client:{$msg}/r/n"; //服務器向客戶端傳值 $my_msg="I am fine,think you/r/n"; $this->send($client_socket,$my_msg); } /** * 這段代碼給你參考,用來判斷是否有客戶端主動失去連接 else{ foreach ( $this->_client_socket_list as $socket ) { $len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接 if ($len < 7) { //這里寫是去連接的客戶端業(yè)務 } } } */ }while(true); } /** * 發(fā)送數(shù)據(jù)給客戶端 */ public function send($client_socket,$str){ return socket_write ( $client_socket,$str, strlen ( $str ) ); } /** * 從客戶端接受數(shù)據(jù) */ public function read($client_socket){ return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關(guān)系,會自動識別 }}$socket_server =new SocketServer();$socket_server->start();//開始監(jiān)聽
注意事項:服務器端請用CLI模式運行,cgi模式會超時,這是新手常喜歡犯的錯誤。那么什么是CLI模式呢？簡單的說就是用命令行去執(zhí)行,而不要用游覽器打開,否則會超時的！
php技術(shù)：php socket客戶端及服務器端應用實例，轉(zhuǎn)載需保留來源！
鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯(lián)系我們修改或刪除，多謝。
