PHP 및 WebSocket: 실시간 데이터 전송 모범 사례
PHP 및 WebSocket: 실시간 데이터 전송을 달성하는 모범 사례 방법
소개:
웹 애플리케이션 개발에서 실시간 데이터 전송은 매우 중요한 기술 요구 사항입니다. 기존 HTTP 프로토콜은 요청-응답 모델 프로토콜이므로 실시간 데이터 전송을 효과적으로 달성할 수 없습니다. 실시간 데이터 전송 요구를 충족하기 위해 WebSocket 프로토콜이 탄생했습니다.
WebSocket은 단일 TCP 연결을 통해 전이중 통신 방법을 제공하는 전이중 통신 프로토콜입니다. HTTP 프로토콜과 비교하여 WebSocket은 더 빠른 데이터 전송과 실시간 데이터 푸시를 달성할 수 있습니다. 뛰어난 성능과 폭넓은 지원으로 인해 WebSocket은 실시간 애플리케이션에서 널리 사용됩니다.
PHP에서 WebSocket 통신을 구현하기 위해 일부 성숙한 라이브러리를 사용하여 개발 프로세스를 단순화할 수 있습니다. 이 기사에서는 Ratchet 라이브러리를 사용하여 PHP와 WebSocket의 통합을 구현하는 방법을 소개하고 실시간 데이터 전송을 위한 애플리케이션을 쉽게 구축할 수 있도록 몇 가지 모범 사례를 제공합니다.
1. 환경 구성 및 종속성 설치
Ratchet 라이브러리를 사용하려면 다음 환경 및 종속성 조건을 충족해야 합니다.
- PHP 버전 >= 7.0;
- 설치 단계는 다음과 같습니다.
- Composer를 사용하여 Ratchet 라이브러리를 설치하세요. 명령줄에 다음 명령을 입력하세요:
composer require cboden/ratchet
로그인 후 복사이렇게 하면 Ratchet 라이브러리와 해당 종속 항목이 자동으로 다운로드되어 설치됩니다.
설치가 완료되면 프로젝트에서 Ratchet 사용을 시작할 수 있습니다. 2. WebSocket 서버 만들기
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 connection] - Connection ID: {$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 closed] - Connection ID: {$conn->resourceId} "; } public function onError(ConnectionInterface $conn, Exception $e) { echo "[Error] - Connection ID: {$conn->resourceId} - {$e->getMessage()} "; $conn->close(); } } $server = new RatchetWebSocketWsServer(new MyWebSocketServer()); $server->disableVersion(0); $server->loop->addPeriodicTimer(60, function() { // 定时任务 }); $socket = new ReactSocketServer('0.0.0.0:8080', $server->loop); $server = new ReactHttpServer($socket, $server->loop); $server->on('request', function ($request, $response) use (&$socket) { $response->end('Hello, World!'); }); echo "WebSocket server is running... "; $server->run();
이 예에서는 먼저 "MyWebSocketServer"라는 클래스를 만들고 Ratchet의 MessageComponentInterface 인터페이스를 구현합니다. 이 인터페이스에는 클라이언트 연결을 처리하는 데 사용되는
onOpen
, onMessage
, onClose
및 onError
의 네 가지 메서드가 포함되어 있습니다. 메시지를 받고, 연결을 끊고, 오류를 처리합니다. onOpen
메소드에서는 서버의 클라이언트 목록을 업데이트하고 새 연결의 ID를 인쇄합니다. onOpen
、onMessage
、onClose
和onError
,用于处理客户端连接、收到消息、关闭连接和处理错误。
在onOpen
方法中,我们更新了服务器中的客户端列表,并打印出新连接的ID。
在onMessage
方法中,我们遍历了客户端列表,并将收到的消息发送给所有的客户端,除了消息来源的客户端。
在onClose
方法中,我们删除了客户端列表中的关闭连接,并打印出连接的ID。
在onError
方法中,我们处理了连接发生错误的情况,并关闭连接。
接下来,我们创建了一个WebSocket服务器的实例,并将MyWebSocketServer
作为参数传递给了WsServer
。然后,创建一个React HTTP服务器的实例。最后,我们通过run
方法启动了WebSocket服务器。
三、前端客户端页面
为了测试WebSocket服务器,我们需要创建一个简单的前端页面,用于模拟WebSocket客户端。以下是一个示例页面:
<!DOCTYPE html> <html> <head> <title>WebSocket Client</title> <script> var socket = new WebSocket("ws://localhost:8080"); socket.onmessage = function(event) { var message = event.data; // 处理收到的消息 console.log(message); }; // 发送消息 function sendMessage() { var message = document.getElementById('message').value; socket.send(message); } </script> </head> <body> <input type="text" id="message" placeholder="Type a message..."> <button onclick="sendMessage()">Send</button> </body> </html>
在这个示例中,我们首先创建了一个WebSocket对象并指定了服务器的地址和端口。然后,我们注册了onmessage
onMessage
메소드에서는 클라이언트 목록을 순회하여 메시지가 발생한 클라이언트를 제외한 모든 클라이언트에게 수신된 메시지를 보냅니다. onClose
메소드에서는 클라이언트 목록에서 닫힌 연결을 삭제하고 연결 ID를 출력합니다. onError
메소드에서는 연결에 오류가 발생한 상황을 처리하고 연결을 닫습니다.
다음으로 WebSocket 서버의 인스턴스를 생성하고 MyWebSocketServer
를 매개변수로 WsServer
에 전달했습니다. 그런 다음 React HTTP 서버의 인스턴스를 만듭니다. 마지막으로 run
메소드를 통해 WebSocket 서버를 시작했습니다.
3. 프런트엔드 클라이언트 페이지
WebSocket 서버를 테스트하려면 WebSocket 클라이언트를 시뮬레이션하기 위한 간단한 프런트엔드 페이지를 생성해야 합니다. 다음은 예제 페이지입니다.rrreee
이 예제에서는 먼저 WebSocket 객체를 생성하고 서버의 주소와 포트를 지정합니다. 그런 다음 수신된 메시지를 처리하기 위해 onmessage
이벤트 핸들러를 등록했습니다. 이 예에서는 단순히 메시지를 콘솔에 인쇄합니다.
또한 사용자가 메시지를 입력하고 보낼 수 있도록 텍스트 입력 상자와 보내기 버튼을 추가했습니다.
- 4. 실행 및 테스트
- 서버에서 WebSocket 서버 스크립트를 실행한 후 브라우저를 열고 프런트 엔드 클라이언트 페이지를 방문하세요. 텍스트 입력 상자와 보내기 버튼이 표시됩니다.
- 문자 입력창에 보내고 싶은 메시지를 입력하고 보내기 버튼을 눌러주세요. 콘솔에 수신된 메시지가 표시됩니다.
위 내용은 PHP 및 WebSocket: 실시간 데이터 전송 모범 사례의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

핫 AI 도구

Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool
무료로 이미지를 벗다

Clothoff.io
AI 옷 제거제

AI Hentai Generator
AI Hentai를 무료로 생성하십시오.

인기 기사

뜨거운 도구

메모장++7.3.1
사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경

드림위버 CS6
시각적 웹 개발 도구

SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)

뜨거운 주제











PHP 8.4는 상당한 양의 기능 중단 및 제거를 통해 몇 가지 새로운 기능, 보안 개선 및 성능 개선을 제공합니다. 이 가이드에서는 Ubuntu, Debian 또는 해당 파생 제품에서 PHP 8.4를 설치하거나 PHP 8.4로 업그레이드하는 방법을 설명합니다.

CakePHP는 PHP용 오픈 소스 프레임워크입니다. 이는 애플리케이션을 훨씬 쉽게 개발, 배포 및 유지 관리할 수 있도록 하기 위한 것입니다. CakePHP는 강력하고 이해하기 쉬운 MVC와 유사한 아키텍처를 기반으로 합니다. 모델, 뷰 및 컨트롤러 gu

CakePHP에 로그인하는 것은 매우 쉬운 작업입니다. 한 가지 기능만 사용하면 됩니다. cronjob과 같은 백그라운드 프로세스에 대해 오류, 예외, 사용자 활동, 사용자가 취한 조치를 기록할 수 있습니다. CakePHP에 데이터를 기록하는 것은 쉽습니다. log() 함수는 다음과 같습니다.

VS Code라고도 알려진 Visual Studio Code는 모든 주요 운영 체제에서 사용할 수 있는 무료 소스 코드 편집기 또는 통합 개발 환경(IDE)입니다. 다양한 프로그래밍 언어에 대한 대규모 확장 모음을 통해 VS Code는

CakePHP는 오픈 소스 MVC 프레임워크입니다. 이를 통해 애플리케이션 개발, 배포 및 유지 관리가 훨씬 쉬워집니다. CakePHP에는 가장 일반적인 작업의 과부하를 줄이기 위한 여러 라이브러리가 있습니다.
