如何在Quarkus中集成IBM MQ并启用可靠事务支持？

IBM MQ不支持基于AMQP的事务，能否无需自行实现复杂逻辑，将Quarkus与IBM MQ连接并使用事务？

已知背景：

• IBM MQ虽支持AMQP但无事务支持，无法使用QPid等适配Quarkus的AMQP框架
• quarkus-artemis-jms不适配，因为IBM MQ采用专有有线协议
• 自行在应用内实现事务的方案测试难度大，无法保障核心的可靠性要求，不可取

请问是否存在其他可靠的Quarkus集成IBM MQ并支持事务的方案？

1. 基于Quarkus JMS扩展 + IBM MQ官方JMS客户端 #

利用Quarkus通用的quarkus-jms扩展，集成IBM MQ官方JMS客户端，通过JMS标准事务机制实现可靠事务，无需自行编写复杂逻辑。

配置示例（application.properties）

# IBM MQ JMS连接工厂配置
quarkus.jms.connection-factory.name=ibmMqConnectionFactory
quarkus.jms.connection-factory.class-name=com.ibm.mq.jms.MQConnectionFactory
quarkus.jms.connection-factory.properties.hostName=你的MQ主机地址
quarkus.jms.connection-factory.properties.port=1414
quarkus.jms.connection-factory.properties.channel=SYSTEM.DEF.SVRCONN
quarkus.jms.connection-factory.properties.queueManager=QM1
quarkus.jms.connection-factory.properties.userName=admin
quarkus.jms.connection-factory.properties.password=你的密码

事务代码示例

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSContext;
import jakarta.transaction.Transactional;

@ApplicationScoped
public class MQTransactionalService {

    @Inject
    ConnectionFactory ibmMqConnectionFactory;

    @Transactional
    public void sendTransactionalMessage(String messageContent) {
        // 使用事务会话创建JMS上下文
        try (JMSContext context = ibmMqConnectionFactory.createContext(JMSContext.SESSION_TRANSACTED)) {
            context.createProducer().send(context.createQueue("YOUR_QUEUE_NAME"), messageContent);
            // 若代码执行过程中抛出异常，事务自动回滚，消息不会被提交到MQ
        }
    }
}

2. 基于Quarkus IBM MQ扩展 + MicroProfile Reactive Messaging #

Quarkus提供官方维护的quarkus-mq扩展（基于IBM MQ原生客户端），结合MicroProfile Reactive Messaging模型，支持事务性的消息生产与消费，可靠性由框架和MQ客户端共同保障。

配置示例（application.properties）

# IBM MQ基础连接配置
quarkus.mq.connection.hostname=你的MQ主机地址
quarkus.mq.connection.port=1414
quarkus.mq.connection.channel=SYSTEM.DEF.SVRCONN
quarkus.mq.connection.queue-manager=QM1
quarkus.mq.connection.username=admin
quarkus.mq.connection.password=你的密码

# 消费端事务配置：开启事务，异常时消息自动回滚到队列
mp.messaging.incoming.mq-consumer.connector=quarkus-mq
mp.messaging.incoming.mq-consumer.destination=INPUT_QUEUE
mp.messaging.incoming.mq-consumer.transactional=true

# 生产端事务配置：绑定到事务上下文，异常时消息不发送
mp.messaging.outgoing.mq-producer.connector=quarkus-mq
mp.messaging.outgoing.mq-producer.destination=OUTPUT_QUEUE
mp.messaging.outgoing.mq-producer.transactional=true

事务代码示例

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.transaction.Transactional;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Outgoing;

@ApplicationScoped
public class TransactionalMessageProcessor {

    @Incoming("mq-consumer")
    @Outgoing("mq-producer")
    @Transactional
    public String processAndForward(String incomingMessage) {
        String processedMsg = "Processed: " + incomingMessage;
        // 若处理过程中抛出异常，消费会回滚（消息重回输入队列），生产操作也会取消
        return processedMsg;
    }
}

核心说明 #

• 两种方案均基于官方成熟组件，无需自行实现事务逻辑，事务可靠性由Quarkus事务管理器和IBM MQ客户端共同保障
• 避免了自行编写事务代码带来的测试复杂度和可靠性风险

内容的提问来源于stack exchange，提问作者3Jane