개발정리

이전의 튜토리얼 에서는 우리는 work queue를 만들었습니다. 추측 하건데,워크 큐는 각각의 task를 정확히 한 워커에 전달합니다. 이번 예제에는 무언가 전혀 다른 것을 할 것 입니다. -우리는 메세지를 여러 consumer들로 전달할 것 입니다. 이러한 패턴을 "pub/sub"이라고 합니다. 이런 패턴을 보여주기 위해 우리는 간단한 로깅 시스템을 구축 할 것 입니다. 이것은 두 프로그램들로 구성될 것 입니다. 첫째는 로그 메세지를 발행할 것 이고,두번째는 메세지를 받아 출력할 것 입니다. 우리들의 로깅 시스템에서 모든 receiver program들은 메세지를 받을 것 입니다. 그러한 방식으로 우리는 한 receiver를 실행 시킬 수 있으며 로그들을 disk로 향하게 합니다. 동시에 또다른 re..

들어가며.. 이전의 Hello World 예제에서는 큐하나에 하나의 컨슈머가 있고 단순히 큐에 보낸 메시지를 컨슈머 하나가 작업하는 단순한 예제를 했었습니다. 이번에는 큐하나에 여러개의 컨슈머를 배치해서 작업을 병렬적으로 해결하는 법을 알아 봅시다. 하나의 worker프로세스는 백그라운드에서 동작 할 것이며 작업을 큐에서 하나 꺼내와 처리할 것 입니다. 만약 여러개의 worker를 사용한다면 큐안의 작업들을 공유하여 해결할 것 입니다. 이러한 개념은 특히 짧은 HTTP요청으로 복잡한 작업을 해결하기 불가능한 웹 어플리케이션에 유용합니다. 준비 이전 예제에서는 단순히 "Hello World"라는 문자열을 보냈지만 우리는 무엇인가 복잡한 작업을 의미하는 메세지를 보내고 싶습니다. 단순히 문자열에 '.'(do..

import java.io.IOException; import java.nio.charset.StandardCharsets; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class Send { private final static String QUEUE_NAME = "hello"; public static void main(String[] args) throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost..

RabbitMQ는 오픈소스 AMQP 브로커입니다. AMQP는 유선을 통해 전송되는 메세지 형식을 포함하는 개발형 프로토콜입니다. AMQP란? 프로그래밍에서 MQ는 프로세스 또는 프로그램 인스턴스가 데이터를 서로 교환할 때 사용하는 방법 이러한 MQ를 오픈소스에 기반한 표준 프로토콜이 AMQP입니다. AMQP의 구성요소와 라우팅 알고리즘 AMQP의 라우팅 모델은 Exchange,Queue,Binding 으로 구성된다. 이름 설명 Exchange Publisher로부터 수신한 메시지를 큐에 분배하는 라우터 역할 Queue 메시지를 메모리나 디스크에 저장했다가 Consumer에게 메시지를 전달하는 역할 Binding Exchange와 Queue의 관계를 정의한 것 Exchange Type Exchange Ty..