swoole实现群体推送

<?php  
$serv = new Swoole\Websocket\Server("0.0.0.0", 9502);  
  
  
$serv->on('Open', function ($server, $req) {  
    echo "\n connection open: " . $req->fd . "\n";  
});  
  
  
$serv->on('Message', function ($server, $frame) {  
    echo "\n message: " . $frame->data . "\n";  
  
  
    foreach ($server->connections as $key => $value) {  
       if($frame->fd != $value){  
          $server->push($value, "客户{$value}:".$frame->data);  
       }  
    }  
});  
  
  
$serv->on('Close', function ($server, $fd) {  
    echo "\n connection close: \n" . $fd;  
});  
  
  
$serv->start();

原文链接 http://blog.csdn.net/qq_28666081/article/details/54023152