在 IBM MQ 中设置 MQRFH2 标头时出现问题

Question

我正在尝试发送设置了 MD 和 RFH2 标头的 MQ 消息。 我需要消息在 AppWatch 上显示为这样。

但 RFH2 部分作为消息数据的一部分作为连续字符串出现。

我正在使用以下代码：

MQMessage msg = new MQMessage();
msg.writeString("Data to go as Message Content"); 

//Setting MQMD values
msg.persistence = MQConstants.MQPER_PERSISTANT;
msg.encoding = MQConstants.MQENC_S390;
msg.characterSet = 500;

//Setting RFH2 Values
MQRFH2 rfh2 = new MQRFH2();
rfh2.setEncoding(CMSQC.MQENC_NATIVE);
rfh2.setCodedCharSetId(CMSQC.MQCCSI_INHERIT);
rfh2.setFormat(CMSQC.MQFMT_STRING);
rfh2.setFlags(0);
rfh2.setNameValueCCSID(1208);
rfh2.setFieldValue("mcd","msd","jms_text");
rfh2.setNameValueData(<xml><usr><ENTRYNUM>123</ENTRYNUM><text>TEST123</text></usr></xml>);

//Setting the Header to the Message
rfh2.write(msg);

MQQueue queue = qmngr.accessQueue(qname,MQConstants.MQOO_OUTPUT);
queue.put(msg,pmo);
queue.close;

谁能帮我正确设置 RFH2 值。

注意：以上截图只是示例，代码与截图无关

Answer 1

但是 RFH2 部分作为消息数据的一部分作为连续的 字符串。

是的，从技术上讲，MQRFH2 标头和文件夹是消息正文的一部分。

看来我在其他关于 MQRFH2 类的帖子中不够明确。做事的顺序很重要。

即如果你做 A 那么 B 你的信息将是 AB。如果你做 B 那么 A 你的信息将是 BA。 MQ 不会重新排序。

您是否查看过原始形式的 MQRFH2 消息？看这里：https://www.ibm.com/support/knowledgecenter/en/SSFKSJ_9.0.0/com.ibm.mq.ref.dev.doc/q099250_.htm

有几种工具可以显示原始布局：amqsbcg、MQ Visual Edit、MO71 等...

从上面的代码中，你做的事情倒退了。您添加了消息有效负载，然后添加了 RFH2 标头和文件夹。这对 MQ 来说是垃圾。

正确的顺序应该是 MQRFH2 后跟消息负载。

MQMessage msg = new MQMessage();

//Setting RFH2 Values
MQRFH2 rfh2 = new MQRFH2();
rfh2.setEncoding(CMQC.MQENC_NATIVE);
rfh2.setCodedCharSetId(CMQC.MQCCSI_INHERIT);
rfh2.setFormat(CMQC.MQFMT_STRING);
rfh2.setFlags(0);
rfh2.setNameValueCCSID(1208);
rfh2.setFieldValue("usr", "ENTRYNUM", "123");
rfh2.setFieldValue("usr", "text", "TEST123");

//Setting the Header to the Message
rfh2.write(msg);

msg.writeString("Data to go as Message Content");

//Setting MQMD values
msg.persistence = CMQC.MQPER_PERSISTANT;
msg.format = CMQC.MQFMT_RF_HEADER_2;

MQQueue queue = qmngr.accessQueue(qname, CMQC.MQOO_FAIL_IF_QUIESCING + CMQC.MQOO_OUTPUT);
queue.put(msg,pmo);
queue.close;

---

2018 年 4 月 5 日更新。

Ok Faizan，通过你下面的 cmets，你仍然没有得到它。

我运行了一个示例 JMS MQ 程序并将以下消息数据放入队列中：“非常简单的测试。'ms' 中的时间是 -> 1522946795894”。

注意：我将 MQ 可视化编辑首选项从“将消息属性显示为命名属性”更改为“将消息属性显示为消息正文中的 MQRFH2 结构”。 （有关 MQGetMessageOptions 的更多信息，请参阅这篇文章的底部）。

MQ Visual Edit 的前 3 个屏幕截图向您展示了消息在队列中的外观（如您所见）：

屏幕截图 #1 显示消息的 MQMD 格式为“MQHRF2”：

屏幕截图 #2 显示了 HEX 格式的消息负载：

屏幕截图 #3 显示了为 MQRFH2 正确格式化的消息：

如果我将 MQ Visual Edit 的首选项切换回“将消息属性显示为命名属性”，那么（这完全是相同的消息）：

屏幕截图 #4 显示消息的 MQMD 格式为“MQSTR”（字符串）：

屏幕截图 #5 显示了 HEX 格式的消息负载：

屏幕截图 #6 将消息负载显示为：

屏幕截图 #7 显示 MQRFH2 文件夹中的所有值现在都是命名属性：

注意：在这两种情况下，它是相同的消息，但不同之处在于您希望 RECEIVING 应用程序如何处理它。

MQGetMessageOptions 类有一个名为“options”的选项字段。您可以向该字段添加（或）MQGMO_PROPERTIES_IN_HANDLE 或 MQGMO_PROPERTIES_FORCE_MQRFH2 选项。现在，您似乎正在使用 MQGMO_PROPERTIES_FORCE_MQRFH2。更多信息请看这里：https://www.ibm.com/support/knowledgecenter/en/SSFKSJ_9.0.0/com.ibm.mq.ref.dev.doc/q096780_.htm

Answer 2

通过稍微修改代码而不使用 MQRFH2 类，我能够查看屏幕截图中显示的消息。

我还必须考虑 Roger 在他的回答中建议的点，首先设置标头，然后设置消息负载。

参考：http://www.mqseries.net/phpBB2/viewtopic.php?t=35456

  String m_usr_data = "<usr><ENTRYNUM>123</ENTRYNUM><text>TEST123</text></usr>"
  MQMessage msg = new MQMessage();

  //Setting MQMD values
  msg.persistence = CMQC.MQPER_PERSISTANT;
  msg.format = CMQC.MQFMT_RF_HEADER_2;

  //Setting RFH2 Values
  msg.writeString(rfhStrucID);      //StrucID 
  msg.writeInt4(rfhVersion);        //Version 
  msg.writeInt4(rfhStrucLength );     //StrucLength 
  msg.writeInt4(CMQC.MQENC_NATIVE);       //Encoding 
  msg.writeInt4(CMQC.MQCCSI_INHERIT); //CodedCharSetID 
  msg.writeString(CMQC.MQFMT_STRING);       //Format 
  msg.writeInt4(0);          //Flags 
  msg.writeInt4(1208); //NameValueCCSID 
  msg.writeInt4(m_usr_data.getBytes().length);//NameValueLength <usr> 
  msg.writeString(m_usr_data);      //NameValueData <usr> 
  msg.write(rfhDataBytes);       //Actual MESSAGE data 

  msg.writeString("Data to go as Message Content");

  MQQueue queue = qmngr.accessQueue(qname, CMQC.MQOO_FAIL_IF_QUIESCING + CMQC.MQOO_OUTPUT);
  queue.put(msg,pmo);
  queue.close;