[RabbitMQ] RabbitMQ?

미들웨어

미들웨어는 양 쪽을 연결하여 데이터를 주고 받을 수 있도록 중간에서 매개 역할을 하는 소프트웨어, 네트워크를 통해서 연결된 여러 개의 컴퓨터에 있는 많은 프로세스들에게 어떤 서비스를 사용할 수 있도록 연결해 주는 소프트웨어를 말한다. 3계층 클라이언트/서버 구조에서 미들웨어가 존재한다. 웹 브라우저에서 데이터베이스로부터 데이터를 저장하거나 읽어올 수 있게 중간에 미들웨어가 존재하게 된다.

 

 

메세지 지향 미들웨어

메시지 지향 미들웨어(Message-oriented middleware, MOM)는 응용 소프트웨어 간의 데이터 통신을 위한 소프트웨어이며, 일반적으로 비동기 메시지 전달에 기초한 것을 가리킨다. 많은 메시지 지향 미들웨어는 메시지 큐 시스템을 기반으로 하지만, 그 밖에도 브로드캐스트 형식 메시지 시스템과 멀티 캐스트 형식의 메시지 시스템적인 내용도 있다. 장점으로는 저장(미들웨어에서 메세지를 백업), 라우팅(미들웨어에서 배포 가능), 변환(송/수신자에 맞춰 형식 변환 가능) 단점으로는 메세지 전송 에이전트 필요, 표준이라고 부를 규격이 존재하지 않음

 

 

메시지 큐 시스템

메시지 지향 미들웨어를 구현한 것, 메시지 공급자 위치에 일종의 버퍼(Queue)를 둔다. 클라이언트와 동기 방식으로 많은 데이터 통신을 하게 되면 병목현상이 발생해 서버의 성능이 저하된다. 미들웨어에 메시지를 위임해 순차적으로 처리하도록 해 순차적으로 처리할 수 있다. 표준이 없어 구현하는 사람마다 사용법이나 구현방식이 모두 다르다. 

 

 

AMQP

AMQP(Advanced Message Queueing Protocol)는 메세지 큐의 표준을 정의한 것이다. 많은 블로그에서 조금 헷갈리게 정의하고 있는데, 이 표준은 AMQP(프로토콜)과 AMQM(모델 설계 방식)을 포함하고 있다. 

AMQP의 프로토콜은 어플리케이션 계층, 네트워크 계층에서 정의된다. 어플리케이션 계층에서는 클라이언트가 서버에 이야기하고 상호작용할 수 있는 규칙을, 네트워크 계층에서는 메시지 브로커를 무사히 지나가 프로세스 간 통신을 할 수 있는 규칙을 정의한다.

AMQP는 미들웨어와 클라이언트의 동작에 대해 각기 다른 프로그램이 상호 운용될 수 있는 정도로까지 권한을 주며, SMTP, HTTP, FTP 등도 상호 운용이 가능하다. (API + 메시지 송신자가 해야 하는 행위)를 정의하는 JMS와는 다르게, AMQP는 데이터 형식을 정의하고 그것을 따르는 메시지를 만들고 해석할 수 있는 도구라면 구현 언어에 관계 없이 다른 호환 도구와 상호 운용이 가능하다. 

 

 

AMQM

이것이 AMQP의 모델이다. 자세한 설명은 이 모델을 따르는 RabbitMQ의 모델을 보며 더 자세히 알아보자.

 

 

RabbitMQ 동작

AMQP를 따르는 메시지 브로커이다.  아래 링크 설명이 좋으니 첨부한다.

RabbitMQ란?

 

 

RabbitMQ 튜토리얼

0. Docker 설치(설치 링크)

설치 중 WSL을 업데이트 하라는 창이 나올 수 있다. 링크를 쫓아가 설치하고 Restart 버튼을 누르면 된다.

 

1. RabbitMQ 설치(참고 링크)

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

 

2. 각자 사용할 언어에 맞게 추가 설치

본인은 파이썬을 사용(Pycharm, Anaconda, pika 라이브러리 설치)

 

3. 튜토리얼 따라하기

번역본(링크)

RabbitMQ Tutorials — RabbitMQ

 

4. 튜토리얼을 따라가며 공부했던 것들

• Vhost(virutal host)
  • Virtual Host를 통해서 하나의 RabbitMQ 인스턴스 안에 사용하고 있는 Application을 분리할 수 있습니다.
• Connection
  • 물리적인 TCP Connection, HTTPS -> TLS(SSL) Connection을 사용
• Channel
  • 하나의 물리적인 Connection 내에 생성되는 가상의 Connection
  • Consumer의 process나 thread는 각자 Channel을 통해 Queue에 연결 될 수 있습니다.

 

RPC란?

 

 

참고링크:

위키백과 'AMQP' : https://ko.wikipedia.org/wiki/AMQP

CloudAMQP 'What is AMQP and why is it used in RabbitMQ?' : https://www.cloudamqp.com/blog/what-is-amqp-and-why-is-it-used-in-rabbitmq.html

CloudAMQP 'Microservices - why use RabbitMQ?' : https://www.cloudamqp.com/blog/why-use-rabbitmq-in-a-microservice-architecture.html

티스토리 'RabbitMQ를 사용하는 이유' ; https://kamang-it.tistory.com/entry/AMQPRabbitMQRabbitMQ%EB%A5%BC-%EC%82%AC%EC%9A%A9%ED%95%98%EB%8A%94-%EC%9D%B4%EC%9C%A0%EC%99%80-%EC%84%A4%EC%B9%98%EB%B0%A9%EB%B2%95-1

티스토리 'RabbitMQ의 기본 개념': https://ram2ram2.tistory.com/3

'RabbitMQ 계정 설정' : http://abh0518.net/tok/?p=384 

[Rabbitmq] 1. 초보를 위한 RabbitMQ 후딱 설치하고 설정하기 | 아브의 꿀오분

http://gjchoi.github.io/rabbit/rabbit-mq-%EC%9D%B4%ED%95%B4%ED%95%98%EA%B8%B0/

RabbitMQ - 이해하기

https://blog.ashon.dev/blog/2018/10/14/rabbitmq-message-mirroring-using-shovel.html

RabbitMQ shovel 플러그인을 이용한 메시지 미러링

https://m.blog.naver.com/tmondev/221051503100

RabbitMQ로 메시지 손실 최소화 하는 법(1)

https://m.blog.naver.com/PostView.naver?isHttpsRedirect=true&blogId=zltmwnffldpt&logNo=220914409334 

rabbitmq ha 및 클러스터링 성능 관련 내용정리