phpとWebsocketを使ったリアルタイム監視システムの開発-PHPチュートリアル-php.cn

phpとWebsocketを使ったリアルタイム監視システムの開発

WBOY

リリース： 2023-12-02 09:06:01

オリジナル

950 人が閲覧しました

phpとWebsocketを使ったリアルタイム監視システムの開発

PHP と WebSocket を使用したリアルタイム監視システムの開発

インターネットの急速な発展とスマートデバイスの普及により、リアルタイム監視システムが開発されています。さまざまな分野で重要な役割を果たしています。産業制御、交通管理、環境監視のいずれであっても、リアルタイム監視システムはタイムリーで信頼性の高いデータとフィードバックを提供し、人々が正確な意思決定を行えるようにします。この記事では、PHP と WebSocket テクノロジを使用してシンプルなリアルタイム監視システムを開発する方法を紹介し、具体的なコード例を示します。

開発プロセスを開始するには、まず WebSocket テクノロジの基本概念と原則を理解する必要があります。 WebSocket は HTTP プロトコルをベースとした全二重通信プロトコルであり、永続的な接続を確立することでサーバーとクライアント間のリアルタイムのデータ転送を実現します。従来の HTTP 要求/応答モデルと比較して、WebSocket はより効率的かつリアルタイムであり、頻繁な通信が必要なシナリオに適しています。

PHP では、成熟した WebSocket ライブラリである Ratchet を使用して WebSocket サーバーを実装できます。まず、Composer を使用して Ratchet ライブラリをインストールする必要があります。コマンドラインで次のコマンドを実行します。

composer require cboden/ratchet

ログイン後にコピー

インストール後、クライアント接続を監視し、リアルタイムでデータをプッシュするための単純な WebSocket サーバーを作成できます。

<?php

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class MyWebSocketServer implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New client connected ({$conn->resourceId})" . PHP_EOL;
    }

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

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

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error occurred: {$e->getMessage()}" . PHP_EOL;

        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new MyWebSocketServer()
        )
    ),
    9000
);

echo "WebSocket server started" . PHP_EOL;

$server->run();

ログイン後にコピー

上記のコードでは、Ratchet が提供する MessageComponentInterface インターフェイスを実装する MyWebSocketServer という名前のクラスを定義します。このインターフェイスには、onOpen、onMessage、onClose、onError などの必要なメソッドが含まれており、それぞれクライアント接続、メッセージ受信、接続終了、エラー処理を処理するために使用されます。

onOpen メソッドでは、新しく接続したクライアントをクライアントリストに追加します。 onMessage メソッドでは、クライアントリストを反復処理し、メッセージ送信者を除く他のクライアントにメッセージを送信します。 onClose メソッドでは、閉じられた接続をクライアントリストから削除します。最後に、onError メソッドで例外を処理し、接続を閉じます。

WebSocket サーバーを起動するには、Ratchet が提供する IoServer ファクトリクラスを使用します。 HTTP サーバー、WebSocket サーバー、および定義した MyWebSocketServer インスタンスを指定することで、WebSocket サーバーを作成し、指定されたポート (この例では 9000) でリッスンできます。

クライアントでは、JavaScript を使用して WebSocket 接続を作成し、リアルタイムのデータ送受信を実行できます。以下は簡単な例です。

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>WebSocket Client</title>
</head>
<body>
    <script>
        var socket = new WebSocket("ws://localhost:9000");

        socket.onopen = function() {
            console.log("WebSocket connection established");
        };

        socket.onmessage = function(event) {
            var message = event.data;
            console.log("Received message: " + message);
        };

        socket.onclose = function() {
            console.log("WebSocket connection closed");
        };

        socket.onerror = function(event) {
            console.log("An error occurred: " + event.data);
        };
    </script>
</body>
</html>

ログイン後にコピー

上記のコードでは、JavaScript を使用してソケットという名前の WebSocket オブジェクトを作成し、前に作成した WebSocket サーバーへの接続アドレスを指定します。 onopen、onmessage、onclose、onerror イベントをリッスンすることで、接続ステータスの変化をリアルタイムで認識し、サーバーから送信されたメッセージを受信できます。

上記の PHP と WebSocket のコード例を通じて、この単純な実装に基づいて、より複雑なリアルタイム監視システムを開発できます。センサーデータの収集、ステータスの更新、リアルタイムのデータ表示など、特定のニーズに応じてビジネスロジックを作成できます。 PHP と WebSocket テクノロジーを使用して、高性能、リアルタイム、信頼性の高い監視システムを実装し、さまざまな分野のリアルタイム監視ニーズにソリューションを提供します。

以上がphpとWebsocketを使ったリアルタイム監視システムの開発の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。