在使用jms与ibm mq进行swift消息（尤其是fileact）交互时，应用程序不应手动构建mqrfh2头部。ibm mq客户端会自动为jms消息生成和管理mqrfh2头部。正确的做法是通过jms api设置消息属性，这些属性将自动映射到mqrfh2的“usr”文件夹中。对于消息负载，xml内容应使用textmessage，二进制文件内容则应使用bytesmessage，并在需要时通过jms属性传递文件元数据。
理解JMS与MQRFH2头部
在使用Java Message Service (JMS) 与IBM MQ进行消息通信时，一个常见的误解是需要手动构造MQRFH2头部来承载消息属性或特定格式信息。实际上，当一个JMS应用程序发送消息时，IBM MQ的JMS客户端会自动处理MQRFH2头部的创建和管理。这意味着开发者不应该在JMS应用程序中直接实例化和操作MQRFH2对象。
MQRFH2头部在IBM MQ中用于存储消息的元数据，包括JMS相关的属性（如目标、消息类型等）以及用户自定义的属性。JMS API提供了一套标准的方法来设置和获取这些属性，而无需开发者关心底层MQRFH2的实现细节。当JMS消息发送到队列时，这些JMS属性会被自动封装到MQRFH2头部的相应部分（例如，用户自定义属性通常位于<usr>文件夹下）。
正确发送JMS消息（包含负载和属性）
要正确地通过JMS发送包含特定负载（如XML或二进制文件）和自定义属性的SWIFT消息，应遵循JMS标准API。
1. 设置消息属性
如果需要为消息添加元数据，例如文件名、压缩类型、请求者等，应使用JMSProducer或Message接口提供的setProperty()方法。这些属性将被IBM MQ自动放置在MQRFH2头部的用户数据区（usr文件夹）中。
import com.ibm.mq.jms.MQConnectionFactory;
import com.ibm.mq.MQRFH2; // 仅为说明，实际发送JMS时不需要直接使用
import javax.jms.*;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class SwiftMessageSender {
public void sendSwiftFileActMessage(MQConnectionFactory connectionFactory, Destination destination, String filePath) throws JMSException, IOException {
try (JMSContext context = connectionFactory.createContext()) {
JMSProducer producer = context.createProducer();
// 1. 设置JMS消息属性，这些属性将自动映射到MQRFH2的usr文件夹
producer.setProperty("OriginatorApplication", "data");
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", "data.zip"); // 文件名作为JMS属性
producer.setProperty("FileReference", "data.zip"); // 文件引用作为JMS属性
// 2. 创建BytesMessage来承载二进制文件内容
BytesMessage bytesMessage = context.createBytesMessage();
// 3. 将文件内容写入BytesMessage
try (FileInputStream inStream = new FileInputStream(filePath)) {
byte[] buffer = new byte[4096];
int bytesRead;
int totalBytesWritten = 0;
while ((bytesRead = inStream.read(buffer)) != -1) {
bytesMessage.writeBytes(buffer, 0, bytesRead);
totalBytesWritten += bytesRead;
System.out.println("Writing " + bytesRead + " bytes into message...");
}
System.out.println("Finished writing " + totalBytesWritten + " bytes into message from file: " + filePath);
}
// 4. 发送消息
producer.send(destination, bytesMessage);
System.out.println("SWIFT FileAct message sent successfully.");
}
}
public static void main(String[] args) {
// 示例用法：配置MQConnectionFactory并调用sendSwiftFileActMessage
// 注意：这里需要替换为实际的MQ连接配置
// MQConnectionFactory connectionFactory = new MQConnectionFactory();
// connectionFactory.setHostName("localhost");
// connectionFactory.setPort(1414);
// connectionFactory.setQueueManager("QM1");
// connectionFactory.setChannel("DEV.APP.SVRCONN");
//
// try {
// Queue queue = connectionFactory.createContext().createQueue("DEV.QUEUE.1");
// new SwiftMessageSender().sendSwiftFileActMessage(connectionFactory, queue, "/opt/mq/TC.SB13.0015484631.zip");
// } catch (JMSException | IOException e) {
// e.printStackTrace();
// }
}
}注意事项：
- 上述代码移除了手动创建MQRFH2对象的逻辑，因为JMS客户端会代为处理。
- 所有的元数据（如OriginatorApplication, FileName等）都通过producer.setProperty()方法设置，它们将作为JMS属性附加到消息上。
- 文件内容作为二进制数据写入BytesMessage的负载。
2. 发送XML消息
如果SWIFT消息的负载是XML格式，应使用TextMessage。如果XML中包含二进制数据，应使用CDATA块来封装二进制内容，或者考虑将二进制数据作为单独的BytesMessage发送，并通过JMS属性关联两者。
// 示例：发送XML消息
public void sendXmlMessage(MQConnectionFactory connectionFactory, Destination destination, String xmlContent) throws JMSException {
try (JMSContext context = connectionFactory.createContext()) {
JMSProducer producer = context.createProducer();
TextMessage textMessage = context.createTextMessage(xmlContent);
// 同样可以设置JMS属性
producer.setProperty("MessageType", "SWIFT_XML");
producer.send(destination, textMessage);
System.out.println("XML message sent successfully.");
}
}正确接收JMS消息
接收JMS消息时，同样应使用JMS API来读取消息类型、负载和属性。
import com.ibm.mq.jms.MQConnectionFactory;
import javax.jms.*;
import java.io.FileOutputStream;
import java.io.IOException;
public class SwiftMessageReceiver {
public void receiveSwiftMessage(MQConnectionFactory connectionFactory, Destination destination) throws JMSException, IOException {
try (JMSContext context = connectionFactory.createContext()) {
JMSConsumer consumer = context.createConsumer(destination);
Message message = consumer.receive(); // 或者使用 receive(timeout)
if (message == null) {
System.out.println("No message received.");
return;
}
// 1. 读取JMS属性
System.out.println("--- Message Properties ---");
System.out.println("OriginatorApplication: " + message.getStringProperty("OriginatorApplication"));
System.out.println("FileName: " + message.getStringProperty("FileName"));
// 可以遍历所有属性，如果需要
// Enumeration<String> propertyNames = message.getPropertyNames();
// while (propertyNames.hasMoreElements()) {
// String propName = propertyNames.nextElement();
// System.out.println(propName + ": " + message.getObjectProperty(propName));
// }
System.out.println("--------------------------");
// 2. 根据消息类型处理负载
if (message instanceof TextMessage) {
System.out.println("-- Reading TEXT-message..");
TextMessage textMessage = (TextMessage) message;
String content = textMessage.getText();
System.out.println("-- MyMessageListener received message with payload: " + content);
// 可以将XML内容保存到文件或进行解析
} else if (message instanceof BytesMessage) {
System.out.println("-- Reading BYTE-message..");
BytesMessage bytesMessage = (BytesMessage) message;
// 获取文件名属性，用于保存文件
String fileName = message.getStringProperty("FileName");
if (fileName == null || fileName.isEmpty()) {
fileName = "received_file.bin"; // 默认文件名
}
String outputPath = "/opt/mq/" + fileName;
try (FileOutputStream fos = new FileOutputStream(outputPath)) {
byte[] buffer = new byte[4096];
int bytesRead;
int totalBytesRead = 0;
// 使用readBytes(byte[] buffer) 逐块读取，而不是一次性读取整个消息体
while ((bytesRead = bytesMessage.readBytes(buffer)) != -1) {
fos.write(buffer, 0, bytesRead);
totalBytesRead += bytesRead;
}
System.out.println("Finished reading " + totalBytesRead + " bytes and saved to: " + outputPath);
}
} else {
System.out.println("-- Received unknown message type: " + message.getClass().getName());
}
}
}
public static void main(String[] args) {
// 示例用法：配置MQConnectionFactory并调用receiveSwiftMessage
// 注意：这里需要替换为实际的MQ连接配置
// MQConnectionFactory connectionFactory = new MQConnectionFactory();
// connectionFactory.setHostName("localhost");
// connectionFactory.setPort(1414);
// connectionFactory.setQueueManager("QM1");
// connectionFactory.setChannel("DEV.APP.SVRCONN");
//
// try {
// Queue queue = connectionFactory.createContext().createQueue("DEV.QUEUE.1");
// new SwiftMessageReceiver().receiveSwiftMessage(connectionFactory, queue);
// } catch (JMSException | IOException e) {
// e.printStackTrace();
// }
}
}注意事项：
- 接收端通过message.getStringProperty()等方法直接读取JMS属性，这些属性已由MQRFH2头部解析并提供。
- 对于BytesMessage，应使用readBytes(byte[] buffer)方法分块读取消息体，而不是尝试一次性读取整个消息体（bytesMessage.readBytes(textBytes, textLength)可能导致内存问题，且在某些情况下行为不符合预期）。
- 文件名等元数据可以直接从JMS属性中获取，用于保存接收到的文件。
总结与最佳实践
- JMS与MQRFH2的自动管理： 在JMS应用程序中，IBM MQ客户端会自动处理MQRFH2头部的创建和解析。开发者不应尝试手动构建或解析MQRFH2头部。
- 使用JMS属性： 所有需要作为消息元数据传递的信息（如FileAct相关的FileName、Compression等）都应通过JMS API的setProperty()方法进行设置。这些属性将安全地存储在MQRFH2头部的“usr”文件夹中，并在接收时通过getProperty()方法轻松访问。
-
选择正确的JMS消息类型：
- 对于文本数据（如XML），使用TextMessage。
- 对于二进制数据（如压缩文件），使用BytesMessage。
- 处理二进制数据： 在发送BytesMessage时，将二进制文件内容直接写入消息体。在接收时，分块读取BytesMessage的负载以避免内存问题。
- FileAct集成： SWIFT FileAct通常涉及特定的消息格式和传输协议。当通过JMS与MQ集成时，JMS消息用于传输FileAct的控制消息或文件内容。文件元数据应作为JMS属性传递，而文件本身作为BytesMessage的负载。
遵循这些原则，可以确保JMS应用程序与IBM MQ之间进行SWIFT消息（包括FileAct场景）的健壮和高效通信，同时避免不必要的复杂性和潜在的错误。
