AMQP、SQL Server 和 XA

Question

我们正在开发具有以下特点的应用程序：

• 独立 spring 3.1.0.RELEASE 应用程序
• JPA with Hibernate 3.6.7.Final
• AMQP（RabbitMQ 作为服务器，Spring AMQP 作为客户端）
• 带有 jTDS 驱动程序的 SQL Server 2008

我们需要在 RabbitMQ 和 SQL Server 之间同步事务，所以我们正在尝试使用 atomikos 设置 XA。问题是我们无法为这种情况找到一个实际有效的 spring 示例配置文件。我们使用来自 Spring 文档、谷歌、论坛等的示例尝试了很多组合。总是缺少一些东西。

请有人提供这样的文件，以便我们可以将其用作配置的起始模板。

附： 我们真的需要 XA 吗？

谢谢。

Answer 1

在研究了各种候选解决方案（Change Data Capture 的使用、SQL Server Service Broker 的适配器以及从 MSMQ 到 RabbitMQ 的可能转换）之后，我找到了一个适合您的解决方案。

事实证明，您可以将WCF 客户端和服务合同绑定到 SQL Server。从这里，您可以使用RabbitMQ's AMQP binding for WCF 来回翻译消息，因为前面链接的PDF 文档非常详细。

我不清楚这里是否需要像 XA 这样的额外事务管理器，但如果您遇到事务重复、循环和错误消息的问题，那么作为连接的中介进行调查是值得的。如果您走那条路线，则需要以与问题陈述中定义的相同方式将其焊接到网关中。如果这需要澄清，我很乐意在这里展开。

祝您申请顺利。从外部看，这听起来像是一个集成 hydra，但是一旦你把所有东西都放在一起，它应该会很好地工作。

Answer 2

据我所知，RabbitMQ 不支持 XA 样式的事务。

是的，你可以用 Java 做到这一点：

TestConfiguration.java

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.SingleConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class TestConfiguration extends AbstractRabbitConfiguration {

    private String routingKey = "test.queue";
    private String testQueueName = "test.queue";

    public ConnectionFactory getConnectionFactory() {
        SingleConnectionFactory connectionFactory = new SingleConnectionFactory("localhost");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        return connectionFactory;
    }

    @Override
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(getConnectionFactory());
        rabbitTemplate.setRoutingKey(routingKey);
        rabbitTemplate.setQueue(testQueueName);
        return rabbitTemplate;

发送的简单示例：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;

public class MessageSender {

    @Autowired
    private AmqpTemplate template;

    public void send(String text) {
        template.convertAndSend(text);
    }
}

..并接收：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
public class MessageHandler implements MessageListener {
    @Override
    public void onMessage(Message message) {
        System.out.println("Received message: " + message);
    }
}

• 这里有一些参考资料
  • Spring AMQP - Reference Documentation
  • Using RabbitMQ, Spring AMQP and Spring Integration
  • Spring Framework AMQP RabbitMQ Connection
  • Blog（详细说明一个应用事件管理情况下需要用Java配置的所有流程）