如何让workerman轻松搭建高效的聊天系统?
- 内容介绍
- 文章标签
- 相关推荐
本文共计922个文字,预计阅读时间需要4分钟。
相关专题:
composer create-project topthink/think=5.1.x-dev tp5andWorkerman
安装 think-worker
composer require topthink/think-worker=2.0.*
直接安装 Workerman
composer require workerman/workerman
(2)我们先看 think-worker 的代码
config/worker_server.php
先来个服务器广播消息的示例,每10秒钟定时广播一条消息
'onWorkerStart' => function ($worker) { \Workerman\Lib\Timer::add(10, function()use($worker){ // 遍历当前进程所有的客户端连接,发送自定义消息 foreach($worker->connections as $connection){ $send['name'] = '系统信息'; $send['content'] = '这是一个定时任务信息'; $send['time'] = time(); $connection->send(json_encode($send)); } });}
但是在 onMessage 时,我们获取不到 $worker 对象,所以无法广播消息。
本文共计922个文字,预计阅读时间需要4分钟。
相关专题:
composer create-project topthink/think=5.1.x-dev tp5andWorkerman
安装 think-worker
composer require topthink/think-worker=2.0.*
直接安装 Workerman
composer require workerman/workerman
(2)我们先看 think-worker 的代码
config/worker_server.php
先来个服务器广播消息的示例,每10秒钟定时广播一条消息
'onWorkerStart' => function ($worker) { \Workerman\Lib\Timer::add(10, function()use($worker){ // 遍历当前进程所有的客户端连接,发送自定义消息 foreach($worker->connections as $connection){ $send['name'] = '系统信息'; $send['content'] = '这是一个定时任务信息'; $send['time'] = time(); $connection->send(json_encode($send)); } });}
但是在 onMessage 时,我们获取不到 $worker 对象,所以无法广播消息。

