如何解决监控与 SQS 的连接并在它丢失时重新连接
我有一个 Spring-Boot 微服务,它侦听 Amazon SQS 队列。监听器的配置如下:
@SqsListener(value = "${sqs.queue.name}",deletionPolicy = ON_SUCCESS)
public void queueListener(Message message) throws Exception {
// some logic here
}
一切正常,但有时由于我无法理解的原因(没有例外或任何事情),我的微服务只是停止接收消息。根据 Amazon SQS 控制台消息,消息开始堆积在队列中,没有人读取它们。
如果我重新部署微服务,所有堆积的消息都会立即得到处理。暂时一切正常,直到这个问题再次出现。
我的想法是实现一些 cron-job 来监控与 SQS 的连接。如果连接丢失(如果首先是这种情况)我会重新建立它。
那么有没有办法连接到 SQS 并在应用程序启动期间而不是在运行时开始侦听队列?
我使用的是 Spring-Boot 2.4.0。我也有这些依赖项:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-aws-messaging</artifactId>
<version>1.2.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-aws-autoconfigure</artifactId>
<version>1.2.2.RELEASE</version>
</dependency>
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。