<?php
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Redis\Client;
use Workerman\Timer;
use Workerman\Worker;

global $redis, $redis1;

$worker = new Worker("http://0.0.0.0:8111");

function timer_test(){
    echo "\ntimer is running.";
    global $redis1;
    $redis1->setEx("test_key", 5, "123");
    $redis1->setEx（
}
function expire_test($redis, $pattern, $channel, $message) {
    echo "$pattern, $channel, $message"; 
}
$worker->onWorkerStart = function($worker) {
    global $cfg, $redis1, $redis;

    if($worker->id == 0){
        Timer::add(10, "timer_test");
    }

    $redis1 = new Client('redis://127.0.0.1:6379');
    $redis2 = new Client('redis://127.0.0.1:6379');

    $redis2->psubscribe(array("__keyevent@0__:expired"), "expire_test");
};

$worker->onMessage = function($connection, $data) {
};

Worker::runAll();