spring整合jms(ibm) send_queue receive_queue 异步转同步

要实现Spring整合IBM MQ的JMS异步消息发送和同步消息接收，可以按照以下步骤来操作：

1. 在Spring配置文件中配置JmsTemplate和ConnectionFactory，并指定IBM MQ的相关连接信息。

2. 配置一个消息队列发送器和一个消息队列接收器，分别用于异步发送和同步接收消息。

3. 在消息队列发送器中，通过JmsTemplate异步发送消息到指定的队列。

4. 在消息队列接收器中，通过JmsTemplate同步接收消息，并将消息内容返回。

具体代码实现可以参考以下示例：

1. 配置JmsTemplate和ConnectionFactory

<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
    <property name="transportType" value="1" />
    <property name="hostName" value="localhost" />
    <property name="port" value="1414" />
    <property name="queueManager" value="QUEUE.MANAGER" />
    <property name="channel" value="SYSTEM.DEF.SVRCONN" />
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
    <property name="defaultDestinationName" value="SEND.QUEUE" />
    <property name="pubSubDomain" value="false" />
    <property name="sessionTransacted" value="true" />
</bean>

2. 配置消息队列发送器和接收器

<bean id="messageSender" class="com.example.MessageSender">
    <property name="jmsTemplate" ref="jmsTemplate" />
</bean>

<bean id="messageReceiver" class="com.example.MessageReceiver">
    <property name="jmsTemplate" ref="jmsTemplate" />
    <property name="destinationName" value="RECEIVE.QUEUE" />
</bean>

3. 实现消息队列发送器和接收器

public class MessageSender {
    private JmsTemplate jmsTemplate;

    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void sendMessage(final String message) {
        jmsTemplate.send(new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage(message);
            }
        });
    }
}

public class MessageReceiver {
    private JmsTemplate jmsTemplate;
    private String destinationName;

    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void setDestinationName(String destinationName) {
        this.destinationName = destinationName;
    }

    public String receiveMessage() {
        Message message = jmsTemplate.receive(destinationName);
        if (message instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) message;
            try {
                return textMessage.getText();
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
        return null;
    }
}

通过以上步骤，就可以实现Spring整合IBM MQ的JMS异步消息发送和同步消息接收。