AMQP, SQL Server i XA

Question

rozwijamy aplikację z następujących cech:

• samodzielny wiosna 3.1.0.RELEASE aplikacja
• JPA z hibernacji 3.6.7.Final
• AMQP (RabbitMQ jako serwer, Wiosna AMQP jako Client)
• SQL Server 2008 z kierowcą jTDS

Musimy zsynchronizować transakcje między RabbitMQ a nd SQL Server, więc staramy się skonfigurować XA z atomikos. Problem polega na tym, że nie możemy znaleźć pojedynczego pliku konfiguracji próbki sprężyny dla tej sytuacji, która faktycznie działa. Próbowaliśmy wielu kombinacji przy użyciu próbek z dokumentacji Spring, google, forów itp. Coś brakuje.

Czy ktoś mógłby podać nam taki plik, abyśmy mogli go użyć jako szablonu początkowego dla naszej konfiguracji.

P.S. Czy naprawdę potrzebujemy XA?

Dzięki.

Answer 1

Po wykopaniu przez różnych rozwiązań kandydujących (wykorzystanie Change Data Capture, adaptery do SQL Server Service Broker i możliwe konwersje z MSMQ do RabbitMQ), doszedłem do rozwiązania, które powinny pracować dla Ciebie.

Okazuje się, że można powiązać klientów i umowy serwisowe z SQL Server. Z tego miejsca można użyć tłumaczenia RabbitMQ's AMQP binding for WCF, aby tłumaczyć wiadomości w tę iz powrotem, jako szczegółowo powiązane dokumenty PDF.

Nie jestem pewien, czy wymagany będzie dodatkowy menedżer transakcji, taki jak XA, ale jeśli masz problemy z duplikowaniem transakcji, pętlami i błędami, warto sprawdzić, czy jest to pośrednik połączenia. Jeśli wybierzesz tę trasę, musisz spawać ją ze swoją bramą w taki sam sposób, jaki zdefiniowałeś w opisie problemu. Jeśli wymaga to wyjaśnienia, chętnie pomogę w tym zakresie.

Powodzenia z aplikacją. Brzmi to jak hydra integracyjna z zewnątrz, ale gdy już wszystko zacznie się rozmawiać, powinno działać ładnie.

Answer 2

Jak wiem, RabbitMQ nie obsługuje transakcji w stylu XA w postaci.

I tak można to zrobić w Javie:

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; 

Prosty przykład wysyłania:

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

..i otrzymują:

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

• Oto niektóre odniesienia
  • Spring AMQP - Reference Documentation
  • Using RabbitMQ, Spring AMQP and Spring Integration
  • Spring Framework AMQP RabbitMQ Connection
  • Blog (szczegółowe opisy wszystkich procesów, które muszą być skonfigurowane w Javie w przypadku zarządzania jednym zdarzeniem aplikacji)