問題描述

項目發(fā)版執(zhí)行 php start.php reload 重啟服務時，如果 redis 消費者進程正在處理消息，會導致這些消息丟失。
請問各位大佬，在不改 webman/redis-queue 插件源碼的情況下，有辦法解決這個問題嗎？還是說只能換專業(yè)的 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');
    }
}

重現(xiàn)問題的步驟

• 投遞消息

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

• 監(jiān)控日志文件

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

• 在消費者進程執(zhí)行過程中，重啟 webman 服務

  php start.php reload

• 我原本預期 webman 服務平滑重啟時，會將消費者進程執(zhí)行一半的消息重入隊列，重啟完成后，這些消息將再次被執(zhí)行，但測試驗證結果并非如此（項目的日志文件沒有執(zhí)行日志）。

操作系統(tǒng)環(huán)境及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