centos7.9，最新webman，按文檔使用隊(duì)列，內(nèi)容如下，即時(shí)隊(duì)列可以正常消費(fèi)，延時(shí)隊(duì)列不能正常消費(fèi)。

正常的流程應(yīng)該是當(dāng){redis-queue}-delayed里面的隊(duì)列時(shí)間到指定的延長時(shí)間，就會(huì)將里面的數(shù)據(jù)轉(zhuǎn)移到{redis-queue}-waiting里面，現(xiàn)在我的情況是{redis-queue}-waiting里面的均能正常消費(fèi)，但是{redis-queue}-delayed的數(shù)據(jù)一直不處理。 plugin.webman.redis-queue.consumer這個(gè)進(jìn)程是存在的，要不然也不會(huì)只消費(fèi)即時(shí)隊(duì)列的數(shù)據(jù)。

琢磨了一下午。有大神能指點(diǎn)一下嗎？

隊(duì)列投遞

<?php

namespace app\rsapi\v2\controller;

use support\Request;
use Webman\RedisQueue\Redis;

class TestController
{
    public function index(Request $request)
    {
        // 隊(duì)列名
        $queue = 'timeout_order_queue';
        // 數(shù)據(jù)，可以直接傳數(shù)組，無需序列化
        $data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
        // 投遞消息
        Redis::send($queue, $data);
        // 投遞延遲消息，消息會(huì)在60秒后處理
        Redis::send($queue, $data, 5);

        return response('redis queue test');
    }
}

隊(duì)列消費(fèi)

<?php

namespace app\queue\redis;

use Webman\RedisQueue\Consumer;

class TimeoutOrderQueue implements Consumer
{
    // 要消費(fèi)的隊(duì)列名
    public $queue = 'timeout_order_queue';

    // 連接名，對(duì)應(yīng) plugin/webman/redis-queue/redis.php 里的連接`
    public $connection = 'default';

    // 消費(fèi)
    public function consume($data)
    {
        // 無需反序列化
        var_export($data);
    }
}

最近我發(fā)現(xiàn)，這個(gè)類名和$queue的名稱一定要對(duì)應(yīng)，否則延遲隊(duì)列不會(huì)生效，$queue是小寫的方式。