我正在使用 spring、dsl、solace 与 spring boot 的集成。我的一个订阅者的应用程序每秒能够轮询大约 80 条消息,而 4 个订阅者每秒能够轮询大约 125 条消息。我想每秒处理至少 500 条消息。我的 JMS 流程如下所述-
public @Bean IntegrationFlow defaultJmsFlow()
{
return IntegrationFlows.from(
//read JMS topic
Jms.messageDrivenChannelAdapter(this.connectionFactory).destination(this.config.getInputQueueName()).errorChannel(errorChannel()).configureListenerContainer(c ->
{
final DefaultMessageListenerContainer container = c.get();
container.setSessionTransacted(true);
container.setMaxConcurrentConsumers(10);
container.setConcurrentConsumers(4);
}).get())
.channel(messageProcessingChannel()).get();
}
阅读消息后,我将这些消息发送到 DirectChannel。需要进行任何特殊配置以提高我的应用程序的性能,以便每秒处理至少 500 条消息。