From 83536d83098574211e93fb85c6e0bb9565f4f984 Mon Sep 17 00:00:00 2001 From: augushong Date: Sun, 6 Oct 2024 17:07:59 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6=E5=99=A8?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- extend/base/common/command/TimerBase.php | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/extend/base/common/command/TimerBase.php b/extend/base/common/command/TimerBase.php index d03e1d4..0117319 100644 --- a/extend/base/common/command/TimerBase.php +++ b/extend/base/common/command/TimerBase.php @@ -121,7 +121,15 @@ class TimerBase extends Command $worker->timerRequestList = $this->requestList; $worker->onWorkerStart = function () use ($worker, $host, $site_host, $output, $input) { - Timer::add(1, function () use ($worker, $host, $site_host, $output, $input) { + $options = [ + 'max_conn_per_addr' => Config::get('timer.max_conn_per_addr', 1000), + 'keepalive_timeout' => Config::get('timer.keepalive_timeout', 86400), + 'connect_timeout' => Config::get('timer.connect_timeout', 86400), + 'timeout' => Config::get('timer.timeout', 86400), + ]; + $http = new HttpClient($options); + + Timer::add(1, function () use ($worker, $host, $site_host, $output, $input, $http) { $request_list = $worker->timerRequestList; foreach ($request_list as $request_item) { $output->writeln(date('Y-m-d H:i:s') . ': build site request async:' . $request_item['target']); @@ -147,14 +155,6 @@ class TimerBase extends Command // - $options = [ - 'max_conn_per_addr' => Config::get('timer.max_conn_per_addr', 1000), - 'keepalive_timeout' => Config::get('timer.keepalive_timeout', 86400), - 'connect_timeout' => Config::get('timer.connect_timeout', 86400), - 'timeout' => Config::get('timer.timeout', 86400), - ]; - $http = new HttpClient($options); - $http->request($host . $request_item['target'], [ 'headers' => [ 'Host' => $site_host, @@ -162,7 +162,7 @@ class TimerBase extends Command ], 'success' => function ($response) use ($request_item, $output) { $request_item['is_running'] = false; - $output->writeln($response->getBody()); + $output->writeln((string) $response->getBody()); }, 'error' => function ($exception) use ($request_item, $output) { $request_item['is_running'] = false;