Penyepaduan Swoole dan Redis: Bina sistem IM ketersediaan tinggi dengan pantas

Dengan peningkatan Internet mudah alih, sistem pemesejan segera (IM) telah menjadi bahagian yang amat diperlukan dalam kehidupan seharian kita. Oleh itu, membangunkan sistem IM yang praktikal dan berprestasi tinggi telah menjadi salah satu matlamat yang dikejar oleh banyak pembangun. Dalam proses ini, Swoole dan Redis ialah dua alatan prestasi yang biasa digunakan yang boleh membantu kami membina sistem IM ketersediaan tinggi dengan cepat.

Artikel ini akan memperkenalkan konsep dan prinsip asas Swoole dan Redis, serta memberikan kes seni bina sistem IM dan pelan pelaksanaan berdasarkan dua alatan ini. Saya berharap melalui artikel ini, pembaca dapat memahami cara menggunakan kedua-dua alat ini untuk membina sistem IM berprestasi tinggi.

1. Gambaran Keseluruhan Swoole dan Redis

1.1 Swoole

Swoole ialah rangka kerja rangkaian lanjutan berdasarkan PHP Ia adalah enjin bahagian pelayan berprestasi tinggi yang tidak segerak sepenuhnya yang menyokong protokol TCP, UDP, WebSocket dan HTTP. Swoole boleh meningkatkan prestasi dan keselarasan proses PHP dengan ketara, terutamanya kerana mekanisme reactonya berdasarkan epoll atau kqueue, yang menggunakan teknologi coroutine untuk melaksanakan pengaturcaraan tak segerak tanpa sekatan.

1.2 Redis

Redis ialah pangkalan data nilai kunci dalam memori sumber terbuka yang menyokong pelbagai struktur data, termasuk rentetan, cincang, senarai, set dan set tersusun. Redis mempunyai prestasi tinggi dan berskala serta boleh mengendalikan berjuta-juta permintaan serentak. Redis digunakan terutamanya dalam senario seperti caching, baris gilir mesej dan kunci yang diedarkan.

2. Integrasi Swoole dan Redis

2.1 Cara Swoole berfungsi dengan Redis

Biasanya terdapat dua cara untuk menggunakan Redis dalam Swoole:

• Gunakan klien Swoole Redis
• Gunakan klien Swoole Coroutine Redis

Antaranya, klien Swoole Redis ialah klien Redis tradisional dan perlu menggunakan fungsi panggil balik untuk memproses respons permintaan ; Pelanggan Redis mengendalikan permintaan dan respons melalui coroutine, yang lebih mudah dan cekap untuk digunakan.

2.2 Penerangan Seni Bina

Untuk mencapai komunikasi masa nyata, sistem IM biasanya menggunakan protokol WebSocket untuk menghantar mesej. Dalam artikel ini, kami akan membina pelayan WebSocket berdasarkan Swoole dan Redis Mesej yang dihantar oleh pelanggan akan disimpan dalam Redis dan kemudian ditolak kepada pelanggan lain melalui pelayan.

• 1. Pelanggan menghantar mesej ke pelayan WebSocket
• 2. Pelayan WebSocket menyimpan mesej ke Redis
• 3. Redis menolak mesej ke pelayan
• 4. Pelayan WebSocket menolak mesej kepada pelanggan lain

3. Pelan pelaksanaan

Seterusnya, kami akan memperkenalkan pelan pelaksanaan secara terperinci untuk setiap langkah.

Kod pelayan 3.1

(1) Mulakan pelayan WebSocket

Gunakan API pelayan WebSocket yang disediakan oleh Swoole untuk memulakan pelayan, kodnya adalah seperti berikut:

$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $frame) {
    echo "connection open
";
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    $redis = new SwooleCoroutineRedis();
    $redis->connect('127.0.0.1', 6379);
    $redis->lPush('messages', $frame->data);
});

$server->on('close', function (SwooleWebSocketServer $server, $fd) {
    echo "connection close
";
});

$server->start();

Ini Dalam coretan kod, kami menggunakan fungsi $server->on() untuk menetapkan fungsi panggilan balik acara buka, mesej dan tutup WebSocket. Apabila pelanggan menyambung ke pelayan, kod dalam fungsi terbuka akan dilaksanakan apabila pelanggan menghantar mesej kepada pelayan, kod dalam fungsi mesej akan dilaksanakan. Dalam fungsi mesej, kami mencipta klien Coroutine Redis dan cache mesej yang dihantar oleh klien ke dalam baris gilir Redis.

(2) Tekan mesej kepada pelanggan

Seterusnya, kita perlu melaksanakan logik pelayan menolak mesej kepada pelanggan. Ini boleh dicapai menggunakan fungsi push() yang disediakan oleh Swoole Kodnya adalah seperti berikut:

// 推送消息给客户端
$server->tick(1000, function () use ($server) {
    $redis = new SwooleCoroutineRedis();
    $redis->connect('127.0.0.1', 6379);

    while ($message = $redis->rPop('messages')) {
        foreach ($server->connections as $fd) {
            $server->push($fd, $message);
        }
    }
});

Dalam kod ini, kami menggunakan fungsi tick() yang disediakan oleh Swoole untuk melaksanakan kod dengan kerap, dan menggunakan kod ini. Pelanggan Coroutine Redis untuk melaksanakan kod daripada Redis Dapatkan mesej dan tolak mesej kepada semua pelanggan.

3.2 Kod pelanggan

Kod klien agak mudah Kami hanya perlu menggunakan klien WebSocket untuk menyambung ke pelayan WebSocket dan menghantar serta menerima data melalui JavaScript. Kodnya adalah seperti berikut:

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>IM System</title>
</head>
<body>
    <h1>IM System</h1>
    <form>
        <label for="name">Name:</label>
        <input type="text" id="name">
        <br><br>
        <label for="message">Message:</label>
        <input type="text" id="message">
        <br><br>
        <input type="submit" value="Send Message">
    </form>
    <br><br>
    <div id="message-list"></div>
    <script>
        var socket = new WebSocket('ws://localhost:9501');

        socket.onopen = function(event) {
            console.log('WebSocket connect succeed');
        };

        socket.onmessage = function(event) {
            var message = JSON.parse(event.data);

            var messageList = document.getElementById('message-list');
            var p = document.createElement('p');
            p.innerText = message.name + ": " + message.message;
            messageList.prepend(p);
        };

        document.querySelector('form').addEventListener('submit', function(event) {
            event.preventDefault();

            var name = document.getElementById('name').value;
            var message = document.getElementById('message').value;

            socket.send(JSON.stringify({
                name: name,
                message: message
            }));

            document.getElementById('message').value = "";
        });
    </script>
</body>
</html>

Dalam kod ini, kami mula-mula menggunakan klien WebSocket untuk menyambung ke pelayan WebSocket. Apabila pelanggan berjaya menyambung, kami boleh menghantar mesej kepada pelayan melalui kaedah send() objek WebSocket dalam JavaScript Kami juga perlu menetapkan fungsi panggilan balik onmessage untuk menerima mesej yang ditolak oleh pelayan.

4. Ringkasan

Dalam artikel ini, kami memperkenalkan konsep dan prinsip asas Swoole dan Redis, dan berkongsi kes seni bina pelayan WebSocket dan pelan pelaksanaan berdasarkan Swoole dan Redis. Melalui kes ini, kita boleh mempelajari cara Swoole dan Redis bekerjasama untuk membina sistem IM berprestasi tinggi dan ketersediaan tinggi.

Sudah tentu, ini hanyalah contoh mudah Dalam amalan, banyak aspek perlu dipertimbangkan, seperti keselamatan, pengoptimuman prestasi, dll. Saya berharap agar pembaca dapat mempelajari penggunaan kedua-dua alatan ini melalui artikel ini Saya juga berharap agar pembaca dapat terus mengkaji kedua-dua alatan ini dan teknologi lain yang berkaitan dengan lebih mendalam dan memberi lebih banyak sumbangan kepada pembangunan aplikasi berprestasi tinggi.

Atas ialah kandungan terperinci Penyepaduan Swoole dan Redis: Bina sistem IM ketersediaan tinggi dengan pantas. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!