PHP监听Socket

PHP监听Socket

1. set_time_limit(10);
2. $commonProtocol = getprotobyname("tcp");
3. $socket = socket_create(AF_INET, SOCK_STREAM, $commonProtocol);
4. if ($socket) {
5. $result = socket_bind($socket, 'localhost', 1337);
6. if ($result) {
7. $result = socket_listen($socket, 5);
8. if ($result) {
9. echo "监听成功";
10. }
11. }
12. }else{
13. echo "监听失败";
14. }
15. do {
16. if (($msgsock = socket_accept($socket))) { /* 发送提示信息给连接上来的用户 */
17. $msg = "==========================================\r\n" .
18. "Welcome to the PHP Test Server. \r\n\r\n" .
19. "To quit, type 'quit'. \r\n" .
20. "To shut down the server type 'shutdown'.\r\n" .
21. "To get help message type 'help'.\r\n" .
22. "==========================================\r\n" .
23. "php>";
24. }
26. socket_write($msgsock, $msg, strlen($msg));
28. do {
29. $buf = socket_read($msgsock, 2048, PHP_BINARY_READ);
31. if (false === $buf) {
32. echo "socket_read() failed: reason: " . socket_strerror($result) . "\n";
33. break 2;
34. }
35. if (!$buf = trim($buf)) {
36. continue;
37. } /* 客户端输入quit命令时候关闭客户端连接 */
38. if ($buf == 'q') {
39. break;
40. } /* 客户端输入shutdown命令时候服务端和客户端都关闭 */
41. if ($buf == 'shutdown') {
42. socket_close($msgsock);
43. break 2;
44. } /* 客户端输入help命令时候输出帮助信息 */
45. if ($buf == 'h') {
46. $msg = " PHP Server Help Message \r\n\r\n" .
47. " To quit, type 'quit'. \r\n" .
48. " To shut down the server type 'shutdown'.\r\n" .
49. " To get help message type 'help'.\r\n" .
50. "php> ";
51. socket_write($msgsock, $msg, strlen($msg));
52. continue;
53. } /* 客户端输入命令不存在时提示信息 */
54. $talkback = "PHP: unknow command '$buf'.\r\nphp> ";
55. socket_write($msgsock, $talkback, strlen($talkback));
56. echo "$buf\n";
57. } while (true);
58. socket_close($msgsock);
59. }while (true);
60. /* 关闭Socket连接 */
61. socket_close($socket);

复制代码