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

本篇文章给大家分享《使用JMS发送和接收SWIFT消息：MQRFH2头与消息结构最佳实践 》，覆盖了文章的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

本文深入探讨了在Java消息服务（JMS）环境中发送和接收SWIFT FileAct消息时，如何正确处理MQRFH2头和消息负载。我们将澄清JMS与IBM MQ集成时MQRFH2头的自动生成机制，并提供通过JMS属性设置消息元数据，以及有效传输XML负载和二进制附件的实用指南和代码示例，避免手动构建MQRFH2的常见误区。

引言：JMS与SWIFT FileAct消息传输的挑战

在金融领域，通过JMS（Java Message Service）与IBM MQ集成来发送和接收SWIFT FileAct消息是一种常见的实践。这类消息通常结构复杂，可能包含XML格式的业务负载、用于路由和处理的元数据（通常涉及MQRFH2头），以及作为附件的二进制文件。然而，许多开发者在尝试实现此类功能时，常常会遇到关于如何正确构造消息，特别是如何处理MQRFH2头的困惑。一个常见的误解是，需要手动创建并附加MQRFH2头到JMS消息中，这不仅增加了代码复杂性，还可能导致接收端无法正确解析消息。本教程旨在澄清这一误区，并提供一套基于JMS规范和IBM MQ最佳实践的解决方案。

JMS与IBM MQRFH2头的关系解析

理解JMS与IBM MQRFH2头之间的关系是正确实现消息传输的关键。

核心澄清：MQRFH2头的自动生成 当应用程序使用JMS API与IBM MQ（作为JMS提供者）进行交互时，IBM MQ会自动为JMS消息生成和管理MQRFH2头。这意味着，开发者不应在JMS应用程序中手动构建MQRFH2对象并将其作为消息体的一部分发送。这种做法是错误的，因为它会导致消息体中包含重复或格式不正确的头部信息，使得接收端难以区分真正的消息负载和手动添加的头部字节。

JMS属性映射到MQRFH2的usr文件夹 JMS规范提供了一种通用的方式来为消息设置自定义属性，例如使用JMSProducer.setProperty()或JMSMessage.setStringProperty()等方法。当这些JMS消息通过IBM MQ传输时，IBM MQ会自动将这些自定义属性封装到其内部生成的MQRFH2头的usr文件夹中。因此，所有需要作为元数据传输的信息（如SWIFT FileAct的各种控制参数）都应该通过JMS属性来设置，而不是通过手动构造MQRFH2字节流。

构建和发送结构化JMS消息

为了正确发送包含负载和元数据的JMS消息，我们应遵循以下步骤：

1. 选择合适的消息负载（Payload）类型

根据您的消息内容，选择最合适的JMS消息类型：

• XML负载： 如果您的主要负载是XML字符串，建议使用javax.jms.TextMessage。JMS提供者会高效地处理文本编码。如果XML中需要嵌入二进制数据（例如，文件内容的Base64编码），请务必使用XML的CDATA块来封装，以避免解析错误。
• 二进制负载（附件）： 对于文件内容（如ZIP文件、图片或其他二进制数据），应使用javax.jms.BytesMessage。BytesMessage允许您直接写入和读取原始字节流。

2. 设置消息元数据（JMS属性）

所有需要作为消息头部信息或控制参数的元数据，都应该通过JMS消息的属性来设置。这些属性将由IBM MQ自动映射到MQRFH2头的usr文件夹中。

示例：发送包含文件附件和元数据的BytesMessage

以下代码演示了如何创建一个BytesMessage，设置必要的JMS属性（模拟FileAct的元数据），并将一个文件的内容作为消息负载发送。

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

接收和解析结构化JMS消息

在接收端，处理JMS消息变得直观，因为JMS API已经为您抽象了MQRFH2头的解析。

1. 识别消息类型

首先，判断接收到的Message对象的实际类型：

• instanceof TextMessage：处理XML字符串。
• instanceof BytesMessage：处理二进制数据。

2. 提取消息负载

• TextMessage： 使用getText()方法直接获取完整的XML字符串。
• BytesMessage： 使用readBytes()方法循环读取消息体中的二进制数据，直到所有数据被读取完毕。

3. 获取消息元数据

通过JMSMessage接口提供的方法（如getStringProperty(String name)、getIntProperty(String name)等），可以直接访问发送端设置的所有JMS属性。这些属性是透明的，无需手动解析任何头部字节流。

示例：接收包含文件附件和元数据的BytesMessage

以下代码演示了如何接收一个BytesMessage，读取其JMS属性，并将消息负载保存到文件中。

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

今天关于《使用JMS发送和接收SWIFT消息：MQRFH2头与消息结构最佳实践 》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！