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

标签 java spring jms integration weblogic12c

我使用消息驱动 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" 
/>

最佳答案

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

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

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

关于java - Spring集成消息驱动 channel 适配器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20943174/

相关文章:

java - Spring @RestController 调用大量请求

spring - 使用 Spring MVC 将 JRebel 与自定义 Ant/Ivy/Tomcat Web 应用程序集成

java - JMS队列怎么画?

jakarta-ee - JMS 消息重新传递到队列

java - Android: onPause() 是否保证在 finish() 之后被调用?

java - 在 SWT UI 中删除窗口边框会禁用重新定位

java - 迭代excel值并与txt文件值匹配

java - 使用基于注解的配置创建延迟初始化的 Spring bean

java - MQConstants.USE_MQCSP_AUTHENTICATION_PROPERTY 和 JMSConstants.USER_AUTHENTICATION_MQCSP 的字符串属性名称是什么?

java - Spring REST - RequestBody 内的数组仅包含一个元素