Hyperf Channel通道怎么使用-php教程-PHP中文网

hyperf 的 channel 是 swoole 协程通道，仅限单协程内通信，非队列或消息中间件；必须在协程中使用，支持阻塞式 push/pop，需设容量防内存溢出，不可跨请求/进程，与 context 分工明确。

hyperf channel通道怎么使用

Hyperf 的 Channel 不是队列，也不是消息中间件，它只在单个协程生命周期内有效，跨协程通信必须靠它，但跨进程、跨请求、跨 Worker 完全无效。

Channel 初始化和基本 push/pop 用法

Hyperf 中的 Channel 来自 Swoole 原生协程通道（Swoole\Coroutine\Channel），不是 Hyperf 自研组件。它不依赖 Redis 或其他外部服务，纯内存操作，但必须在协程上下文中使用——直接在非协程环境（如 __construct、同步控制器方法）中 new 一个 Channel，会报错或行为不可预测。

常见错误现象：Fatal error: Uncaught Swoole\Exception: must be called in the coroutine

必须用 co(function() { ... }) 或 go() 启动协程后再创建
push() 和 pop() 都是阻塞式调用：空时 pop() yield，满时 push() yield（默认容量为 -1，即无限，但生产环境建议显式设限）
不要在 pop() 后再做耗时 I/O（比如 $client->get()），否则会卡住整个协程调度；应先 pop，再并发发起 I/O

示例：

co(function() {
    $channel = new \Swoole\Coroutine\Channel(2); // 容量为 2
    co(function() use ($channel) {
        $channel->push('task-1');
        $channel->push('task-2'); // 此时 channel 已满
        $channel->push('task-3'); // 协程在此 yield，等待有人 pop
    });
    \co::sleep(0.1);
    echo $channel->pop(); // 'task-1'
    echo $channel->pop(); // 'task-2'
});

Channel 用于多协程协作时的数据同步

典型场景是「多个生产者 + 一个消费者」或「一个生产者 + 多个消费者」，比如并发请求后统一收口处理结果。注意：多个协程同时 pop() 时，谁先抢到谁拿走数据，无顺序保证（除非加锁或用 Channel 配合 Context 控制）。

容易踩的坑：

误以为 Channel 能跨 HTTP 请求共享数据——不行。每个请求是独立协程，Channel 实例不复用，也不传递
在 WebSocket onMessage 里把 $channel 存成类属性，然后在另一个协程里读——协程上下文已销毁，$channel 可能已被 GC 或指向错误实例
未设置超时，pop() 无限等待导致协程永久挂起（可配合 Channel::pop(float $timeout = -1) 使用）

正确做法是：每次协作逻辑内新建 Channel，或通过闭包 use 显式传递，不依赖任何类成员变量。