在gatewayworker中,使用redis做消息訂閱,由于數(shù)據(jù)量大,現(xiàn)在在兩臺服務(wù)器上做的分布式部署,每臺服務(wù)器businessworker都是開的十個(gè)進(jìn)程,但是進(jìn)程還是會(huì)很快都阻塞,請問各位大牛們怎么解決呢
public static function onWebSocketConnect($client_id, $data)
{
$token=$data;
$encryptedData = base64_decode($token);
$arr=json_decode($encryptedData,true);
$codeArr=explode(',',strtoupper($arr));
global $redis;
$_SESSION = $client_id;
$redis->subscribe($codeArr,function ($instance, $channelName, $message){
if(!empty($message)){
var_dump($message);
}
});
}