redis-queue 延遲隊(duì)列不消費(fèi)，使用的官方源碼安裝

tl54577 更新于2024-12-18

問題描述

程序代碼或配置

Redis::connection('house')->send('merchant-cancel-order', ['id' =>$orderInfo['id']], 3600);

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

隊(duì)列數(shù)據(jù)：
配置文件：

操作系統(tǒng)環(huán)境及workerman/webman等具體版本

使用webman 1.6.9 redis版本：7.2

 732  1 1

1個(gè)回答

nitron 2024-12-17

你這隊(duì)列名和你上面send的對(duì)不上啊
一個(gè)merchant-cancel-order,一個(gè)order-push-hall, delay值也對(duì)不上啊,一個(gè)3600一個(gè)120

tl54577 2024-12-17

粘貼錯(cuò)了，是這樣寫的。 Redis::connection('other')->send('order-push-hall', ['id' => $result->id], 120);
nitron 2024-12-17

消費(fèi)進(jìn)程的代碼呢

tl54577 2024-12-17

<?php
namespace app\queue\redis;

use app\api\model\Order;
use Webman\RedisQueue\Consumer;

//顯示到服務(wù)大廳
class OrderPushHall implements Consumer
{
// 要消費(fèi)的隊(duì)列名
public $queue = 'order-push-hall';

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

// 消費(fèi)
public function consume($data)
{
    Order::where('id', $data['id'])->update(['is_visible' => 0]);
    return  true;
}

}

nitron 2024-12-17

有沒有報(bào)錯(cuò),重啟了沒
tl54577 2024-12-17

沒有報(bào)錯(cuò)。重啟都試過了
nitron 2024-12-17

不清楚,166->169沒看到對(duì)隊(duì)列代碼有改動(dòng)
tanhongbin 2024-12-17

剛才測試了沒任何問題呀
tl54577 2024-12-17

可以看看你的隊(duì)列數(shù)據(jù)嗎
tanhongbin 2024-12-17

這也截不了圖呀，而且我用的是我魔改群主插件后的隊(duì)列，和群主原生有一些區(qū)別，就是可以用中間件
tanhongbin 2024-12-18

應(yīng)該不會(huì) 要是有問題早就反饋了，你看看你卸載這個(gè)插件再裝一下試試
tl54577 2024-12-18

消費(fèi)的時(shí)候使用只能使用 public $connection = 'default'。如果使用other house。都不行。
tl54577 2024-12-18

投遞時(shí)候使用Redis::connection('house')->send();不行。直接使用Redis::send()可以
tanhongbin 2024-12-18

你投遞的時(shí)候 Redis用的是那個(gè)類？
nitron 2024-12-18

把發(fā)送任務(wù),消費(fèi)任務(wù)的整個(gè)代碼都帖全吧