Chinaunix

标题: php Socket初探 [打印本页]
作者: ywl_php_fly    时间: 2011-12-20 09:48
标题: php Socket初探

server端代码：

  1. <?php

  3. $addr = "127.0.0.1";
  4. $port = 1003;

  6. $remoteIP = "";
  7. $remotePort = "";

  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. }

  23. socket_set_nonblock($socket);

  25. echo "Wainting fro a connection:\n";

  27. $clients = array($socket);
  28. while(true) {
  29.     $read = $clients;
  30.     if(socket_select($read, $writes=NULL, $execs=NULL, 3) < 1){
  31.         //echo ".";

  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.     }

  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.         }

  82.         socket_write($read_sock, $writer);
  83.         //exit;

  85.     }
  86. }
  87. socket_close($socket);

  89. ?>

 

client端源代码：

  1. <?php
  2. // Client

  4. // 设置错误处理

  6. error_reporting (E_ALL);

  8. $ip = "127.0.0.1"; // IP 地址

  10. $port = 1003; // 端口号


  13. $socket = socket_create (AF_INET, SOCK_STREAM, SOL_TCP); // 创建一个SOCKET

  15. if ($socket)
  16.     echo "socket_create() successed!\n";
  17. else
  18.     echo "socket_create() failed:".socket_strerror ($socket)."\n";

  20. $conn = socket_connect ($socket, $ip, $port); // 建立SOCKET的连接

  22. if ($conn)
  23.     echo "Success to connection![".$ip.":".$port."]\n";
  24. else
  25.     echo "socket_connect() failed:".socket_strerror ($conn)."\n";

  27. echo socket_read ($socket, 1024);

  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. ?>




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2