RabbitMQ

RabbitMQ는 오픈 소스 메시지 브로커 소프트웨어(메시지 지향 미들웨어)로서, AMQP를 구현하였으며 그 이후로 STOMP, MQTT 등의 프로토콜을 지원하기 위해 플러그인 구조와 함께 확장되고 있다.

RabbitMQ

개발자	피보탈 소프트웨어
안정화 버전	4.0.5 / 2024년 12월 15일(9개월 전)(2024-12-15)
저장소	github.com/rabbitmq
프로그래밍 언어	얼랭
운영 체제	크로스 플랫폼
종류	AMQP, 메시지 지향 미들웨어
라이선스	모질라 퍼블릭 라이선스
웹사이트	www.rabbitmq.com

RabbitMQ

메시지를 생산하는 생산자(Producer)가 메시지를 큐에 저장해 두면, 메시지를 수신하는 소비자(Consumer)가 메시지를 가져와 처리하는 Publish/Subscribe 방식의 메시지 전달 브로커이다.

예

송신

#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

수신

#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
print(' [*] Waiting for messages. To exit press CTRL+C')
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
channel.basic_consume('hello', callback)
channel.start_consuming()

같이 보기

• 아파치 카프카

외부 링크

• RabbitMQ - 공식 웹사이트