监控与 SQS 的连接并在它丢失时重新连接

编程问答 2022-06-01

问题描述

我有一个 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 (将#修改为@）

amazon-sqsjavajavalistenerlistenerspringspringspring-boot