經常有朋友會對php的socket應用充滿疑惑，本文就以實例代碼作一講解，希望能對初學php的朋友起到一點幫助作用
具體代碼如下：
1.服務器端代碼:
|
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
<?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服務器端監聽端口 */ public function start(){ // 創建端口 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 ) )); } // 監聽 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; //把新來的用戶加入 客戶端數組里 $this->_client_socket_list[]=$client_socket; echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量 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) { //這里寫是去連接的客戶端業務 } } } */ }while(true); } /** * 發送數據給客戶端 */ public function send($client_socket,$str){ return socket_write ( $client_socket,$str, strlen ( $str ) ); } /** * 從客戶端接受數據 */ public function read($client_socket){ return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別 }}$socket_server =new SocketServer();$socket_server->start();//開始監聽 |
2.客戶端代碼:
|
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
<?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服務器端監聽端口 */ public function start(){ // 創建端口 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 ) )); } // 監聽 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; //把新來的用戶加入 客戶端數組里 $this->_client_socket_list[]=$client_socket; echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量 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) { //這里寫是去連接的客戶端業務 } } } */ }while(true); } /** * 發送數據給客戶端 */ public function send($client_socket,$str){ return socket_write ( $client_socket,$str, strlen ( $str ) ); } /** * 從客戶端接受數據 */ public function read($client_socket){ return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別 }}$socket_server =new SocketServer();$socket_server->start();//開始監聽 |
注意事項:服務器端請用CLI模式運行,cgi模式會超時,這是新手常喜歡犯的錯誤。那么什么是CLI模式呢？簡單的說就是用命令行去執行,而不要用游覽器打開,否則會超時的！
