AMQP, SQL Server và XA

Question

chúng tôi đang phát triển một ứng dụng với đặc điểm sau:

• 3.1.0.RELEASE mùa xuân độc lập ứng dụng
• JPA với Hibernate 3.6.7.Final
• AMQP (RabbitMQ như Server, mùa xuân AMQP như Client)
• SQL Server 2008 với tài xế jTDS

Chúng ta cần phải đồng bộ hóa các giao dịch giữa RabbitMQ một nd SQL Server, vì vậy chúng tôi đang cố gắng thiết lập XA với atomikos. Vấn đề là chúng ta không thể tìm thấy một tệp cấu hình mẫu mùa xuân duy nhất cho tình huống thực sự hoạt động. Chúng tôi đã thử rất nhiều kết hợp bằng cách sử dụng các mẫu từ tài liệu Spring, google, diễn đàn, vv.

Ai đó, vui lòng cung cấp cho chúng tôi một tệp như vậy để chúng tôi có thể sử dụng nó làm mẫu bắt đầu cho cấu hình của mình.

P.S. Chúng ta có thực sự cần XA không?

Cảm ơn.

Answer 1

Sau khi đào bới trong các giải pháp ứng cử viên khác nhau (sử dụng Change Data Capture, adapter cho SQL Server Service Broker, và chuyển đổi có thể từ MSMQ để RabbitMQ), tôi đến một giải pháp mà nên làm việc cho bạn.

Hóa ra bạn có thể ràng buộc WCF khách hàng và hợp đồng dịch vụ với SQL Server. Từ đây, bạn có thể sử dụng RabbitMQ's AMQP binding for WCF để dịch thông báo qua lại, dưới dạng các tài liệu PDF được báo cáo chi tiết một cách chi tiết.

Tôi không rõ liệu một người quản lý giao dịch bổ sung như XA sẽ được yêu cầu ở đây hay không, nhưng nếu bạn gặp vấn đề với sao chép giao dịch, lặp lại và mismessaging, nó đáng để điều tra như một trung gian cho kết nối. Nếu bạn đi theo lộ trình đó, bạn cần phải hàn nó vào cổng của bạn theo cách tương tự như bạn đã xác định trong câu lệnh vấn đề. Nếu điều này cần làm rõ, tôi rất sẵn lòng mở rộng điều này ở đây.

Chúc bạn may mắn với ứng dụng của mình. Nghe có vẻ giống như một hydra tích hợp từ bên ngoài, nhưng một khi bạn nhận được tất cả mọi thứ nói chuyện với nhau, nó sẽ làm việc độc đáo.

Answer 2

Như tôi biết RabbitMQ không hỗ trợ giao dịch kiểu XA.

Và có bạn có thể làm điều đó trong 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; 

dụ đơn giản của gửi:

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

..và nhận:

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

• Dưới đây là một số tài liệu tham khảo
  • Spring AMQP - Reference Documentation
  • Using RabbitMQ, Spring AMQP and Spring Integration
  • Spring Framework AMQP RabbitMQ Connection
  • Blog (mô tả chi tiết về tất cả các quá trình đó cần phải được cấu hình trong Java trong trường hợp của một ứng dụng quản lý sự kiện)