PHP および MySQL での大規模データのクエリと送信のための Swoole と Workerman の最適化手法

Swoole と Workerman は、PHP 用の 2 つの高性能ネットワーク フレームワークであり、大量のデータのクエリと送信のための特定の最適化メソッドを備えています。この記事では、これら 2 つのフレームワークに焦点を当て、特に PHP と MySQL での大規模データのクエリと送信の最適化方法を紹介し、対応するコード例を示します。

1. PHP および MySQL の大規模データのクエリと送信のための Swoole の最適化方法:

1. コルーチンの使用: Swoole はコルーチンをサポートしており、コルーチンを通じてノンブロッキング非同期を実現できます。 O オペレーションにより、クエリと送信の効率が向上します。コルーチンを使用すると、スレッド切り替えのオーバーヘッドを回避し、同時実行パフォーマンスを向上させることができます。

以下は、MySQL クエリに Swoole コルーチンを使用するためのサンプル コードです:

<?php
Coun(function () {
    $db = new SwooleCoroutineMySQL();
    $db->connect([
        'host' => '127.0.0.1',
        'port' => 3306,
        'user' => 'root',
        'password' => '123456',
        'database' => 'test',
    ]);

    // 开始协程
    go(function () use ($db) {
        $result = $db->query('SELECT * FROM table');
        var_dump($result);
    });

    // 开始协程
    go(function () use ($db) {
        $result = $db->query('SELECT * FROM table2');
        var_dump($result);
    });
});
?>

2. 接続プールの使用: Swoole は、接続プールを使用して MySQL との接続を管理し、パフォーマンスを向上させるために、頻繁に接続を個別に作成および破棄することを避けてください。

以下は、MySQL クエリに Swoole 接続プールを使用するためのサンプル コードです:

<?php
$dbPool = new SwooleCoroutineChannel(10); // 设置连接池大小为10

$dbConfig = [
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'root',
    'password' => '123456',
    'database' => 'test',
];

for ($i = 0; $i < 10; $i++) {
    go(function () use ($dbConfig, $dbPool) {
        $db = new SwooleCoroutineMySQL();
        $db->connect($dbConfig);
        $dbPool->push($db); // 将连接放入连接池
    });
}

go(function () use ($dbPool) {
    $db = $dbPool->pop(); // 从连接池中取出一个连接
    $result = $db->query('SELECT * FROM table');
    var_dump($result);
    $dbPool->push($db); // 将连接放回连接池
});
?>

2. PHP および MySQL の大規模データ クエリと送信のための Workerman の最適化方法:

1. マルチプロセス クエリ: Workerman はマルチプロセス モデルをサポートしており、マルチプロセス クエリを通じてクエリ効率を向上させることができます。 PHP の fork 関数を使用して子プロセスを作成でき、各子プロセスがクエリ タスクを担当します。

以下は、Workerman マルチプロセス クエリ MySQL を使用するためのサンプル コードです:

<?php
use WorkermanWorker;
use WorkermanConnectionTcpConnection;

$worker = new Worker();
$worker->count = 4; // 设置进程数为4

$worker->onWorkerStart = function ($worker) {
    $db = new mysqli('127.0.0.1', 'root', '123456', 'test');
    if ($db->connect_errno) {
        printf("Connect failed: %s
", $db->connect_error);
        exit();
    }

    // 每个进程中的回调函数单独查询数据
    $worker->onMessage = function (TcpConnection $connection, $data) use ($db) {
        $result = $db->query('SELECT * FROM table');
        $connection->send($result->fetch_all(MYSQLI_ASSOC));
    };
};

Worker::runAll();
?>

2. キャッシュの使用: Workerman はキャッシュを使用してクエリ結果を保存し、複数のクエリを回避できます。キャッシュ機能は、PHP の memcached 拡張機能または Redis 拡張機能を使用して実装できます。

以下は、Workerman を使用してクエリ結果をキャッシュする (キャッシュとして Redis を使用) ためのサンプル コードです:

<?php
use WorkermanWorker;
use WorkermanConnectionTcpConnection;
use WorkermanlibTimer;
use PredisClient;

$worker = new Worker();
$worker->count = 4;

$redis = new Client(array(
    'scheme' => 'tcp',
    'host'   => '127.0.0.1',
    'port'   => 6379,
));

$worker->onWorkerStart = function ($worker) use ($redis) {
    // 查询数据并存入缓存
    $current_time = time();
    $result = $redis->get('data');
    if (!$result) {
        $db = new mysqli('127.0.0.1', 'root', '123456', 'test');
        if ($db->connect_errno) {
            printf("Connect failed: %s
", $db->connect_error);
            exit();
        }
        $result = $db->query('SELECT * FROM table');
        $redis->set('data', serialize($result));
        $redis->expire('data', 60); // 设置缓存失效时间为60秒
        $db->close();
    } else {
        $result = unserialize($result);
    }

    // 每个进程中的回调函数返回缓存结果
    $worker->onMessage = function (TcpConnection $connection, $data) use ($result) {
        $connection->send($result);
    };
};

// 定期更新缓存
$worker->onWorkerStart = function ($worker) use ($redis) {
    Timer::add(60, function () use ($redis, $worker) {
        $db = new mysqli('127.0.0.1', 'root', '123456', 'test');
        if ($db->connect_errno) {
            printf("Connect failed: %s
", $db->connect_error);
            exit();
        }
        $result = $db->query('SELECT * FROM table');
        $redis->set('data', serialize($result));
        $db->close();

        // 更新每个进程中的结果
        foreach ($worker->connections as $connection) {
            $connection->send($result);
        }
    });
};

Worker::runAll();
?>

上記は、PHP および MySQL 大規模向けの Swoole と Workerman の最適化です。データのクエリと送信 メソッドの詳細な紹介と、対応するコード例。 Swoole のコルーチンと接続プール、Workerman のマルチプロセスとキャッシュを使用することで、PHP や MySQL での大規模なデータのクエリと送信の効率を向上させ、システムのパフォーマンスを向上させることができます。

以上がPHP および MySQL での大規模データのクエリと送信のための Swoole と Workerman の最適化手法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。