Cara menggunakan Swoole untuk melaksanakan pelayan WebSocket dan interaksi pangkalan data

Cara menggunakan Swoole untuk melaksanakan pelayan WebSocket dan interaksi pangkalan data

Pengenalan:
WebSocket ialah protokol komunikasi dupleks penuh berdasarkan protokol TCP, yang boleh mewujudkan komunikasi dua hala masa nyata antara pelanggan dan pelayan . Swoole ialah sambungan PHP yang boleh melaksanakan pengaturcaraan tak segerak dan serentak berprestasi tinggi dengan mudah. Dalam artikel ini, kami akan memperkenalkan secara terperinci cara menggunakan Swoole untuk membina pelayan WebSocket dan berinteraksi dengan pangkalan data.

Langkah 1: Pasang sambungan Swoole

Mula-mula, kita perlu memasang sambungan Swoole. Ia boleh dipasang melalui arahan berikut:

pecl install swoole

Langkah 2: Buat pelayan WebSocket

Seterusnya, kami mencipta pelayan WebSocket, mendengar port yang ditentukan, dan mewujudkan sambungan dengan klien. Ini boleh dicapai menggunakan kod berikut:

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

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new connection open: {$request->fd}
";
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
    
    // 处理数据库交互
    $db = new mysqli('localhost', 'username', 'password', 'database');
    $result = $db->query("SELECT * FROM users");
    while ($row = $result->fetch_assoc()) {
        $server->push($frame->fd, json_encode($row));
    }
    $db->close();
});

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

$server->start();
?>

Dalam kod di atas, kami mencipta pelayan WebSocket dan menambah tiga fungsi panggil balik acara. Apabila sambungan diwujudkan, acara open akan dicetuskan apabila mesej diterima, acara message akan dicetuskan apabila sambungan ditutup, ; acara tutup akan dicetuskan. Dalam acara message, kami boleh melaksanakan operasi interaktif pangkalan data. open事件将被触发；当收到消息时，message事件将被触发；当连接关闭时，close事件将被触发。在message事件中，我们可以进行数据库的交互操作。

步骤三：与数据库交互

在message事件回调函数中，我们使用了MySQLi扩展来与数据库进行交互。首先，我们创建了一个$db对象，并使用mysqli的构造函数连接到数据库。接着，我们执行了一条查询语句，并通过while循环将查询结果发送给客户端。最后，我们关闭了数据库连接。

需要注意的是，为了安全起见，我们应该将数据库的相关信息（如用户名和密码）设置为环境变量，并通过getenv()函数来获取这些值，以避免直接暴露在代码中。

步骤四：运行服务器

最后，我们使用命令行来运行上述代码。在命令行中切换到代码所在的目录，并执行以下命令：

php server.php

如果一切正常，你将看到WebSocket服务器成功启动，并等待客户端的连接。当有客户端连接到服务器时，open事件将被触发，并在命令行中显示连接的ID。当收到客户端发来的消息时，message事件将被触发，并在命令行中显示收到的消息。当连接关闭时，close事件将被触发，同样在命令行中显示连接的关闭。

总结：
本文详细介绍了如何使用Swoole实现WebSocket服务器与数据库的交互。通过创建WebSocket服务器，并在message

Langkah 3: Berinteraksi dengan pangkalan data 🎜🎜Dalam fungsi panggil balik acara mesej, kami menggunakan sambungan MySQLi untuk berinteraksi dengan pangkalan data. Mula-mula, kami mencipta objek $db dan menggunakan pembina mysqli untuk menyambung ke pangkalan data. Seterusnya, kami melaksanakan pernyataan pertanyaan dan menghantar hasil pertanyaan kepada klien melalui gelung while. Akhirnya, kami menutup sambungan pangkalan data. 🎜🎜Perlu diambil perhatian bahawa atas sebab keselamatan, kita harus menetapkan maklumat berkaitan pangkalan data (seperti nama pengguna dan kata laluan) sebagai pembolehubah persekitaran dan mendapatkan nilai ini melalui fungsi getenv() untuk mengelakkan langsung terdedah dalam kod. 🎜🎜Langkah 4: Jalankan pelayan🎜🎜Akhir sekali, kami menggunakan baris arahan untuk menjalankan kod di atas. Beralih ke direktori di mana kod terletak pada baris arahan dan laksanakan arahan berikut: 🎜rrreee🎜 Jika semuanya berjalan lancar, anda akan melihat bahawa pelayan WebSocket bermula dengan jayanya dan sedang menunggu pelanggan untuk menyambung. Apabila pelanggan menyambung ke pelayan, acara open akan dicetuskan dan ID sambungan akan dipaparkan pada baris arahan. Apabila mesej daripada klien diterima, acara message akan dicetuskan dan mesej yang diterima akan dipaparkan pada baris arahan. Apabila sambungan ditutup, acara close akan dicetuskan dan penutupan sambungan juga akan dipaparkan pada baris arahan. 🎜🎜Ringkasan: 🎜Artikel ini memperincikan cara menggunakan Swoole untuk melaksanakan interaksi antara pelayan WebSocket dan pangkalan data. Dengan mencipta pelayan WebSocket dan melakukan interaksi pangkalan data dalam fungsi panggil balik acara mesej, kami boleh mencapai komunikasi dua hala masa nyata. Menggunakan sambungan Swoole, kami boleh melakukan pengaturcaraan tak segerak dan serentak berprestasi tinggi dengan mudah. Saya harap artikel ini akan membantu anda dalam menggunakan Swoole untuk berinteraksi dengan pangkalan data. 🎜

Atas ialah kandungan terperinci Cara menggunakan Swoole untuk melaksanakan pelayan WebSocket dan interaksi pangkalan data. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!