:$pidFile = '/var/run/workerman_relay.pid';
$tcp_worker = new Worker("tcp://0.0.0.0:2347");
// 启动4个进程对外提供服务>lastMessageTime > Relay::$heartbeat_time){
$connection->close();
}
}
});
// 开启一个内部端口,方便内部系统推送数据5332');
$inner_text_worker->onMessage = function ($connection, $buffer) use ($tcp_worker) {
// $data数组格式,里面有uid,表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
$uid = $data['padCode'];
// 通过workerman,向uid的页面推送数据
$ret = Relay::sendMessageByUid($tcp_worker,$uid, json_encode($data['param']));
dump($data