webman的Redis消息队列组件 redis-queue文档中没有提及,如何告知服务部分消费成功?例子中没有说明,试验代码,会按重试次数重试。
Stomp组件则有下面这种代码,告知服务端已经消费成功。
// 值为 client 时需要调用$ack_resolver->ack()告诉服务端已经成功消费 // 值为 auto 时无需调用$ack_resolver->ack() public $ack = 'auto';
没有抛异常就算成功。如果抛出异常算作失败,会进入重试队列。
非常感谢,现在发现未查到的原因,public function consume($data) 执行了两次。 'max_attempts' => 0 也会有两次
这个问题解决了吗!,这一点我也有点疑惑
redis这种非专业的MQ,没有ack机制
没有抛异常就算成功。如果抛出异常算作失败,会进入重试队列。
非常感谢,现在发现未查到的原因,public function consume($data) 执行了两次。 'max_attempts' => 0 也会有两次
这个问题解决了吗!,这一点我也有点疑惑
redis这种非专业的MQ,没有ack机制