Pembangunan pekerja: Cara melaksanakan pemesejan segera berdasarkan protokol WebSocket

Pembangunan Pekerja: Cara melaksanakan pemesejan segera berdasarkan protokol WebSocket

Pengenalan:
Dengan perkembangan pesat Internet, pemesejan segera telah menjadi cara penting untuk orang ramai berkomunikasi dalam kehidupan seharian. Sebagai protokol komunikasi dupleks penuh, protokol WebSocket boleh mencapai penghantaran data dua hala masa nyata, jadi ia digunakan secara meluas dalam bidang pemesejan segera. Artikel ini akan memperkenalkan cara menggunakan rangka kerja PHP Workerman untuk membangunkan aplikasi pemesejan segera berdasarkan protokol WebSocket, dan menyediakan contoh kod khusus.

1. Kerja penyediaan:
Sebelum memulakan pembangunan, kita perlu melakukan beberapa kerja persediaan.

1. Pasang Workerman:
   Workerman ialah rangka kerja pelayan soket tak segerak berprestasi tinggi yang dibangunkan dalam PHP, yang boleh membangunkan komunikasi WebSocket dengan mudah. Kita boleh menggunakan Komposer untuk memasang:

composer require workerman/workerman

2. Buat projek:
   Buat folder projek baharu pada pelayan web pilihan anda dan buat fail PHP baharu di dalamnya, seperti index.php< /code> . <code>index.php。
3. 引入Workerman：
   将以下代码添加到index.php文件中，引入Workerman的自动加载文件：

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

二、实现基本功能：
下面我们开始实现基于WebSocket协议的即时通讯。

1. 创建Worker对象：
   在index.php文件中，添加以下代码创建一个WebSocket服务器实例：

$ws_worker = new WorkermanWorker('websocket://0.0.0.0:8000');

2. 监听连接事件：
   添加以下代码监听连接事件，当有新的WebSocket连接时，会自动触发回调函数：

$ws_worker->onConnect = function ($connection) {
    echo "New connection
";
};

3. 监听消息事件：
   添加以下代码监听消息事件，当有WebSocket客户端发送消息时，会自动触发回调函数：

$ws_worker->onMessage = function ($connection, $data) {
    echo "Received message: $data
";
};

4. 监听关闭事件：
   添加以下代码监听关闭事件，当有WebSocket连接关闭时，会自动触发回调函数：

$ws_worker->onClose = function ($connection) {
    echo "Connection closed
";
};

5. 启动服务器：
   添加以下代码启动服务器，开始监听客户端的连接和消息：

WorkermanWorker::runAll();

三、完整示例代码：
下面是一个完整的示例代码，展示如何使用Workerman实现基于WebSocket协议的即时通讯：

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

$ws_worker = new WorkermanWorker('websocket://0.0.0.0:8000');
$ws_worker->onConnect = function ($connection) {
    echo "New connection
";
};
$ws_worker->onMessage = function ($connection, $data) {
    echo "Received message: $data
";
    $connection->send('Hello, ' . $data . '!');
};
$ws_worker->onClose = function ($connection) {
    echo "Connection closed
";
};

WorkermanWorker::runAll();

四、运行测试：
保存并启动index.php文件后，在浏览器中打开WebSocket客户端，连接到ws://localhost:8000

Perkenalkan Pekerja:

Tambahkan kod berikut pada fail index.php dan perkenalkan fail pemuatan automatik Workerman:

rrreee🎜 2. Laksanakan fungsi asas: 🎜 Seterusnya kita mula melaksanakan protokol WebSocket- berasaskan IM. 🎜🎜🎜Buat objek Pekerja: 🎜Dalam fail index.php, tambahkan kod berikut untuk mencipta instance pelayan WebSocket: 🎜🎜rrreee🎜🎜Dengar acara sambungan: 🎜Tambah kod berikut untuk mendengar untuk acara sambungan apabila terdapat Apabila sambungan WebSocket baharu dibuat, fungsi panggil balik akan dicetuskan secara automatik: 🎜🎜rrreee

🎜Dengar acara mesej: 🎜Tambah kod berikut untuk mendengar mesej acara. Apabila klien WebSocket menghantar mesej, fungsi panggil balik akan dicetuskan secara automatik ：🎜🎜rrreee
🎜Dengar acara penutup: 🎜Tambahkan kod berikut untuk mendengar acara penutup sambungan WebSocket ditutup, fungsi panggil balik akan dicetuskan secara automatik: 🎜🎜rrreee
🎜 Mulakan pelayan: 🎜Tambah kod berikut untuk memulakan pelayan dan mula mendengar sambungan dan mesej pelanggan: 🎜🎜 rrreee🎜 3. Kod sampel lengkap: 🎜Berikut ialah kod contoh lengkap yang menunjukkan cara menggunakan Workerman untuk melaksanakan pemesejan segera berdasarkan protokol WebSocket: 🎜 rrreee🎜4 Jalankan ujian:🎜Selepas menyimpan dan melancarkan indeks .php, buka klien WebSocket dalam penyemak imbas dan sambung ke ws://localhost:8000. Kemudian masukkan mesej di bahagian klien dan hantarkannya Anda boleh melihat mesej yang dicetak pada bahagian pelayan dan mengembalikan balasan yang sepadan. 🎜🎜Ringkasan: 🎜Artikel ini memperkenalkan cara menggunakan rangka kerja Workerman untuk membangunkan aplikasi pemesejan segera berdasarkan protokol WebSocket. Dengan mencipta objek Pekerja, mendengar sambungan, mesej dan acara penutup, kami boleh melaksanakan pelayan WebSocket komunikasi dua hala yang mudah. Melalui contoh kod di atas, anda boleh mengembangkan dan mengoptimumkan lagi aplikasi anda untuk memenuhi keperluan pemesejan segera yang lebih kompleks. 🎜

Atas ialah kandungan terperinci Pembangunan pekerja: Cara melaksanakan pemesejan segera berdasarkan protokol WebSocket. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!