<?php
$subscriber = $events->getSubscriber();
$subscriber->subscribeLocally(function ($subscription) {
    $subscription->setChannel("subscription channel");
    $subscription->setId("subscription id");
}, function ($it) use ($console) {
    $console->log("sub.php 收到事件", $it->getData(), $it->getTime(), $it->getChannel());
});
$subscriber->subscribeGlobally(function ($subscription) {
    $subscription->setChannel("subscription channel");
    $subscription->setId("subscription id");
}, function ($it) use ($console) {
    $console->log("sub.php 收到事件", $it->getData(), $it->getTime(), $it->getChannel());
});
$mainThread = $script->getThreads()->getMain();
$timer = $mainThread->getTimer();
$timer->setTimeout(function () {
    // 保持脚本3秒钟不结束
}, 3000);