PHP et WebSocket : créer une plateforme de chat en temps réel performante

Avec le développement continu d'Internet, la communication en temps réel est devenue une fonctionnalité essentielle de nombreux sites Web et applications, il est donc devenu particulièrement important de créer une plateforme de chat en temps réel performante. En développement, l'utilisation de PHP et WebSocket peut bien répondre aux besoins de communication en temps réel, et la combinaison de ces deux technologies peut également améliorer considérablement les performances de la plateforme.

WebSocket est un protocole de communication full-duplex grâce auquel une connexion durable peut être établie entre le navigateur et le serveur, afin que le serveur puisse envoyer activement des messages en temps réel au client. Ce protocole se caractérise par une efficacité élevée, une fiabilité et de bonnes performances en temps réel, il est donc très approprié pour créer une plate-forme de communication en temps réel.

PHP est actuellement l'un des langages de développement Web les plus utilisés, et il existe de nombreux frameworks matures disponibles, tels que Laravel, Symfony, etc. Utilisez PHP pour créer une plate-forme de discussion en temps réel, utilisez WebSocket comme protocole de communication et utilisez les outils fournis par le framework pour implémenter rapidement une logique métier afin d'obtenir un développement rapide et des performances élevées.

Ce qui suit va créer un exemple de plate-forme de discussion Web basée sur le framework Laravel et utiliser WebSocket pour envoyer des messages en temps réel. Vous devez d’abord télécharger et installer la bibliothèque Ratchet, qui est une bibliothèque de serveur WebSocket basée sur ReactPHP et très simple à utiliser.

Installez la bibliothèque Ratchet :

composer require cboden/ratchet

Définissez ensuite la route WebSocket dans le fichier routes/web.php : routes/web.php文件中定义WebSocket的路由：

use AppHttpControllersChatController;
use RatchetHttpHttpServer;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

Route::get('/chat', function () {
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new ChatController()
            )
        ),
        8080
    );
    $server->run();
})->name('chat');

ChatController就是WebSocket的控制器，用于处理WebSocket的连接和消息。我们在app/Http/Controllers/ChatController.php中定义：

namespace AppHttpControllers;

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class ChatController 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();
    }
}

ChatController实现了MessageComponentInterface接口，包含了四个方法：onOpen、onMessage、onClose和onError。其中，onOpen在连接建立时触发，onMessage在接收到消息时触发，onClose在连接关闭时触发，onError在发生错误时触发。在onOpen中，将连接保存到$clients数组中；在onMessage中，将接收到的消息发送给所有其他连接；在onClose中，从$clients数组中删除关闭的连接；在onError

var conn = new WebSocket("ws://localhost:8080/chat");

conn.onmessage = function (event) {
    // 接收到聊天信息后的处理
};

function sendChatMessage(message) {
    conn.send(message);
}

rrreee

rrreee

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!