本文深入探讨了在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的元数据），并将一个文件的内容作为消息负载发送。
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 
