如何广播(群发)数据

范例（定时广播）

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

说明：

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

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

GatewayWorker手册地址 https://doc2.workerman.net