redis-queue 队列插件能不能主动抛出异常？

kspade

https://www.workerman.net/plugin/12
下面是webman 官方插件的一些说明： 

消费失败重试
如果消费失败(发生了异常)，则消息会放入延迟队列，等待下次重试。重试次数通过参数 max_attempts 控制，重试间隔由
retry_seconds 和 max_attempts共同控制。比如max_attempts为5，retry_seconds为10，第1次重试间隔为1*10秒，第2次重试时间间隔为 2*10秒，第3次重试时间间隔为3*10秒，以此类推直到重试5次。如果超过了max_attempts设置测重试次数，则消息放入key为{redis-queue}-failed的失败队列。
注意
消费过程中没有抛出异常视为消费成功，否则消费失败，进入重试队列

问题

因为redis没有ack 模式，
1.能否故意把某个队列抛出为异常（目的是为了丢进重试队列）
2.又或者能不能主动把某条队列丢入重试队列

原因

因为我的队列消费时的工作场景为：curl 携带XX参数，访问一个异步通知地址，当整个地址返回的内容为：success 代表消费成功，否则丢入重试队列(xx秒后重试 - 一共重试5次)

rabbitmq 的stomp是符合我的使用场景的，搞了两天了都没搞定这玩意 太难了！
什么都搞好了，投递消息就提示：Stomp client: not_found
放弃了 搞redis-queue

1504 4 0
4个回答
2548a

使用 throw new \Exception();不就好了吗

  • kspade 2022-05-22

    public function consume 里面 怎么使用哦
  • 2548a 2022-05-22

    判断返回地址,不符合要求就调用 throw new \Exception('xx不符合,重试'); 就完了,这句话就是手动抛异常的.这样它就会判断队列执行失败,等会就会再重新执行了
  • kspade 2022-05-22

    我试了一下并不行，产生一堆垃圾信息

    0 /log/webman/vendor/workerman/redis-queue/src/Client.php(218): app\queue\redis\MyMailSend->consume()

    1 /log/webman/vendor/workerman/redis/src/Client.php(422): Workerman\RedisQueue\Client->Workerman\RedisQueue{closure}()

    2 /log/webman/vendor/workerman/workerman/Connection/TcpConnection.php(638): Workerman\Redis\Client->Workerman\Redis{closure}()

    3 [internal function]: Workerman\Connection\TcpConnection->baseRead()

    4 /log/webman/vendor/workerman/workerman/Events/Event.php(193): EventBase->loop()

    5 /log/webman/vendor/workerman/workerman/Worker.php(2435): Workerman\Events\Event->loop()

    6 /log/webman/vendor/workerman/workerman/Worker.php(1555): Workerman\Worker->run()

    7 /log/webman/vendor/workerman/workerman/Worker.php(1397): Workerman\Worker::forkOneWorkerForLinux()

    8 /log/webman/vendor/workerman/workerman/Worker.php(1371): Workerman\Worker::forkWorkersForLinux()

    9 /log/webman/vendor/workerman/workerman/Worker.php(1692): Workerman\Worker::forkWorkers()

    10 /log/webman/vendor/workerman/workerman/Worker.php(1641): Workerman\Worker::monitorWorkersForLinux()

    11 /log/webman/vendor/workerman/workerman/Worker.php(551): Workerman\Worker::monitorWorkers()

    12 /log/webman/start.php(108): Workerman\Worker::runAll()
  • damao 2022-05-23

    可以的，如果发生异常会显示异常包括调用栈，然后自动扔到重试队列里。你贴的这个就是显示的异常信息
nitron

我给个思路吧,也是现在在用的,不使用提供的失败队列,没有得到需要的结果重新将任务发送到队列内,如果执行有异常则catch住后重新将任务发送到队列内,自己记数,超过了设定的次数都未得到需要的结果则丢弃(即不再送入队列),同时记录日志,通知系统有处理失败的任务

  • 暂无评论
yzh52521 
 // 队列名
    public $queue = '/topic/send_mail';

    // 连接名，对应 config/redis_queue.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {
        // 无需反序列化
        //var_export($data); // 输出 ['to' => 'tom@gmail.com', 'content' => 'hello']
        throw new \Exception('异常消息');
    }
  • 暂无评论
evilk

我现在的做法是:
1.
在消费过程中,如果失败了,则手动抛出异常,让该任务进入原队列,等待重新执行

2.
如果最终超过重试次数,则进入失败队列

3.
为了防止失败队列中的任务堆积 和 监控失败的任务
在整个服务启动的时候,单独起一个自定义进程
在进程启动的时候,开启一个定时器
每5秒(时间自定义,我目前设置的是每5秒执行一次),从失败队列中,取出一个失败的任务
把这个任务所有的数据(包括任务本身 和 异常堆栈),入库(一个专门存放失败任务的表)

4.
在后台,开一个页面,可以看到这个表里的数据,也就是所有失败的任务
在这个页面,根据任务失败的原因,可以选择

  • 重新丢入原队列执行
  • 删除该任务
  • 暂无评论
相似问题
关于redis队列插件中为了触发重试主动抛异常的情况
【webman】redis队列插件，windows下面不能正常消费。
redis queue队列消费不能用Timer::add()???
workman为什么不能抛出异常呢
webman/queue 如何优雅抛出异常？
Redis消息队列插件 redis-queue 连接名问题
年代过于久远，无法发表回答
月贡献榜
1
walkor
🚀
2
Tinywan
♨️ 请叫我 webman 推广大使
3
小Z先生
4
efnic
5
ngrok.cc内网穿透
ngrok.cc 可以让外网访问内网的设备和网站，适用于支付异步回调调试，微信公众号开发，外网控制内网服务器等等
赞助商
+成为赞助商

app,小程序,H5聊天源码

语音|视频|文字聊天

客服系统源码

小程序客服|h5客服|网页客服
×
🔝