Spring Boot 健康检查 - SQS 消费者

Question

SQS 是否有 Spring Boot Actuator Health Check 端点？我已经建立了一个 SQS 消费者，我想检查 SQS 是否已启动并正在运行。我没有使用 JMSlistener 连接到 SQS，而是使用 Spring Cloud Libraries。

我实现了以下健康检查端点。当我删除队列并尝试点击运行状况检查端点时，这将返回以下错误。如果存在连接问题或 SQS 服务出现故障，我是否会收到类似的错误，最终导致运行状况检查端点失败？

com.amazonaws.services.sqs.model.QueueDoesNotExistException： 此 wsdl 版本不存在指定的队列。 （服务： 亚马逊SQS；状态码：400；错误代码： AWS.SimpleQueueService.NonExistentQueue；请求编号： cd8e205d-dc43-535e-931f-7332733bd16c)

public class SqsQueueHealthIndicator extends AbstractHealthIndicator {

    private final AmazonSQSAsync amazonSQSAsync;
    private final String queueName;

    public SqsQueueHealthIndicator(AmazonSQSAsync amazonSQSAsync, String queueName) {
        this.amazonSQSAsync = amazonSQSAsync;
        this.queueName = queueName;
    }

    @Override
    protected void doHealthCheck(Health.Builder builder) {
        try {
            amazonSQSAsync.getQueueUrl(queueName);
            builder.up();
        } catch (QueueDoesNotExistException e) {
            e.printStackTrace();
            builder.down(e);
        }
    }

}

豆类

@Bean
SqsQueueHealthIndicator queueHealthIndicator(@Autowired AmazonSQSAsync amazonSQSAsync, @Value("${sqs.queueName}") String queueName) {
    return new SqsQueueHealthIndicator(amazonSQSAsync, queueName);
}

@Bean
SqsQueueHealthIndicator deadLetterQueueHealthIndicator(@Autowired AmazonSQSAsync amazonSQSAsync, @Value("${sqs.dlQueueName}") String deadLetterQueueName) {
    return new SqsQueueHealthIndicator(amazonSQSAsync, deadLetterQueueName);
}

Answer 1

您必须编写如下自定义运行状况检查，通过使用AWS Java SDK lib 调用getQueueUrl 来检查您的队列是否存在。

    @Component
public class SQSHealthCheck implements HealthIndicator {
    @Override
    public Health health() {
        int errorCode = check(); // perform some specific health check
        if (errorCode != 0) {
            return Health.down()
              .withDetail("Error Code", errorCode).build();
        }
        return Health.up().build();
    }

    public int check() {
        /**
        your logic to check queue exists or not using by calling getQueueUrl . e.g you will get queue url of a queue named "SampleQueue" like https://sqs.us-east-1.amazonaws.com/12XXX56789XXXX/SampleQueue
        **/
        return 0; // 0 or 1 based on result
    }
    }