AWS 集成 spring：延长可见性超时

Question

是否可以延长正在传输的消息的可见时间。

看：

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html。

部分：更改消息的可见性超时。

http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/sqs/AmazonSQSClient.html#changeMes​​sageVisibility-com.amazonaws.services.sqs.model.ChangeMes​​sageVisibilityRequest-

总之，我希望能够延长正在运行的给定消息的第一组可见性超时。

例如，如果 15 秒过去了，我想将超时再延长 20 秒。上面的 java 文档中有更好的例子。

根据我对上面链接的理解，您可以在亚马逊方面执行此操作。

以下是我当前的设置；

  SqsMessageDrivenChannelAdapter adapter =
  new SqsMessageDrivenChannelAdapter(queue);
  adapter.setMessageDeletionPolicy(SqsMessageDeletionPolicy.ON_SUCCESS);
  adapter.setMaxNumberOfMessages(1);
  adapter.setSendTimeout(2000);
  adapter.setVisibilityTimeout(200);
  adapter.setWaitTimeOut(20);

是否可以延长这个超时时间？

Answer 1

Spring Cloud AWS 从 2.0 版本开始支持此功能。在 SQS 侦听器方法中注入Visiblity参数即可解决问题：

  @SqsListener(value = "my-sqs-queue")
  void onMessageReceived(@Payload String payload, Visibility visibility) {
    ...
    var extension = visibility.extend(20);
    ...
  }

请注意，这extend将异步工作并返回一个 Future。因此，如果您想进一步确定处理过程，消息的可见性确实在 AWS 方面得到了扩展，可以使用以下方法阻止 Future，extension.get()或者使用以下命令查询 Future：extension.isDone()

Answer 2

好的。看来我明白你的观点了。

我们可以使用 API 更改特定消息的可见性：

AmazonSQS.changeMessageVisibility(String queueUrl, String receiptHandle, Integer visibilityTimeout)

为此，在下游流程中，您必须访问（注入）AmazonSQSbean 并从以下位置提取特殊标头Message：

@Autowired
AmazonSQS amazonSqs;

@Autowired
ResourceIdResolver resourceIdResolver;
...


MessageHeaders headers = message.getHeaders();

DestinationResolver destinationResolver = new DynamicQueueUrlDestinationResolver(this.amazonSqs, this.resourceIdResolver);

String queueUrl = destinationResolver.resolveDestination(headers.get(AwsHeaders.QUEUE));

String receiptHandle = headers.get(AwsHeaders.RECEIPT_HANDLE);

amazonSqs.changeMessageVisibility(queueUrl, receiptHandle, YOUR_DESIRED_VISIBILITY_TIMEOUT);

但是，呃，我同意我们应该就此事提供一些开箱即用的功能。这甚至可能类似于QueueMessageAcknowledgment新标头。或者甚至只是changeMessageVisibility除此之外的另一种方法。

请就此事向Spring Cloud AWS项目提出 GH 问题，并链接到此 SO 主题。