【php】socket_read的两个参数:PHP_NORMAL_READ 和 PHP_BINARY_READ

简单地拿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);

我把服务端启动之后,客户端发送数据会报错:
【php】socket_read的两个参数:PHP_NORMAL_READ 和 PHP_BINARY_READ
但是把客户端的socket_read改成PHP_BINARY_READ就可以了;

回答

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

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

赞同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程序流程

以上是 【php】socket_read的两个参数:PHP_NORMAL_READ 和 PHP_BINARY_READ 的全部内容, 来源链接: utcz.com/a/102567.html

回到顶部