php Socket初探

ywl_php_fly

server端代码：

1. <?php
   
2. 
   
3. $addr = "127.0.0.1";
   
4. $port = 1003;
   
5. 
   
6. $remoteIP = "";
   
7. $remotePort = "";
   
8. 
   
9. $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
   
10. if($socket < 0) {
    
11.         echo "Socket create:".$socket_strerror($socket)."\n";
    
12.         exit;
    
13. }
    
14. if ( ($ret = socket_bind($socket, $addr, $port)) < 0 ) {
    
15.     echo "socket bind:".socket_strerror()."\n";
    
16.     exit;
    
17. }
    
18. if ( ($ret = socket_listen($socket, 5)) < 0 ) {
    
19.     echo "socket listen:".socket_strerror()."\n";
    
20.     exit;
    
21. }
    
22. 
    
23. socket_set_nonblock($socket);
    
24. 
    
25. echo "Wainting fro a connection:\n";
    
26. 
    
27. $clients = array($socket);
    
28. while(true) {
    
29.     $read = $clients;
    
30.     if(socket_select($read, $writes=NULL, $execs=NULL, 3) < 1){
    
31.         //echo ".";
    
32. 
    
33.         continue;
    
34.     }
    
35.     if(in_array($socket,$read)) {
    
36.         $clients[] = $newsock = socket_accept($socket);
    
37.         socket_set_nonblock($newsock);
    
38.         socket_getpeername($newsock,&$remoteIP,&$remotePort);
    
39.         $key = array_search($socket,$read);
    
40.         unset($read[$key]);
    
41.         $msg = "Server: $addr\r\n".
    
42.                 "Notice:Welcome the user from ".$remoteIP.":".$remotePort.".\r\n";
    
43.         echo $remoteIP.":".$remotePort." conected in.\r\n";
    
44.         socket_write($newsock,$msg);
    
45.     }
    
46. 
    
47.     foreach($read as $read_sock) {
    
48.         $data = @socket_read($read_sock,1024,PHP_BINARY_READ);
    
49.         if($data == false) {
    
50.             $key = array_search($read_sock,$clients);
    
51.             print_r($clients[$key]);
    
52.             unset($clients[$key]);
    
53.             socket_close($read_sock);
    
54.             echo "Client disconnected.\n";
    
55.             continue;
    
56.         }
    
57.         
    
58.         $command = strtoupper ($data);
    
59.         
    
60.         switch ($command)
    
61.         {
    
62.             case "LIST":
    
63.                 $writer = print_r($clients,1);
    
64.                 break;
    
65.             case "HELLO":
    
66.                 $writer = "Hello Everybody!";
    
67.                 break;
    
68.             case "QUIT":
    
69.                 $writer = "Bye-Bye";
    
70.                 break;
    
71.             case "SLEEP":
    
72.                 sleep(30);
    
73.                 $writer = "sleeped 10 seconds!";
    
74.                 break;
    
75.             case "HELP":
    
76.                 $writer = "HELLO\tQUIT\tHELP";
    
77.                 break;
    
78.             default:
    
79.                 $writer = "Error Command!\r\nType help for help message!";
    
80.         }
    
81. 
    
82.         socket_write($read_sock, $writer);
    
83.         //exit;
    
84. 
    
85.     }
    
86. }
    
87. socket_close($socket);
    
88. 
    
89. ?>

 

client端源代码：

1. <?php
   
2. // Client
   
3. 
   
4. // 设置错误处理
   
5. 
   
6. error_reporting (E_ALL);
   
7. 
   
8. $ip = "127.0.0.1"; // IP 地址
   
9. 
   
10. $port = 1003; // 端口号
    
11. 
    
12. 
    
13. $socket = socket_create (AF_INET, SOCK_STREAM, SOL_TCP); // 创建一个SOCKET
    
14. 
    
15. if ($socket)
    
16.     echo "socket_create() successed!\n";
    
17. else
    
18.     echo "socket_create() failed:".socket_strerror ($socket)."\n";
    
19. 
    
20. $conn = socket_connect ($socket, $ip, $port); // 建立SOCKET的连接
    
21. 
    
22. if ($conn)
    
23.     echo "Success to connection![".$ip.":".$port."]\n";
    
24. else
    
25.     echo "socket_connect() failed:".socket_strerror ($conn)."\n";
    
26. 
    
27. echo socket_read ($socket, 1024);
    
28. 
    
29. $stdin = fopen ('php://stdin', 'r');
    
30. while (true)
    
31. {
    
32.     $command = trim (fgets ($stdin, 1024));
    
33.     socket_write ($socket, $command, strlen ($command));
    
34.     $msg = trim (socket_read ($socket, 1024));
    
35.     echo $msg."\n";
    
36.     if ($msg == "Bye-Bye")
    
37.         break;
    
38. }
    
39. fclose ($stdin);
    
40. socket_close ($socket);
    
41. ?>