PHP dan WebSocket: penyelesaian yang cekap untuk menolak mesej masa nyata-tutorial php-php.cn

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

PHPz

Lepaskan： 2023-12-18 12:44:02

asal

1338 orang telah melayarinya

PHP和WebSocket: 实现实时消息推送的高效方案

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.

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.

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

Salin selepas log masuk

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();

Salin selepas log masuk

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

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

php server.php

Salin selepas log masuk

运行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');
};

Salin selepas log masuk

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

实现消息推送

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

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

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

Salin selepas log masuk

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

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

Salin selepas log masuk

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

结束WebSocket连接

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

connection.close();

Salin selepas log masuk

在服务器端，可以在onClose

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

Salin selepas log masuk

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

onMessage

connection.close()

onClose

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!