PHPとWebSocketを使用したリアルタイム通信

インターネット技術の発展に伴い、ますます多くの Web サイトやアプリケーションがリアルタイム通信の実現に重点を置き始めています。 WebSocket プロトコルは、リアルタイム通信を実現する効果的な方法とみなされています。この記事では、PHPとWebSocketを使ってリアルタイム通信機能を実装する方法を紹介します。

WebSocket とは

WebSocket は、ブラウザとサーバーの間に永続的な接続を確立して双方向のリアルタイム通信を実現できる TCP ベースのプロトコルです。 HTTP プロトコルとは異なり、WebSocket プロトコルは全二重プロトコルであり、ブラウザがサーバーの応答を受信するためにリクエストを送信する必要はなく、双方向で直接通信できます。

WebSocket は長時間接続方式を採用しているため、データ転送効率が大幅に向上し、サーバーの負荷を軽減できます。リアルタイム通信のシナリオでは、WebSocket は不可欠なテクノロジになっています。

PHP と WebSocket

PHP にはサーバーサイド言語として、WebSocket をサポートするフレームワークもいくつかあります。有名なものとしては、Rachet フレームワーク、swoole フレームワークなどが挙げられます。

この記事では、Rachet フレームワークを使用してリアルタイム通信機能を実装します。 Rachet フレームワークは PHP 用のオープンソース フレームワークであり、WebSocket のサーバー側実装を提供し、Apache、Nginx などのさまざまな Web サーバーをサポートできます。

実装手順

1. Rachet フレームワークをインストールします

Composer を使用して Rachet フレームワークをインストールします:

composer require cboden/ratchet

2. PHP コードを作成します

以下は、Rachet フレームワークを使用してリアルタイム通信を実装する単純な PHP コードです。

<?php
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

require 'vendor/autoload.php';

class MyChat 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 ($from !== $client) {
                $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 HttpServer(
        new WsServer(
            new MyChat()
        )
    ),
    8080
);

$server->run();

このコードは、Ratchet フレームワークで MessageComponentInterface インターフェイスを実装する MyChat という名前のクラスを定義します。これには、次の 4 つのメソッドが含まれています。

• onOpen() は、新しい接続が確立されるときに呼び出されます。
• onMessage() コードがメッセージを受信したときに呼び出されます。
• onClose() 接続が閉じられたときに呼び出されます。
• onError() エラーが発生したときに呼び出されます。

このうち、onOpen() メソッドは新しい接続によって確立された情報を記録し、onMessage() メソッドは受信したメッセージをすべてのユーザーにブロードキャストします。接続されたクライアントが終了し、onClose() メソッドが接続終了情報を記録します。

最後に、コードは IoServer::factory() を使用してサーバーを作成し、監視を有効にします。

3. テスト

コマンド ラインでサーバーを起動します:

php chat-server.php

次に、ブラウザで複数のクライアント ページを開くと、各ページでリアルタイム メッセージを送受信できます。リアルタイムコミュニケーションの効果を実現します。

概要

この記事では、PHP と Rachet フレームワークを使用してリアルタイム通信機能を実装する方法を紹介します。 WebSocket プロトコルを使用すると、ブラウザとサーバーの間に永続的な接続を確立でき、双方向のリアルタイム通信を実現できます。リアルタイム通信シナリオでは、WebSocket プロトコルの使用は不可欠なテクノロジとなっており、Rachet フレームワークはシンプルで効率的な実装方法を提供します。

以上がPHPとWebSocketを使用したリアルタイム通信の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。