本教程旨在澄清在使用JMS与IBM MQ集成时，关于MQRFH2消息头、XML负载以及附件处理的常见误区。我们将深入探讨JMS应用中如何正确设置消息属性、传输二进制数据，并提供符合JMS规范的发送与接收代码示例，避免手动构建MQRFH2头，从而确保消息的正确解析与互操作性。
1. 引言：JMS与复杂消息传输挑战
在企业级应用集成中，特别是在金融领域，通过消息队列系统（如IBM MQ）发送和接收复杂消息（如SWIFT FileAct消息，其中可能包含XML数据和二进制附件）是常见需求。Java Message Service (JMS) 作为Java EE的标准API，为消息的发送和接收提供了统一的接口。然而，在实际操作中，开发者常对底层消息格式（如IBM MQ的MQRFH2头）的理解存在误区，尤其是在尝试手动处理这些底层细节时，容易导致消息格式不正确，从而影响消息的互操作性和解析。本教程将聚焦于如何以符合JMS规范的方式，高效、准确地处理这类复杂消息。
2. MQRFH2在JMS中的角色：自动处理而非手动构建
MQRFH2（Message Queue Reason Format Header 2）是IBM MQ特有的一种消息头格式，用于承载消息的各种属性，包括JMS消息属性。它是IBM MQ实现JMS规范的关键组成部分。
核心概念：
JMS的抽象层： JMS API为应用程序提供了一个高级、平台无关的消息编程模型。当JMS应用程序与IBM MQ交互时，JMS客户端库（如com.ibm.mq.jms）负责将JMS消息对象转换为IBM MQ能够理解的格式，并在其中自动创建和管理MQRFH2头。这个MQRFH2头用于封装JMS消息的各种属性（如JMSCorrelationID、JMSType以及自定义属性等）。误区纠正： 许多开发者误以为需要手动构建MQRFH2对象并将其作为消息体的一部分发送。这是不正确的。 如果你的应用程序是一个纯粹的JMS应用程序，那么你不应该手动创建MQRFH2头。IBM MQ客户端会自动为你处理。手动构建MQRFH2通常只适用于非JMS的原生IBM MQ应用程序，它们直接使用MQI（Message Queue Interface）进行编程。
结论： 在JMS应用程序中，无需手动创建MQRFH2实例。所有通过JMS API设置的消息属性都会被自动映射到由IBM MQ客户端生成的MQRFH2头中。
3. 正确设置JMS消息属性
JMS提供了一套标准化的API来设置和获取消息属性。这些属性是键值对，可以用于传递消息的元数据，而无需修改消息体内容。这些JMS属性在底层会被IBM MQ客户端自动封装到MQRFH2头的特定“文件夹”中，例如自定义属性通常会放入“usr”文件夹。
发送方设置JMS属性示例：
瞬映
AI 快速创作数字人视频，一站式视频创作平台，让视频创作更简单。
57 查看详情
以下代码演示了如何使用JMSProducer设置与SWIFT FileAct相关的消息属性。这些属性将由JMS客户端自动转换为MQRFH2头的一部分。
import com.ibm.mq.jms.MQConnectionFactory;import com.ibm.msg.client.wmq.WMQConstants;import javax.jms.*;import java.io.File;import java.io.FileInputStream;import java.io.IOException;public class SwiftMessageSender { public void sendSwiftFileActMessage(JmsConnectionFactory connectionFactory, Destination destination, String filePath) throws JMSException, IOException { try (JMSContext producerContext = connectionFactory.createContext(); FileInputStream inStream = new FileInputStream(filePath)) { JMSProducer producer = producerContext.createProducer(); BytesMessage bytesMessage = producerContext.createBytesMessage(); // 设置JMS属性，这些属性将自动映射到MQRFH2头 // 注意：属性名应遵循JMS规范或特定协议要求 producer.setProperty("OriginatorApplication", "IF_COBA"); producer.setProperty("Requestor", "ou=data,o=data,o=swift"); producer.setProperty("Responder", "ou=data,o=data,o=swift"); producer.setProperty("Service", "swift.data"); producer.setProperty("RequestType", "data"); producer.setProperty("Compression", "Zip"); producer.setProperty("FileName", new File(filePath).getName()); producer.setProperty("FileReference", new File(filePath).getName()); // 可选：设置IBM MQ特定的格式属性，告知MQ消息体是什么格式 // 对于二进制文件，通常设置为MQFMT_NONE (0x00000000) producer.setProperty(WMQConstants.JMS_IBM_FORMAT, WMQConstants.MQFMT_NONE); // 对于二进制文件，字符集通常不适用，但如果属性值有非ASCII字符，可能需要设置 // producer.setProperty(WMQConstants.JMS_IBM_CHARACTER_SET, 1208); // UTF-8 byte[] buffer = new byte[8192]; // 缓冲区大小 int bytesRead; long bytesTotalSize = 0; // 将文件内容写入BytesMessage的负载 while ((bytesRead = inStream.read(buffer)) != -1) { bytesMessage.writeBytes(buffer, 0, bytesRead); bytesTotalSize += bytesRead; } System.out.println("Finished writing " + bytesTotalSize + " bytes into message payload!"); producer.send(destination, bytesMessage); System.out.println("Message sent successfully with properties and file payload."); } catch (JMSException | IOException e) { System.err.println("Error sending message: " + e.getMessage()); throw e; } } // 假设这是一个主方法或测试方法 public static void main(String[] args) { // 实际应用中，JmsConnectionFactory和Destination需要正确配置 // 这里仅为演示目的提供一个占位符 JmsConnectionFactory connectionFactory = null; // ... 实际初始化 Destination destination = null; // ... 实际初始化 String testFilePath = "/opt/mq/TC.SB13.0015484631.zip"; // 示例文件路径 try { // 假设connectionFactory和destination已被正确初始化 // connectionFactory = new MQConnectionFactory(); // connectionFactory.setHostName("localhost"); // connectionFactory.setPort(1414); // connectionFactory.setQueueManager("QM1"); // connectionFactory.setChannel("DEV.APP.SVRCONN"); // destination = connectionFactory.createContext().createQueue("DEV.QUEUE.1"); new SwiftMessageSender().sendSwiftFileActMessage(connectionFactory, destination, testFilePath); } catch (JMSException | IOException e) { e.printStackTrace(); } }}
4. 传输XML负载与二进制附件
根据消息内容的类型和结构，JMS提供了不同的消息类型来处理：
XML负载：TextMessage： 如果XML内容是纯文本且不包含二进制数据，最直接的方式是使用TextMessage。JMS客户端会处理字符编码。BytesMessage： 如果XML内容本身是二进制编码的（例如，使用了特定的压缩或加密），或者你需要更精细地控制字节流，可以使用BytesMessage。但请确保接收方知道如何解析这些字节以还原XML。二进制附件（文件）：直接作为BytesMessage负载： 如果整个消息体就是一个二进制文件（如SWIFT FileAct中的ZIP文件），最简单且推荐的方式是将其作为BytesMessage的负载。文件的元数据（如文件名、压缩类型）应通过JMS属性传递，如上节所示。在XML中嵌入二进制数据： 如果二进制附件需要作为XML消息的一部分传输，通常有两种方法：CDATA节： 对于较小的二进制数据，可以将其Base64编码后，放入XML的CDATA节中。Base64编码： 将二进制数据进行Base64编码，然后作为XML元素的值。接收方需要解码以还原原始二进制数据。
本教程的示例将重点放在将二进制文件作为BytesMessage的负载，并利用JMS属性传递元数据。
5. 接收和解析JMS消息
接收方应用程序需要能够识别消息类型，并正确地从JMS消息中提取属性和负载。
接收方解析JMS消息示例：
以下代码演示了如何接收JMS消息，判断其类型，并提取JMS属性以及BytesMessage中的文件负载。
import com.ibm.mq.jms.MQConnectionFactory;import com.ibm.msg.client.wmq.WMQConstants;import javax.jms.*;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;public class SwiftMessageReceiver { public void receiveSwiftFileActMessage(Message message, String outputDirPath) throws JMSException, IOException { if (
以上就是使用JMS发送和接收SWIFT消息：MQRFH2、XML负载与附件处理指南的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/972993.html
微信扫一扫 
支付宝扫一扫 
