环境配置:
     swoole 1.9.3、centos6.5(虚拟机)、PHP7.01

思路:
     ①通过server中的collections取出fd
     ②写一个 admin.html(管理员推送页面) 与 client.html(客户端),html页面的websocket自行可编写
          并在server.php中message事件用循环push数据(server中的collections取出fdfd组)    
$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);
       }
    }
});
注:其实这里需要admin.html发送数据时传token并在message事件中验证是否管理员请求( 数据库操作),是才执行推送,否则不做操作

server.php代码如下:
<?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();

效果图:


注:客户端websocket自行编写。

上面推送小实例实现中有点问题,并未将客户端与服务端分离开来,以下分离开。
     因为swoole_websocket_server 继承自 swoole_http_server,所以可在websocket中用Request事件,另外用global引入用于在Request事件中push


①首先admin.html改为http请求,且client.html保持不变
<form method="post" action="http://localhost:9502/server.php">
    <input name="test" type="text" placeholder="please input something">
    <input type="submit" value="submit">
</form>

②将Message事件的push部分删掉,如下:
$serv->on('Message', function ($server, $frame) use($redis) {
    echo "\n message: " . $frame->data . "\n";
     //将来可用于写数据库信息
});

③添加http的Request事件,如下:
//服务端请求更新数据,这里是http方式
$serv->on('Request', function ($req, $respone) {
    global $serv;    //全局引入$serv
    global $redis;     //全局引入redis
    print_r($req->post);
    if(count($req->post)){ //判断下是否有数据
    	foreach (@$serv->connections as $key => $value) {    
        	@$serv->push($value, "客户{$value}:".$req->post["test"]);
    	}
    	$respone->end("success");
    }
});






Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐