


Cara menggunakan Swoole untuk melaksanakan pelayan WebSocket dan interaksi pangkalan data
Nov 07, 2023 am 09:32 AMCara 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
事件將被觸發(fā);當收到消息時,message
事件將被觸發(fā);當連接關閉時,close
事件將被觸發(fā)。在message
事件中,我們可以進行數據庫的交互操作。
步驟三:與數據庫交互
在message
事件回調函數中,我們使用了MySQLi擴展來與數據庫進行交互。首先,我們創(chuàng)建了一個$db
對象,并使用mysqli
的構造函數連接到數據庫。接著,我們執(zhí)行了一條查詢語句,并通過while
循環(huán)將查詢結果發(fā)送給客戶端。最后,我們關閉了數據庫連接。
需要注意的是,為了安全起見,我們應該將數據庫的相關信息(如用戶名和密碼)設置為環(huán)境變量,并通過getenv()
函數來獲取這些值,以避免直接暴露在代碼中。
步驟四:運行服務器
最后,我們使用命令行來運行上述代碼。在命令行中切換到代碼所在的目錄,并執(zhí)行以下命令:
php server.php
如果一切正常,你將看到WebSocket服務器成功啟動,并等待客戶端的連接。當有客戶端連接到服務器時,open
事件將被觸發(fā),并在命令行中顯示連接的ID。當收到客戶端發(fā)來的消息時,message
事件將被觸發(fā),并在命令行中顯示收到的消息。當連接關閉時,close
事件將被觸發(fā),同樣在命令行中顯示連接的關閉。
總結:
本文詳細介紹了如何使用Swoole實現(xiàn)WebSocket服務器與數據庫的交互。通過創(chuàng)建WebSocket服務器,并在message
$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!

Alat AI Hot

Undress AI Tool
Gambar buka pakaian secara percuma

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Clothoff.io
Penyingkiran pakaian AI

Video Face Swap
Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Keluaran terbaharu Apple bagi sistem iOS18, iPadOS18 dan macOS Sequoia telah menambah ciri penting pada aplikasi Photos, yang direka untuk membantu pengguna memulihkan foto dan video yang hilang atau rosak dengan mudah disebabkan pelbagai sebab. Ciri baharu ini memperkenalkan album yang dipanggil "Dipulihkan" dalam bahagian Alat pada apl Foto yang akan muncul secara automatik apabila pengguna mempunyai gambar atau video pada peranti mereka yang bukan sebahagian daripada pustaka foto mereka. Kemunculan album "Dipulihkan" menyediakan penyelesaian untuk foto dan video yang hilang akibat kerosakan pangkalan data, aplikasi kamera tidak disimpan ke pustaka foto dengan betul, atau aplikasi pihak ketiga yang menguruskan pustaka foto. Pengguna hanya memerlukan beberapa langkah mudah

Data JSON boleh disimpan ke dalam pangkalan data MySQL dengan menggunakan perpustakaan gjson atau fungsi json.Unmarshal. Pustaka gjson menyediakan kaedah kemudahan untuk menghuraikan medan JSON dan fungsi json.Unmarshal memerlukan penuding jenis sasaran kepada data JSON unmarshal. Kedua-dua kaedah memerlukan penyediaan pernyataan SQL dan melaksanakan operasi sisipan untuk mengekalkan data ke dalam pangkalan data.

MySQL adalah sistem pengurusan pangkalan data sumber terbuka. 1) Buat Pangkalan Data dan Jadual: Gunakan perintah Createdatabase dan Createtable. 2) Operasi Asas: Masukkan, Kemas kini, Padam dan Pilih. 3) Operasi lanjutan: Sertai, subquery dan pemprosesan transaksi. 4) Kemahiran Debugging: Semak sintaks, jenis data dan keizinan. 5) Cadangan Pengoptimuman: Gunakan indeks, elakkan pilih* dan gunakan transaksi.

Untuk mengendalikan ralat sambungan pangkalan data dalam PHP, anda boleh menggunakan langkah berikut: Gunakan mysqli_connect_errno() untuk mendapatkan kod ralat. Gunakan mysqli_connect_error() untuk mendapatkan mesej ralat. Dengan menangkap dan mengelog mesej ralat ini, isu sambungan pangkalan data boleh dikenal pasti dan diselesaikan dengan mudah, memastikan kelancaran aplikasi anda.

Punca dan penyelesaian untuk kesilapan Apabila menggunakan PECL untuk memasang sambungan dalam persekitaran Docker Apabila menggunakan persekitaran Docker, kami sering menemui beberapa sakit kepala ...

Oracle bukan sahaja syarikat pangkalan data, tetapi juga pemimpin dalam pengkomputeran awan dan sistem ERP. 1. Oracle menyediakan penyelesaian yang komprehensif dari pangkalan data ke perkhidmatan awan dan sistem ERP. 2. Oraclecloud mencabar AWS dan Azure, menyediakan perkhidmatan IaaS, PaaS dan SaaS. 3. Sistem ERP Oracle seperti E-BusinessSuite dan FusionApplications membantu perusahaan mengoptimumkan operasi.

MySQL adalah sistem pengurusan pangkalan data relasi sumber terbuka, terutamanya digunakan untuk menyimpan dan mengambil data dengan cepat dan boleh dipercayai. Prinsip kerjanya termasuk permintaan pelanggan, resolusi pertanyaan, pelaksanaan pertanyaan dan hasil pulangan. Contoh penggunaan termasuk membuat jadual, memasukkan dan menanyakan data, dan ciri -ciri canggih seperti Operasi Join. Kesalahan umum melibatkan sintaks SQL, jenis data, dan keizinan, dan cadangan pengoptimuman termasuk penggunaan indeks, pertanyaan yang dioptimumkan, dan pembahagian jadual.

MySQL sesuai untuk aplikasi web dan sistem pengurusan kandungan dan popular untuk sumber terbuka, prestasi tinggi dan kemudahan penggunaan. 1) Berbanding dengan PostgreSQL, MySQL melakukan lebih baik dalam pertanyaan mudah dan operasi membaca serentak yang tinggi. 2) Berbanding dengan Oracle, MySQL lebih popular di kalangan perusahaan kecil dan sederhana kerana sumber terbuka dan kos rendah. 3) Berbanding dengan Microsoft SQL Server, MySQL lebih sesuai untuk aplikasi silang platform. 4) Tidak seperti MongoDB, MySQL lebih sesuai untuk data berstruktur dan pemprosesan transaksi.
