众所周之，传统的PHP（特指php-fpm）开发web应用很爽，但是涉及到长时间等待的场景就有点难受
痛点一
php-fpm的进程数是有限的，假设一个服务器实例开启了40个php-fpm进程，一瞬间能处理的就是40个php请求，超过nginx很容易报502。
假设每个请求都是100ms，理论值就是1s内一个进程可以处理10个请求（一个进程处理完请求之后可以继续处理其他请求），40个进程就可以处理400个请求（理论值）。但假设一个请求处理需要1s甚至更长，意味着40个进程同1s只能处理40个请求，那么并发处理能力就直线下降。所以响应时长对一个服务器的总体性能影响还是蛮重要的
痛点二
一般来说，一个PHP脚本的执行最大时长为30s（php.ini默认值）。
如果某些特殊的场景（例如离线数据同步，如果要查询大量的数据会耗时比较长），也会比较容易报超时错误。
解决以上通点可以通过websocket的方式实现，也可以通过MQ实现（但是数据同步不及时）
我们先来模拟一下数据同步耗时问题
本文用的swoole实现websocket服务
swoole代码如下
<?php
//include "db.php";
//创建WebSocket Server对象，监听0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server('0.0.0.0', 9501);
//监听WebSocket连接打开事件
$ws->on('Open', function ($ws, $request) {
$ws->push($request->fd, "hello, welcome\n");
});
//监听WebSocket消息事件
$ws->on('Message', function ($ws, $frame) {
//模拟超时环境
sleep(50);
$result = ["data"=>"长时间等待后获取到到数据"];
$data = json_encode($result,JSON_UNESCAPED_UNICODE);
$ws->push($frame->fd, $data);
});
//监听WebSocket连接关闭事件
$ws->on('Close', function ($ws, $fd) {
echo "client-{$fd} is closed\n";
});
$ws->start();
启动socket服务
image.png
js的websocket代码如下
<!DOCTYPE html>
<html>
<head>
<title></title>
<meta charset="utf-8">
</head>
<body>
<div id="output"></div>
</body>
<script type="text/javascript">
var wsUri ="ws://127.0.0.1:9501/";
var output;
function init() {
output = document.getElementById("output");
testWebSocket();
}
function testWebSocket() {
websocket = new WebSocket(wsUri);
websocket.onopen = function(evt) {
onOpen(evt)
};
websocket.onclose = function(evt) {
onClose(evt)
};
websocket.onmessage = function(evt) {
onMessage(evt)
};
websocket.onerror = function(evt) {
onError(evt)
};
}
function onOpen(evt) {
writeToScreen("CONNECTED");
doSend("WebSocket rocks");
}
function onClose(evt) {
writeToScreen("DISCONNECTED");
}
function onMessage(evt) {
writeToScreen('<span style="color: blue;">RESPONSE: '+ evt.data+'</span>');
websocket.close();
}
function onError(evt) {
writeToScreen('<span style="color: red;">ERROR:</span> '+ evt.data);
}
function doSend(message) {
writeToScreen("SENT: " + message);
websocket.send(message);
}
function writeToScreen(message) {
var pre = document.createElement("p");
pre.style.wordWrap = "break-word";
pre.innerHTML = message;
output.appendChild(pre);
}
window.addEventListener("load", init, false);
</script>
</html>
测试结果
image.png
轻松解决长时间等待问题。而且每个socket都是链接都是独立，不相互影响，并行处理。
