집 > 기사 > PHP 프레임워크 > Workerman 개발 모델: 실시간 데이터 푸시 기능 구현을 위한 모범 사례

Workerman 개발 모델: 실시간 데이터 푸시 기능 구현을 위한 모범 사례

PHPz원래의: 2023-08-05 08:13:131103검색

소개:
인터넷의 급속한 발전으로 인해 실시간 데이터 푸시는 많은 애플리케이션에 필요한 기능이 되었습니다. PHP 분야에서 Workerman은 의심할 여지 없이 가장 강력한 실시간 데이터 푸시 프레임워크 중 하나입니다. 이 기사에서는 Workerman을 사용하여 실시간 데이터 푸시 기능을 개발하는 방법을 설명하고 몇 가지 모범 사례 코드 예제를 제공합니다.

1. 워커맨이란?
Workerman은 PHP 분야의 고성능 PHP 비동기 네트워크 통신 프레임워크로, 종속성이 없는 순수 PHP를 기반으로 개발되었으며 독립적으로 실행할 수 있습니다. Workerman은 Non-Blocking IO 모델을 채택하여 많은 수의 동시 연결을 처리할 수 있습니다. 동시에 편리하고 사용하기 쉬운 인터페이스도 제공하므로 개발자는 고성능 실시간 애플리케이션을 빠르게 개발할 수 있습니다.

2. 간단한 실시간 데이터 푸시 애플리케이션 만들기
먼저 작곡가를 사용하여 Workerman을 설치해야 합니다.

composer require workerman/workerman

그런 다음 server.php 파일을 만들고 다음 코드를 입력합니다.

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

use WorkermanWorker;

// 创建一个Worker监听8080端口，使用websocket协议通讯
$ws_worker = new Worker('websocket://0.0.0.0:8080');

// 启动4个进程对外提供服务
$ws_worker->count = 4;

// 当客户端与服务端建立连接时触发
$ws_worker->onConnect = function ($connection) {
    echo "New connection
";
};

// 当客户端给服务端发送消息时触发
$ws_worker->onMessage = function ($connection, $data) use ($ws_worker) {
    // 将消息广播给所有客户端
    foreach ($ws_worker->connections as $client_connection) {
        $client_connection->send($data);
    }
};

// 当客户端与服务端断开连接时触发
$ws_worker->onClose = function ($connection) {
    echo "Connection closed
";
};

// 运行worker
Worker::runAll();

이 코드는 간단히 생성됩니다. 웹소켓 서버는 새 클라이언트가 연결하거나 메시지를 보내거나 연결이 끊어질 때 해당 이벤트를 트리거합니다. 특정 이벤트 처리 논리는 실제 필요에 따라 수정될 수 있습니다.

3. 클라이언트 코드 예시
실시간 데이터 푸시 기능을 테스트하기 위해 간단한 HTML 파일을 생성하여 클라이언트를 시뮬레이션할 수 있습니다. 이 html 파일에서는 javascript를 사용하여 websocket 연결을 구현하고 메시지를 보내고 받습니다.

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>实时数据推送</title>
    <script>
        var ws = new WebSocket('ws://127.0.0.1:8080');

        ws.onopen = function () {
            console.log('已连接服务器');
        };

        ws.onmessage = function (event) {
            console.log('收到消息：' + event.data);
        };

        function send() {
            var message = document.getElementById('message').value;
            ws.send(message);
            console.log('发送消息：' + message);
        }
    </script>
</head>
<body>
    <input type="text" id="message" placeholder="请输入要发送的消息">
    <button onclick="send()">发送</button>
</body>
</html>

이 자바스크립트 코드는 웹소켓 연결을 생성하고 서버와의 연결 설정, 메시지 수신 및 메시지 전송과 관련된 이벤트를 정의합니다. 입력창에 보낼 메시지를 입력하고 "보내기" 버튼을 클릭하면 해당 메시지가 서버로 전송되고 수신된 메시지가 콘솔에 표시됩니다.

4. 모범 사례
실제 개발에서는 권한 제어, 그룹 관리, 메시지 확인 등 고려해야 할 요소가 많습니다. 모범 사례에 대한 샘플 코드는 다음과 같습니다.

사용자 로그인 확인:

// 在onConnect事件中验证用户登录
$ws_worker->onConnect = function ($connection) {
    // 获取用户token
    $token = $connection->getRequestHeader('token');
    // 验证token
    if (!verifyToken($token)) {
        $connection->close();
    }
};

그룹 관리:

// 创建分组、加入分组和发送给指定分组的示例代码
$group = new WorkermanConnectionConnections();
$group->add($client_connection);
$ws_worker->group['group_name'] = $group;
...

// 发送消息给指定分组
$ws_worker->group['group_name']->send($data);

지정된 클라이언트에게 메시지 보내기:

// 在onMessage事件中判断要发送的客户端id
$id = $data['recipient_id'];
if ($connection = $ws_worker->uidConnections[$id] ?? null) {
    // 找到对应的客户端连接并发送消息
    $connection->send($data);
}

결론:
이 문서에서는 사용 방법을 설명합니다. 실시간 데이터 푸시 기능을 개발하고 몇 가지 모범 사례 코드 예제를 제공하는 Workerman Framework. 이러한 예제를 연구함으로써 독자는 Workerman을 빠르게 시작하고 이를 사용하여 고성능 실시간 애플리케이션을 개발할 수 있다고 믿습니다. Workerman에 대해 계속해서 깊이있게 배우고 싶다면 자세한 공식 문서를 참조하세요. Workerman을 활용하여 실시간 데이터 푸시 기능을 개발하시길 바랍니다!

위 내용은 Workerman 개발 모델: 실시간 데이터 푸시 기능 구현을 위한 모범 사례의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명：

이전 기사：작업자 개발 사례 공유 : 실시간 채팅 시스템의 높은 안정성 확보다음 기사：작업자 개발 사례 공유 : 실시간 채팅 시스템의 높은 안정성 확보