使用JMS发送和接收SWIFT消息：MQRFH2、XML负载与附件处理指南

import com.ibm.mq.jms.MQConnectionFactory;
import com.ibm.msg.client.wmq.WMQConstants;

import javax.jms.*;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

public class SwiftMessageSender {

    public void sendSwiftFileActMessage(JmsConnectionFactory connectionFactory, Destination destination, String filePath) throws JMSException, IOException {
        try (JMSContext producerContext = connectionFactory.createContext();
             FileInputStream inStream = new FileInputStream(filePath)) {

            JMSProducer producer = producerContext.createProducer();
            BytesMessage bytesMessage = producerContext.createBytesMessage();

            // 设置JMS属性，这些属性将自动映射到MQRFH2头
            // 注意：属性名应遵循JMS规范或特定协议要求
            producer.setProperty("OriginatorApplication", "IF_COBA");
            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", new File(filePath).getName());
            producer.setProperty("FileReference", new File(filePath).getName());

            // 可选：设置IBM MQ特定的格式属性，告知MQ消息体是什么格式
            // 对于二进制文件，通常设置为MQFMT_NONE (0x00000000)
            producer.setProperty(WMQConstants.JMS_IBM_FORMAT, WMQConstants.MQFMT_NONE);
            // 对于二进制文件，字符集通常不适用，但如果属性值有非ASCII字符，可能需要设置
            // producer.setProperty(WMQConstants.JMS_IBM_CHARACTER_SET, 1208); // UTF-8

            byte[] buffer = new byte[8192]; // 缓冲区大小
            int bytesRead;
            long bytesTotalSize = 0;

            // 将文件内容写入BytesMessage的负载
            while ((bytesRead = inStream.read(buffer)) != -1) {
                bytesMessage.writeBytes(buffer, 0, bytesRead);
                bytesTotalSize += bytesRead;
            }
            System.out.println("Finished writing " + bytesTotalSize + " bytes into message payload!");

            producer.send(destination, bytesMessage);
            System.out.println("Message sent successfully with properties and file payload.");

        } catch (JMSException | IOException e) {
            System.err.println("Error sending message: " + e.getMessage());
            throw e;
        }
    }

    // 假设这是一个主方法或测试方法
    public static void main(String[] args) {
        // 实际应用中，JmsConnectionFactory和Destination需要正确配置
        // 这里仅为演示目的提供一个占位符
        JmsConnectionFactory connectionFactory = null; // ... 实际初始化
        Destination destination = null; // ... 实际初始化
        String testFilePath = "/opt/mq/TC.SB13.0015484631.zip"; // 示例文件路径

        try {
            // 假设connectionFactory和destination已被正确初始化
            // connectionFactory = new MQConnectionFactory();
            // connectionFactory.setHostName("localhost");
            // connectionFactory.setPort(1414);
            // connectionFactory.setQueueManager("QM1");
            // connectionFactory.setChannel("DEV.APP.SVRCONN");
            // destination = connectionFactory.createContext().createQueue("DEV.QUEUE.1");

            new SwiftMessageSender().sendSwiftFileActMessage(connectionFactory, destination, testFilePath);
        } catch (JMSException | IOException e) {
            e.printStackTrace();
        }
    }
}

import com.ibm.mq.jms.MQConnectionFactory;
import com.ibm.msg.client.wmq.WMQConstants;

import javax.jms.*;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;

public class SwiftMessageReceiver {

    public void receiveSwiftFileActMessage(Message message, String outputDirPath) throws JMSException, IOException {
        if (