php中socket编程一例

2. error_reporting(E_ALL);
3. set_time_limit(0);
4. echo "

   TCP/IP Connection

   \n";
6. $port = 1935;
7. $ip = "127.0.0.1";
9. /*
10. +-------------------------------
11. * @socket连接整个过程
12. +-------------------------------
13. * @socket_create
14. * @socket_connect
15. * @socket_write
16. * @socket_read
17. * @socket_close
18. +--------------------------------
19. */
21. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
22. if ($socket echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n";
23. }else {
24. echo "OK.\n";
25. }
27. echo "试图连接 '$ip' 端口 '$port'...\n";
28. $result = socket_connect($socket, $ip, $port);
29. if ($result echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";
30. }else {
31. echo "连接OK\n";
32. }
34. $in = "Ho\r\n";
35. $in .= "first blood\r\n";
36. $out = '';
38. if(!socket_write($socket, $in, strlen($in))) {
39. echo "socket_write() failed: reason: " . socket_strerror($socket) . "\n";
40. }else {
41. echo "发送到服务器信息成功！\n";
42. echo "发送的内容为:$in
    ";
43. }
45. while($out = socket_read($socket, 8192)) {
46. echo "接收服务器回传信息成功！\n";
47. echo "接受的内容为:",$out;
48. }
50. echo "关闭SOCKET...\n";
51. socket_close($socket);
52. echo "关闭OK\n";
53. ?>

复制代码

服务器端代码：

2. //确保在连接客户端时不会超时
3. set_time_limit(0);
5. $ip = '127.0.0.1';
6. $port = 1935;
8. /*
9. +-------------------------------
10. * @socket通信整个过程
11. +-------------------------------
12. * @socket_create
13. * @socket_bind
14. * @socket_listen
15. * @socket_accept
16. * @socket_read
17. * @socket_write
18. * @socket_close
19. +--------------------------------
20. */
22. /*----------------以下操作都是手册上的-------------------*/
23. if(($sock = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) echo "socket_create() 失败的原因是:".socket_strerror($sock)."\n";
24. }
26. if(($ret = socket_bind($sock,$ip,$port)) echo "socket_bind() 失败的原因是:".socket_strerror($ret)."\n";
27. }
29. if(($ret = socket_listen($sock,4)) echo "socket_listen() 失败的原因是:".socket_strerror($ret)."\n";
30. }
32. $count = 0;
34. do {
35. if (($msgsock = socket_accept($sock)) echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";
36. echo "等待连接...";
37. break;
38. } else {
40. //发到客户端
41. $msg ="测试成功！\n";
42. socket_write($msgsock, $msg, strlen($msg));
44. echo "测试成功了啊\n";
45. $buf = socket_read($msgsock,8192);
47. $talkback = "收到的信息:$buf\n";
48. echo $talkback;
50. if(++$count >= 5){
51. break;
52. };
53. }
54. //echo $buf;
55. socket_close($msgsock);
57. } while (true);
59. socket_close($sock);
60. ?>

复制代码