pdostatement :: fetchall을 사용하여 멀티 스레드 쿼리 성능을 최적화 할 수 있습니까? 구체적으로 구현하는 방법?

M66 2025-07-07

동시성 또는 데이터 집약적 인 응용 프로그램에서 데이터베이스 액세스는 종종 성능 병목 현상 중 하나입니다. 이 문제에 대한 응답으로 개발자는 종종 "다중 스레드 쿼리"를 통해 처리 기능을 향상시키는 것을 고려합니다. PHP 개발자는 다음 과 같은 생각을 할 것입니다. 이 기사는 기술적 인 관점에서이를 분석하고 실현 가능한 구현 전략을 제공합니다.

1. Fetchall의 본질과 성능에 대한 토론

pdostatement :: fetchall ()은 pdo가 결과 세트에서 한 번에 모든 행에서 모든 행을 제거하기 위해 제공하는 편리한 방법입니다. 결과 세트가 적은 상황에 적합하며 장점은 코드를 단순화하고 데이터베이스 연결에 대한 설문 조사 수를 줄이는 것입니다. 그러나 본질적으로 "동시성"또는 "멀티 스레드"의 능력이 없으며 동기식 차단 작업 일뿐입니다. 즉, FetchAll ()을 몇 번이나 쓰더라도 모든 데이터가 가져올 때까지 차례로 실행됩니다.

목표가 특정 쿼리의 풀링 방법을 최적화하는 대신 대규모 쿼리의 효율성을 향상시키는 것이라면 다중 프로세스 (PCNTL), 멀티 스레드 (PTHREADS) 또는 비동기 작업 스케줄 (예 : SWOOLE, ReactPHP, AMP 등)과 같은 동시성 전략을 도입해야합니다.

2. 왜 Fetchall이 때때로 잘못된 "더 빠른"것으로 생각 되는가?

실제로 사용하면 FetchAll () ()는 중소형 결과 세트 에서 데이터를 배치로 반환하고 반복 된 I/O 작업을 피하기 때문에 더 잘 수행하지 않습니다. 그러나 일단 수백만 행의 데이터에 직면하면 메모리 서지 또는 PHP 프로세스 막힘을 유발할 수 있습니다.

따라서 동시 쿼리에서 fetchall ()을 사용하려면 구현 메커니즘의 일부일 뿐이며 실제 성능 최적화는 여전히 다음과 같습니다.

여러 데이터베이스 또는 테이블 파티션을 병렬로 연결합니다.
동시 비동기 모드를 통해 여러 SQL 요청을 시작합니다.
자식 스레드 또는 하위 프로세스에서 쿼리를 별도로 실행하고 FetchAll ()을 사용하여 하위 작업 데이터를 빠르게 가져옵니다.

3. 특정 구현 계획 (Swoole + PDO 기반)

Swoole은 비 차단 데이터베이스 작업을 구현할 수있는 Coroutine MySQL 클라이언트를 제공합니다. FetchAll () 과 결합하여 더 높은 처리량을 얻을 수 있습니다. 예는 다음과 같습니다.

<code> swoole \ coroutine 사용; Swoole \ coroutine \ mysql을 사용하십시오;

co \ run (function () {
$ queries = [
"30 세 이상의 사용자 중에서 선택 *",
"select *에서 status = 'pending', 주문에서 선택
"created_at> now () - 1 일 간격
];

 $results = [];

foreach ($queries as $i =&gt; $sql) {
    Coroutine::create(function () use (&$results, $i, $sql) {
        $db = new MySQL();
        $db-&gt;connect([
            'host' =&gt; 'm66.net',
            'user' =&gt; 'root',
            'password' =&gt; '123456',
            'database' =&gt; 'demo'
        ]);
        $stmt = $db-&gt;prepare($sql);
        if ($stmt) {
            $results[$i] = $stmt-&gt;execute();
        }
    });
}

// 모든 코 루틴이 끝날 때까지 기다립니다，처리 결과
Coroutine::sleep(1); // 간단한 대기，보다 고급 코 루틴 신호 처리를 사용할 수 있습니다
print_r($results);

});
</코드>

위의 코드에서 3 개의 SQL 쿼리는 동시에 실행되며, 각각 Coroutine 연결을 사용하고 Execute ()를 빠르게 호출합니다 (내부적으로 fetchall () 의 의미를 사용하는 것과 동일). 데이터베이스 호스트 이름은 m66.net을 사용합니다.

4. 예방 조치 및 최적화 제안

연결 풀 멀티플렉싱 : Swoole에서 제공 한 연결 풀을 사용하면 연결 오버 헤드가 줄어 듭니다.
하위 방출 및 테이블 지원 : 동시 쿼리는 특히 하위 방출 시나리오에서 효과적입니다.
자원 제한 : 자원이 과부하되는 것을 방지하기 위해 합리적인 수의 코 루틴 및 데이터베이스 연결을 설정하는 데주의를 기울입니다.
메모리 제어 : 결과 세트가 특히 크면 fetchall () 대신 fetch () + traversal을 사용하는 것이 좋습니다.

5. 요약

pdostatement :: fetchall () 자체는 멀티 스레딩 성능을 향상시키지 않고 데이터 단계를 추출하는 방법 일뿐입니다. 그러나 코 루틴 및 동시 실행 구조와 협력하는 경우 FetchAll ()은 데이터를 빠르게 재활용하기위한 강력한 도구가 될 수 있습니다. PHP에서 실제 멀티 스레드 동시 동시 쿼리를 구현하려면 Swoole 또는 기타 비동기 프레임 워크와 같은 코 루틴 메커니즘을 사용하여 단일 스레드 모델의 한계를 근본적으로 파괴하고 고성능 데이터 쿼리 시스템을 실현하는 것이 좋습니다.

PDOStatement::fetchAll