PHPを介してWebSocketプロトコルとリアルタイムで通信する方法

M66 2025-06-07

PHPを介してWebSocketプロトコルとリアルタイムで通信する方法

Webアプリケーションの開発により、オンラインチャット、株式市場のプッシュ、その他のシナリオでリアルタイム通信が重要になっています。 WebSocketプロトコルを使用すると、ブラウザとサーバーが継続的な双方向接続を確立し、効率的なリアルタイムデータ交換を可能にします。この記事では、PHPとWebsocketプロトコルを使用してリアルタイム通信を完了し、コードの例を使用してそれを実証する方法を紹介します。

1。WebSocket契約の紹介

WebSocketプロトコルはTCPプロトコルに基づいており、完全な二重通信をサポートしています。従来のHTTPと比較して、WebSocketはサーバーがデータを積極的にプッシュできるようにし、クライアントはすぐに応答できます。その主な機能には次のものがあります。

リアルタイムの双方向通信：クライアントのポーリングは必要ありません。サーバーとクライアントはリアルタイムでやり取りできます。
低い通信オーバーヘッド：パケットヘッダーは小さく、帯域幅リソースを節約します。
優れたパフォーマンス：長い接続を維持し、握手の数を減らし、応答速度を向上させます。

2。PHP Websocket拡張の紹介

PHPはWebSocketを直接サポートしていませんが、関連する機能は拡張ライブラリを介して実装できます。一般的に使用される拡張機能は次のとおりです。

ラチェット：軽量のWebsocketライブラリは、サーバーとクライアントをサポートします。
Swoole：複数のプロトコルをサポートする高性能ネットワーク通信ライブラリ。
Workerman：マルチスレッドソケットフレームワークは、WebSocketサーバーとクライアントをサポートします。

この記事では、Ratchet拡張機能を例として使用して、WebSocket通信の実装プロセスを実証します。

3.ラチェット拡張機能をインストールします

作曲家経由でラチェットをインストールします。

<span class="fun">作曲家はcboden/ラチェットを必要とします</span>

4. WebSocketサーバーを作成します

次の例は、すべての接続されたクライアントにメッセージを受信し、ブロードキャストする単純なサーバーを示しています。

 <?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
<p>require 'vendor/autoload.php';</p>
<p>class MyWebSocketServer implements MessageComponentInterface {<br>
protected $clients;</p>
<pre class="overflow-visible!"><div class="contain-inline-size rounded-2xl border-[0.5px] border-token-border-medium relative bg-token-sidebar-surface-primary"><div class="flex items-center text-token-text-secondary px-4 py-2 text-xs font-sans justify-between h-9 bg-token-sidebar-surface-primary dark:bg-token-main-surface-secondary select-none rounded-t-2xl">php</div><div class="sticky top-9"><div class="absolute end-0 bottom-0 flex h-9 items-center pe-2"><div class="bg-token-sidebar-surface-primary text-token-text-secondary dark:bg-token-main-surface-secondary flex items-center gap-4 rounded-sm px-2 font-sans text-xs"><button class="flex gap-1 items-center select-none py-1" aria-label="コピー"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path fill-rule="evenodd" clip-rule="evenodd" d="M7 5C7 3.34315 8.34315 2 10 2H19C20.6569 2 22 3.34315 22 5V14C22 15.6569 20.6569 17 19 17H17V19C17 20.6569 15.6569 22 14 22H5C3.34315 22 2 20.6569 2 19V10C2 8.34315 3.34315 7 5 7H7V5ZM9 7H14C15.6569 7 17 8.34315 17 10V15H19C19.5523 15 20 14.5523 20 14V5C20 4.44772 19.5523 4 19 4H10C9.44772 4 9 4.44772 9 5V7ZM5 9C4.44772 9 4 9.44772 4 10V19C4 19.5523 4.44772 20 5 20H14C14.5523 20 15 19.5523 15 19V10C15 9.44772 14.5523 9 14 9H5Z" fill="currentColor"></path></svg>コピー</button><button class="flex items-center gap-1 py-1 select-none"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path d="M2.5 5.5C4.3 5.2 5.2 4 5.5 2.5C5.8 4 6.7 5.2 8.5 5.5C6.7 5.8 5.8 7 5.5 8.5C5.2 7 4.3 5.8 2.5 5.5Z" fill="currentColor" stroke="currentColor" stroke-linecap="round" stroke-linejoin="round"></path><path d="M5.66282 16.5231L5.18413 19.3952C5.12203 19.7678 5.09098 19.9541 5.14876 20.0888C5.19933 20.2067 5.29328 20.3007 5.41118 20.3512C5.54589 20.409 5.73218 20.378 6.10476 20.3159L8.97693 19.8372C9.72813 19.712 10.1037 19.6494 10.4542 19.521C10.7652 19.407 11.0608 19.2549 11.3343 19.068C11.6425 18.8575 11.9118 18.5882 12.4503 18.0497L20 10.5C21.3807 9.11929 21.3807 6.88071 20 5.5C18.6193 4.11929 16.3807 4.11929 15 5.5L7.45026 13.0497C6.91175 13.5882 6.6425 13.8575 6.43197 14.1657C6.24513 14.4392 6.09299 14.7348 5.97903 15.0458C5.85062 15.3963 5.78802 15.7719 5.66282 16.5231Z" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path><path d="M14.5 7L18.5 11" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path></svg>編集</button></div></div></div><div class="overflow-y-auto p-4" dir="ltr">public function __construct() {
    $this->clients = new \SplObjectStorage;
}

public function onOpen(ConnectionInterface $conn) {
    $this->clients->attach($conn);
}

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

public function onClose(ConnectionInterface $conn) {
    $this->clients->detach($conn);
}

public function onError(ConnectionInterface $conn, \Exception $e) {
    echo "Error: {$e->getMessage()}\n";
    $conn->close();
}

}

$ server = new \ ratchet \ server \ ioserver（ new \ ratchet \ http \ httpserver（ new \ ratchet \ websocket \ wsserver（新しいmywebsocketserver（））））、、 new \ React \ socket \ server（ '0.0.0.0:8000'、new \ React \ eventloop \ streamselectloop（）））;

$ server-> run（）;

`5. WebSocketクライアントを作成します`

次のクライアントの例では、サーバーに接続し、メッセージの送信、回答の受信を実装します。

 <?php
use Ratchet\Client\WebSocket;
use Ratchet\Client\Connector;
use React\EventLoop\Factory as EventLoopFactory;
<p>require 'vendor/autoload.php';</p>
<p>$loop = EventLoopFactory::create();<br>
$connector = new Connector($loop);</p>
<p>$connector('ws://localhost:8000')->then(function(WebSocket $conn) {<br>
$conn->on('message', function($msg) use ($conn) {<br>
echo "Received: {$msg}\n";<br>
$conn->close();<br>
});</p>
<pre class="overflow-visible!"><div class="contain-inline-size rounded-2xl border-[0.5px] border-token-border-medium relative bg-token-sidebar-surface-primary"><div class="flex items-center text-token-text-secondary px-4 py-2 text-xs font-sans justify-between h-9 bg-token-sidebar-surface-primary dark:bg-token-main-surface-secondary select-none rounded-t-2xl">perl</div><div class="sticky top-9"><div class="absolute end-0 bottom-0 flex h-9 items-center pe-2"><div class="bg-token-sidebar-surface-primary text-token-text-secondary dark:bg-token-main-surface-secondary flex items-center gap-4 rounded-sm px-2 font-sans text-xs"><button class="flex gap-1 items-center select-none py-1" aria-label="コピー"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path fill-rule="evenodd" clip-rule="evenodd" d="M7 5C7 3.34315 8.34315 2 10 2H19C20.6569 2 22 3.34315 22 5V14C22 15.6569 20.6569 17 19 17H17V19C17 20.6569 15.6569 22 14 22H5C3.34315 22 2 20.6569 2 19V10C2 8.34315 3.34315 7 5 7H7V5ZM9 7H14C15.6569 7 17 8.34315 17 10V15H19C19.5523 15 20 14.5523 20 14V5C20 4.44772 19.5523 4 19 4H10C9.44772 4 9 4.44772 9 5V7ZM5 9C4.44772 9 4 9.44772 4 10V19C4 19.5523 4.44772 20 5 20H14C14.5523 20 15 19.5523 15 19V10C15 9.44772 14.5523 9 14 9H5Z" fill="currentColor"></path></svg>コピー</button><button class="flex items-center gap-1 py-1 select-none"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path d="M2.5 5.5C4.3 5.2 5.2 4 5.5 2.5C5.8 4 6.7 5.2 8.5 5.5C6.7 5.8 5.8 7 5.5 8.5C5.2 7 4.3 5.8 2.5 5.5Z" fill="currentColor" stroke="currentColor" stroke-linecap="round" stroke-linejoin="round"></path><path d="M5.66282 16.5231L5.18413 19.3952C5.12203 19.7678 5.09098 19.9541 5.14876 20.0888C5.19933 20.2067 5.29328 20.3007 5.41118 20.3512C5.54589 20.409 5.73218 20.378 6.10476 20.3159L8.97693 19.8372C9.72813 19.712 10.1037 19.6494 10.4542 19.521C10.7652 19.407 11.0608 19.2549 11.3343 19.068C11.6425 18.8575 11.9118 18.5882 12.4503 18.0497L20 10.5C21.3807 9.11929 21.3807 6.88071 20 5.5C18.6193 4.11929 16.3807 4.11929 15 5.5L7.45026 13.0497C6.91175 13.5882 6.6425 13.8575 6.43197 14.1657C6.24513 14.4392 6.09299 14.7348 5.97903 15.0458C5.85062 15.3963 5.78802 15.7719 5.66282 16.5231Z" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path><path d="M14.5 7L18.5 11" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path></svg>編集</button></div></div></div><div class="overflow-y-auto p-4" dir="ltr">$conn->send('Hello, WebSocket Server!');

}、function（\ exception $ e）use（$ loop）{ echo "接続できませんでした：{$ e-> getMessage（）} \ n"; $ loop-> stop（）; }）;

$ loop-> run（）;

`6. WebSocketサービスを開始します`

コマンドラインでサーバーとクライアントを起動します。

 php server.php
php client.php

この時点で、クライアントとサーバーは、リアルタイムデータの双方向通信を実現できます。

`要約します`

この記事では、PHPを使用してリアルタイム通信のためにWebsocketプロトコルを組み合わせて、ラチェット拡張機能のインストールとコード実装の実証に焦点を当てる基本的な方法を紹介します。 WebSocketプロトコルを通じて、PHPアプリケーションは効率的なサーバープッシュとクライアントの応答を実現し、最新のWebリアルタイムインタラクションのニーズを満たすことができます。


				
					
						
						
																													
						
					
				
											
						関連内容
						
																			
								
									
								
								
																
																		PHPを介してWebSocketプロトコルとリアルタイムで通信する方法