1、socket_select函数说明

1.1、函数原型

socket_select( array &$read, array &$write, array &$except, int $tv_sec[, int $tv_usec = 0] )

其中,

$read存放可读的socket集合，即遍历那些socket读缓冲区不为空

$write存放可写socket集合,即遍历哪些socket写缓冲区为空

$except排除不进行遍历监听的socket集合

$tv_sec时间，单位为秒

$tv_usec时间，单位为微妙

默认情况，socket_select根据设置的($tv_sec+$tv_usec)进行阻塞,如都为零，则不阻塞立即返回

2、案例

创建一个tcp服务端.再使用telnet作为客户端进行测试

2.1、源码

<?php

/**

* Copyright (C) Iamasb

* @project : 3、workerman相关知识点

* @explain : select函数使用

* @filename : 33、select函数使用.php

* @author : xiaobei

*/

// 创建tcp

if (!($resource = socket_create(AF_INET,SOCK_STREAM,SOL_TCP))) {

echo "socket create is error";

exit();

}

// 绑定当前主机和端口

if (!socket_bind($resource,'0.0.0.0','1234')) {

echo "socket bind is error";

exit();

}

// 启动监听

if (!socket_listen($resource)) {

echo "socket listen is error";

exit();

}

// 设置端口复用

if (!socket_set_option($resource, SOL_SOCKET, SO_REUSEADDR, 1)) {

echo 'Unable to set option on socket: '. socket_strerror(socket_last_error()) . PHP_EOL;

exit;

}

$read[] = $resource;

$write = NULL;

$except = NULL;

$start = "welcome to!\r\n";

$end = "good bye \r\n";

while (true) {

$rst = $read;

socket_select($rst,$write,$except,0);

if (count($rst)) {

foreach ($rst as $value) {

// 判断是否是主socket，还是子socket

if ($value === $resource) {

$client = socket_accept($resource);

socket_write($client,$start,strlen($start));

$read[] = $client;

} else {

$str = trim(socket_read($value,1024));

if ($str == "quit") {

socket_write($value,$end,strlen($end));

socket_close($value);

$key = array_search($value,$read);

unset($read[$key]);

echo "client->",$key,"--> close.";

}

echo "receive-> ",$str,PHP_EOL;

}

}

}

}

2.2、测试

• 启动tcp服务端
• telnet进行连接

• tcp服务端

3、总结

由上面的运行结果，可以看出，当某个telnet发起数据交互时，服务端都能够及时进行处理。而不用等到一个socket处理完毕后，再进行。这样大大提升了通信效率