webman的redis-queue队列消费怎么算成功呢?

wenmingpig

webman的Redis消息队列组件 redis-queue文档中没有提及,如何告知服务部分消费成功?例子中没有说明,试验代码,会按重试次数重试。

Stomp组件则有下面这种代码,告知服务端已经消费成功。

// 值为 client 时需要调用$ack_resolver->ack()告诉服务端已经成功消费
// 值为 auto   时无需调用$ack_resolver->ack()
public $ack = 'auto';
1738 2 0
2个回答

walkor

没有抛异常就算成功。如果抛出异常算作失败,会进入重试队列。

  • wenmingpig 2021-12-03

    非常感谢,现在发现未查到的原因,public function consume($data) 执行了两次。 'max_attempts' => 0 也会有两次

  • yoyo_admin 2021-12-21

    这个问题解决了吗!,这一点我也有点疑惑

evilk

redis这种非专业的MQ,没有ack机制

  • 暂无评论
年代过于久远,无法发表回答
🔝