실시간 데이터 처리/RabbitMQ 4

RabbitMQ Mirrored Queue

RabbitMQ Mirrored QueueRabbitMQ는 Single Node에서 사용을 할수 있으나 SPOF이 되기때문에 여러개의 Node구성된 Cluster를 사용할수가 있다.SPOF : Single point of fail, 실패의 하나의 점, 하나의 서버, 하나의 노드이면 서버가 다운된 경우에는 서비스를 할수가 없다.Mirroed Queue는 하나의 Node에 Queue Message가 들어오게 되면 다른 Node로 메시지를 복제(Replication)을 한다.queue의 Master Node, Slave Node로 구별이 된다. - 해당하는 Queue가 Mirroed되는지 확인하는 방법은 management UI를 이용하여 확인할수 있다. Queue Agruments that control m..

RabbitMQ Exchange Fanout

RabbitMQ Exchange Fanouthttp://www.rabbitmq.com/tutorials/tutorial-three-python.htmlPublish/Subscribe 형태Exchange에 Queue를 Bind하는 형식Fanout방식은 Exchnage에 bind 되어있는 모든 Queue에 메세지를 보낸다.channel.exchange_declare(exchange='logs', type='fanout')exchange를 선언(declare), type은 fanout으로 한다.channel.basic_publish(exchange='logs', routing_key='', body=message)기존 Queue에 메세지를 보낸 것과 달리 Publish에서는 exchange를 대상으로 publ..

RabbitMQ Simple Queue

RabbitMQ Simple Queue용어 정리Producing메세지를 큐에 보낸다.Queue우편통처럼 메세지를 저장해놓는 장소Consuming큐를 통해 메시지를 받는다.Hello World!Sending#!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()connection과 channel를 생성channel.queue_declare(queue='hello')channel를 통해 queue 선언(declare) 한다.channel.basic_publish(exchange='', routing_key='hell..

RabbitMQ

RabbitMQ비동기 메시지 큐 플랫폼Brew를 이용하여 설치하는 방법https://www.rabbitmq.com/install-homebrew.htmlbrew update brew install rabbitmqUbuntu에서 설치하는 방법https://www.rabbitmq.com/install-debian.htmlrabbitmq.com APT Repostiroy 추가echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.listapt-get updatesudo apt-get updateinstallsudo apt-get install rabbitmq-serverCommandSer..