test/mix
1
0
Fork 0
mirror of https://gitee.com/mix-php/mix.git synced 2024-12-02 03:37:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: Use Process\Pool to manage coroutines (grpc,websocket)

Browse Source
This commit is contained in:
cexll 2022-04-14 17:05:14 +08:00
parent a1aea9f0fe
commit d1536d57c4
2 changed files with 115 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
examples/grpc-skeleton/bin/swoolecopool.php Normal file
View File

@ -0,0 +1,59 @@
#!/usr/bin/env php
<?php
ini_set('display_errors', 'on');
ini_set('display_startup_errors', 'on');
ini_set('error_reporting', E_ALL ^ E_NOTICE);
ini_set('memory_limit', '1G');
require __DIR__ . '/../vendor/autoload.php';
use App\Error;
use App\Container\Logger;
use App\Grpc;
use Dotenv\Dotenv;
use Mix\Init\StaticInit;
Dotenv::createUnsafeImmutable(__DIR__ . '/../', '.env')->load();
define("APP_DEBUG", env('APP_DEBUG'));
Error::register();
$host = '0.0.0.0';
$port = 9502;
$worker_num = 4;
$pool = new \Swoole\Process\Pool($worker_num, SWOOLE_IPC_NONE);
$pool->set(['enable_coroutine' => true]);
$pool->on('WorkerStart', function ($pool, $id) use ($host, $port) {
StaticInit::finder(__DIR__ . '/../src/Container')->exec('init');
App\Container\DB::enableCoroutine();
App\Container\RDS::enableCoroutine();
$grpc = Grpc::new();
$server = new \Swoole\Coroutine\Http\Server($host, $port, false, true);
$server->handle('/', $grpc->handler());
$server->set([
'open_http2_protocol' => true,
'http_compression' => false,
]);
$server->start();
});
$pool->on('WorkerStop', function ($pool, $workerId) {
App\Container\Shutdown::trigger();
});
echo <<<EOL
____
______ ___ _____ ___ _____ / /_ _____
/ __ `__ \/ /\ \/ /__ / __ \/ __ \/ __ \
/ / / / / / / /\ \/ _ / /_/ / / / / /_/ /
/_/ /_/ /_/_/ /_/\_\ / .___/_/ /_/ .___/
/_/ /_/
EOL;
printf("System Name: %s\n", strtolower(PHP_OS));
printf("PHP Version: %s\n", PHP_VERSION);
printf("Swoole Version: %s\n", swoole_version());
printf("WorkerNum Version: %s\n", $worker_num);
printf("Listen Addr: http://%s:%d\n", $host, $port);
Logger::instance()->info('Start swoole coroutine server');
$pool->start();

56
examples/websocket-skeleton/bin/swoolecopool.php Normal file
View File

@ -0,0 +1,56 @@
#!/usr/bin/env php
<?php
ini_set('display_errors', 'on');
ini_set('display_startup_errors', 'on');
ini_set('error_reporting', E_ALL ^ E_NOTICE);
ini_set('memory_limit', '1G');
require __DIR__ . '/../vendor/autoload.php';
use App\Error;
use App\Container\Logger;
use App\Vega;
use Dotenv\Dotenv;
use Mix\Init\StaticInit;
Dotenv::createUnsafeImmutable(__DIR__ . '/../', '.env')->load();
define("APP_DEBUG", env('APP_DEBUG'));
Error::register();
$host = '0.0.0.0';
$port = 9502;
$worker_num = 4;
$pool = new \Swoole\Process\Pool($worker_num, SWOOLE_IPC_NONE);
$pool->set(['enable_coroutine' => true]);
$pool->on('WorkerStart', function ($pool, $id) use ($host, $port) {
StaticInit::finder(__DIR__ . '/../src/Container')->exec('init');
App\Container\DB::enableCoroutine();
App\Container\RDS::enableCoroutine();
$vega = Vega::new();
$server = new \Swoole\Coroutine\Http\Server($host, $port, false, true);
$server->handle('/', $vega->handler());
$server->start();
});
$pool->on('WorkerStop', function ($pool, $workerId) {
App\Container\Upgrader::instance()->closeAll();
App\Container\Shutdown::trigger();
});
echo <<<EOL
____
______ ___ _____ ___ _____ / /_ _____
/ __ `__ \/ /\ \/ /__ / __ \/ __ \/ __ \
/ / / / / / / /\ \/ _ / /_/ / / / / /_/ /
/_/ /_/ /_/_/ /_/\_\ / .___/_/ /_/ .___/
/_/ /_/
EOL;
printf("System Name: %s\n", strtolower(PHP_OS));
printf("PHP Version: %s\n", PHP_VERSION);
printf("Swoole Version: %s\n", swoole_version());
printf("WorkerNum Version: %s\n", $worker_num);
printf("Listen Addr: http://%s:%d\n", $host, $port);
Logger::instance()->info('Start swoole coroutine server');
$pool->start();