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

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();
        // }
    }
}

// 示例：发送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.");
    }
}

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();
        // }
    }
}