RabbitMQ Java Publisher Uygulaması

RabbitMQ Dersleri’ne devam ediyorum.

RabbitMQ Dashbordumuzda bir Queue oluşturalım ve bu Queue’ya bir Java uygulaması yaparak mesaj gönderelim.

Kuyruk-1 adında bir Queue oluşturduk. Yapacağımız Java Publisher Uygulamasından mesajımızı RabbitMQ’ ya gönderirken Kuyruk-1’e yollayacağız.

Uygulamaya geçelim. Maven projesi yapacağız. Maven projesinde gerekli olan bağımlılığımızı ekleyelim.

    <dependencies>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>5.14.0</version>
        </dependency>
    </dependencies>
Code language: HTML, XML (xml)

Bağımlılığımız ekledikten sonra Java uygulamamıza geçebiliriz. Publisher adında bir class oluşturalım. Bu classın içerinden mesaj göndereceğimiz Main metodu oluşturalım ve sonrasında neler yaptık bahsedeyim.

public class Publisher {
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory connectionFactory = new ConnectionFactory();
        Connection connection = connectionFactory.newConnection();

        Channel channel = connection.createChannel();

        String message="Merhaba Dünya";

        channel.basicPublish("", "Kuyruk-1", null, message.getBytes());
        channel.close();
        connection.close();
    }
}
Code language: JavaScript (javascript)

• ConnectionFactory

Connection Factory RabbitMQ’ya bağlanmak için gerekli connection bilgisini oluşturulur.

• Connection

Connection Factory ile yeni bir connection sağlanır.

• Channel

RabbitMQ’daki erişmemiz gereken kanal bilgisini sağlamaktadır.

• basicPublish

RabbitMQ’ya göndermek isteğimiz mesajın hangi Queue’ya gideceğini ve oluşturduğumuz mesajı byte olarak gönderiyoruz.

RabbitMQ’dan gönderdiğimiz mesajımıza bakalım.

Mesajımızı RabbitMQ’den okuduk.

Java uygulamasından RabbitMQ’ye mesaj gönderme işlemini görmüş olduk. Sonraki yazıda görüşmek üzere.