本文深入探讨了在java消息服务（jms）环境中发送和接收swift fileact消息时，如何正确处理mqrfh2头和消息负载。我们将澄清jms与ibm mq集成时mqrfh2头的自动生成机制，并提供通过jms属性设置消息元数据，以及有效传输xml负载和二进制附件的实用指南和代码示例，避免手动构建mqrfh2的常见误区。
引言：JMS与SWIFT FileAct消息传输的挑战
在金融领域，通过JMS（Java Message Service）与IBM MQ集成来发送和接收SWIFT FileAct消息是一种常见的实践。这类消息通常结构复杂，可能包含XML格式的业务负载、用于路由和处理的元数据（通常涉及MQRFH2头），以及作为附件的二进制文件。然而，许多开发者在尝试实现此类功能时，常常会遇到关于如何正确构造消息，特别是如何处理MQRFH2头的困惑。一个常见的误解是，需要手动创建并附加MQRFH2头到JMS消息中，这不仅增加了代码复杂性，还可能导致接收端无法正确解析消息。本教程旨在澄清这一误区，并提供一套基于JMS规范和IBM MQ最佳实践的解决方案。
JMS与IBM MQRFH2头的关系解析
理解JMS与IBM MQRFH2头之间的关系是正确实现消息传输的关键。
核心澄清：MQRFH2头的自动生成当应用程序使用JMS API与IBM MQ（作为JMS提供者）进行交互时，IBM MQ会自动为JMS消息生成和管理MQRFH2头。这意味着，开发者不应在JMS应用程序中手动构建MQRFH2对象并将其作为消息体的一部分发送。这种做法是错误的，因为它会导致消息体中包含重复或格式不正确的头部信息，使得接收端难以区分真正的消息负载和手动添加的头部字节。
JMS属性映射到MQRFH2的usr文件夹JMS规范提供了一种通用的方式来为消息设置自定义属性，例如使用JMSProducer.setProperty()或JMSMessage.setStringProperty()等方法。当这些JMS消息通过IBM MQ传输时，IBM MQ会自动将这些自定义属性封装到其内部生成的MQRFH2头的usr文件夹中。因此，所有需要作为元数据传输的信息（如SWIFT FileAct的各种控制参数）都应该通过JMS属性来设置，而不是通过手动构造MQRFH2字节流。
构建和发送结构化JMS消息
为了正确发送包含负载和元数据的JMS消息，我们应遵循以下步骤：
1. 选择合适的消息负载（Payload）类型
根据您的消息内容，选择最合适的JMS消息类型：
XML负载： 如果您的主要负载是XML字符串，建议使用javax.jms.TextMessage。JMS提供者会高效地处理文本编码。如果XML中需要嵌入二进制数据（例如，文件内容的Base64编码），请务必使用XML的CDATA块来封装，以避免解析错误。二进制负载（附件）： 对于文件内容（如ZIP文件、图片或其他二进制数据），应使用javax.jms.BytesMessage。BytesMessage允许您直接写入和读取原始字节流。
2. 设置消息元数据（JMS属性）
所有需要作为消息头部信息或控制参数的元数据，都应该通过JMS消息的属性来设置。这些属性将由IBM MQ自动映射到MQRFH2头的usr文件夹中。
示例：发送包含文件附件和元数据的BytesMessage
以下代码演示了如何创建一个BytesMessage，设置必要的JMS属性（模拟FileAct的元数据），并将一个文件的内容作为消息负载发送。
Fireflies.ai
自动化会议记录和笔记工具，可以帮助你的团队记录、转录、搜索和分析语音对话。
99 查看详情
import com.ibm.mq.jms.MQConnectionFactory;import javax.jms.*;import java.io.*;import java.nio.file.Files;import java.nio.file.Paths;public class SwiftJmsMessageSender { /** * 发送一个包含文件内容作为负载和JMS属性作为元数据的BytesMessage。 * * @param connectionFactory JMS连接工厂 * @param destination 目标队列 * @param filePath 要发送的文件的路径 * @throws JMSException JMS操作异常 * @throws IOException 文件读写异常 */ public void sendFileActMessage(ConnectionFactory connectionFactory, Destination destination, String filePath) throws JMSException, IOException { // 使用JMS 2.0的try-with-resources语法，确保资源自动关闭 try (JMSContext context = connectionFactory.createContext(); InputStream inStream = Files.newInputStream(Paths.get(filePath))) { JMSProducer producer = context.createProducer(); BytesMessage bytesMessage = context.createBytesMessage(); // 1. 设置JMS属性：这些属性将自动映射到MQRFH2头的usr文件夹 bytesMessage.setStringProperty("OriginatorApplication", "FileActApp"); bytesMessage.setStringProperty("Requestor", "ou=dept,o=bank,o=swift"); bytesMessage.setStringProperty("Responder", "ou=target,o=partner,o=swift"); bytesMessage.setStringProperty("Service", "swift.fileact.transfer"); bytesMessage.setStringProperty("RequestType", "FileTransfer"); bytesMessage.setStringProperty("Compression", "Zip"); // 假设文件已压缩 bytesMessage.setStringProperty("FileName", new File(filePath).getName()); bytesMessage.setStringProperty("FileReference", "REF-" + System.currentTimeMillis()); bytesMessage.setJMSCorrelationID("CORRELID-" + System.nanoTime()); // 示例：设置关联ID // 2. 将文件内容作为BytesMessage的负载写入 byte[] buffer = new byte[4096]; int bytesRead; long totalBytesWritten = 0; while ((bytesRead = inStream.read(buffer)) != -1) { bytesMessage.writeBytes(buffer, 0, bytesRead); totalBytesWritten += bytesRead; } System.out.println("Finished writing " + totalBytesWritten + " bytes into message from file: " + filePath); // 3. 发送消息 producer.send(destination, bytesMessage); System.out.println("FileAct message sent successfully with properties and payload to " + destination); } catch (JMSException | IOException e) { System.err.println("Error sending message: " + e.getMessage()); throw e; // 重新抛出以便上层处理 } } public static void main(String[] args) throws Exception { // 示例：配置IBM MQ连接工厂和目标队列 MQConnectionFactory connectionFactory = new MQConnectionFactory(); connectionFactory.setHostName("localhost"); // MQ主机名 connectionFactory.setPort(1414); // MQ监听端口 connectionFactory.setQueueManager("QM1"); // 队列管理器名称 connectionFactory.setChannel("DEV.APP.SVRCONN"); // SVRCONN通道名称 Queue queue = connectionFactory.createQueue("DEV.QUEUE.1"); // 目标队列名称 SwiftJmsMessageSender sender = new SwiftJmsMessageSender(); String testFilePath = "/opt/mq/TC.SB13.0015484631.zip"; // 替换为实际存在的测试文件路径 // 确保测试文件存在 if (!Files.exists(Paths.get(testFilePath))) { System.err.println("Error: Test file not found at " + testFilePath); // 可以创建一个虚拟文件用于测试 Files.write(Paths.get(testFilePath), "This is a test file content for FileAct.".getBytes()); System.out.println("Created a dummy test file for demonstration."); } sender.sendFileActMessage(connectionFactory, queue, testFilePath); }}
接收和解析结构化JMS消息
在接收端，处理JMS消息变得直观，因为JMS API已经为您抽象了MQRFH2头的解析。
1. 识别消息类型
首先，判断接收到的Message对象的实际类型：
instanceof TextMessage：处理XML字符串。instanceof BytesMessage：处理二进制数据。
2. 提取消息负载
TextMessage： 使用getText()方法直接获取完整的XML字符串。BytesMessage： 使用readBytes()方法循环读取消息体中的二进制数据，直到所有数据被读取完毕。
3. 获取消息元数据
通过JMSMessage接口提供的方法（如getStringProperty(String name)、getIntProperty(String name)等），可以直接访问发送端设置的所有JMS属性。这些属性是透明的，无需手动解析任何头部字节流。
示例：接收包含文件附件和元数据的BytesMessage
以下代码演示了如何接收一个BytesMessage，读取其JMS属性，并将消息负载保存到文件中。
import com.ibm.mq.jms.MQConnectionFactory;import javax.jms.*;import java.io.*;import java.nio.file.Files;import java.nio.file.Paths;import java.util.Enumeration;public class SwiftJmsMessageReceiver { /** * 接收一个FileAct消息，读取其JMS属性和负载，并将负载保存到指定目录。 * * @param connectionFactory JMS连接工厂 * @param destination 目标队列 * @param outputDir 保存接收文件的目录 * @throws JMSException JMS操作异常 * @throws IOException 文件读写异常 */ public void receiveFileActMessage(ConnectionFactory connectionFactory, Destination destination, String outputDir) throws JMSException, IOException { try (JMSContext context = connectionFactory.createContext()) { JMSConsumer consumer = context.createConsumer(destination); System.out.println("Waiting for messages on " + destination + "..."); Message message = consumer.receive(60000); // 等待最多60秒 if (message == null) { System.out.println("No message
以上就是使用JMS发送和接收SWIFT消息：MQRFH2头与消息结构最佳实践的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/866128.html
微信扫一扫 
支付宝扫一扫 
