眾所周之，傳統(tǒng)的PHP（特指php-fpm）開發(fā)web應用很爽，但是涉及到長時間等待的場景就有點難受
痛點一
php-fpm的進程數(shù)是有限的尺铣，假設一個服務器實例開啟了40個php-fpm進程，一瞬間能處理的就是40個php請求，超過nginx很容易報502颗管。
假設每個請求都是100ms，理論值就是1s內(nèi)一個進程可以處理10個請求（一個進程處理完請求之后可以繼續(xù)處理其他請求）滓走，40個進程就可以處理400個請求（理論值）垦江。但假設一個請求處理需要1s甚至更長，意味著40個進程同1s只能處理40個請求，那么并發(fā)處理能力就直線下降比吭。所以響應時長對一個服務器的總體性能影響還是蠻重要的
痛點二
一般來說绽族，一個PHP腳本的執(zhí)行最大時長為30s（php.ini默認值）。
如果某些特殊的場景（例如離線數(shù)據(jù)同步衩藤，如果要查詢大量的數(shù)據(jù)會耗時比較長）吧慢，也會比較容易報超時錯誤。
解決以上通點可以通過websocket的方式實現(xiàn)赏表，也可以通過MQ實現(xiàn)（但是數(shù)據(jù)同步不及時）
我們先來模擬一下數(shù)據(jù)同步耗時問題
本文用的swoole實現(xiàn)websocket服務
swoole代碼如下
<?php
//include "db.php";
//創(chuàng)建WebSocket Server對象检诗，監(jiān)聽0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server('0.0.0.0', 9501);
//監(jiān)聽WebSocket連接打開事件
$ws->on('Open', function ($ws, $request) {
$ws->push($request->fd, "hello, welcome\n");
});
//監(jiān)聽WebSocket消息事件
$ws->on('Message', function ($ws, $frame) {
//模擬超時環(huán)境
sleep(50);
$result = ["data"=>"長時間等待后獲取到到數(shù)據(jù)"];
$data = json_encode($result,JSON_UNESCAPED_UNICODE);
$ws->push($frame->fd, $data);
});
//監(jiān)聽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>
測試結(jié)果
image.png
輕松解決長時間等待問題。而且每個socket都是鏈接都是獨立瓢剿，不相互影響逢慌，并行處理。
