PHP如何实现简单的Socket

首先使用PHP制作的Socket服务端，其主要是设置Socket的IP地址及端口号；然后监听端口，如果有客户端连接的话，则接收连接请求和数据，最后处理数据并且返回数据即可。

示例代码：

1. <?php 
2.  
3. //确保在连接客户端时不会超时 
4.  
5. set_time_limit(0); 
6.  
7. //设置IP和端口号 
8.  
9. $address = "127.0.0.1"; 
10.  
11. $port = 2048; //调试的时候，可以多换端口来测试程序！ 
12.  
13. /** 
14.  
15.  * 创建一个SOCKET  
16.  
17.  * AF_INET=是ipv4 如果用ipv6，则参数为 AF_INET6 
18.  
19.  * SOCK_STREAM为socket的tcp类型，如果是UDP则使用SOCK_DGRAM 
20.  
21. */ 
22.  
23. $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n"); 
24.  
25. //阻塞模式 
26.  
27. socket_set_block($sock) or die("socket_set_block() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n"); 
28.  
29. //绑定到socket端口 
30.  
31. $result = socket_bind($sock, $address, $port) or die("socket_bind() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n"); 
32.  
33. //开始监听 
34.  
35. $result = socket_listen($sock, 4) or die("socket_listen() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n"); 
36.  
37. echo "OK\nBinding the socket on $address:$port ... "; 
38.  
39. echo "OK\nNow ready to accept connections.\nListening on the socket ... \n"; 
40.  
41. do { // never stop the daemon 
42.  
43.  //它接收连接请求并调用一个子连接Socket来处理客户端和服务器间的信息 
44.  
45.  $msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n"); 
46.  
47.    
48.  
49.  //读取客户端数据 
50.  
51.  echo "Read client data \n"; 
52.  
53.  //socket_read函数会一直读取客户端数据,直到遇见\n,\t或者\0字符.PHP脚本把这写字符看做是输入的结束符. 
54.  
55.  $buf = socket_read($msgsock, 8192); 
56.  
57.  echo "Received msg: $buf \n"; 
58.  
59.    
60.  
61.  //数据传送 向客户端写入返回结果 
62.  
63.  $msg = "welcome \n"; 
64.  
65.  socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n"); 
66.  
67.  //一旦输出被返回到客户端,父/子socket都应通过socket_close($msgsock)函数来终止 
68.  
69.  socket_close($msgsock); 
70.  
71. } while (true); 
72.  
73. socket_close($sock);

Tags: Socket

分享到：