swoole实现websocket推送
环境配置:swoole 1.9.3、centos6.5(虚拟机)、PHP7.01思路:①通过server中的collections取出fd
·
环境配置:
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");
}
});
更多推荐
已为社区贡献4条内容
所有评论(0)