Workererman을 사용하여 실시간으로 메시지를 푸시하고 수신하는 방법-Workerman-php.cn

Workererman을 사용하여 실시간으로 메시지를 푸시하고 수신하는 방법

王林

풀어 주다： 2023-09-08 13:42:23

원래의

897명이 탐색했습니다.

Workererman을 사용하여 실시간으로 메시지를 푸시하고 수신하는 방법

workererman을 사용하여 실시간 메시지 푸시 및 수신을 달성하는 방법

인터넷의 급속한 발전으로 인해 실시간 메시지 푸시는 많은 애플리케이션의 필수 사항이 되었습니다. 이전 구현에서는 일반적으로 서버를 폴링하여 새 메시지가 있는지 확인한 다음 푸시했습니다. 이 방법은 비효율적일 뿐만 아니라 서버의 부담도 증가시킵니다. 이제 이를 구현하는 보다 효율적인 방법이 있습니다. 즉, Workerman 프레임워크를 사용하여 실시간 메시지 푸시 및 수신을 달성하는 것입니다.

Workerman은 PHP가 긴 연결을 유지할 수 없는 문제를 해결하기 위해 설계된 고성능 이벤트 중심 PHP 프레임워크입니다. 이는 PHP의 비동기 비차단 I/O 구현을 사용하며 실시간 메시지 푸시 및 수신을 달성하기 위해 많은 수의 동시 연결을 처리할 수 있습니다.

다음은 Workererman을 사용하여 실시간 메시지 푸시 및 수신을 구현하는 단계와 코드 예제입니다.

workererman 설치

먼저, Workererman을 서버에 설치해야 합니다. 작곡가를 사용하여 다음 명령으로 설치할 수 있습니다:

composer require workerman/workerman

로그인 후 복사

메시지 푸시 서버 생성

다음으로 메시지 푸시 서버로 push_server.php라는 PHP 파일을 생성합니다.

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;

$pusher = new Worker();
$pusher->count = 4;

$pusher->onWorkerStart = function ($pusher) {
    $inner_ws = new Worker('websocket://127.0.0.1:8000');
    
    $inner_ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $inner_ws->onMessage = function ($connection, $data) use ($pusher) {
        echo "Received message: $data
";
        
        // 接收到消息后，将消息推送给所有在线客户端
        foreach ($pusher->connections as $client) {
            $client->send($data);
        }
    };
    
    $inner_ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

로그인 후 복사

메시지 수신 서버 생성

그런 다음 메시지 수신 서버로 receive_server.php라는 PHP 파일을 생성합니다.

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;

$receiver = new Worker();
$receiver->count = 4;

$receiver->onWorkerStart = function ($receiver) {
    $ws = new Worker('websocket://127.0.0.1:8001');
    
    $ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $ws->onMessage = function ($connection, $data) {
        echo "Received message: $data
";
        
        // 处理接收到的消息
        // ...
    };
    
    $ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

로그인 후 복사

서버 시작

마지막으로 명령줄을 통해 메시지 푸시 서버와 메시지 수신 서버를 각각 시작합니다.

php push_server.php start

로그인 후 복사

php receive_server.php start

로그인 후 복사

이제 실시간 메시지 푸시 및 수신이 완료됩니다.

실제 응용에서는 필요에 따라 해당 기능 확장 및 최적화를 수행할 수 있습니다. 예를 들어, 인증된 사용자만 메시지를 푸시하고 수신하도록 제한하는 인증 및 권한 부여 메커니즘을 추가할 수 있습니다. 또한 오프라인 사용자가 온라인 상태가 된 후 읽지 않은 메시지를 받을 수 있도록 메시지를 데이터베이스에 유지할 수도 있습니다.

요약하자면, 워커맨 프레임워크를 사용하면 효율적인 실시간 메시지 푸시 및 수신을 달성할 수 있습니다. 비동기 및 비차단 특성을 통해 서버는 많은 수의 동시 연결을 처리할 수 있으므로 메시지 전송 효율성이 향상됩니다. 이 글이 워커맨을 이해하고 적용하여 실시간 푸시 및 메시지 수신을 구현하는 데 도움이 되기를 바랍니다.

위 내용은 Workererman을 사용하여 실시간으로 메시지를 푸시하고 수신하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!