Spring-JMS(Websphere MQ)

Question

我在 Spring 中有以下配置，它工作正常但性能太低(20 条消息需要 1 分钟)。您能否建议我进行更改以提高性能。

<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> 
        <property name="transportType"><value>1</value></property> 
        <property name="queueManager"><value></value></property> 
        <property name="hostName"><value></value></property> 
        <property name="port"><value></value></property> 
        <property name="channel"><value></value></property> 
        <property name="clientId"><value></value></property>        
    </bean>
        <bean id="SenderJMSTemplate" class="org.springframework.jms.core.JmsTemplate"> 
        <property name="connectionFactory"><ref bean="jmsConnectionFactory" />  </property> 
        <property name="pubSubDomain"><value>false</value></property> 
        <property name="defaultDestination"><ref bean="senderQueue" /></property> 
    </bean>  
<bean id="senderQueue" class="com.ibm.mq.jms.MQQueue"> 
        <constructor-arg value="TEST" /> 
        <property name="baseQueueManagerName"><value>tree.queue.manager</value></property> 
        <property name="baseQueueName"><value>ORANGE.QUEUE</value></property>  
    </bean> 
    <bean id="jmsSender" class="org.tree.jms.spring.JMSSender"> 
        <property name="jmsTemplate"><ref bean="SenderJMSTemplate"/></property>     
    </bean>

我从 Spring 调用

JMSSender obj = (JMSSender) context.getBean("jmsSender");

我的发件人程序是:

        @Cacheable("message")

     public void sendMesage() {

        jmsTemplate.send(new MessageCreator() {
        public Message createMessage(Session session)throws JMSException {
        message = (Message) session.createTextMessage(stringBuffer.toString());
        return message;
        }
        });

    }
}

Answer 1

使用 JMSTemplate 从 JavaEE 容器发送消息时的一个常见问题是速度极慢，因为它为每条消息获取一个新连接(然后关闭它)。您可能需要一个池化/缓存连接来提高速度。

阅读这篇文章，它是为 ActiveMQ 编写的，但以类似的方式应用于 WebSphere MQ:http://activemq.apache.org/jmstemplate-gotchas.html

您可以在 spring 中使用如下方式设置缓存连接工厂:

<bean id="cachedConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory"
p:targetConnectionFactory-ref="jmsConnectionFactory"
p:sessionCacheSize="10" />

然后使用它代替原来的 JMS 连接。