diff --git a/EdgeManager.php b/EdgeManager.php index 6b6f593..a173e43 100644 --- a/EdgeManager.php +++ b/EdgeManager.php @@ -9,7 +9,7 @@ require_once __DIR__ . '/vendor/autoload.php'; use EdgeManager\EDataCapture\{ EDataCapture, ENodeConfigure }; use EdgeManager\EController\{ EConfigure, ECommand }; -$options = getopt('h::', ['no_dup_code', 'relay_device_status', 'server_name:', 'port::', 'user:', 'password:', 'help::']); +$options = getopt('h::', ['no_dup_code', 'relay_device_status', 'server_name:', 'port::', 'user:', 'password:', 'worker_num::', 'help::']); if (array_key_exists('h', $options) or array_key_exists('help', $options)) { print_r( @@ -21,6 +21,7 @@ if (array_key_exists('h', $options) or array_key_exists('help', $options)) { --user pg实例的用户名 --port pg实例的端口号 --password pg实例的密码 + --worker_num 主程序进程数,默认为20个 -h, --help 显示此帮助信息 " ); @@ -31,7 +32,7 @@ init_db($options['server_name'], $options['port'] ?? 5432, $options['user'], $op $worker = new Worker('http://0.0.0.0:8888'); $worker -> name = 'EntryPoint'; -$worker -> count = 20; +$worker -> count = $options['worker_num'] ?? 20; $worker -> onWorkerStart = function(Worker $worker) { global $options, $dbconn;