Senario aplikasi langganan dan penerbitan mesej Swoole dan Workerman dalam PHP dan MySQL

Swoole dan Workerman ialah dua rangka kerja komunikasi rangkaian berprestasi tinggi berdasarkan PHP Mereka mempunyai pelbagai senario aplikasi dalam langganan dan penerbitan mesej. Artikel ini akan meneroka aplikasi khusus Swoole dan Workerman dalam melaksanakan langganan dan penerbitan mesej dalam PHP dan MySQL, dan menyediakan contoh kod yang sepadan.

1. Pengenalan latar belakang
Dalam banyak aplikasi, adalah perlu untuk melaksanakan fungsi seperti tolak mesej masa nyata atau pemantauan acara, serta penjadualan tugas yang diedarkan. Kaedah pembangunan PHP tradisional biasanya menggunakan pengundian, yang bukan sahaja tidak cekap tetapi juga mengambil banyak sumber sistem. Swoole dan Workerman boleh menyediakan fungsi langganan dan penerbitan mesej berprestasi tinggi dalam cara tak segerak dan tidak menyekat.

2. Ciri-ciri Swoole dan Workerman

1. Swoole: Swoole ialah enjin komunikasi rangkaian berprestasi tinggi untuk bahasa PHP. Ia menyediakan set lengkap ciri utama seperti asynchronous, coroutine, dan multi-threading, dan telah menerima perhatian dan aplikasi yang meluas untuk prestasi tinggi dan kependaman rendahnya.
2. Workerman: Workerman ialah perpustakaan berasaskan peristiwa tak segerak PHP sumber terbuka untuk membina aplikasi rangkaian berprestasi tinggi dan boleh skala. Ia menggunakan pendekatan dipacu peristiwa dan menyediakan fungsi seperti pelayan TCP/UDP/SCTP, rangka kerja pembangunan, pengimbangan beban dan tugas tak segerak.

3. Senario aplikasi Swoole dan Workerman

1. Tekanan mesej masa nyata: Apabila terdapat mesej baharu yang perlu dihantar kepada pelanggan, anda boleh menggunakan fungsi WebSocket Swoole atau Workerman. Berikut ialah contoh kod untuk menggunakan Swoole untuk melaksanakan push mesej masa nyata:

<?php
$serv = new swoole_websocket_server("0.0.0.0", 9501);

$serv->on('open', function($serv, $request) {
    echo "client connected
";
});

$serv->on('message', function($serv, $frame) {
    foreach ($serv->connections as $fd) {
        $serv->push($fd, $frame->data);
    }
});

$serv->on('close', function($serv, $fd) {
    echo "client closed
";
});

$serv->start();

2. Pemantauan acara: Apabila peristiwa berlaku, anda boleh menggunakan Swoole dan Workerman untuk mendengar dan mengendalikan acara yang sepadan. Berikut adalah contoh kod yang menggunakan Workerman untuk melaksanakan pemantauan acara:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;

$worker = new Worker();
$worker->onWorkerStart = function($worker) {
    $worker->onMessage = function($connection, $data) {
        // 处理事件
        echo "event happened: " . $data . "
";
    };
};

Worker::runAll();

IV Aplikasi Swoole dan Workerman digabungkan dengan MySQL
Selain aplikasi dalam komunikasi rangkaian, Swoole dan Workerman juga boleh digabungkan dengan pangkalan data MySQL untuk dilaksanakan. fungsi langganan dan penerbitan mesej. Berikut ialah contoh kod yang menggunakan Swoole dan MySQL untuk melaksanakan langganan dan penerbitan mesej:

<?php
$server = new SwooleServer('0.0.0.0', 9501, SWOOLE_BASE);

$server->on('receive', function ($server, $fd, $from_id, $data) {
    $conn = new mysqli('localhost', 'username', 'password', 'database');
    if ($conn->connect_error) {
        echo "MySQL Connection Error: " . $conn->connect_error . "
";
        return;
    }

    // 消息入队
    $insert_sql = "INSERT INTO message_queue (message) VALUES ('$data')";
    $conn->query($insert_sql);

    $conn->close();
});

$server->on('workerStart', function ($server, $worker_id) {
    if ($worker_id === 0) {
        // 消息出队
        $timer = SwooleTimer::tick(1000, function () {
            $conn = new mysqli('localhost', 'username', 'password', 'database');
            if ($conn->connect_error) {
                echo "MySQL Connection Error: " . $conn->connect_error . "
";
                return;
            }

            $query_sql = "SELECT message FROM message_queue LIMIT 1";
            $result = $conn->query($query_sql);
            if ($result && $result->num_rows > 0) {
                $row = $result->fetch_assoc();
                // 处理消息
                echo "Processing message: " . $row['message'] . "
";
                // 消息出队
                $delete_sql = "DELETE FROM message_queue WHERE message = '" . $row['message'] . "'";
                $conn->query($delete_sql);
            }

            $conn->close();
        });
    }
});

$server->start();

Dalam kod di atas, operasi enqueue dan dequeue mesej dilaksanakan melalui baris gilir mesej Swoole, dengan itu merealisasikan fungsi langganan dan penerbitan mesej.

Ringkasan:
Sama ada dari segi tolak mesej masa nyata atau pemantauan acara, Swoole dan Workerman menyediakan penyelesaian berprestasi tinggi. Dengan menggabungkan dengan pangkalan data MySQL, senario aplikasi yang lebih kompleks dapat direalisasikan. Saya berharap melalui pengenalan dan contoh kod artikel ini, pembaca dapat memahami dengan lebih jelas tentang pelaksanaan langganan dan penerbitan mesej Swoole dan Workerman dalam PHP dan MySQL.

Atas ialah kandungan terperinci Senario aplikasi langganan dan penerbitan mesej Swoole dan Workerman dalam PHP dan MySQL. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!