用于AWS SQS队列配置的Spring JMS侦听器，具有并发性

Question

我试图弄清楚如何配置jms侦听器来侦听AWS队列并在多个线程中处理消息（同时大约100个线程）。

下面是我的配置。

@Configuration
@EnableJms
public class JmsConfig {

    @Bean
    public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(AmazonSQS amazonSQS) {
        ProviderConfiguration providerConfiguration = new ProviderConfiguration().withNumberOfMessagesToPrefetch(0);
        SQSConnectionFactory connectionFactory = new SQSConnectionFactory(providerConfiguration, amazonSQS);
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setDestinationResolver(new DynamicDestinationResolver());
        factory.setConcurrency("30-100");
        factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        factory.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONNECTION);
        factory.setErrorHandler(t -> {
        });
        return factory;
    }

}

随着这种混乱，我不断收到以下错误：

SQSMessage消费者-30秒后无法终止执行器服务消费者预取，一些正在运行的线程将立即关闭

此外，将消息发布到Amazon SQS实例需要20秒。

我尝试了NumberOfMessagesToPrefetch和CacheLevel的不同组合，但都无法正常工作。

CacheLevel=CACHE_CONSUMER没有错误，但一次处理1条消息。

请帮我配置这个。谢谢！

库：

>

aws java sdk：1.11.41

spring jms:5.1.7

Amazon-sq s-java-消息传递-lib：1.0.6

Answer 1

@Boris I能够通过以下方式解决此问题。我不设置缓存级别。提供程序配置仍在禁用预取

<代码>ProviderConfiguration ProviderConfiguration=新ProviderConfiguration（）。withNumberOfMessagesToPrefetch（0）

此外，我使用DefaultJmsListenerContainerFactory，然后设置以下值，以及未显示的其他值：

<代码>工厂。setConcurrency（“5-10”）//这将取决于您的用例工厂。setSessionAcknowledgeMode（会话.客户端\u确认）//用于飞行中的错误消息工厂。setTaskExecutor（threadPoolTaskExecutor（））//使用threadpooltask执行器，请参阅下面的工厂。setMaxMessagesPerTask（10）//不需要，但可以减少线程切换。这将取决于您的用例

在使用ThreadPool Executor之前，请先阅读ThreadPool Executor，它写于12年前，但仍然有效。我没有在@JmsListener级别上设置并发，因为它会导致额外的复杂性JmsListener并发