1

我正在使用 JmsTemplate 向 IBM MQ 队列发送和接收消息。我的应用程序安装在 WebSphere 应用程序服务器 8.5 上，为了检索连接，我使用了 jndi 查找。

我的春豆：

<bean id="jmsQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean"> 
    <property name="jndiName" value="jndiTest" /> 
    <property name="lookupOnStartup" value="false" /> 
    <property name="cache" value="true" /> 
    <property name="proxyInterface" value="javax.jms.QueueConnectionFactory" /> 
</bean> 

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsQueueConnectionFactory" />
    <property name="receiveTimeout" value="10000" /> 
    <property name="sessionAcknowledgeMode" value="1" /> 
</bean>

<bean id="mqServerDao" class="MqServerDao" > 
    <constructor-arg name="jmsTemplate" ref="jmsTemplate" />
</bean>

我的 Java 类：

public class MqServerDao {

    private JmsTemplate jmsTemplate;

    public MqServerDao(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public String write(byte[] request, final String correlationId)
                                   throws Exception {

       MQQueue mqQueue = new MQQueue(MQ_INPUT_QUEUE);
       mqQueue.setTargetClient(WMQConstants.WMQ_CLIENT_NONJMS_MQ);

       MqRequestMessageCreator messageCreator = new MqRequestMessageCreator(
                                       request, correlationId);
       jmsTemplate.send(mqQueue, messageCreator);
       return messageCreator.getMessageId();
    }

    public byte[] read(String messageId, String correlationId) throws Exception {

       MQQueue mqQueue = new MQQueue(MQ_OUTPUT_QUEUE);
       mqQueue.setTargetClient(WMQConstants.WMQ_CLIENT_NONJMS_MQ);

       String messageSelector = "JMSCorrelationID = 'ID:" + correlationId
                                       + "' AND JMSMessageID = '" + messageId + "'";
       TextMessage receiveMessage = (TextMessage) jmsTemplate.receiveSelected(
                                       mqQueue, messageSelector);
       return receiveMessage.getText().getBytes();
    }
}

我想知道这是否是正确的方法，我有一些问题：

  1. 建议添加 CachingConnectionFactory 还是应用服务器本身管理 che 连接？
  2. 这是使用 JmsTemplate 的正确方法吗？如果同时调用两次 MqServerDao 的“写入”方法是否安全？或者我会在“写”和“读”方法中创建一个新的 JmsTemplate 实例吗？
4

1 回答 1

1
  1. WebSphere 将为您管理连接。来自http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/jms/core/JmsTemplate.html：

在 Java EE 环境中，确保 ConnectionFactory 是通过 JNDI 从应用程序的环境命名上下文中获取的；应用程序服务器通常在那里公开池化的事务感知工厂。

  1. Spring Template 类，包括JmsTemplate，被设计为可重用的、线程安全的单例。你绝对不想继续创造新的。

我为此寻找了权威参考，但找不到。（你会认为它会在上面的 JavaDoc 链接中。IMO，Spring 的文档通常还有一些不足之处。）到目前为止，我能找到的最好的是 RestTemplate 的描述，它说：

从概念上讲，它与 JdbcTemplate、JmsTemplate 以及 Spring Framework 和其他投资组合项目中的各种其他模板非常相似。这意味着，例如，RestTemplate 在构造后是线程安全的，并且您可以使用回调来自定义其操作。

于 2016-07-15T14:49:24.317 回答