Channel 협고 통로

Channel은 협고간 통신을 위한 메커니즘입니다. 하나의 협고는 데이터를 통로에 푸시할 수 있으며, 다른 협고는 그로부터 데이터를 팝하여 협고 간의 동기화 및 데이터 공유를 구현할 수 있습니다.

팁
이 기능은 workerman>=5.1.0이 필요합니다.

주의

• 하위에서 자동으로 Swoole/Swow/Fiber/Select/Event 구동을 지원합니다.
• Select/Event 구동을 사용할 때는 pop/push의 타임아웃 매개변수를 지원하지 않습니다.

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Channel;
use Workerman\Coroutine;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// Http 서버
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // 또는 Swow::class 또는 Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $channel = new Channel(2);
    Coroutine::create(function () use ($channel) {
        $channel->push('작업 1 완료');
    });
    Coroutine::create(function () use ($channel) {
        $channel->push('작업 2 완료');
    });
    $result = [];
    for ($i = 0; $i < 2; $i++) {
        $result[] = $channel->pop();
    }
    $connection->send(json_encode($result)); // 응답: ["작업 1 완료","작업 2 완료"]
};
Worker::runAll();

인터페이스 설명

interface ChannelInterface
{
    /**
     * 데이터를 통로에 푸시합니다. 타임아웃을 지원합니다(단위: 초), 타임아웃 시 false를 반환합니다.
     */
    public function push(mixed $data, float $timeout = -1): bool;

    /**
     * 통로에서 데이터를 팝합니다. 타임아웃을 지원합니다(타임아웃 단위: 초), 타임아웃 시 false를 반환합니다.
     */
    public function pop(float $timeout = -1): mixed;

    /**
     * 통로의 데이터 길이를 가져옵니다.
     */
    public function length(): int;

    /**
     * 통로의 용량을 가져옵니다.
     */
    public function getCapacity(): int;

    /**
     * 소비자가 있는지 확인합니다. 즉, pop 데이터를 기다리는 협고가 있는지 확인합니다.
     */
    public function hasConsumers(): bool;

    /**
     * 생산자가 있는지 확인합니다. 즉, 통로에 데이터를 푸시할 것을 기다리는 협고가 있는지 확인합니다.
     */
    public function hasProducers(): bool;

    /**
     * 통로를 닫습니다.
     */
    public function close(): void;

}