रैबिटमक्यू और स्प्रिंग बूट का सरल एकीकरण

सरल? पर कैसे?

स्वतः कॉन्फ़िगरेशन

वाह, लेकिन विन्यास में क्या दिखता है application.properties?

spring.rabbitmq.custom.some-event.host=localhost
spring.rabbitmq.custom.some-event.port=5672
spring.rabbitmq.custom.some-event.ttlRetryMessage=5000
spring.rabbitmq.custom.some-event.maxRetriesAttempts=5
spring.rabbitmq.custom.some-event.ttlMultiply=2
spring.rabbitmq.custom.some-event.queueRoutingKey=ROUTING.KEY.TEST
spring.rabbitmq.custom.some-event.exchange=ex.custom.direct
spring.rabbitmq.custom.some-event.exchangeType=direct
spring.rabbitmq.custom.some-event.queue=queue.custom.test
spring.rabbitmq.custom.some-event.autoCreate=true
spring.rabbitmq.custom.some-event.concurrentConsumers=1
spring.rabbitmq.custom.some-event.maxConcurrentConsumers=1
spring.rabbitmq.custom.some-event.virtualHost=tradeshift
spring.rabbitmq.custom.some-event.primary=true
spring.rabbitmq.custom.some-event.sslConnection=true
spring.rabbitmq.custom.some-event.tlsKeystoreLocation=file:///etc/tradeshift/your-service/tls-keystore.pkcs12
spring.rabbitmq.custom.some-event.tlsKeystorePassword=${RABBITMQ_PASS_CERT}

spring.rabbitmq.custom.another-event.host=localhost
spring.rabbitmq.custom.another-event.port=5672
spring.rabbitmq.custom.another-event.ttlRetryMessage=5000
spring.rabbitmq.custom.another-event.maxRetriesAttempts=5
spring.rabbitmq.custom.another-event.queueRoutingKey=TEST.QUEUE
spring.rabbitmq.custom.another-event.exchange=ex_test_1
spring.rabbitmq.custom.another-event.exchangeType=direct
spring.rabbitmq.custom.another-event.queue=queue_test_1
spring.rabbitmq.custom.another-event.autoCreate=true
spring.rabbitmq.custom.another-event.concurrentConsumers=1
spring.rabbitmq.custom.another-event.maxConcurrentConsumers=1
spring.rabbitmq.custom.another-event.username=guest
spring.rabbitmq.custom.another-event.password=${RABBITMQ_PASS}

अच्छा है, लेकिन आप नई रीप्ले रणनीति के बारे में कुछ कह रहे थे, है ना?

• यदि आपने समय-समय पर लाइव (TTL, जीवनकाल) को परिभाषित नहीं किया है , तो RabbitMQ लगातार आपके संदेश को पंक्तिबद्ध करने का प्रयास करेगा।
• यदि आपने टीटीएल को परिभाषित किया है, लेकिन डीएलएक्स को परिभाषित नहीं किया है , तो टीटीएल के बाद संदेश कतार से हटा दिया जाएगा और आप इसे खो देंगे।
• यदि आपने TTL और dlx को परिभाषित किया है , तो TTL के बाद dlx में परिभाषित एक्सचेंजर को संदेश भेजा जाएगा ।

लेकिन क्या होगा यदि हम बढ़ते हुए टीटीएल (उदाहरण के लिए, अस्थिर संचालन के मामले में) चाहते हैं और रिट्रीट की संख्या को नियंत्रित करते हैं?

रणनीतियों का पुन: प्रयास करें

डिफ़ॉल्ट रूप से स्प्रिंग एएमक्यूपी

spring.rabbitmq.listener.simple.retry.enabled=true
spring.rabbitmq.listener.simple.retry.initial-interval=2000
spring.rabbitmq.listener.simple.retry.max-attempts=5
spring.rabbitmq.listener.simple.retry.multiplier=2
spring.rabbitmq.listener.simple.max-concurrency=5
spring.rabbitmq.listener.simple.concurrency=5

वसंत खरगोश ट्यूनिंग

पर कैसे?

क्या मैं ऑटोकैनफिगरेशन के बिना आपकी रिट्री रणनीति का उपयोग कर सकता हूं? मेरे पास पहले से ही कई फलियाँ हैं, और मेरे पास उन्हें फिर से लिखने का समय नहीं है।

spring.rabbitmq.enable.custom.autoconfiguration=false

लेकिन मेरे पास दो अलग-अलग कनेक्शन हैं, मुझे इस मामले में क्या करना चाहिए?

बहुत अच्छा! इसलिए, मैं इसका उपयोग करना चाहता हूं। मैं यह कैसे कर सकता हूँ? क्या आपके पास एक उदाहरण या दस्तावेज है?

प्रकाशक

@Value("${spring.rabbitmq.custom.some-event.exchange}")
private String exchangeSomeEvent;

@Value("${spring.rabbitmq.custom.some-event.queueRoutingKey}")
private String routingKeySomeEvent;

@Autowired
private final RabbitTemplateHandler rabbitTemplateHandler;

public void sendMessage(final String message) {
   rabbitTemplateHandler.getRabbitTemplate("some-event").convertAndSend(exchangeSomeEvent, routingKeySomeEvent, message);
}

ग्राहक

वर्चुअल होस्ट के लिए सही कंटेनरफैक्टरी नाम कैसे पता करें?

@RabbitListener(containerFactory = "some-event", queues = "${spring.rabbitmq.custom.some-event.queue}")
@EnableRabbitRetryAndDlq(event = "some-event", exceptions = { IllegalArgumentException.class, RuntimeException.class })
public void onMessage(Message message) {
   ...
}

उन्हें विशेष धन्यवाद