请问阻塞调用的子进程如何接收信号，并处理呢?

dazhaozhao 2021-12-30

请问大佬，我想用workerman来做redis stream的消费端，我试了这么写，好像发送信号，响应不了啊

<?php

use Workerman\Events\EventInterface;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

$worker                = new Worker();
$worker->count         = 1;
$worker->onWorkerStart = function ($worker) {

    echo 'Pid is ' . posix_getpid() . "\n";

    // 当进程收到SIGALRM信号时，打印输出一些信息
    Worker::$globalEvent->add(SIGALRM, EventInterface::EV_SIGNAL, function () {
        //？？？ 打印不了啊
        echo "Get signal SIGALRM\n";
    });

    while (true) {
        //这里做redis 阻塞读取 消息 
        echo "123\n";
        sleep(3);
    }

};
// 运行worker
Worker::runAll();

 1159  3 0

3个回答

phpcreeper 2021-12-30

1、信号无法响应原因是：
while死循环剥夺了workerman的控制权，换句话也就是导致event.loop()循环永远都执行不到；
2、建议将while死循环改成定时器；

暂无评论

Tinywan 2021-12-30

定时器实现

Timer::add(1, function (){
    RedisStreamQueue::consumer(
        RedisStreamQueue::STREAM_CHANNEL,
        RedisStreamQueue::GROUP_CHANNEL,
        RedisStreamQueue::CONSUMER_CHANNEL_A
    );
});