如何广播数据

范例（定时广播）

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

范例（群聊）

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