Advanced Workerman 개발: 분산 다중 프로세스 통신 구현

Advanced Workerman 개발: 분산 다중 프로세스 통신 구현

인터넷 애플리케이션의 발전과 함께 웹 백엔드 개발의 요구 사항이 점점 더 다양해지고 복잡해지고 있습니다. 기존의 단일 프로세스 단일 스레드 개발 모델은 더 이상 대규모 트래픽과 높은 동시성 요구 사항을 충족할 수 없습니다. 시스템의 성능과 확장성을 향상시키기 위해 분산 다중 프로세스 통신이 핵심 기술이 되었습니다.

이 글에서는 Workerman 프레임워크를 사용하여 분산 다중 프로세스 통신을 구현하는 방법을 소개합니다. Workerman은 고성능 TCP/UDP 서버 및 클라이언트 프로그래밍을 지원하는 간단하고 사용하기 쉬운 PHP 다중 프로세스 네트워크 프로그래밍 프레임워크입니다. Workerman의 강력한 기능을 활용하여 고성능의 확장 가능한 분산 애플리케이션을 쉽게 구축할 수 있습니다.

먼저 Workerman 프레임워크의 기본 사용법을 이해하겠습니다. 다음은 Workerman을 기반으로 한 간단한 TCP 서버 샘플 코드입니다.

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

use WorkermanWorker;

$worker = new Worker('tcp://0.0.0.0:8888');
$worker->count = 4;

$worker->onWorkerStart = function($worker) {
    echo "Worker {$worker->id} started
";
};

$worker->onConnect = function($connection) {
    echo "New connection from {$connection->getRemoteIp()}:{$connection->getRemotePort()}
";
};

$worker->onMessage = function($connection, $data) {
    echo "Received message: {$data}
";
    $connection->send("Hello, {$data}!
");
};

Worker::runAll();

위 샘플 코드에서는 로컬 8888 포트를 수신하고 연결을 처리하기 위해 4개의 프로세스를 설정하는 TCP 프로토콜 기반 Worker 개체를 만들었습니다. 각 프로세스는 시작 시 작업자 번호를 출력하는 데 사용되는 onWorkerStart 콜백 함수를 실행합니다. 새로운 연결이 설정되면 onConnect 콜백 함수가 실행되고 연결 관련 정보가 콘솔에 출력됩니다. 클라이언트로부터 메시지가 수신되면 onMessage 콜백 함수가 트리거되고 수신된 메시지가 콘솔에 출력된 후 Hello 및 메시지 내용이 클라이언트로 다시 전송됩니다.

위의 예는 Workerman의 기본 사용법에 불과합니다. 다음으로 Workerman을 사용하여 분산 다중 프로세스 통신을 구현하는 방법을 소개합니다. 많은 수의 이미지 업로드를 처리해야 하는 애플리케이션이 있다고 가정해 보겠습니다. 성능을 향상시키기 위해 이미지 업로드 작업을 여러 프로세스에 분산하여 처리하려고 합니다. 다음은 분산 다중 프로세스 통신을 구현하는 샘플 코드입니다.

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

use WorkermanWorker;
use WorkermanLibTimer;

$taskWorkerCount = 4;
$uploadWorkerCount = 2;

$taskWorker = new Worker();
$taskWorker->count = $taskWorkerCount;

$uploadWorker = new Worker();
$uploadWorker->count = $uploadWorkerCount;

$taskWorker->onWorkerStart = function($worker) {
    $uploadWorker = new Worker();
    $uploadWorker->count = $GLOBALS['uploadWorkerCount'];
    $uploadWorker->onMessage = function($connection, $data) {
        echo "TaskWorker {$worker->id} received upload message: {$data}
";
        $connection->send("TaskWorker {$worker->id} received upload message: {$data}
");
    };

    $uploadWorker->listen('tcp://127.0.0.1:5678');
    echo "TaskWorker {$worker->id} started
";
};

$uploadWorker->onWorkerStart = function($worker) {
    Timer::add(1, function() use($worker) {
        $taskWorkerId = rand(0, $GLOBALS['taskWorkerCount'] - 1);
        $taskWorker = $worker->getWorkerById($taskWorkerId);
        $taskWorker->send("Upload message");
    });
    echo "UploadWorker {$worker->id} started
";
};

Worker::runAll();

위 샘플 코드에서는 TaskWorker와 UploadWorker를 생성했습니다. TaskWorker는 UploadWorker로부터 메시지를 수신하고 수신된 메시지를 콘솔에 출력하는 역할을 담당합니다. UploadWorker는 1초마다 TaskWorker에 메시지를 보내는 역할을 담당합니다. 편의를 위해 각 TaskWorker는 시작 시 UploadWorker를 생성하고 로컬 포트 ​​5678을 수신하여 UploadWorker로부터 메시지를 수신합니다.

위의 샘플 코드를 통해 Workerman을 사용하여 간단한 분산 다중 프로세스 통신을 구현하는 방법을 확인할 수 있습니다. 작업을 적절하게 할당하고 여러 프로세스를 활용함으로써 고성능 및 확장 가능한 애플리케이션을 달성할 수 있습니다.

요약하자면 Workerman 프레임워크는 분산 다중 프로세스 통신에 매우 적합한 도구입니다. Workerman의 기능을 유연하게 사용함으로써 고성능, 확장 가능한 분산 애플리케이션을 쉽게 구축할 수 있습니다. 이 글이 모든 분들의 업무와 공부에 도움이 되기를 바랍니다.

위 내용은 Advanced Workerman 개발: 분산 다중 프로세스 통신 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!