0

我们有一个将数据推送到 SQS 的外部系统,消费者是另一个 java 服务,它侦听并创建请求,分发任务,然后确认 SQS。

但是有一次出现了内存堆问题,从日志中可以理解,java消费者多次消费了Queue,但每次都抛出内存异常,后来好像都省了。所以 Q 没有得到确认,因此消费者可以获得数据。数据库提交仅在一段时间后发生。

避免此类问题的策略,我们可以采取什么方法?异常处理,SQS 重试机制更改,检查是否存在某种验证..?

4

0 回答 0