[TOC] ## redis 事件訂閱發布 ``` <?php use Swoole\Coroutine; use Swoole\Coroutine\Redis as SwooleCoroutineRedis; // 創建 Swoole 協程 Coroutine\run(function () { // 協程1：發送 Redis 事件 Coroutine::create(function () { $publisher = new SwooleCoroutineRedis(); $publisher->connect('127.0.0.1', 6379); while (true) { $message = time(); // 示例：發送當前時間作為消息 $publisher->publish('channel', $message); echo "Sent message: $message\n"; Coroutine::sleep(1); // 每秒發送一次事件 } }); //創建 Redis 訂閱客戶端 //協程2：訂閱 Redis 事件 Coroutine::create(function () { $subscriber = new SwooleCoroutineRedis(); $subscriber->connect('127.0.0.1', 6379); // 訂閱 Redis 事件 $subscriber->subscribe(['channel']); while (true) { $message = $subscriber->recv(); // 接收消息 if ($message !== false) { list($a,$channel, $msg) = $message; echo "Received message from channel:$channel: $msg\n"; } } }); }); ```