AMQP, SQL Server und XA

Question

wir eine Anwendung mit folgenden Eigenschaften entwickeln:

• eigenständige Feder 3.1.0.RELEASE Anwendung
• JPA mit Hibernate 3.6.7.Final
• AMQP (RabbitMQ als Server, Frühling AMQP als Client)
• SQL Server 2008 mit jTDS Treiber

Wir brauchen Transaktionen zwischen RabbitMQ eines synchronisieren nd SQL Server, also versuchen wir, XA mit Atomikos einzurichten. Das Problem ist, dass wir keine einzige Spring-Beispielkonfigurationsdatei für diese Situation finden können, die tatsächlich funktioniert. Wir haben so viele Kombinationen mit Samples aus Spring-Dokumentation, Google, Foren usw. ausprobiert. Irgendwas fehlt immer.

Könnte uns bitte jemand eine solche Datei zur Verfügung stellen, damit wir sie als Vorlage für unsere Konfiguration verwenden können.

P.S. Brauchen wir wirklich XA?

Danke.

Answer 1

Nach dem Durchsuchen der verschiedenen Kandidaten-Lösungen (Verwendung von Change Data Capture, Adapter für SQL Server Service Broker und mögliche Konvertierungen von MSMQ zu RabbitMQ), kam ich zu einer Lösung, die für Sie arbeiten sollte.

Es stellt sich heraus, dass Sie WCF Clients und Serviceverträge an SQL Server binden können. Von hier aus können Sie RabbitMQ's AMQP binding for WCF verwenden, um Nachrichten wie die oben verlinkten PDF-Dokumente sehr detailliert zu übersetzen.

Ich bin unklar, ob ein zusätzlicher Transaktionsmanager wie XA hier erforderlich sein wird, aber wenn Sie Probleme mit Transaktionsduplizierung, Schleifen und Mismessen haben, lohnt es sich, als Vermittler für die Verbindung zu untersuchen. Wenn Sie diese Route verwenden, müssen Sie diese auf dieselbe Weise in Ihr Gateway einbinden, wie Sie es in der Problembeschreibung definiert haben. Wenn dies geklärt werden muss, würde ich mich hierauf freuen.

Viel Glück mit Ihrer Anwendung. Es klingt wie eine Integration Hydra von außen, aber sobald Sie alles miteinander reden, sollte es gut funktionieren.

Answer 2

Wie ich weiß RabbitMQ nicht Unterstützung XA Stil Transaktionen.

Und ja Sie es in Java tun können:

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; 

Einfaches Beispiel von Sende:

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

..und erhalten:

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

• Hier sind einige Referenzen
  • Spring AMQP - Reference Documentation
  • Using RabbitMQ, Spring AMQP and Spring Integration
  • Spring Framework AMQP RabbitMQ Connection
  • Blog (eine detaillierte Beschreibung aller Verfahren, die in Java im Fall konfiguriert werden müssen einer Anwendung Ereignisverwaltung)