redis做了一个简单消息队列，在消费队列执行的时候遇到异常，消费队列停止执行，如何继续？

Question

Jedis jedis = RedisUtil.getJedis();
while (true) {
    List<String> messages = jedis.brpop(0, "testQueue");
    +++++++++++++++++++++++++++++++++++++++++++++++++++
}

如题目，在消费过程中报错，如何让消息队列继续执行消费其他数据？

 

Answer 1

嗯，人工介入这块也需要完善下，感谢指点！

Answer 2

命令你可以用rpoplpush 弹出对接的同时追加到另一个队列 如果没报错清空另一个队列 如果报错取出另一个队列的值再执行一次 如果还有问题就人工介入处理

Answer 3

是的，这块还不是很完善，确实需要另一个队列再处理下，感谢！

Answer 4

类似mq，你加个本地队列，异常后抛到本地队列异步继续执行，或者抛到redis另外一个队列异步继续执行；