具有 JMS 队列和 MQ 队列的 Websphere

Question

我是 IBM Websphere MQ 服务器的新手，在使用它时几乎没有问题。我正在使用MQQueueConnectionFactory将消息发送到队列。这是我的代码。

MQQueueConnectionFactory connectionFactory = null;
QueueConnection queueConn = null;
QueueSession queueSession = null;
QueueSender queueSender = null;
TextMessage message = null;

try
{
    connectionFactory = new MQQueueConnectionFactory();
    connectionFactory.setHostName("192.16.34.45");
    connectionFactory.setPort(1415);
    connectionFactory.setTransportType(1);
    connectionFactory.setQueueManager("MQSLLXQ1");
    connectionFactory.setChannel("TO.MQSLLXQ1");

    queueConn = connectionFactory.createQueueConnection("username", "password");
    queueSession = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    queueSender = queueSession.createSender(queueSession.createQueue("TestQueue"));
    queueSender.setDeliveryMode(DeliveryMode.PERSISTENT);
    message = queueSession.createTextMessage("Test Message");
    queueSender.send(message);
    queueConn.close();

} catch (Exception je) {
    je.printStackTrace();
}

在带有 JMS 标头的 MQ 队列中可见的消息。

  <mcd><Msd>jms_text</Msd></mcd>
    <jms><Dst>queue:///TestQueue</Dst><Tms>1454047279356</Tms><Div>2</Div></jms>
   Test Message

1） 有没有办法避免这个 jms 标头并仅获取 MQ 队列中的有效负载？

2） 有没有办法同时同步 MQ 队列和 JMS 队列？

Answer 1

如果您有兴趣使用 JMS 向传统的 MQI 应用程序发送消息，那么可以使用 JMS 队列的 TARGCLIENT 选项。请注意，这意味着不会传输某些 JMS 属性。

正如 Shashi 之前所解释的，MQ JMS 队列指向 MQ 队列;它还具有 MQ JMS 代码用来知道如何打开队列的属性、要使用的属性等。

Answer 2

JMS 是一个 API 规范，而不是一个线级协议规范。因此，不同的供应商有自己的实现JMS API规范的方式。IBM MQ（又名 WebSphere MQ）使用 RFH2 标头来实现 JMS API。

1） 如果使用 JMS API 接收消息，则该标头将作为不同的消息属性提供给应用程序。可以使用 message.getBody（）（在 MQ v8 中）方法检索有效负载。根据消息的类型，即文本，字节等，您可以使用getText（），readBytes（）等方法来检索消息正文。

如果您的接收应用程序使用 MQ API，则可以通过更改队列属性来去除消息标头。

2） 在 IBM MQ 中，JMS 队列实际上指向 MQ 队列。