PHP dan WebSocket: penyelesaian yang cekap untuk menolak mesej masa nyata

PHP dan WebSocket: Penyelesaian yang cekap untuk push mesej masa nyata

Dalam aplikasi web, push mesej masa nyata adalah keperluan biasa. Model respons permintaan tradisional berdasarkan protokol HTTP tidak dapat memenuhi keperluan masa nyata, jadi teknologi lain perlu digunakan untuk mencapai push mesej masa nyata. WebSocket ialah teknologi yang boleh mewujudkan sambungan berterusan antara penyemak imbas dan pelayan, yang boleh mencapai tolakan mesej masa nyata dan lebih baik dari segi prestasi dan sumber pelayan daripada kaedah pengundian tradisional.

Artikel ini akan memperkenalkan cara menggunakan PHP dan WebSocket untuk melaksanakan push mesej masa nyata dan memberikan contoh kod khusus.

1. Fahami protokol WebSocket

Protokol WebSocket ialah protokol komunikasi dupleks penuh yang membolehkan komunikasi masa nyata antara kedua-dua pihak dengan mewujudkan sambungan berterusan antara penyemak imbas dan pelayan. Tidak seperti protokol HTTP, sambungan WebSocket adalah dua arah, dan pelayan dan klien boleh menghantar mesej antara satu sama lain pada bila-bila masa.

2. Melaksanakan pelayan WebSocket

Dalam PHP, anda boleh menggunakan perpustakaan Ratchet untuk melaksanakan pelayan WebSocket. Ratchet ialah perpustakaan PHP berkuasa yang menyediakan pelbagai fungsi untuk melaksanakan pelayan WebSocket.

Mula-mula, gunakan Komposer untuk memasang perpustakaan Ratchet:

composer require cboden/ratchet

Kemudian, buat fail PHP bernama server.php dan tambah kod berikut: server.php，并添加以下代码：

require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

$server = IoServer::factory(
    new Chat(),
    8080
);

$server->run();

上述代码定义了一个名为Chat的类，实现了Ratchet的MessageComponentInterface接口。在onOpen、onMessage、onClose和onError方法中，分别处理新连接建立、收到消息、连接关闭和错误的情况。

最后，使用命令行启动WebSocket服务器：

php server.php

3. 运行WebSocket客户端

在浏览器中，可以使用JavaScript来实现WebSocket客户端。以下是一个简单的例子：

var connection = new WebSocket('ws://localhost:8080');

connection.onopen = function() {
    console.log('Connected to WebSocket server');
};

connection.onmessage = function(event) {
    console.log('Received message: ' + event.data);
};

connection.onclose = function() {
    console.log('Disconnected from WebSocket server');
};

上述代码创建了一个WebSocket连接，并处理了连接建立、接收到消息和连接关闭的事件。

4. 实现消息推送

在服务器端，可以根据需要实现消息的推送逻辑。例如，假设有一个按钮，当点击时向服务器发送一条消息，并将该消息广播给所有连接的客户端。

在客户端，可以通过WebSocket向服务器发送消息。以下是一个示例：

document.getElementById('button').addEventListener('click', function() {
    connection.send('Hello, World!');
});

在服务器端，可以修改onMessage方法来处理收到的消息，并将该消息广播给所有连接的客户端。例如：

public function onMessage(ConnectionInterface $from, $msg) {
    $receivedMsg = $from->resourceId . ': ' . $msg;
    foreach ($this->clients as $client) {
        $client->send($receivedMsg);
    }
}

上述代码将收到的消息加上客户端的resourceId，并广播给所有连接的客户端。

5. 结束WebSocket连接

在客户端，可以使用connection.close()方法来结束WebSocket连接。例如：

connection.close();

在服务器端，可以在onClose

public function onClose(ConnectionInterface $conn) {
    $this->clients->detach($conn);
    echo "Connection {$conn->resourceId} has disconnected
";
}

Kod di atas mentakrifkan fail yang dipanggil Chat The kelas melaksanakan antara muka MessageComponentInterface Ratchet. Dalam kaedah onOpen, onMessage, onClose dan onError, penubuhan sambungan baharu, penerimaan mesej, penutupan sambungan dan ralat dikendalikan masing-masing.

Akhir sekali, mulakan pelayan WebSocket menggunakan baris arahan:

rrreee

Jalankan klien WebSocket 🎜🎜🎜Dalam penyemak imbas, anda boleh menggunakan JavaScript untuk melaksanakan klien WebSocket. Berikut ialah contoh mudah: 🎜rrreee🎜Kod di atas mencipta sambungan WebSocket dan mengendalikan peristiwa penubuhan sambungan, mesej diterima dan penutupan sambungan. 🎜
🎜Laksanakan message push🎜🎜🎜Di bahagian pelayan, anda boleh melaksanakan logik tolak mesej mengikut keperluan. Sebagai contoh, katakan anda mempunyai butang yang, apabila diklik, menghantar mesej kepada pelayan dan menyiarkan mesej itu kepada semua pelanggan yang disambungkan. 🎜🎜Di sisi pelanggan, mesej boleh dihantar ke pelayan melalui WebSocket. Berikut ialah contoh: 🎜rrreee🎜 Di bahagian pelayan, kaedah onMessage boleh diubah suai untuk mengendalikan mesej yang diterima dan menyiarkan mesej kepada semua pelanggan yang disambungkan. Contohnya: 🎜rrreee🎜Kod di atas menambahkan resourceId pelanggan pada mesej yang diterima dan menyiarkannya kepada semua pelanggan yang disambungkan. 🎜
🎜Tamatkan sambungan WebSocket🎜🎜🎜Di bahagian klien, anda boleh menggunakan kaedah connection.close() untuk menamatkan sambungan WebSocket. Contohnya: 🎜rrreee🎜Di bahagian pelayan, logik penutupan sambungan boleh dikendalikan dalam kaedah onClose. Contohnya: 🎜rrreee🎜Kod di atas akan mengalih keluar klien yang terputus sambungan daripada senarai klien dan mengeluarkan ID sumber yang terputus. 🎜🎜Melalui langkah di atas, kami boleh menggunakan PHP dan WebSocket untuk melaksanakan penyelesaian yang cekap untuk menolak mesej masa nyata. WebSocket menyediakan sambungan berterusan dan keupayaan komunikasi dua hala, menjadikan mesej masa nyata menolak lebih mudah dan lebih cekap. Menggunakan perpustakaan Ratchet boleh memudahkan pelaksanaan pelayan WebSocket, menyediakan fungsi yang kaya dan API yang mudah digunakan. 🎜

Atas ialah kandungan terperinci PHP dan WebSocket: penyelesaian yang cekap untuk menolak mesej masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!