您当前的位置: 首页 > 慢生活 > 程序人生 网站首页程序人生
workerman利用属性connections遍历向客户端定时发消息
发布时间:2021-11-30 22:12:17编辑:雪饮阅读()
connections存储了当前进程的所有的客户端连接对象,其中id为connection的id编号。
如果得知connection的编号为$id,可以很方便的通过$worker->connections[$id]获得对应的connection对象,从而操作对应的socket连接,例如通过$worker->connections[$id]->send('...') 发送数据。
注意:如果连接关闭(触发onClose),对应的connection会从$connections数组里删除。
实例:
test.php:
<?php
use Workerman\Worker;
use Workerman\Lib\Timer;
require_once __DIR__ . '/vendor/autoload.php';
$worker = new Worker('text://0.0.0.0:2020');
// 进程启动时设置一个定时器,定时向所有客户端连接发送数据
$worker->onWorkerStart = function($worker)
{
// 定时,每10秒一次
Timer::add(10, function()use($worker)
{
// 遍历当前进程所有的客户端连接,发送当前服务器的时间
foreach($worker->connections as $connection)
{
$connection->send(time());
}
});
};
// 运行worker
Worker::runAll();
?>
实例运行:
[root@izj6c2jeancylo0ppo4vz5z workerman]# php test.php start
Workerman[test.php] start in DEBUG mode
----------------------------------------- WORKERMAN -----------------------------------------
Workerman version:4.0.22 PHP version:7.0.33
------------------------------------------ WORKERS ------------------------------------------
proto user worker listen processes status
tcp root none text://0.0.0.0:2020 1 [OK]
---------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
客户端连接了一会儿后:
[root@izj6c2jeancylo0ppo4vz5z ~]# telnet 127.0.0.1 2020
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
1638235158
1638235168
1638235178
1638235188
1638235198
1638235208
1638235218
1638235228
1638235238
1638235248
1638235258
1638235268
1638235278
1638235288
1638235298
1638235308
1638235318
1638235328
关键字词:workerman,connections