【已解决】写安装引导时很奇怪的502或无响应问题，CPU占用会高

问题描述

之前测试各种业务时都是正常的，偏偏今天在写程序安装引导时遇到502或者直接无响应问题，不知道是我哪里代码的问题，说一下我遇到的情况，麻烦大佬们看看哪里导致的！
1.没有任何报错信息（可能是Nginx代理转发的问题，但我用的免费版宝塔，没有防火墙）
2.一样的代码，我之前的thinkphp6.1程序虽然响应慢一点，但不会出现这个问题（最多SQL语句写入错误）
3.其他业务操作都是正常，只有安装执行SQL的时候会出现, CPU的负载也会被拉起来
4.无响应或者502一般是3、4次到20来次都出现过没有规律，不像是SQL语句错误导致

502报错截图

无响应截图一

无响应截图二

命令行调试截图

Webman运行状态

服务器负载占用截图

程序代码

    /**
     *  执行安装控制器主方法 502或者无响应就是这个请求出现的
     */
   public function onInstall()
    {

        $dbOptions = Cache::get('install.db');
        if (!is_array($dbOptions)) {
            $dbOptions = input('post.database');
        }

        $sql_step = input('post.sql_step/d', 0);

        // 链接数据库
        try {
            $this->getPdoDb($dbOptions);
        } catch (\Throwable $th) {
            // 捕获DbException 此处注意DbException只能用Exception捕获
            $code = $th->getCode();
            if ($code == 2002) {
                return $this->error('数据库链接错误, 数据库地址填写错误');
            } elseif ($code == 1045) {
                return $this->error('数据库链接错误, 账号或密码错误');
            } elseif ($code == 1049) {
                return $this->error('数据库链接错误, 数据库名称对应的数据库不存在');
            }
            return $this->error('数据库链接错误，' . $th->getMessage(), null, [
                'list'   => [],
                'log'    => [],
                'ok'     => 0,
                'result' => ['sql_step' => $sql_step++],
            ]);
        }

        $this->pdo = null;

        // 执行数据库写入
        $sqlFile = dirname(__DIR__) . '/data/install.sql';
        if (!is_file($sqlFile)) {
            return $this->error('数据库安装文件[app/' . module() . '/data/install.sql]不存在，请检查程序完整性', '', ['ok' => 0, 'list' => [], 'log' => [], 'sqlFile' => str_replace(root_path(), '', $sqlFile)]);
        }

        $list = $log = [];
        for ($i = 0; $i < $this->write_num; $i++) {
            $sql = $this->getInstallSql(++$sql_step, $dbOptions['dbprefix'] ?? 'cmypro_');
            $res = $this->doInstallSql($sql_step, $sql);
            if ($res['empty'] != 1) {
                $list[] = $res;
                $log[]  = $this->resMsg($res, $res['success'] === true);
            }
        }

        if ($sql_step >= $this->sql_num) {
            // 执行到最后一步，更新管理员和配置信息等
            $data   = Cache::get('install.data');
            $res    = $this->updateAdmin($data);
            $list[] = $res;
            $log[]  = $this->resMsg($res, $res['success'] === true);

            $res    = $this->updateWebsite($data);
            $list[] = $res;
            $log[]  = $this->resMsg($res, $res['success'] === true);
            $this->updateAdminPath();

            $res    = $this->insertVersionInfo();
            $list[] = $res;
            $log[]  = $this->resMsg($res, $res['success'] === true);
            return $this->success('共' . $this->sql_num . '条, 数据写入成功', null, ['ok' => 1, 'list' => $list, 'log' => $log, 'sql_num' => $this->sql_num, 'sql_all' => $this->sql_all]);
        }

        return $this->success('当前执行完毕', '', ['list' => $list, 'log' => $log, 'ok' => 0, 'result' => $res, 'sql_step' => $sql_step, 'sql_num' => $this->sql_num, 'write_num' => $this->write_num, 'next_array' =>  array_slice(self::$sql_array, ($sql_step > 0 ? $sql_step : 0), $this->write_num)]);
    }
/**
     * 获取当前执行语句
     *
     * @param integer $sql_step 当前步骤
     * @param string $prefix  数据表前缀
     * @return string
     */
    private function getInstallSql($sql_step = 0, $prefix = 'cmypro')
    {
        static $sql_array = null;

        $file          = dirname(__DIR__) . '/data/install.sql';
        if (empty($sql_array) || filemtime($file) > $this->sqlFileMtime) {
            $sql           = file_get_contents($file);
            $this->sqlFileMtime = filemtime($file);
            $this->sql_all = $sql = preg_replace('/;[\s]+\n/', ";\n", $sql);
            $sql_array     = explode(";\n", $sql);
            $sql_array  = array_filter($sql_array, function ($value) {
                return trim($value) != '';
            });

            self::$sql_array =  $sql_array = array_map(function ($value) use ($prefix) {
                return $this->sql_split($value, $prefix);
            }, $sql_array);
        }

        $this->sql_num = count($sql_array);
        if (isset($sql_array[$sql_step])) {
            return $sql_array[$sql_step];
        }
        return '';
    }
/**
     * SQL语句处理
     *
     * @param string $sql
     * @param string $prefix
     * @return string
     */
    private function sql_split($sql, $prefix): string
    {

        try {
            // 统一换行符为\n
            $sql = str_replace(["\r\n", "\r"], "\n", $sql);

            // 保留MySQL条件注释（如/*!50001 ... */）
            $sql = preg_replace_callback('/\/\*!\d{5}.*?\*\//s', function ($matches) {
                return str_replace("\n", " ", $matches[0]); // 防止换行破坏注释结构
            }, $sql);

            // 删除普通注释（改进正则避免破坏条件注释）
            $sql = preg_replace([
                '/\/\*.*?\*\//s',           // /*...*/
                '/\s*-- .*$/m',             // -- 注释
                '/\s*#.*$/m'                // # 注释
            ], ['', "\n", "\n"], $sql);

            // 安全替换表前缀（处理特殊字符）
            foreach ($this->table_prefix as $key => $table_prefix) {
                $oldPrefix = preg_quote($table_prefix, '/');
                $sql = preg_replace([
                    "/`{$oldPrefix}([a-zA-Z0-9_]+)`/",
                    "/(\s){$oldPrefix}([a-zA-Z0-9_]+)(\s)/"
                ], [
                    '`' . $prefix . '$1`',
                    '$1' . $prefix . '$2$3'
                ], $sql);
            }

            // 处理存储引擎和字符集（更精确的匹配）
            $sql = preg_replace([
                '/\bTYPE\s*=\s*(InnoDB|MyISAM|MEMORY)\b/i',
                '/\s*DEFAULT\s+CHARSET\s*=\s*[a-zA-Z0-9_]+/i'
            ], [
                'ENGINE=$1',
                ' DEFAULT CHARSET=utf8mb4'
            ], $sql);

            // 清理多余空白（保留换行用于语句分割）
            $sql = preg_replace([
                '/\n{3,}/',      // 多个空行变单行
                '/\s{2,}/',      // 多个空格变单空格
                '/\s*;\s*$/m'    // 行尾分号清理
            ], [
                "\n\n",
                ' ',
                ';'
            ], $sql);
        } catch (\Throwable $th) {
            $this->outJson(['msg' => $th->getMessage(), 'sql' => $sql]);
        }
        return $sql;
    }
/**
     * 链接Pdo数据库检查数据库信息是否正确
     *
     * @param array $dbOptions 数据库配置信息
     * @return \PDO
     */
    private function getPdoDb(array $dbOptions = [])
    {

        $dbhost = $dbOptions['dbhost'] ?? '127.0.0.1';
        $dbname = $dbOptions['dbname'] ?? 'root';
        $dbuser = $dbOptions['dbuser'] ?? 'root';
        $dbpwd  = $dbOptions['dbpwd'] ?? '123456';
        $dbport = $dbOptions['dbport'] ?? '3306';

        // 数据库类型
        $type   = config('think-orm.default', 'mysql');
        $pdo    = null;
        $option = $type . ":host=" . $dbhost;
        if ($dbport) {
            $option .= ";port=" . $dbport;
        }
        if ($dbname) {
            $option .= ";dbname={$dbname}";
        }
        // PDO配置
        $pdoAttr = [
            //设置数据库字段保持不变
            PDO::ATTR_CASE                     => PDO::CASE_NATURAL,
            //关闭pdo模拟功能
            PDO::ATTR_EMULATE_PREPARES         => false,
            //开启缓存查询
            PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
        ];
        $this->pdo = new PDO($option, $dbuser, $dbpwd, $pdoAttr);
        $this->pdo->exec("set names 'utf8mb4'");
        return $pdo;
    }
/**
     * 执行写入SQL
     *
     * @param integer $sql_step
     * @param string $sql
     * @return array
     */
    private function doInstallSql($sql_step = 0, $sql = '')
    {

        if (trim($sql) == '') {
            return [
                'sql_step' => $sql_step,
                'sql'      => $sql,
                'empty'    => 1,
                'title'    => '无效操作',
                'content'  => 'SQL语句为空! ',
                'sql_num'  => $this->sql_num - 1,
                'success'  => false,
            ];
        }

        $tableName = '';
        if (preg_match('/TABLE IF NOT EXISTS `([\w]+)`/i', $sql, $match1)) {
            $tableName = $match1[1];
        }

        $tableTitle = '';
        if (preg_match("/CHARSET=utf8mb4 COMMENT='(.*?)'/i", $sql, $match2)) {
            $tableTitle = $match2[1];
        }

        if (!$tableName && !$tableTitle) {
            if (preg_match("/insert into `([\w]+)`/i", $sql, $match3)) {
                $tableName = $match3[1];
                $type      = 'insert';
                // 说明是insert语句
                $ret = [
                    'sql_step' => $sql_step,
                    'sql'      => $sql,
                    'title'    => '插入到表>>' . ($tableName ?: '未知'),
                    'content'  => '',
                    'sql_num'  => $this->sql_num - 1,
                    'success'  => false,
                ];
            } else {
                $type = 'insert';
                $ret  = [
                    'sql_step' => $sql_step,
                    'sql'      => $sql,
                    'title'    => '其他写入',
                    'content'  => '',
                    'sql_num'  => $this->sql_num - 1,
                    'success'  => false,
                ];
            }
        } else {
            $type = 'table';
            $ret  = [
                'sql_step' => $sql_step,
                'sql'      => $sql,
                'title'    => '创建表>>' . ($tableTitle ?: $tableName),
                'content'  => '',
                'sql_num'  => $this->sql_num - 1,
                'success'  => false,
            ];
        }
        try {
            $ret['success'] = true;
            $ret['content'] = $type == 'table' ? '创建成功' : '插入成功';
            \support\think\Db::query($sql);
            // $this->pdo->query($sql);
        } catch (\Throwable $th) {
            // 捕获DbException 此处注意DbException只能用\Exception捕获
            $ret['success'] = false;
            if ($type == 'table') {
                $ret['content'] = '创建失败，' . $th->getMessage();
            } else {
                $ret['content'] = '插入失败，' . $th->getMessage();
            }
        }
        $ret['empty'] = 0;
        return $ret;
    }

报错信息

没有报错信息，直接返回502或者无响应

截图报错信息里报错文件相关代码

没有报错信息，直接返回502或者无响应

操作系统及workerman/webman等框架组件具体版本

webman版本：v2.1.2
swoole版本：v5.1.4
Nginx版本： 1.26.1
think-orm： webman/think-orm最新版
用的老大的教程，那个宝塔安装的Nginx转发模式

 # Ws服务
  location ^~ /sysgateway {
      proxy_pass http://127.0.0.1:23111;
      proxy_http_version 1.1;
      proxy_set_header Upgrade $http_upgrade;
      proxy_set_header Connection "upgrade";
      proxy_connect_timeout 300s;
      proxy_send_timeout 300s;
      proxy_read_timeout 300s;
      break;
  }
  # 将请求转发到webman
  location ^~ / {
      proxy_set_header Host $http_host;
      proxy_set_header X-Forwarded-For $remote_addr;
      proxy_set_header X-Forwarded-Proto $scheme;
      proxy_set_header X-Real-IP $remote_addr;
      proxy_http_version 1.1;
      proxy_set_header Connection "";
      if (!-f $request_filename){
          proxy_pass http://127.0.0.1:8787;
      }
  }

  # 拒绝访问 plugins 目录
  location ^~ /plugins {
    return 404;
  }

  # 拒绝访问所有以 .php 结尾的文件
  location ~ $ {
      return 404;
  }

  # 允许访问 .well-known 目录
  location ~ ^/.well-known/ {
    allow all;
  }

  # 拒绝访问所有以 . 开头的文件或目录
  location ~ /. {
      return 404;
  }