Cara menggunakan Swoole untuk melaksanakan sistem tolak mesej segera berprestasi tinggi

Dengan pembangunan aplikasi Internet yang berterusan, tolakan mesej segera dalam talian telah menjadi salah satu fungsi penting pelbagai aplikasi dalam talian. Dalam aplikasi web tradisional, tolakan mesej segera biasanya memerlukan penggunaan pengundian, tinjauan panjang dan teknologi lain. Walau bagaimanapun, teknologi ini mempunyai masalah seperti kecekapan rendah dan pembaziran sumber. Sistem tolakan mesej segera berprestasi tinggi berdasarkan Swoole boleh menyelesaikan masalah ini dengan baik.

Swoole ialah sambungan PHP yang dibangunkan berdasarkan C++, yang menyediakan sokongan pengaturcaraan rangkaian berprestasi tinggi seperti IO tak segerak, berbilang proses dan coroutine. Dengan menggunakan protokol seperti WebSocket dan HTTP dalam Swoole, kami boleh membina sistem tolak mesej segera berprestasi tinggi dengan mudah.

Di bawah, kami akan memperkenalkan cara menggunakan Swoole untuk melaksanakan sistem tolak mesej segera berprestasi tinggi.

Pertama, kita perlu menyediakan persekitaran Swoole. Di sini kami menggunakan sistem pengendalian CentOS 7.6 dan PHP 7.2.

Proses pembinaan khusus adalah seperti berikut:

1. Pasang epel-release dan remi-release sources

yum install epel-release
rpm -Uvh http://rpms.famillecollet.com/enterprise/remi-release-7.rpm

2. Pasang PHP 7.2

yum install --enablerepo=remi-php72 php php-fpm php-mcrypt php-cli php-gd php-curl php-mysql php-ldap php-zip php-fileinfo

.

3. Swo
Pasang Swo

Sambungan semula

e Sambungan Swoole

Dalam php.ini Tambah kandungan berikut pada fail:

pecl install swoole

Mulakan perkhidmatan Swoole

Kami memulakan perkhidmatan melalui pelayan HTTP terbina dalam Swoole, kodnya adalah seperti berikut:

extension=swoole.so

Selepas menjalankan kod di atas, masukkan http://127.0.0.1 dalam pelayar :9501, anda boleh melihat output "Hello World".

Seterusnya, kami akan menggunakan Swoole untuk melaksanakan sistem tolak mesej segera. Proses pelaksanaan khusus adalah seperti berikut:

Tentukan pelayan WebSocket

Kami menggunakan pelayan WebSocket yang disediakan oleh Swoole untuk melaksanakan push mesej segera Kod adalah seperti berikut:

<?php
$server = new swoole_http_server("0.0.0.0", 9501);

$server->on("request", function ($request, $response) {
    $response->header("Content-Type", "text/plain");
    $response->end("Hello World
");
});

$server->start();

Selepas pelanggan membuka sambungan WebSocket, Swoole. secara automatik akan mencetuskan peristiwa "terbuka" dan maklumat sambungan Output. Apabila pelanggan menghantar mesej, Swoole akan mencetuskan acara "mesej" dan memanggil fungsi handleMessage untuk memproses mesej. Akhir sekali, apabila pelanggan menutup sambungan WebSocket, Swoole akan mencetuskan acara "tutup" dan mengeluarkan maklumat penutup.

Memproses mesej

Dalam fungsi handleMessage, kita boleh memproses mesej yang dihantar oleh pelanggan dan menolak mesej yang diproses kepada semua pelanggan melalui kaedah $server->push. Kod pelaksanaan khusus adalah seperti berikut:

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

$server->on("open", function (swoole_websocket_server $server, $request) {
    echo "Client #{$request->fd} connected
";
});

$server->on("message", function (swoole_websocket_server $server, $frame) {
    echo "Received message: {$frame->data}
";

    // 处理消息
    handleMessage($server, $frame->data);
});

$server->on("close", function (swoole_websocket_server $server, $fd) {
    echo "Client #{$fd} disconnected
";
});

function handleMessage($server, $data) {
    // 处理消息并推送给所有客户端
    $server->push($frame->fd, $response);
}

$server->start();

Dengan memproses acara tertentu mengikut jenis mesej dalam fungsi handleMessage, sistem tolak mesej segera kami boleh dibuat lebih fleksibel dan berskala.

Gunakan Swoole coroutine

Dalam pengundian tradisional dan teknologi tinjauan panjang, setiap sambungan akan menduduki urutan atau proses, yang akan menyebabkan pembaziran sumber dan prestasi rendah. Swoole mengelakkan masalah ini dan meningkatkan prestasi dengan menggunakan coroutine.

Kod pelaksanaan khusus adalah seperti berikut:

function handleMessage($server, $data) {
    $message = json_decode($data, true);

    switch ($message['type']) {
        case 'login':
            // 处理用户登录事件
            // ...
            break;

        case 'message':
            // 处理用户发送消息事件
            // ...
            break;

        default:
            // 处理未知消息
            // ...
            break;
    }

    // 将处理后的消息推送给所有客户端
    $response = json_encode($message);
    foreach ($server->connections as $fd) {
        $server->push($fd, $response);
    }
}

Dengan menggunakan coroutine Swoole, kita boleh mengelakkan pembaziran sumber dalam urutan dan proses, dan pada masa yang sama mencapai struktur kod yang lebih cekap dan kelajuan yang lebih pantas.

Ringkasnya, menggunakan Swoole untuk melaksanakan sistem tolak mesej segera berprestasi tinggi boleh mengelakkan masalah seperti ketidakcekapan dan pembaziran sumber dalam kaedah tradisional Pada masa yang sama, menggunakan coroutine juga boleh meningkatkan prestasi sistem. Oleh itu, jika anda perlu membina sistem pemesejan segera berprestasi tinggi, menggunakan Swoole akan menjadi pilihan yang baik.

Atas ialah kandungan terperinci Cara menggunakan Swoole untuk melaksanakan sistem tolak mesej segera berprestasi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!