Spring Boot ile RabbitMQ Kullanımı

By Cem Dırman Last updated Haz 24, 2020

Bu yazımızda RabbitMQ’ya veri yazma üzerinde duracağız. İlk adımımız RabbitMQ’yu docker üzerinde ayağa kaldırmak olacak. Bunun için hub.docker.com gidip Rabbit image’ını indirebiliriz. Eğer docker komutlarına aşina değilseniz basit docker komutlarını anlattığım önceki yazıma bakmanız faydalı olabilir.

http://bilisim.io/2020/05/09/docker-101/

Bu yazı için yeni bir proje başlatmayacağım, önceki yazılarda adım adım ilerlettiğimiz GraphQL projesi üzerine geliştirme yapacağım. O projeye aşağıdaki linkten ulaşabilirsiniz.

https://github.com/cemdrman/SpringBootWithGraphQL

RabbitMQ

Aşağıdaki komutu kullanarak kendi makinenizde RabbitMQ kaldırabilirsiniz. Ayrıca bize arayüz sağlayan bir plugin mevcut. İlgili bilgilere Docker Hub üzerinden ulaşabilirsiniz.



docker run -d --hostname my-rabbit --name myrabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 -p 5672:5672 -p 15672:15672 rabbitmq:3-management

docker run -d --hostname my-rabbit --name myrabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 -p 5672:5672 -p 15672:15672 rabbitmq:3-management

Şimdi aşağıdaki adrese gidip bu pluginin nasıl gözüktüğüne bakabiliriz. Burada belki şöyle bir bilgi vermek gerekir. Aşağıdaki adresteki port bilgisi RabbitMQ’nun değil, management plugin ile gelen uygulamasının port bilgisidir.



http://localhost:15672/

http://localhost:15672/

Java Kodu

Öncelikle dependency ekliyoruz.



<dependency>
        <groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

Gradle için;

implementation 'org.springframework.boot:spring-boot-starter-amqp'

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

Gradle için;

implementation 'org.springframework.boot:spring-boot-starter-amqp'

Burada şunu belirtmek faydalı olabilir ki görüldüğü üzere Rabbit’e özgü bir dependency eklemiyoruz. Çünkü dependency ismindeki AMQP(Advanced Message Queuing Protocol) bir protokol. Bu noktada ürünler değişebilir fakat protokol aynı kalacaktır.

RabbitMQ ayarlarının olacağı bir konfigürasyon class’ı oluşturuyoruz.



@Configuration
@Data
public class RabbitMQConfig {

	@Value("${rabbitmq.queue}")
	private String queueName;

	@Value("${rabbitmq.exchange}")
	private String exchange;

	@Value("${rabbitmq.routingkey}")
	private String routingkey;

	@Bean
	public Queue queue() {
		return new Queue(queueName, false);
	}

	@Bean
	public DirectExchange exchange() {
		return new DirectExchange(exchange);
	}

	@Bean
	public Binding binding(Queue queue, DirectExchange exchange) {
		return BindingBuilder.bind(queue).to(exchange).with(routingkey);
	}

	@Bean
	public MessageConverter jsonMessageConverter() {
		return new Jackson2JsonMessageConverter();
	}

	@Bean
	public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
		final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
		rabbitTemplate.setMessageConverter(jsonMessageConverter());
		return rabbitTemplate;
	}
}

@Configuration

@Data

public class RabbitMQConfig {

@Value("${rabbitmq.queue}")

private String queueName;

@Value("${rabbitmq.exchange}")

private String exchange;

@Value("${rabbitmq.routingkey}")

private String routingkey;

@Bean

public Queue queue() {

return new Queue(queueName, false);

}

@Bean

public DirectExchange exchange() {

return new DirectExchange(exchange);

}

@Bean

public Binding binding(Queue queue, DirectExchange exchange) {

return BindingBuilder.bind(queue).to(exchange).with(routingkey);

}

@Bean

public MessageConverter jsonMessageConverter() {

return new Jackson2JsonMessageConverter();

}

@Bean

public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {

final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);

rabbitTemplate.setMessageConverter(jsonMessageConverter());

return rabbitTemplate;

}

Bir servis katmanı oluşturup RabbitMQ ile yapılacak işlemleri buraya ekliyoruz.



public interface RabbitMQService {
	void send(Blog blog);
}

public interface RabbitMQService {

void send(Blog blog);

}



@Service
public class RabbitMQServiceImpl implements RabbitMQService {

	@Autowired
	private AmqpTemplate rabbitTemplate;

	@Autowired
	private RabbitMQConfig config;

	@Override
	public void send(Blog blog) {
		rabbitTemplate.convertAndSend(config.getExchange(), config.getRoutingkey(), blog);
	}

}

@Service

public class RabbitMQServiceImpl implements RabbitMQService {

@Autowired

private AmqpTemplate rabbitTemplate;

@Autowired

private RabbitMQConfig config;

@Override

public void send(Blog blog) {

rabbitTemplate.convertAndSend(config.getExchange(), config.getRoutingkey(), blog);

}

application.yml dosyamızda ayarlar da aşağıdaki gibi olmalıdır. Docker komutunda belirttiğimiz bilgilerin doğruluğundan emin olmak gerek. RabbitMQ’nun default portu 5672, plugin portu ise 15672.



spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456
rabbitmq.exchange=bilisimio.exchange
rabbitmq.queue=bilisimio.queue
rabbitmq.routingkey=bilisimio.routingkey
spring.main.allow-bean-definition-overriding=true

spring.rabbitmq.host=localhost

spring.rabbitmq.port=5672

spring.rabbitmq.username=admin

spring.rabbitmq.password=123456

rabbitmq.exchange=bilisimio.exchange

rabbitmq.queue=bilisimio.queue

rabbitmq.routingkey=bilisimio.routingkey

spring.main.allow-bean-definition-overriding=true

Şimdi tek kalan işlem Rabbit’e yazmak.



@Autowired
private BlogService service;
	
@Autowired
private RabbitMQService rabbit;

public Blog getBlogById(Long id) {
	Blog blog = service.getBlogById(id);
	rabbit.send(blog);
	return blog;
}

@Autowired

private BlogService service;

@Autowired

private RabbitMQService rabbit;

public Blog getBlogById(Long id) {

Blog blog = service.getBlogById(id);

rabbit.send(blog);

return blog;

}

Artık Rabbite yazıp yazmadığımızı kontrol edebiliriz. Ana sayfadan Queues tabına geçiyoruz. Burada oluşturduğumuz queue ismini görmemiz gerekiyor. Bu queue’nun içinde ilgili bilgiler mevcut. Get messages kısmından yazdığımız kaydı aşağıdaki gibi görebiliriz.

Rabbit UI Plugin: http://localhost:15672/

RabbitMQ ile ilgili diğer yazılarımız için;

Bir sonraki yazımız gönderilen mesajın okunması üzerine olacak.

Faydalı olması dileğiyle.