root/pgserver3.0
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no commit message

Browse Source
This commit is contained in:
annnj-company
2026-04-24 09:23:43 +08:00
parent f7b7dd6639
commit 2838f08ac0
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pgserver/push.php
View File

@@ -5,12 +5,18 @@ require __DIR__ . '/vendor/autoload.php';
use Workerman\Worker; use Workerman\Worker;
use PHPSocketIO\SocketIO; use PHPSocketIO\SocketIO;
// 加载环境变量
$env = parse_ini_file(__DIR__ . '/.env');
$push_config = $env['push'] ?? [];
$socket_port = $push_config['socket_port'] ?? 22121;
$http_port = $push_config['http_port'] ?? 22120;
// 全局数组保存uid在线数据 // 全局数组保存uid在线数据
$uidConnectionMap = []; $uidConnectionMap = [];
// 模拟推送的数值 // 模拟推送的数值
$push_value = rand(100, 1000); $push_value = rand(100, 1000);
// PHPSocketIO服务 // PHPSocketIO服务
$sender_io = new SocketIO(2120); $sender_io = new SocketIO($socket_port);
// 客户端发起连接事件 // 客户端发起连接事件
$sender_io->on('connection', function($socket) use (&$push_value){ $sender_io->on('connection', function($socket) use (&$push_value){
@@ -59,8 +65,8 @@ $sender_io->on('connection', function($socket) use (&$push_value){
}); });
// 监听http端口用于推送和更新数值 // 监听http端口用于推送和更新数值
$sender_io->on('workerStart', function()use ($sender_io){ $sender_io->on('workerStart', function()use ($sender_io, $http_port){
$inner_http_worker = new Worker('http://0.0.0.0:2121'); $inner_http_worker = new Worker("http://0.0.0.0:$http_port");
$inner_http_worker->onMessage = function($http_connection, $request_data)use ($sender_io){ $inner_http_worker->onMessage = function($http_connection, $request_data)use ($sender_io){
global $uidConnectionMap, $push_value; global $uidConnectionMap, $push_value;