Integrasi sederhana RabbitMQ dan Spring Boot

Disederhanakan? Tapi bagaimana caranya?

Konfigurasi otomatis

Wow, tapi seperti apa konfigurasi itu 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}

Bagus, tetapi Anda mengatakan sesuatu tentang strategi replay baru, kan?

• Jika Anda belum menentukan waktu-untuk-hidup (TTL, seumur hidup), maka RabbitMQ akan terus mencoba untuk mengantri pesan Anda.
• Jika Anda mendefinisikan TTL tetapi tidak mendefinisikan dlx , maka setelah TTL pesan akan dihapus dari antrian dan Anda akan kehilangan itu.
• Jika Anda telah menetapkan TTL dan dlx , maka setelah TTL pesan akan dikirim ke exchanger yang didefinisikan dalam dlx.

Tetapi bagaimana jika kita menginginkan TTL yang meningkat (misalnya, jika operasi tidak stabil) dan mengontrol jumlah percobaan ulang?

Coba lagi strategi

Spring AMQP secara default

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 Tuning

Tapi bagaimana caranya?

Bisakah saya menggunakan strategi coba lagi tanpa konfigurasi otomatis? Saya sudah punya banyak kacang, dan saya tidak punya waktu untuk menulis ulang.

spring.rabbitmq.enable.custom.autoconfiguration=false

Tetapi saya memiliki dua koneksi yang berbeda, apa yang harus saya lakukan dalam kasus ini?

Sangat baik! Jadi, saya ingin menggunakan ini. Bagaimana saya bisa melakukan ini? Apakah Anda memiliki contoh atau dokumentasi?

Penerbit

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

Pelanggan

Bagaimana cara mengetahui nama containerFactory yang benar untuk host virtual?

@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) {
   ...
}

Terima kasih khusus untuk