当前位置: 首页 > 文档资料 > WorkerMan 3.x 手册 >

常见问题 - 如何广播数据

优质
小牛编辑
133浏览
2023-12-01

范例(定时广播)

  1. use WorkermanWorker;
  2. use WorkermanLibTimer;
  3. require_once __DIR__ . '/Workerman/Autoloader.php';
  4. $worker = new Worker('websocket://0.0.0.0:2020');
  5. // 这个例子中进程数必须为1
  6. $worker->count = 1;
  7. // 进程启动时设置一个定时器,定时向所有客户端连接发送数据
  8. $worker->onWorkerStart = function($worker)
  9. {
  10. // 定时,每10秒一次
  11. Timer::add(10, function()use($worker)
  12. {
  13. // 遍历当前进程所有的客户端连接,发送当前服务器的时间
  14. foreach($worker->connections as $connection)
  15. {
  16. $connection->send(time());
  17. }
  18. });
  19. };
  20. // 运行worker
  21. Worker::runAll();

范例(群聊)

  1. use WorkermanWorker;
  2. use WorkermanLibTimer;
  3. require_once './Workerman/Autoloader.php';
  4. $worker = new Worker('websocket://0.0.0.0:2020');
  5. // 这个例子中进程数必须为1
  6. $worker->count = 1;
  7. // 客户端发来消息时,广播给其它用户
  8. $worker->onMessage = function($connection, $message)use($worker)
  9. {
  10. foreach($worker->connections as $connection)
  11. {
  12. $connection->send($message);
  13. }
  14. };
  15. // 运行worker
  16. Worker::runAll();

说明:

单进程:

以上例子只能单进程$worker->count=1),因为多进程时多个客户端可能连接到不同的进程中,进程间的客户端是隔离的,无法直接通讯,也就是A进程中无法直接操作B进程的客户端connection对象发送数据。(要做到这点,需要进程间通讯,比如可以使用Channel组件)。

建议用GatewayWorker

在workerman基础上开发的GatewayWoker框架提供了更方便推送机制,包括组播、广播等,可以设置多进程甚至可以多服务器部署,如果需要给客户端推送数据,建议使用GatewayWorker框架。

GatewayWorker手册地址 http://www.workerman.net/gatewaydoc/

GatewayWorker下载地址(linux版本) http://www.workerman.net/download/GatewayWorker.zip

GatewayWorker下载地址(windows版本) http://www.workerman.net/download/GatewayWorker-for-win.zip