問題描述

之前測(cè)試各種業(yè)務(wù)時(shí)都是正常的，偏偏今天在寫程序安裝引導(dǎo)時(shí)遇到502或者直接無響應(yīng)問題，不知道是我哪里代碼的問題，說一下我遇到的情況，麻煩大佬們看看哪里導(dǎo)致的！
1.沒有任何報(bào)錯(cuò)信息（可能是Nginx代理轉(zhuǎn)發(fā)的問題，但我用的免費(fèi)版寶塔，沒有防火墻）
2.一樣的代碼，我之前的thinkphp6.1程序雖然響應(yīng)慢一點(diǎn)，但不會(huì)出現(xiàn)這個(gè)問題（最多SQL語句寫入錯(cuò)誤）
3.其他業(yè)務(wù)操作都是正常，只有安裝執(zhí)行SQL的時(shí)候會(huì)出現(xiàn), CPU的負(fù)載也會(huì)被拉起來
4.無響應(yīng)或者502一般是3、4次到20來次都出現(xiàn)過沒有規(guī)律，不像是SQL語句錯(cuò)誤導(dǎo)致

502報(bào)錯(cuò)截圖

無響應(yīng)截圖一

無響應(yīng)截圖二

命令行調(diào)試截圖

Webman運(yùn)行狀態(tài)

服務(wù)器負(fù)載占用截圖

程序代碼

    /**
     *  執(zhí)行安裝控制器主方法 502或者無響應(yīng)就是這個(gè)請(qǐng)求出現(xiàn)的
     */
   public function onInstall()
    {

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

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

        // 鏈接數(shù)據(jù)庫
        try {
            $this->getPdoDb($dbOptions);
        } catch (\Throwable $th) {
            // 捕獲DbException 此處注意DbException只能用Exception捕獲
            $code = $th->getCode();
            if ($code == 2002) {
                return $this->error('數(shù)據(jù)庫鏈接錯(cuò)誤, 數(shù)據(jù)庫地址填寫錯(cuò)誤');
            } elseif ($code == 1045) {
                return $this->error('數(shù)據(jù)庫鏈接錯(cuò)誤, 賬號(hào)或密碼錯(cuò)誤');
            } elseif ($code == 1049) {
                return $this->error('數(shù)據(jù)庫鏈接錯(cuò)誤, 數(shù)據(jù)庫名稱對(duì)應(yīng)的數(shù)據(jù)庫不存在');
            }
            return $this->error('數(shù)據(jù)庫鏈接錯(cuò)誤，' . $th->getMessage(), null, [
                'list'   => [],
                'log'    => [],
                'ok'     => 0,
                'result' => ['sql_step' => $sql_step++],
            ]);
        }

        $this->pdo = null;

        // 執(zhí)行數(shù)據(jù)庫寫入
        $sqlFile = dirname(__DIR__) . '/data/install.sql';
        if (!is_file($sqlFile)) {
            return $this->error('數(shù)據(jù)庫安裝文件[app/' . module() . '/data/install.sql]不存在，請(qǐng)檢查程序完整性', '', ['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) {
            // 執(zhí)行到最后一步，更新管理員和配置信息等
            $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 . '條, 數(shù)據(jù)寫入成功', null, ['ok' => 1, 'list' => $list, 'log' => $log, 'sql_num' => $this->sql_num, 'sql_all' => $this->sql_all]);
        }

        return $this->success('當(dāng)前執(zhí)行完畢', '', ['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)]);
    }
/**
     * 獲取當(dāng)前執(zhí)行語句
     *
     * @param integer $sql_step 當(dāng)前步驟
     * @param string $prefix  數(shù)據(jù)表前綴
     * @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 {
            // 統(tǒng)一換行符為\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]); // 防止換行破壞注釋結(jié)構(gòu)
            }, $sql);

            // 刪除普通注釋（改進(jìn)正則避免破壞條件注釋）
            $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);
            }

            // 處理存儲(chǔ)引擎和字符集（更精確的匹配）
            $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,}/',      // 多個(gè)空行變單行
                '/\s{2,}/',      // 多個(gè)空格變單空格
                '/\s*;\s*$/m'    // 行尾分號(hào)清理
            ], [
                "\n\n",
                ' ',
                ';'
            ], $sql);
        } catch (\Throwable $th) {
            $this->outJson(['msg' => $th->getMessage(), 'sql' => $sql]);
        }
        return $sql;
    }
/**
     * 鏈接Pdo數(shù)據(jù)庫檢查數(shù)據(jù)庫信息是否正確
     *
     * @param array $dbOptions 數(shù)據(jù)庫配置信息
     * @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';

        // 數(shù)據(jù)庫類型
        $type   = config('think-orm.default', 'mysql');
        $pdo    = null;
        $option = $type . ":host=" . $dbhost;
        if ($dbport) {
            $option .= ";port=" . $dbport;
        }
        if ($dbname) {
            $option .= ";dbname={$dbname}";
        }
        // PDO配置
        $pdoAttr = [
            //設(shè)置數(shù)據(jù)庫字段保持不變
            PDO::ATTR_CASE                     => PDO::CASE_NATURAL,
            //關(guān)閉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;
    }
/**
     * 執(zhí)行寫入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'    => '創(chuàng)建表>>' . ($tableTitle ?: $tableName),
                'content'  => '',
                'sql_num'  => $this->sql_num - 1,
                'success'  => false,
            ];
        }
        try {
            $ret['success'] = true;
            $ret['content'] = $type == 'table' ? '創(chuàng)建成功' : '插入成功';
            \support\think\Db::query($sql);
            // $this->pdo->query($sql);
        } catch (\Throwable $th) {
            // 捕獲DbException 此處注意DbException只能用\Exception捕獲
            $ret['success'] = false;
            if ($type == 'table') {
                $ret['content'] = '創(chuàng)建失敗，' . $th->getMessage();
            } else {
                $ret['content'] = '插入失敗，' . $th->getMessage();
            }
        }
        $ret['empty'] = 0;
        return $ret;
    }

報(bào)錯(cuò)信息

沒有報(bào)錯(cuò)信息，直接返回502或者無響應(yīng)

截圖報(bào)錯(cuò)信息里報(bào)錯(cuò)文件相關(guān)代碼

沒有報(bào)錯(cuò)信息，直接返回502或者無響應(yīng)

操作系統(tǒng)及workerman/webman等框架組件具體版本

webman版本：v2.1.2
swoole版本：v5.1.4
Nginx版本： 1.26.1
think-orm： webman/think-orm最新版
用的老大的教程，那個(gè)寶塔安裝的Nginx轉(zhuǎn)發(fā)模式

 # Ws服務(wù)
  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;
  }
  # 將請(qǐng)求轉(zhuǎn)發(fā)到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 結(jié)尾的文件
  location ~ $ {
      return 404;
  }

  # 允許訪問 .well-known 目錄
  location ~ ^/.well-known/ {
    allow all;
  }

  # 拒絕訪問所有以 . 開頭的文件或目錄
  location ~ /. {
      return 404;
  }