socket_read的两个参数:PHP_NORMAL_READ 和 PHP_BINARY_READ

Question

简单地拿php的socket写了个小daemo, 代码如下:

server端:
<?php

$address = "127.0.0.1";
$port = 20461;
//创建socket资源
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
//阻塞模式
socket_set_block($sock) or die("socket_set_block() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
//绑定到socket端口
$result = socket_bind($sock, $address, $port) or die("socket_bind() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
//监听端口
$result = socket_listen($sock) or die("socket_listen() 失败的原因是:" . socket_strerror(socket_last_error()) . "/n");
echo "OKnBinding the socket on $address:$port ... ";
echo "OKnNow ready to accept connections.nListening on the socket ... n";
do {

$msgsock = socket_accept($sock) or  die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n");
echo "Read client data \n";
$buf = socket_read($msgsock, 8192, PHP_NORMAL_READ);
echo "Received msg: $buf   \n";
//数据传送 向客户端写入返回结果
$msg = "welcome" . PHP_EOL;
socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n");
socket_close($msgsock);

} while (true);
socket_close($sock);

client端:
<?php
global $argv;
$host = "127.0.0.1";
$port = 20461;
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create socketn"); // 创建一个Socket
$connection = socket_connect($socket, $host, $port) or die("Could not connet servern"); // 连接
socket_write($socket, $argv[1] . PHP_EOL) or die("Write failedn");
//$buff = socket_read($socket, 1024, PHP_NORMAL_READ);
while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) {

echo("Response was:" . $buff . PHP_EOL);

}
socket_close($socket);

我把服务端启动之后,客户端发送数据会报错:

但是把客户端的socket_read改成PHP_BINARY_READ就可以了;

Answer 1

我也是一样的错误，你知道为啥normal就不行么

Answer 2

和标题的两个参数都没有关系。
和server端"socket_close($msgsock);"有关。
第一次通信之后，server端就关闭了来自client的socket。
所以会成功通信一次，然后断开连接，自然而然后面的通信就都失败了。

Answer 3

赞同David,主要是你循环的地方不对啦！
1.socket_read：
socket_read函数有两种读模式：PHP_BINARY_READ和PHP_NORMAL_READ。

string$input=socket_read(*resource*$socket,int$length[,*int*$type=PHP_BINARY_READ/PHP_NORMAL_READ]);

这两种模式最大的不同在于对于被读的信息的结束标志的要求。
socket_read是一种阻塞型的函数，所谓阻塞就是别的事情都不做，只做这一件事。当read的字符串长度不长时，read可能只需要几个微秒的执行时间，当字符串很长，或者read迟迟没有返回值时，程序就会陷在read的位置，不会继续往下执行。
PHP手册上对socket_read的具体介绍
PHP_BINARY_READ是默认的socket_read模式，对于结束标志没有固定要求，因此客户端只需要发送信息，服务器端的socket_read读到最后一个字符之后就会结束并返回读到的结果。而PHP_NORMAL_READ则必须在\n、\r或者读到的字符串长度达到参变量$length所规定的最大字符长度之后停止，并返回读操作的结果，否则在NORMAL模式下，socket_read会阻塞程序的进行，一直等待到满足停止read的条件出现为止。
因此在NOAMAL_READ模式下面进行的通信很容易会造成失步。除非每条传输的信息都在末尾加上一个"\n"或者"\r"。
只需要在信息末尾加上换行符或者回车符，NORMAL和BINARY是差不多的。
对于这两个程序来说，并不是客户端发送报错，而是服务器端读指令不能成功结束。

2.socket_close($msgsock)：
看了一下服务器端的do-while循环体，每进行一次循环，都关闭一次$msgsock然后再重新accept一次。
但是客户端并没有循环进行connect连接，只有循环的读显，甚至没有循环写。这就导致了只有在第一次连接的时候可以通信。服务器端程序进入第二个循环之后就会停留在accept那里（然后超时报错）。

这一套一看就是某论坛上的例程啦（我也错在这里过）。

如果只是验证socket通信，而不是检测连接可靠性，建议修改循环，把accept和$msgsock的close部分都放在循环外，两个程序的while循环里面都只进行读和写（和显），就一个客户端进行连接和通信，没必要重复连接和断开。
贴个图：socket程序流程