webman reload 平滑重启，导致 redis 消费者进程正在处理的消息丢失

问题描述

项目发版执行 php start.php reload 重启服务时，如果 redis 消费者进程正在处理消息，会导致这些消息丢失。
请问各位大佬，在不改 webman/redis-queue 插件源码的情况下，有办法解决这个问题吗？还是说只能换专业的 MQTT 服务了？

消费者进程的演示代码

<?php

namespace app\queue\redis;

use support\Log;
use Webman\RedisQueue\Consumer;

class TestConsume implements Consumer
{
    public $queue = 'test-consume';

    public $connection = 'default';

    public function consume($data)
    {
        Log::info('@@@@@@@start');
        for ($i = 0;$i < 10;$i++) {
            sleep(1);
        }
        Log::info('@@@@@@@end');
    }
}

重现问题的步骤

• 投递消息

  Redis::send('test-consume', []);

• 监控日志文件

  tail -f runtime/logs/webman-2025-01-09.log
  #输出
  [2025-01-09 09:54:33] default.INFO: @@@@@@@start [] []

• 在消费者进程执行过程中，重启 webman 服务

  php start.php reload

• 我原本预期 webman 服务平滑重启时，会将消费者进程执行一半的消息重入队列，重启完成后，这些消息将再次被执行，但测试验证结果并非如此（项目的日志文件没有执行日志）。

操作系统环境及workerman/webman等具体版本

Linux CentOS 7
PHP 8.2.22
Webman-framework v1.5.24
webman/redis-queue v1.3.2
Redis Version: 7.0.11