java - Spring集成消息驱动 channel 适配器

Question

我使用消息驱动 channel 适配器从 weblogic JMS 队列接收作为字符串的 xml 消息，然后将此消息传递到 spring 集成 channel 以存储到数据库中，转换为不同的 xml，然后发送将 xml 转换为另一个远程 weblogic JMS 队列。

我的疑问是，我已经设置了并发消费者=“30”，最大并发消费者=“100”，空闲消费者限制=“50”这是正确的吗？

为了在生产系统中获得最佳性能，我必须为并发消费者、最大并发消费者、空闲消费者限制设置正确的值，并且我们将在我们的系统中每分钟收到超过 10K 条消息生产系统。

<int-jms:message-driven-channel-adapter
id="jmsInputQueueAdaptor_DX" channel="requestChannel" connection-factory="connectionFactory"  destination="cbcmInputQueue_DX"
error-channel="errorChannel" 
concurrent-consumers="30" 
max-concurrent-consumers="100"  
idle-consumer-limit="50"         
receive-timeout="500"
send-timeout="500"
acknowledge="auto" 
/>

Answer 1

你的值(value)观似乎是一个好的开始。

要实现最佳/最佳性能，需要考虑很多因素。例如 XML 转换的速度和硬件(核心数量、CPU 速度等)

您实际上只需要测试并找出瓶颈所在。如果您没有充分利用 CPU，则添加更多消费者。