Spring 集成 IBM MQ JMS 客户端

Question

我已经编写了代码来使用 Spring Integration JMS 消息驱动的通道适配器从 IBM MQ 发送/读取消息，但无法解析 JMS 文本响应消息...下面是我的集成 XML

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:int="http://www.springframework.org/schema/integration"
        xmlns:int-jms="http://www.springframework.org/schema/integration/jms"
        xmlns:context="http://www.springframework.org/schema/context"
        xsi:schemaLocation="
            http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/context
            http://www.springframework.org/schema/context/spring-context.xsd
            http://www.springframework.org/schema/integration
            http://www.springframework.org/schema/integration/spring-integration.xsd
            http://www.springframework.org/schema/integration/jms
            http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd">
        <context:annotation-config />
        <context:component-scan base-package="com.*****" />
        <!-- Factory Defintions -->
        <bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
            <property name="transportType" value="1" />
            <property name="queueManager" value="****" />
            <property name="hostName" value="******" />
            <property name="port" value="****" />
            <property name="channel" value="******" />
        </bean>
        <!-- Queue Definition -->
        <bean id="inQueue" class="com.ibm.mq.jms.MQQueue" depends-on="connectionFactory">
            <constructor-arg index="0" value="****" />
            <constructor-arg index="1" value="*****" />
        </bean>
        <bean id="outQueue" class="com.ibm.mq.jms.MQQueue" depends-on="connectionFactory">
            <constructor-arg index="0" value="*****" />
            <constructor-arg index="1" value="******" />
        </bean>
        <bean id="messageListener" class="com.***.MessageListener"/>
        <bean id="messagePublisher" class="com.*****.MessagePublisher"/>
        <!-- OUTBOUND settings -->
        <int:channel id="senderChannel" />
        <int-jms:outbound-channel-adapter id="jmsOut" destination="outQueue" channel="senderChannel"/>
       <!--  <int:service-activator output-channel="senderChannel" ref="messagePublisher" method="processMessage" /> -->
        <!-- INBOUND settings -->
        <int:channel id="recieverChannel" />    
        <int-jms:message-driven-channel-adapter id="jmsIn" destination="inQueue" channel="recieverChannel" extract-payload="false" />
        <int:service-activator input-channel="recieverChannel" ref="messageListener" method="processMessage" />
    </beans>

该进程打算通过 MQ 向外部服务器发送消息，它们可能会(或可能不会(使用确认响应。

发布者代码：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.integration.support.MessageBuilder;
    import org.springframework.messaging.MessageChannel;
    public class MessagePublisher {
        @Autowired
        private MessageChannel senderChannel;
        public void processMessage(String message) {
            System.out.println("MessagePublisher::::::Sent message: " + message);
            senderChannel.send(MessageBuilder.withPayload(message).build());
        }
    }

目前在我的听众中，我尝试将 ack 打印为：

    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.TextMessage;
    public class MessageListener {
        public void processMessage(Message message) {
            if (message instanceof TextMessage) {
                TextMessage txtmsg = (TextMessage) message;
                try {
                    System.out.println("MessageListener::::::Received message: "
                            + txtmsg.getText());
                } catch (JMSException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }

问题是当我收到消息时，正文包含编码字符串，如下所示：

消息侦听器：：：：

：：收到的消息：[在此处打印编码的特殊字符]

如何以正确的格式解析完整的响应文本？我检查了响应对象的实例似乎只是 JMS 文本消息，但是在控制台上打印时，我只看到编码的字符串消息。

Answer 1

好的。我认为您的问题实际上与character encoding有关，这在发送方和接收方上是不同的：

试试这个：

byte[] by = ((TextMessage) msg).getText().getBytes("ISO-8859-1");
String text = new String(by,"UTF-8");

更多信息在这里：编码 JMS 文本消息和这里。