728x90 Message Queue/RabbitMQ5 [RbbitMQ] Delay RabbitMQ Spring Consume Delay RabbitMQ Spring Consume 앞서 발행한 메세지를 실제로 받아보자 java code package com.example.rabbitmqconsumer; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.DeliverCallback; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import java.io.. 2022. 10. 17. [RabbitMQ] Work Queues Work Queue 여러 작업 자들에게 시간이 많이 걸리는 작업을 분배 시키는데 사용 할 대기열 큐를 만든다. 리소스의 집약 적인 작업을 즉시 수행 하지 않도록 한다. 그리고 작업들이 완료될때 까지 기다리는 것을 피하게 한다. 백그라운드에서 작업을 처리하는 작업자는 작업들을 꺼내고 잡을 수행한다. 많은 작업자들을 수행할때 작업들은 공유가 된다. Work Queue 를 사용 해야 되는 이유 쉽게 병렬 처리를 할 수 있다. - 작업이 밀리고 있다면 좀더 많은 worker 들을 추가 하면 된다. 라운드 로빈 방식을 기본적으로 사용한다. - 컨슈머들은 동일한 메세지 수를 받게 된다. - 이렇게 균등하게 분배되는 방식을 라운드 로빈이라고 한다. Message acknowledgment 메세지가 정확하게 처리 되었.. 2022. 10. 3. [RbbitMQ] RabbitMQ 개념 기초 What is RabbitMQ ? 래빗엠큐는 하나의 메세지 브로커이다. 메세지를 publish 하고 consume 할 수 있는 기능을 제공한다. 래빗 엠큐 쉽게 이해하기 래빗 엠큐는 우편함이라고 생각하면 편하다. 발신자가 편지를 넣으면 우체부가 우편함에 꺼내서 수신자에게 준다. 래빗엠큐가 우편함 역할을 하고 있다. 우편함과 다른점은 편지 뿐만 아니라 여러가지 데이터를 처리 할 수 있다는 것이다 Producing, Consuming, Queue P: Producing 프로듀싱은 단순히 메세지를 보내는것을 의미한다. 메세지를 보내는 쪽이 Producer 이다. Queue 레빗엠큐에 있는 우편함이라고 생각하면 편하다. 메세지 버퍼의 역할을 한다. 메세지를 보내면 메세지 큐에 저장이 된다. 그렇기 때문에 호스트.. 2022. 9. 24. [RbbitMQ] Delay RabbitMQ Spring Publish Delay RabbitMQ Spring 연동 스프링 부트를 사용해서 직접 레빗 엠큐에 메세지를 쏴보자 실무에서는 직접 래빗엠큐 정보를 다루는게 편하다 그래서 다른 글과는 다르게 ConnectionFactory 를 이용한다. - 사용자 아이디, 주소등 쉽게 다룰수 있다. 주의사항 코드를 작성할때 임포트를 맞게 제대로 해줘야 한다. import 를 제대로 확인해보자 Gradle 에 라이브러리 추가 implementation 'org.springframework.boot:spring-boot-starter-amqp' testImplementation 'org.springframework.amqp:spring-rabbit-test' application.yml 파일 설정 yml 파일 위치 yml 파일 내용 ra.. 2022. 9. 24. 이전 1 2 다음 728x90 반응형
