socket_read() 如何实现超时.

flyingnn

代码如下

1. 
   
2. $address = "192.168.10.10";
   
3. $port = 8082;
   
4. 
   
5. 
   
6. do
   
7. {
   
8.         if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false)
   
9.         {
   
10.                 echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\r\n";
    
11.         }
    
12.         //socket_set_option($sock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>10, "usec"=>0));        //set read data timeout
    
13.         if (socket_bind($sock, $address, $port) === false)
    
14.         {
    
15.                 echo "socket_bind() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\r\n";
    
16.                 socket_close($sock);
    
17.                 sleep(10);
    
18.                 continue;
    
19.         }
    
20.        
    
21.         if (socket_listen($sock, 1) === false)
    
22.         {
    
23.                 echo "socket_listen() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\r\n";
    
24.                 socket_close($sock);
    
25.                 sleep(10);
    
26.                 continue;
    
27.         }
    
28.         echo "Server started, accepting connections...\r\n";
    
29. 
    
30.         //$read   = array($sock);
    
31.         //$write  = NULL;
    
32.         //$except = NULL;
    
33.         //$num_changed_sockets = socket_select($read, $write, $except, 5);
    
34.        
    
35.         do
    
36.         {
    
37.                 if (($msgsock = socket_accept($sock)) === false)
    
38.                 {
    
39.                         echo $str=date('Y-m-d H:i:s')."socket_accept() failed: reason: " . socket_strerror(socket_last_error($sock)) . "\r\n";
    
40.                         write_log($str,$argv[1]);
    
41.                         sleep(5);
    
42.                         continue;
    
43.                 }
    
44.                 $read   = array($msgsock);
    
45.                 $write  = NULL;
    
46.                 $except = NULL;
    
47.                 //socket_set_option($msgsock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));        //set read data timeout
    
48.                 if (socket_select($read, $write = NULL, $except = NULL,10,0) < 1)
    
49.                 {
    
50.                         echo "timeout!\r\n";
    
51.                         socket_close($msgsock);
    
52.                         continue;
    
53.                 }
    
54.                 @socket_getpeername($msgsock,$remote_host,$remote_port);
    
55.                 echo $str=date('Y-m-d H:i:s ')."Hello $remote_host:$remote_port! had connected! \r\n";
    
56.                 write_log($str,$argv[1]);
    
57.                 /* Send instructions. */
    
58.                 $msg = "\nWelcome to the PHP Test Server. \n" ."To quit, type 'quit'. To shut down the server type 'shutdown'.\r\n";
    
59.                 socket_write($msgsock, $msg, strlen($msg));
    
60.                
    
61.                 do
    
62.                 {
    
63.                         socket_set_option($msgsock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));
    
64.                         if (false === ($buf = socket_read($msgsock, 2048, PHP_NORMAL_READ)))
    
65.                         {
    
66.                                 echo $str=date('Y-m-d H:i:s')."socket_read() failed: reason: " . socket_strerror(socket_last_error($msgsock)) . "\r\n";
    
67.                                 write_log($str,$argv[1]);
    
68.                                 //socket_close($msgsock);
    
69.                                 break ;
    
70.                         }
    
71.                         if (!$buf = trim($buf))
    
72.                         {
    
73.                                 continue;
    
74.                         }
    
75.                         if ($buf == 'quit')
    
76.                         {
    
77.                                 break;
    
78.                         }
    
79.                         if ($buf == 'shutdown')
    
80.                         {
    
81.                                 socket_close($msgsock);
    
82.                                 break 2;
    
83.                         }
    
84.                         $talkback = "PHP: You said '$buf'.\n";
    
85.                         socket_write($msgsock, $talkback, strlen($talkback));
    
86.                         echo "$buf\n";
    
87.                 } while (true);
    
88.                 socket_close($msgsock);
    
89.         } while (true);
    
90.        
    
91.         socket_close($sock);
    
92. } while (true);
    

复制代码

当客户端没有数据发送时,如何做到下面这一句超时呢?
if (false === ($buf = socket_read($msgsock, 2048, PHP_NORMAL_READ)))

试过用以下两个方法,都不理想:
if (socket_select($read, $write = NULL, $except = NULL,10,0) < 1)
socket_set_option($msgsock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));

而当是以下这种方式时,就OK.

1. 
   
2. $address = "192.168.10.10";
   
3. $port = 8082;
   
4. 
   
5. while (true)
   
6. {
   
7.         /* Create a TCP/IP socket. */
   
8.         $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
   
9.         socket_set_option($socket,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>300, "usec"=>0));        //set no data read timeout
   
10.        
    
11.         if ($socket === false)
    
12.         {
    
13.                 echo $str=date('Y-m-d H:i:s')." socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\r\n";
    
14.                 //write_log($str,$argv[1]);
    
15.         }
    
16.         else
    
17.         {
    
18.                 echo $str=date('Y-m-d H:i:s')." socket successfully created.\r\n";
    
19.                 //write_log($str,$argv[1]);
    
20.         }
    
21.        
    
22.         echo "Attempting to connect to '$address' on port '$port'...";
    
23. 
    
24.         $result = socket_connect($socket, $address, $port);
    
25.         if ($result === false)
    
26.         {
    
27.                 echo $str=date('Y-m-d H:i:s')." socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\r\n";
    
28.                 write_log($str,$argv[1]);
    
29.                 sleep(10);  //set reconnect time
    
30.                 continue;
    
31.         }
    
32.         else
    
33.         {
    
34.                 echo $str=date('Y-m-d H:i:s')." successfully connected to $address.\r\n";
    
35.                 write_log($str,$argv[1]);
    
36.         }
    
37.        
    
38.         //*************************************************** read line write to mysql database **********************
    
39.         $i = 0;
    
40.         while (true == true)
    
41.         {
    
42.             $i++;
    
43.           //  echo "Sending $i to server.\n";
    
44.           //  socket_write($socket, $i, strlen($i));
    
45.                 $input = socket_read($socket, 2048);
    
46.                 if ($input===false)
    
47.                 {
    
48.                         break;
    
49.                 }
    
50.                 else
    
51.                 {
    
52.                         data_to_mysql($input,$argv[1]);
    
53.                 }
    
54.            // write_bad($input,$argv[1]);
    
55.             echo "Response from server is: $input\n";
    
56.         //    if ($i>10) exit();
    
57.             //sleep(5);
    
58.         }
    
59.         //sleep(5);
    
60. }       
    
61. echo "Closing socket...";
    
62. socket_close($socket);
    
63. 
    

复制代码

[ 本帖最后由 flyingnn 于 2008-12-26 15:48 编辑 ]

flyingnn

当以SERVER方式运行时:
1> 如果使用这一句:
socket_set_option($msgsock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));
没有超时的现象出现.
2>.这一句呢:
if (socket_select($read, $write = NULL, $except = NULL,10,0) < 1);
则客户程序连接上以后,如果没有数据发送,则超时,
但是,客户连接上后,发送了数据,后面再没有数据发送了,则没有超时了,不知为何.

当以CLIENT方式运行时,用这一句则可以达到要求,没有数据收到,则超时,就用这一句:
socket_set_option($msgsock,SOL_SOCKET, SO_RCVTIMEO, array("sec"=>5, "usec"=>0));

hightman

你应该尝试先搞清楚阻塞IO/与无阻塞IO的概念及含议

flyingnn

用无阻塞IO的话,就是socket_set_nonblock()吧,这样也不太好,socket_read()没等行尾,就返回结果了,这样不好.
现在就是想让socket_read()看到有行尾才返回结果,而且如果在一定的时间内还没有返回,则超时.

hightman

原帖由 flyingnn 于 2008-12-29 11:50 发表
用无阻塞IO的话,就是socket_set_nonblock()吧,这样也不太好,socket_read()没等行尾,就返回结果了,这样不好.
现在就是想让socket_read()看到有行尾才返回结果,而且如果在一定的时间内还没有返回,则超时.

那就用 NON-BLOCKING 的 IO, 搭配 socket_select() 实现一个 socket_gets 之类的...

socket_read 可概要不管读到的是不是 \r \n 之类,

简单来说就是将 socket 设为无阻塞, 然后调用 socket_select() 并指定一个你所希望的"超时时间", 这样无论 SOCKET 是否可读都会返回.

socket_select() 返回表示有数据可读或者出现了系统的中断调用(如信号)或者超时了,  如果出错 socket_selecT() 返回 false, 如果超时应该是返回 0(int),

如果是有数据可读那么调用 socket_read 一字节一字节的读取并加入字符串中, 直到出现 \r\n , 同时你也要考虑 socket_read() 的时候出现的意外错误.


其实建议你用 fsockopen() 这个PHP包装好并且返回 stream 句柄的函数, 你只要调用 fgets() 和设定一个 stream_set_timeout 就可以了

by the way, PHP 手册上有一个 socket_read 的第三参数, 设为 PHP_NORMAL_READ 会自动卡到 \r\n 这里, 搭配 socket_select 应该就可以简单实现了

[ 本帖最后由 hightman 于 2008-12-29 12:38 编辑 ]

flyingnn

现在就是这样的,用 NON-BLOCKING 的 IO, socket_set_nonblock(),搭配 socket_select(),这样的情况,是客户连上后,如果没有任何输入,就会超时,但是如果客户连接上以后,输入了一些字符,就不会超时了,然后,socket_read(),就算加上了第三个参数socket_read($msgsock, 2048, PHP_NORMAL_READ),在这时,它也不管有没有看到\r\n,也会返回结果的.

[ 本帖最后由 flyingnn 于 2008-12-29 14:05 编辑 ]

flyingnn

现在程序是作为SERVER运行的,客户程序自动连接后发送数据的,fsockopen()可以作为SERVER端运行吗?

flyingnn

现在不行的话,只有这样解决了:
用 socket_set_nonblock(),搭配 socket_select(),用 socket_read 一字节一字节的读取并加入字符串中, 直到出现 \r\n.

很感谢版主的热心帮助.在此谢过了!

flyingnn

另外有个问题就是,为什么只有客户端输入字符后,才会输出这一句呢?
echo $str=date('Y-m-d H:i:s ')."Hello $remote_hostremote_port! had connected! \r\n";
而不是客户一连接上就输出呢?

hightman

原帖由 flyingnn 于 2008-12-29 14:04 发表
现在就是这样的,用 NON-BLOCKING 的 IO, socket_set_nonblock(),搭配 socket_select(),这样的情况,是客户连上后,如果没有任何输入,就会超时,但是如果客户连接上以后,输入了一些字符,就不会超时了,然后,socket_r ...

你可以再判断socket_read得到的数据最后一个字节是不是\n