昨天初审时候客户提出一个问题,说下,看能否有人提供一个思路:
我们是从 rabbitMq 中读到消息,然后就是在 java 中进行一系列的处理,然后发送到各个地方,比如邮箱。
问题是,如果读进来的那条消息,因为一些未知的异常,一直在 java 中处理,那这条消息在 mq 中就会一直等待返回。
别的 mq 消息应该是不会有影响的,因为不是排队处理的。
但是怎么样判断一下,进来 java 处理的这条消息,进来了多久了,比如说进来了 1 分钟了,还没有处理完,那我就把这条消息当成异常输出到别的文件中。
我之前想,难道要这条消息进来时候看一下时间,然后设定一个 timeout 时间,等超过了这个时间,就做处理?
还有别的方法吗?
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于