使用JMS发送和接收SWIFT消息：MQRFH2头与消息结构最佳实践

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

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