From e85e1e57b13c0aa9025a3ea70ef009b2223b4486 Mon Sep 17 00:00:00 2001
From: Wang <69124377+YiwanGi@users.noreply.github.com>
Date: Tue, 24 Jan 2023 12:11:41 +0800
Subject: [PATCH] init database in task worker (#271)

---
 src/ZM/Event/SwooleEvent/OnWorkerStart.php | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/ZM/Event/SwooleEvent/OnWorkerStart.php b/src/ZM/Event/SwooleEvent/OnWorkerStart.php
index 51d36aa3..f3de22c3 100644
--- a/src/ZM/Event/SwooleEvent/OnWorkerStart.php
+++ b/src/ZM/Event/SwooleEvent/OnWorkerStart.php
@@ -130,6 +130,15 @@ class OnWorkerStart implements SwooleEvent
             Framework::saveProcessState(ZM_PROCESS_TASKWORKER, $server->worker_pid, ['worker_id' => $worker_id]);
             try {
                 Framework::$server = $server;
+                $this->initMySQLPool();
+                $redis = ZMConfig::get('global', 'redis_config');
+                if ($redis !== null && $redis['host'] != '') {
+                    if (!extension_loaded('redis')) {
+                        Console::error(zm_internal_errcode('E00029') . "Can not find redis extension.\n");
+                    } else {
+                        ZMRedisPool::init($redis);
+                    }
+                }
                 $this->loadAnnotations();
                 Console::success('TaskWorker #' . $server->worker_id . ' started');
             } catch (Exception $e) {