# MQ

[Kubernetes] Rabbitmq Cluster 구축 (삽질기)
rabbitmq-system이라는 네임스페이스에 CRD를 포함한 필요한 리소스들이 생성된다. 그리고 이 API를 사용하여 rabbimq를 요청하면 statefulset을 생성해준다.내가 요청한 yaml은 노드 수는 3개, gp2 sc에 pvc를 요청하여 동적 볼륨을 할

메세지 큐(Message Queue)
프로세스(프로그램) 간에 데이터를 교환할 때 사용하는 통신 방법 중에 하나로 더 큰 개념으로는 MOM(Message Oriented Middleware : 메시지 지향 미들웨어 이하 MOM)을 의미MOM이란 비동기 메시지를 사용하는 프로그램 간의 데이터 송수신을 의미하

카프카(kafka)란? (기본구조, 토픽, 파티션)
카프카(kafka)는 메세지큐의 대표적인 솔루션 중 하나이다. 링크드인에서 개발했으며 현재는 오픈소스로 공개되어있어 데이터 파이프라인 구축을 위해 많은 사람들이 사용하고 있다. 카프카 기본 구조 카프카는 크게 브로커, 컨슈머, 프로듀서 세가지 컴포넌트로 구성된다.
MQ(Message Queue) 를 사용하는 이유
MQ는 어떤 장점이 있고 왜 사용하는지에 대한 포스트 입니다. Case 1. 한가지 시나리오를 생각해보자. 시스템 A 는 시스템 B,C,D 에게 동일한 데이터를 전송중이다. 만약 시스템 E도 이 데이터를 원한다면 어떻게 될까? 만약 시스템 C가 이 데이터를 더이상 원
PubSub + MessageQueue
publisher - message broker - subscriber 형식으로 이루어져 있다.publisher가 event 발생시 message broker 에게 알려주고 해당 토픽 혹인 컨텐츠를 구독하고 있는 subscriber에게 메세지를 전달하는 방식이다.pub

Message Queue
Message Queue는 대용량의 데이터를 처리하기 위해 분산 처리할때 쓰는 것이다. 또한, 프로세스 또는 프로그램 간에 데이터를 교환할 때 사용하는 통신 방법 중에 하나이다.

Spring boot - RebbitMq 적용기
관리자 채팅 페이지 제작을 위해 채팅서버를 알아보다..20년도에 적용하려다 실패한 rebbitMq를 해보려고 한다.그때는 WebFlux로 하려고 했지만 지금은 javaSpring이니... 자료도 많고 하기도 쉬어보인당.도커가 정상적으로 실행되면 localhost:808

메세지 지향 미들웨어(MOM)
메세지 지향 미들웨어(Message Oriented Middleware > MOM) 미들웨어란 애플리케이션들을 연결해 이들이 서로 데이터를 교환할 수 있게 해주는 소프트웨어 메세지 지향 시스템이란 메세지 API를 통해 각 분산되어있는 애플리케이션간의 다리역할을 함으로써 데이터를 교환할 수 있도록 하는 시스템 메세지를 통해 여러 분산되어 있는 시스템간의 C...

MQ 비교 (Kafka, RabbitMQ, Redis)
개념AMQP를 따르는 오픈소스 메세지💡 AMQP(Advanced Message Queuing Protocol): 메세지 지향 미들웨어를 위한 개방형 표준 응용 계층 프로토콜구성 요소producer: 메세지를 보냄exchange: 메세지를 목적지(큐)에 맞게 전달qu

22.6.13 Message Queue
인풋을 통해 들어오는 프로세스에 대한 다양한 요청, 이벤트 등을 메시지라고 한다. 메시지 큐(Message Queue)는 프로세스 또는 프로그램 인스턴스가 데이터를 서로 교환할 때 사용하는 통신 방법이다. 브로커라고 불리기도 한다. 모니터링, 로그, 이벤트 메시지 등
pulsar
zookeeperpulsar-managerbroker/bookie initbroker/bookie실행 순서에 따라 확인 진행실행zookeeper 켜졌는데 다른 컨테이너가 이를 인식하지 못해서 Init 단계에서 멈춰 있었음(on-prem)부하테스트 실패 후 healthy

메시지 큐(Message Queue) & Node.js에서 celery queue로 메시지 보내기 | 오늘의 맛집은? 돼지맨숀
구조 깡패가 되기 위한 발길질 ...
[MQ] 메세지 큐를 사용하는 이유
프로세스 부하를 적게 유지할 수 있다.예를 들어 사용자가 임의의 시간에 리소스부하가 큰 작업을 실행할 시 동기적으로 실행하는대신 큐에 작업을 임시로 저장할 수 있다.워커프로세스는 정해진 절차에 따라 큐에서 작업을 할당받아 작업할 수 있다.어플리케이션으 스케일업에 따라