如何使用PHP构建一个高性能的弹幕后端服务
我们来分别剖析一下每一个事件的含义。
$serv->on('Open', function($server, $req) {
echo "connection open: ".$req->fd;
});
顾名思义，Open表示打开一个新的链接，并且在事件触发之后echo出连接上服务端的客户端id，该客户端唯一id为回调函数第二个参数中的fd字段。这也是服务端区分客户端的唯一id。
$serv->on('Message', function($server, $frame) {
echo "message: ".$frame->data;
$server->push($frame->fd, json_encode(["hello", "world"]));
});
同样顾名思义，Message表示消息到达服务端的事件，并且在事件触发之后echo出发送给服务端的数据，该数据为回调函数第二个参数的data字段。另外我们还看到它调用了$server->push，这是回调函数的第一个参数中的`push方法，它是一个服务端给客户的发送数据的方法，第一个参数为要发送的客户端id，第二个为要发送的数据，这里的含义是向发给服务端消息的那个客户端发送["hello", "world"]这个数组（方括号写数组为PHP5.4的新特性，如果你是PHP5.3请使用传统的array工厂函数生成数组）经过json序列化之后的数据。
$serv->on('Close', function($server, $fd) {
echo "connection close: ".$fd;
});
最后一个事件Close更加容易理解，就是关闭事件，当然关闭的不是服务端，而是客户端，可以理解为客户端与服务端断开连接的事件。回调函数中的代码含义为echo出与服务端断开连接的那个客户端id。
基本的API都清楚了，下面就直接看代码吧，短短二十行而已。
https://github.com/cw1997/danmu-demo/blob/master/server.php
$server = new swoole_websocket_server("0.0.0.0", 1997);
$server->on('open', function (swoole_websocket_server $server, $request) {
echo "server: handshake success with fd{$request->fd} ";
//$request->fd 是客户端id
});
$server->on('message', function (swoole_websocket_server $server, $frame) {
echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},
fin:{$frame->finish} ";
//$frame->fd 是客户端id，$frame->data是客户端发送的数据
//服务端向客户端发送数据是用$server->push( '客户端id' , '内容')
$data = $frame->data;
foreach($server->connections as $fd){
$server->push($fd , $data);//循环广播
}});
$server->on('close', function ($ser, $fd) {
echo "client {$fd} closed ";
});
$server->start();
这里最核心的广播代码其实还用到了一个之前没有提到过的成员，也就是swoole_websocket_server对象的connections成员，这个成员中保存了所有已连接上该WebSocket服务端的fd，也就是客户端id。因此我们只要在message事件中使用foreach遍历该成员，循环将所有服务端收到的弹幕消息都发送给其他已连接上该服务端的客户端即可。
后端讲完了再讲讲前端吧。
前端代码也不是很多https://github.com/cw1997/danmu-demo/blob/master/
var ws = new WebSocket("ws://192.168.1.107:1997");
ws.onopen = function(){
console.log("握手成功");
ws.send('hello world!!!');
};
ws.onmessage = function(e){
console.log("message:" + e.data);
var time = jQuery('#danmu').data("nowtime") + 1;
var text_obj = '{ "text":"' + e.data + '" , "color":"green" ,"size":"1","position":"0","time":"' + time + '" ,"isnew":" "}'; //构造加上了innew属性的字符串danmu对象
console.log(text_obj);
var new_obj = eval('(' + text_obj + ')'); //转化为js对象
jQuery('#danmu').danmu("add_danmu", new_obj); //向插件中添加该danmu对象
};
ws.onerror = function(){
console.log("error");
};
核心代码都在这里，使用new WebSocket("ws://192.168.1.107:1997")创建一个WebSocket客户端连接对象，通过该对象的各种事件进行对应的操作，和服务端是不是很像？更多代码解释可以参考源代码中的注释，这里不做更多介绍。
看到这里相信作为一名PHPer的你也可以开发出属于自己的弹幕系统了。这里展示的只是一个最基础最原始的弹幕平台。我们也了解到了使用PHP开发一个弹幕平台需要涉及到的技术有WebSocket，Swoole扩展，甚至碰到了很多初级开发者平时不怎么接触的工具，比如说PECL，比如说Linux。
其实PHP结合Swoole扩展还可以做很多事情，比如说对接各种家电，对接各种硬件接口实现在Web端实时控制家电，又比如说结合树莓派做智能小车，通过web端进行遥控等等，各种新奇的玩法等你发现。谁说PHP只能做Web开发？PHP拥有了Swoole扩展其实能做的事情还有很多，Swoole就像他的宣传标题一样：重新定义PHP。
【如何使用PHP构建一个高性能的弹幕后端服务】相关文章：