OpenSource/RabbitMQ (5) 썸네일형 리스트형 Spring AMQP를 사용하여 RabbitMQ Producer, Consumer 예제 코드 작성하기 spring-amqp dependency 추가 org.springframework.boot spring-boot-starter-amqp org.springframework.amqp spring-rabbit-test test application.yml 설정spring: rabbitmq: host: localhost #hostIp port: 5672 #default 5672 username: "admin" #username password: "admin" #password Queue 생성 및 설정spring boot 환경에서는 Configuration 설정을 통해 쉽게 Queue, Binding, Exchange를 설정할 수 있습니다.DirectExchan.. Docker로 RabbitMQ 클러스터 구성하기 RabbitMQ는 인프라 유지보수, 업그레이드 및 장애로부터 데이터베이스와 데이터를 보호하기 위해 복제, 장애 복구 및 고가용성 기능을 제공합니다.배치에는 세 개의 노드가 있는 클러스터가 포함되어 있으며 사용자, 가상 호스트, 큐, 교환, 바인딩, 런타임 매개변수 및 기타 분산 상태가 세 개의 모든 노드에서 공유됩니다.노드가 실패하면 노드가 삭제되거나 다시 시작된 후 해당 노드 또는 새 노드가 클러스터에 재동기화 됩니다 .docker pull rabbitmq:managementdocker network 생성docker network create prod3대의 RabbitMQ 컨테이너 실행docker run -d --name rabbitmq_node1 -h rabbitmq_node1 -it --networ.. Docker에 RabbitMQ 설치 도커로 RabbitMQ 설치아래의 명령으로 docker container를 띄웁니다docker run -d --name rabbitmq -p 5672:5672 -p 8080:15672 --restart=unless-stopped rabbitmq:management docker 옵션 정보-d : 백그라운드로 실행--name rabbitmq : 해당 컨테이너 이름을 rabbitmq로 실행-p 5672:5672 -p 8080:15672 : Host와 컨테이너간 포트 포워딩 (5672: rabbitmq 기본 통신 포트, 15672: rabbitmq 관리자 페이지 통신 포트) 클러스터 구성이 필요할 경우 25672 추가(추후 추가 예정)-restart=unless-stopped : 해당.. [RabbitMQ] RabbitMQ 설치 및 Cluster 구성 방법 RabbitMQ 설치 및 Cluster 구성 방법에 대한 내용입니다.1. EPEL 저장소 설치$ yum install -y epel-release2. erlang 설치 및 확인erlang 설치클러스터 구성된 노드끼리 통신을 위해 Erlang Cookie가 필요하므로 erlang을 설치합니다.$ yum install -y erlangerlang 설치 확인erl 명령어 입력 시 아래와 같이 나오면 잘 설치 된 겁니다.$ erlErlang/OTP 23 [erts-11.2] [source] [64-bit] [smp:1:1] [ds:1:1:10] [async-threads:1] [hipe]Eshell V11.2 (abort with ^G)1>3. RabbitMQ 설치 및 실행$ yum install -y rab.. [RabbitMQ] RabbitMQ의 주요 개념 Core Concept RabbitMQ에서 중요한 개념은 Producer, Consumer, Queue, Exchange, Binding이 있습니다. Producer 메세지를 생성하고 발송하는 주체입니다. 이 메시지는 Queue에 저장되는데 주의할 점은 Producer는 Queue에 직접 접근하지 않고, 항상 Exchange를 통해 접근하게 됩니다. message를 consumer에게 위임하기 위해 message를 exchange에 publish 합니다. message 전송하는 일 외에는 아무 일도 하지 않습니다. Consumer 메세지를 수신하는 주체입니다. Consumer는 Queue에 직접 접근하여 메세지를 가져옵니다. Message 처리해야 할 내용이 담겨져 있습니다. Queue Queue는 Pr.. 이전 1 다음
