'나의 주니어 개발 일기/RabbitMQ' 카테고리의 글 목록

RABBITMQ 에서 Queue에서 Consume 하고 있는 대상을 명확히 식별하고 싶을때

Consumer Tag를 이용해보자. RabbitMQ 모니터링 사이트에서 Queue 정보를 확인 했을 때 누가 Consume 하고있는지 Consumer tag 로 확인이 가능하다. 그러나 Consumer tag 값은 mq가 랜덤으로 생성한 값이기 때문에 명확한 식별이 안됀다. Consumer Tag를 이용해 명확한 식별자를 만들어주자. 1. Consumer 단에서 mq factory 생성시 `setConsumerTagStrategy` 를 사용하여 내가 원하는 식별자 이름을 주입하자. @Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory( SimpleRabbitListenerContainerFactoryConfigu..

나의 주니어 개발 일기/RabbitMQ 2024. 3. 18. 09:27

RABBITMQ 심화속성 정보

db 업데이트 작업의 의존성 분리 db 서버에 대한 쓰기 작업 수를 제한함으로써 확장 문제를 해결하는 동시에 새로운 사이트 추가로 인해 발생하는 부하를 제어 db에 부하가 생기면 시스템 성능에 문제를 준다. 애플리케이션의 의존성 제거 mq를 사용해 느슨하게 결합된 설계로 변경함으로써 애플리케이션 아키텍처는 어디상 db 쓰기 성능에 영향을 받지 않으며 핵심 애플리케이션의 코드를 수정하지 않고도 데이터를 처리하는 새로운 애플리케이션을 쉽게 추가 db쓰기 의존성 제거 db와 강결합된 구조는 동기/비동기 애플리케이션 모두에서 성능상의 병목이 발생할 가능성이 있다. RABBITMQ 심화속성 정보 Properties의 expiration 값이나 큐 정의시 x-message-ttl 값으로 데이터 만료기능을 설정할 수..

나의 주니어 개발 일기/RabbitMQ 2024. 3. 6. 17:29

RABBITMQ HA,클러스터 구성방법

RabbitMQ 클러스터 구성시 모든 노드는 hostname 기반으로 통신한다. rabbitmqctl cluster_status 명령어를 실행하면 rabbit@호스트네임 을 확인할 수 있다. 클러스터를 위한 준비사항 서버끼리의 RabbitMQ 버전을 통일화 한다. 클러스터 된 노드들 끼리 hostname 으로 찾을수 있어야 한다. /etc/hosts 파일에서 세팅해주자. 포트 설정 4369, 25672, 5672, 5671, 15672 포트가 열려있는지, 방화벽에 막히지는 않는지 확인하자. .erlang.cookie 값은 모드 노드가 같은 값을 갖고 있어야 한다. 클러스터 시작 상황 물리적으로 다른 서버 192.168.0.1(master), 192.168.0.2(slave) 를 클러스터링 해야한다. 19..

나의 주니어 개발 일기/RabbitMQ 2024. 3. 5. 10:00

Rabbit MQ Queue 정보를 다른 Rabbit MQ 서버로 이전하는 방법

Rabbit MQ Queue 정보를 다른 Rabbit MQ 서버로 이전하고 싶을땐? 1. 사이트에서 다운로드 한다. 또는 1.RABBITMQ CLI로 다운로드 한다. rabbitmqadmin export ./definitions.file.json 2. Rabbitmq.conf를 만든다. mq에 대한 기본 정보들이 기입되어 있으며 management.load_definitions 값에 queue 정보가 정의되어있는 definitions.file.json 이 위치 경로를 입력한다. rabbitmq.conf listeners.tcp.default = 5672 management.tcp.port = 15672 ## ## Security, Access Control ## ============== ## loopb..

나의 주니어 개발 일기/RabbitMQ 2024. 2. 20. 16:51

NGINX 로 RabbitMQ 로드밸런싱 하기

NGINX 로 RabbitMQ 로드밸런싱 하기 nginx 다운 docker pull nginx:latest /etc/nginx/nginx.conf 수정 events { worker_connections 768; } stream { # List of upstream AMQP connections upstream stream_amqp { least_conn; #알고리즘 적용, 커넥션이 최소인것 선택 server 192.168.0.190:5673; # 로드밸런스 서버 적용 server 10.100.0.2:5676; # 로드밸런스 서버 적용 } # AMQP definition server { listen 15000; # mq 접근시 단일 접근 포트 설정 proxy_pass stream_amqp; # forwar..

나의 주니어 개발 일기/RabbitMQ 2023. 7. 12. 11:41

haproxy 로 RabbitMQ서버 로드밸런싱 하기

**haproxy 다운** docker pull haproxy:latest **haproxy.cfg 샐성 및 설정** listen rebbitmq bind 192.168.0.190:5670 #단일 진입점 mode tcp balance roundrobin #로드밸런싱 알고리즘 설정 server 10.100.0.2:5676 check #MQ서버 1 server 196.168.0.190:5673 check #MQ서버 2 아무 폴더에 `vi haproxy.cfg` 로 설정파일을 생성한다. 클라이언트는 `192.168.0.190:5670` 단일 진입점으로만 접근한다. `server` 에 로드밸런싱이 필요한 서버 정보를 기입힌다. 나같은 경우 MQ 서버정보를 입력했다. **도커 실행** docker run -d -..

나의 주니어 개발 일기/RabbitMQ 2023. 7. 11. 14:52

basicReject vs basicNack

https://www.rabbitmq.com/nack.html Negative Acknowledgements — RabbitMQ Negative Acknowledgements Consumers in AMQP 0-9-1 can choose to use manual acknowledgements of deliveries. The AMQP 0-9-1 specification defines the basic.reject method that allows clients to reject individual, delivered messages, instructing the broker to www.rabbitmq.com 스프링에서 @RabbitListener 어노테이션을 사용해서 consume 하는 코드가 있다. ..

나의 주니어 개발 일기/RabbitMQ 2022. 12. 6. 00:53

기억의 파편들

나의 주니어 개발 일기/RabbitMQ 검색 결과