AMQP, SQL Server y XA

Question

estamos desarrollando una aplicación con las siguientes características:

• 3.1.0.RELEASE primavera aplicación independiente
• JPA con Hibernate 3.6.7.Final
• AMQP (como RabbitMQ servidor, primavera AMQP como cliente)
• SQL Server 2008 con jTDS controlador

Tenemos que sincronizar las transacciones entre un RabbitMQ nd SQL Server, entonces estamos tratando de configurar XA con atomikos. El problema es que no podemos encontrar un solo archivo de configuración de muestra de primavera para esa situación que realmente funcione. Probamos tantas combinaciones usando muestras de la documentación de Spring, google, foros, etc. Siempre falta algo.

Podría alguien, por favor, denos un archivo para que podamos utilizarlo como una plantilla de partida para nuestra configuración.

P.S. ¿Realmente necesitamos XA?

Gracias.

Answer 1

Después de cavar a través de las diversas soluciones candidatas (uso de Change Data Capture, adaptadores para SQL Server Service Broker, y las posibles conversiones de MSMQ a RabbitMQ), llegué a una solución que debería funcionar para usted.

Resulta que puede vincular WCF clientes y contratos de servicio a SQL Server. Desde aquí, puede usar RabbitMQ's AMQP binding for WCF para traducir mensajes de ida y vuelta, como los documentos PDF anteriormente mencionados en gran detalle.

No tengo claro si se requerirá un administrador de transacciones adicional como XA aquí, pero si tiene problemas con la duplicación de transacciones, bucles y mensajes incorrectos, vale la pena investigar como intermediario para la conexión. Si sigue esa ruta, debe soldar eso en su puerta de enlace de la misma manera que lo ha definido en la declaración del problema. Si esto necesita una aclaración, me gustaría ampliar esto aquí.

La mejor de las suertes con su aplicación. Suena como una hidra de integración desde el exterior, pero una vez que hable todo, debería funcionar bien.

Answer 2

Como sé, RabbitMQ no admite transacciones de estilo XA.

Y sí puede hacerlo en 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; 

ejemplo simple de envío:

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

..y recibir:

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

• Estas son algunas referencias
  • Spring AMQP - Reference Documentation
  • Using RabbitMQ, Spring AMQP and Spring Integration
  • Spring Framework AMQP RabbitMQ Connection
  • Blog (descripciones detalladas acerca de todos los procesos que necesitan ser configurados en Java en el caso de una aplicación gestión de eventos)