AMQP, एसक्यूएल सर्वर और XA

Question

हम निम्नलिखित विशेषताओं के साथ एक आवेदन विकसित कर रहे हैं:

• स्टैंडअलोन वसंत 3.1.0.RELEASE आवेदन
• हाइबरनेट 3.6.7.Final
• AMQP साथ जेपीए (RabbitMQ के रूप में jTDS ड्राइवर के साथ सर्वर, स्प्रिंग AMQP ग्राहक के रूप में)
• एसक्यूएल सर्वर 2008

हम RabbitMQ एक बीच लेन-देन सिंक्रनाइज़ करने की आवश्यकता एनडी एसक्यूएल सर्वर, तो हम atomikos के साथ एक्सए सेट करने की कोशिश कर रहे हैं। समस्या यह है कि हम उस स्थिति के लिए एक वसंत नमूना विन्यास फाइल नहीं ढूंढ सकते जो वास्तव में काम करता है। हमने स्प्रिंग प्रलेखन, गूगल, फ़ोरम इत्यादि के नमूनों का उपयोग करके इतने सारे संयोजनों की कोशिश की। कुछ भी गायब है।

कोई भी, कृपया हमें ऐसी फ़ाइल प्रदान कर सकता है ताकि हम इसे हमारे कॉन्फ़िगरेशन के लिए प्रारंभिक टेम्पलेट के रूप में उपयोग कर सकें।

पीएस क्या हमें वास्तव में एक्सए की आवश्यकता है?

धन्यवाद।

Answer 1

विभिन्न उम्मीदवार समाधान के माध्यम से खुदाई (संभव रूपांतरण MSMQ से RabbitMQ को Change Data Capture के उपयोग, SQL Server Service Broker के लिए एडेप्टर, और) के बाद, मैं एक समाधान है कि आप के लिए काम करना चाहिए के लिए आया था।

यह पता चला है कि आप WCF क्लाइंट और सेवा अनुबंध SQL सर्वर पर बाध्य कर सकते हैं। यहां से, आप RabbitMQ's AMQP binding for WCF का उपयोग संदेशों को आगे और आगे अनुवाद करने के लिए कर सकते हैं, जैसा कि उपरोक्त लिंक किए गए पीडीएफ दस्तावेज़ों में बहुत विस्तार से है।

मुझे पता नहीं है कि एक्सए जैसे अतिरिक्त लेनदेन प्रबंधक की आवश्यकता होगी, लेकिन यदि आपको लेनदेन नकल, लूप और मिस्सेसिंग के साथ समस्याएं आती हैं, तो कनेक्शन के लिए मध्यस्थ के रूप में जांच करना उचित है। यदि आप उस मार्ग पर जाते हैं, तो आपको उस समस्या के विवरण में परिभाषित करने के तरीके में अपने गेटवे में वेल्ड करना होगा। अगर इसे स्पष्टीकरण की आवश्यकता है, तो मुझे यहां विस्तार करने में खुशी होगी।

आपके आवेदन के साथ शुभकामनाएँ। यह बाहर से एकीकरण हाइड्रा की तरह लगता है, लेकिन एक बार जब आप सब कुछ एक साथ बात कर लेते हैं, तो इसे अच्छी तरह से काम करना चाहिए।

Answer 2

जैसा कि मुझे पता है कि RabbitMQ समर्थन XA शैली लेनदेन नहीं है।

और हां आप जावा में कर सकते हैं:

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 (सभी प्रक्रिया के बारे में विस्तृत विवरण मामले में जावा में विन्यस्त किया जा करने की आवश्यकता है एक आवेदन घटना प्रबंधन का)