SimpleMessageListenerContainer 亚马逊 SQS 轮询间隔

Question

SimpleMessageListenerContainer 亚马逊 SQS 轮询间隔

springamazon-web-servicesspring-bootspring-cloudamazon-sqs

4

我正在使用Spring Cloud库轮询SQS。如何设置轮询间隔？

@Bean
@Primary
public AmazonSQSAsync amazonSQSAsync() {
    return AmazonSQSAsyncClientBuilder.standard().
            withCredentials(awsCredentialsProvider()).
            withClientConfiguration(clientConfiguration()).
            build();
}


@Bean
@ConfigurationProperties(prefix = "aws.queue")
public SimpleMessageListenerContainer simpleMessageListenerContainer(AmazonSQSAsync amazonSQSAsync) {
    SimpleMessageListenerContainer simpleMessageListenerContainer = new SimpleMessageListenerContainer();
    simpleMessageListenerContainer.setAmazonSqs(amazonSQSAsync);
    simpleMessageListenerContainer.setMessageHandler(queueMessageHandler());
    simpleMessageListenerContainer.setMaxNumberOfMessages(10);
    simpleMessageListenerContainer.setTaskExecutor(threadPoolTaskExecutor());
    return simpleMessageListenerContainer;
}


@Bean
public QueueMessageHandler queueMessageHandler() {
    QueueMessageHandlerFactory queueMessageHandlerFactory = new QueueMessageHandlerFactory();
    queueMessageHandlerFactory.setAmazonSqs(amazonSQSAsync());
    QueueMessageHandler queueMessageHandler = queueMessageHandlerFactory.createQueueMessageHandler();
    return queueMessageHandler;
}


@Bean
public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    executor.setMaxPoolSize(10);
    executor.setThreadNamePrefix("oaoQueueExecutor");
    executor.initialize();
    return executor;
}

- Punter Vicky

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Raj · Accepted Answer

请在您的 queueMessageHandler() 函数中调用 org.springframework.cloud.aws.messaging.listener 包中 AbstractMessageListenerContainer 基类的 setWaitTimeOut(N) 方法。其中 N 是长轮询超时时间（以秒为单位）。例如，如果您希望等待 5 秒钟才返回，请在函数中使用以下代码行。如果不调用此函数，则默认值为 1 秒。长轮询超时的最大值为 20 秒，因此您可以将此函数的最大值设置为 20，表示“等待 20 秒”。

simpleMessageListenerContainer.setWaitTimeOut (5);

源代码在这里：https://github.com/spring-cloud/spring-cloud-aws/blob/master/spring-cloud-aws-messaging/src/main/java/org/springframework/cloud/aws/messaging/listener/AbstractMessageListenerContainer.java

意思是该网页提供了源代码的下载链接，可以点击链接获取源代码。

/**
     * Configures the wait timeout that the poll request will wait for new message to arrive if the are currently no
     * messages on the queue. Higher values will reduce poll request to the system significantly.
     *
     * @param waitTimeOut
     *         - the wait time out in seconds
     */
    public void setWaitTimeOut(Integer waitTimeOut) {
        this.waitTimeOut = waitTimeOut;
    }