使用JMS发送和接收SWIFT消息：MQRFH2头部的正确实践

在使用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头部的相应部分（例如，用户自定义属性通常位于文件夹下）。

正确发送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();        // }    }}

注意事项：

Cowriter

AI 作家，帮助加速和激发你的创意写作

107 查看详情 上述代码移除了手动创建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 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场景）的健壮和高效通信，同时避免不必要的复杂性和潜在的错误。

以上就是使用JMS发送和接收SWIFT消息：MQRFH2头部的正确实践的详细内容，更多请关注创想鸟其它相关文章！