PHPとSocketを使ってリアルタイムデータ通信を実現する方法-PHPチュートリアル-php.cn

インターネットの継続的な発展に伴い、リアルタイムデータ通信がさまざまなアプリケーションの標準になりました。 PHP と Socket を使用してリアルタイムデータ通信を実装することは、一般的な方法の 1 つです。この記事では、PHPとSocketを使ってリアルタイムデータ通信を実現する方法を紹介します。

ソケットは、アプリケーション間の通信に使用されるメカニズムです。これは、さまざまなアプリケーションが異なるコンピュータ間で通信できるようにするインターフェイスの標準セットを提供します。 PHP では、ソケット拡張ライブラリを使用してソケット通信を実装できます。

ソケット接続の実装

ソケット接続を使用してリアルタイムデータ通信を実現するには、まずソケット接続を確立する必要があります。ソケット接続は通常、サーバー側とクライアント側の 2 つのエンドポイントで構成されます。

サーバー側:

$ip = '127.0.0.1'; $port = 8888; $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_bind($server, $ip, $port); socket_listen($server); $client = socket_accept($server); socket_close($server);

ログイン後にコピー

クライアント側:

$ip = '127.0.0.1'; $port = 8888; $client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_connect($client, $ip, $port); socket_close($client);

ログイン後にコピー

上記はソケット接続を確立する基本的な操作であり、socket_create関数はSocket オブジェクトの作成に使用されます。socket_bindこの関数はローカルバインディングを実装します。socket_listenこの関数はクライアントからの接続リクエストのリッスンを開始し、クライアントが接続するまでブロックします。socket_acceptこの関数は、新しい接続を作成するための新しい Socket オブジェクトを返します。クライアント側の操作も比較的簡単で、socket_connect関数を使用してサーバーに接続し、socket_close関数を使用して接続を閉じます。

リアルタイムデータ通信

ソケット接続が正常に確立されると、リアルタイムデータ通信を開始できます。ソケット接続では、データはストリーム経由で転送されます。サーバーはsocket_recv関数を通じてクライアントからデータを受信でき、クライアントはsocket_send関数を通じてサーバーにデータを送信できます。

サーバー側:

$ip = '127.0.0.1'; $port = 8888; $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_bind($server, $ip, $port); socket_listen($server); $client = socket_accept($server); while(true){ $message = socket_recv($client, 1024, MSG_WAITALL); if($message === false){ socket_close($client); break; } echo "收到消息: $message "; } socket_close($server);

ログイン後にコピー

クライアント側:

$ip = '127.0.0.1'; $port = 8888; $client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); socket_connect($client, $ip, $port); $message = "Hello World!"; socket_send($client, $message, strlen($message), 0); socket_close($client);

ログイン後にコピー

以上がメッセージの送受信の基本動作ですが、サーバー側ではメッセージが 1 つしか受信できないという問題を解決します。ループ処理にかかる時間。このリアルタイムデータ通信方法は簡単かつ効率的に使用でき、適切に使用すれば非常に有益です。

WebSocket を使用してリアルタイムデータ通信を実現する

WebSocket は、ブラウザとサーバーの間に永続的な接続を作成できる HTTP プロトコルに基づくプロトコルです。 PHP では、Ratchet などのサードパーティライブラリを使用して WebSocket 通信を実装できます。

WebSocket 接続の実装

サーバーコード:

require __DIR__ . '/vendor/autoload.php'; use RatchetMessageComponentInterface; use RatchetConnectionInterface; class WebSocketServer implements MessageComponentInterface { protected $clients; public function __construct() { $this->clients = new SplObjectStorage; } public function onOpen(ConnectionInterface $conn) { $this->clients->attach($conn); echo "有新的客户端连接：{$conn->resourceId} "; } public function onMessage(ConnectionInterface $from, $message) { foreach ($this->clients as $client) { if ($from !== $client) { $client->send($message); } } } public function onClose(ConnectionInterface $conn) { $this->clients->detach($conn); echo "客户端离开：{$conn->resourceId} "; } public function onError(ConnectionInterface $conn, Exception $e) { echo "发生错误：{$e->getMessage()} "; $conn->close(); } public function run() { $server = RatchetServerIoServer::factory( new RatchetHttpHttpServer( new RatchetWebSocketWsServer( $this ) ), 8080 ); echo "WebSocket服务已启动... "; $server->run(); } } $server = new WebSocketServer(); $server->run();

ログイン後にコピー

上記は、MessageComponentInterfaceを使用して 4 つの基本メソッドをそれぞれ実装する単純な WebSocket サーバーです。onOpen、onMessage、onClose、onError。新しいクライアントのリソース ID がonOpenメソッドに追加され、クライアントが離れるときにクライアントを識別します。受信したメッセージはonMessageメソッド、onCloseでブロードキャストされます。オフラインクライアントはメソッドのクライアントリストから削除され、クライアントとの接続エラーはonErrorメソッドで処理されます。

クライアントコード:

var socket = new WebSocket('ws://' + window.location.host + ':8080'); socket.onopen = function() { console.log('WebSocket已打开'); }; socket.onerror = function() { console.log('WebSocket出错'); }; socket.onmessage = function(event) { console.log('收到消息：' + event.data); }; socket.onclose = function() { console.log('WebSocket已关闭'); };

ログイン後にコピー

上記はクライアントコードです。WebSocketオブジェクトを使用して WebSocket 接続を作成し、onopen、onerror、onmessage をそれぞれ処理します。 . 、oncloseイベント。受信したメッセージはonmessageメソッドで出力されます。

WebSocket を使用すると、従来の Socket よりもブラウザとサーバー間のリアルタイム通信が容易になります。 Ratchet などのサードパーティライブラリを使用して WebSocket 通信を実装すると、開発の複雑さを軽減できます。

結論

上記の紹介を通じて、PHP と Socket を使用してリアルタイムデータ通信を実現することは比較的柔軟であり、さまざまなアプリケーションシナリオに適用できることがわかります。同時に、Ratchetなどのサードパーティライブラリを使用したWebSocket通信は、ブラウザやサーバーサイドで実装される従来のSocket通信よりも簡単に始めることができ、より短期間で通信開発を加速できます。開発者は、自分のニーズに応じて適切な通信方法を選択できます。

以上がPHPとSocketを使ってリアルタイムデータ通信を実現する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。