PHP 및 MySQL에서 데이터 일괄 작업 및 일괄 작업 제출을 위한 Swoole 및 Workerman의 최적화 방법

PHP 및 MySQL의 데이터 일괄 작업 및 일괄 작업 제출을 위한 Swoole과 Workerman의 최적화 방법

PHP 개발에서 데이터베이스와의 상호 작용은 매우 일반적인 작업입니다. 그러나 데이터의 양이 많은 경우 한 번에 많은 양의 데이터를 데이터베이스에 제출하면 성능 저하가 발생할 수 있습니다. 이 문제를 해결하기 위해 Swoole과 Workerman을 사용하여 데이터의 일괄 작업을 구현하고 일괄 작업 제출을 최적화할 수 있습니다.

1. Swoole 사용
Swoole은 PHP용 다중 프로세스 모델 및 코루틴 모델을 지원할 수 있는 고성능 PHP 확장입니다. 다음은 데이터 일괄 작업 및 일괄 작업 제출을 위해 Swoole을 사용하기 위한 샘플 코드입니다.

<?php
// 创建Swoole进程
$worker = new SwooleProcess(function () {
    // 连接到数据库
    $db = new mysqli('localhost', 'root', 'password', 'database');
    
    // 批量操作数据
    $sql = 'INSERT INTO `table` (`id`, `name`) VALUES ';
    for ($i = 0; $i < 10000; $i++) {
        $sql .= '(' . ($i + 1) . ', "name' . ($i + 1) . '"),';
    }
    $sql = rtrim($sql, ',');

    // 执行SQL语句
    $db->query($sql);
    
    // 关闭数据库连接
    $db->close();
});

// 启动Swoole进程
$worker->start();

위 샘플 코드에서는 Swoole 프로세스를 생성하고 프로세스에서 mysqli를 사용하여 데이터베이스에 연결한 다음 SQL을 스플라이싱했습니다. 명령문 데이터에 대해 일괄 작업을 수행합니다. SQL 문을 실행한 후 데이터베이스 연결을 닫습니다.

2. Workerman의 사용
Workerman은 긴 연결과 다수의 동시 요청을 처리할 수 있는 메모리 상주 PHP 고성능 프레임워크입니다. 아래는 Workerman을 사용한 데이터 일괄 작업 및 일괄 작업 제출을 위한 샘플 코드입니다.

<?php
use WorkermanMySQLConnection;
use WorkermanWorker;

// 连接到数据库
$db = new Connection('host', 'port', 'user', 'password', 'database');

// 创建一个Worker监听端口
$worker = new Worker();

// 接收到数据后的回调函数
$worker->onMessage = function ($connection, $data) use ($db) {
    // 批量操作数据
    $sql = 'INSERT INTO `table` (`id`, `name`) VALUES ';
    for ($i = 0; $i < 10000; $i++) {
        $sql .= '(' . ($i + 1) . ', "name' . ($i + 1) . '"),';
    }
    $sql = rtrim($sql, ',');

    // 执行SQL语句
    $db->query($sql);
    
    // 返回结果
    $connection->send('Data inserted successfully');
};

// 运行Worker
Worker::runAll();

위 샘플 코드에서는 먼저 Workerman의 MySQL 연결 클래스를 사용하여 데이터베이스에 연결합니다. 그런 다음 Worker 인스턴스를 생성하고 onMessage 콜백 함수를 통해 수신된 데이터를 처리합니다. 콜백 함수에서는 동일한 메소드를 사용하여 일괄 작업 및 데이터 제출을 수행하고 send 메소드를 통해 결과를 반환합니다.

3. 일괄 작업 및 제출 최적화
위 예제 코드에서는 SQL 문을 연결하는 방법을 사용하여 일괄 작업 및 데이터 제출을 수행합니다. 그러나 데이터 양이 매우 큰 경우 이 접근 방식은 문자열 연결에 성능 문제를 일으킬 수 있습니다. 배치 작업 및 커밋을 최적화하기 위해 준비된 문과 트랜잭션을 사용하여 성능을 향상시킬 수 있습니다. 다음은 준비된 문과 트랜잭션을 이용한 일괄 데이터 작업 및 제출을 위한 샘플 코드입니다.

<?php
// 连接到数据库
$db = new mysqli('localhost', 'root', 'password', 'database');

// 开启事务
$db->begin_transaction();

// 预处理SQL语句
$stmt = $db->prepare('INSERT INTO `table` (`id`, `name`) VALUES (?, ?)');

// 批量操作数据
for ($i = 0; $i < 10000; $i++) {
    $id = $i + 1;
    $name = 'name' . $id;
    $stmt->bind_param('is', $id, $name);
    $stmt->execute();
}

// 提交事务
$db->commit();

// 关闭数据库连接
$db->close();

위 샘플 코드에서는 먼저 mysqli를 사용하여 데이터베이스에 연결하고 Begin_transaction 메서드를 통해 트랜잭션을 시작합니다. 그런 다음 준비 메서드를 사용하여 SQL 문을 전처리하고, Bind_param을 통해 매개 변수를 바인드하여 일괄 작업의 효과를 얻습니다. 마지막으로 커밋 메소드를 통해 트랜잭션을 제출하여 일괄 작업 및 제출을 완료합니다. 코드 실행이 완료되면 데이터베이스 연결을 닫습니다.

최적화된 배치 작업 및 제출 방법을 통해 PHP 및 MySQL의 성능을 향상시키고 대용량 데이터를 처리할 때 효율성을 높일 수 있습니다. 동시에 Swoole 및 Workerman과 같은 고성능 프레임워크를 사용하면 PHP의 동시성 기능을 크게 향상시키고 프로그램 성능을 더욱 향상시킬 수 있습니다.

위 내용은 PHP 및 MySQL에서 데이터 일괄 작업 및 일괄 작업 제출을 위한 Swoole 및 Workerman의 최적화 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!