스프링 부트에서 RabbitMQ와 연동하려면 아래와 같은 작업을 수행해야 합니다.
1. 의존성 추가: `build.gradle` 또는 `pom.xml` 파일에 RabbitMQ 라이브러리 의존성을 추가합니다.
2. RabbitMQ 설정: `application.properties` 또는 `application.yml` 파일에 RabbitMQ 연결 정보를 설정합니다. 예를 들어, 다음과 같이 설정할 수 있습니다.
spring.rabbitmq.host=<RabbitMQ 서버 호스트>
spring.rabbitmq.port=<RabbitMQ 서버 포트>
spring.rabbitmq.username=<RabbitMQ 사용자명>
spring.rabbitmq.password=<RabbitMQ 비밀번호>
3. RabbitMQ 메시지 수신: 메시지를 받기 위한 리스터를 작성합니다. 스프링 부트에서는 `@RabbitListener` 어노테이션을 사용하여 메시지 리스너를 등록할 수 있습니다.
예를 들어, 다음과 같이 메시지를 수신하는 메소드를 작성할 수 있습니다.
@RabbitListener(queues = "<큐 이름>")
public void receiveMessage(String message) {
// 메시지 처리 로직
}
위의 예시는 `<큐 이름>`에 정의된 큐에서 메시지를 받아 `receiveMessage` 메소드가 호출되는 방식입니다. 받은 메시지는 `String` 형태로 전달됩니다.
4. RabbitMQ 메시지 발송: 메시지를 발송하기 위해서는 `RabbitTemplate`을 사용합니다. 스프링 부트에서는 자동으로 빈으로 등록되므로, 필요한 곳에서 `@Autowired` 어노테이션을 사용하여 주입받을 수 있습니다. 예를 들어, 다음과 같이 메시지를 발송할 수 있습니다.
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("<큐 이름>", message);
}
위의 예시는 `<큐 이름>`에 정의된 큐로 `String` 형태의 메시지를 발송하는 방법입니다.
이렇게하면 스프링 부트에서 RabbitMQ와의 연동을 구성할 수 있습니다. 추가로, RabbitMQ의 고급 기능을 사용하기 위해서는 `RabbitAdmin` 또는 `AmqpTemplate` 등을 사용할 수도 있습니다.
'Springboot' 카테고리의 다른 글
ORM이란 (0) | 2023.09.18 |
---|---|
오라클 연동 및 예제 (0) | 2023.09.18 |
MariaDB 연동 예제 (0) | 2023.09.17 |
로깅 라이브러리 @Slf4J 예제 (0) | 2023.09.17 |
@ResponseEntity를 활용한 PUT 메서드 예제 (0) | 2023.09.17 |