PHP와 Websocket을 활용한 실시간 모니터링 시스템 개발-PHP 튜토리얼-php.cn

PHP와 Websocket을 활용한 실시간 모니터링 시스템 개발

WBOY

풀어 주다： 2023-12-02 09:06:01

원래의

925명이 탐색했습니다.

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 중국어 웹사이트의 기타 관련 기사를 참조하세요!