RabbitMQ Fanout Exchange Java Publisher / Consumer Uygulaması
RabbitMQ Dersleri‘ne devam ediyorum.
Önceki derste gördüğümüz Exchange çeşitlerinden Fanout Exhance’ı detaylı olarak ele alacağım.
![RabbitMQ Dersleri Fanout Excahnge](https://blog.burakkutbay.com/wp-content/uploads/2022/02/RabbitMQ-Dersleri-Fanout-Exchange.jpeg)
Fanout Exchange kendisine gelen tüm mesajları kendisine bağlı olan tüm consumerlara iletmekle görevlidir.
RabbitMQ’u açalım ve bir Fanout Exchange oluşturalım. Exchange çeşitleri içerisinde oluşturduğumuzdan emin olalım.
![RabbitMQ Fanout Exchange Oluşturmak](https://blog.burakkutbay.com/wp-content/uploads/2022/02/image-4.png)
Kuyruklarımızı oluşturalım.
![blank](https://blog.burakkutbay.com/wp-content/plugins/wp-fastest-cache-premium/pro/images/blank.gif)
Oluşturduğumuz Queues’lerimizi oluşturduğumuz Fanout Exchange’mize bind edeceğiz. Direct Exchange’de yaptığımız gibi routing key vermeyeceğiz.
![RabbitMQ Fanout Exchange Binding Queue](https://blog.burakkutbay.com/wp-content/plugins/wp-fastest-cache-premium/pro/images/blank.gif)
Fanout Exchange uygulaması için Publisher ve Consumer Java uygulaması yapalım.
Publisher uygulamıza geçelim.
public class FanoutPublisher {
public static void main(String[] args) throws IOException, TimeoutException {
ConnectionFactory connectionFactory=new ConnectionFactory();
Connection connection=connectionFactory.newConnection();
Channel channel=connection.createChannel();
String message="Tablet and Desktop!";
channel.basicPublish("Fanout-Exchange","", null,message.getBytes() );
channel.close();
connection.close();
}
}
Code language: JavaScript (javascript)
RabbitMQ’ye bir mesaj gönderiyoruz ve içerisinde Tablet ve Desktop kelimeleri geçiyor. Programımızı çalıştırdıktan sonra RabbitMQ’ya bakalım.
![blank](https://blog.burakkutbay.com/wp-content/plugins/wp-fastest-cache-premium/pro/images/blank.gif)
Mesajımız tüm consumerlara gönderilmek üzere Queue’da bekledildiğini görebiliyoruz.
Sonraki yazıda görüşmek üzere
No Comment! Be the first one.