클라우드 컴퓨팅 & NoSQL/RabbitMq 6

RabbitMQ 기본 기동

1. 설치- Erlang 설치- Rabbit MQ 다운로드 후 설치 2. 기본 명령서버 기동 : sbin/rabbitmq-server start. 윈도우즈에서는 services.msc에서 서비스로 시작상태 체크 : sbin/rabbitmqctl status서버 중지 : sbin/rabbitmqctl stop3. Web Admin 모듈web admin 모듈 enable - "rabbitmq-plugins enable rabbitmq_management" (이다음 서비스를 restart해야 함)http://localhost:15672/ 접속후 guest/guest로 로그인

RabbitMQ 공부 노트

http://www.rabbitmq.com/tutorials/amqp-concepts.html Rabbit MQ 기본 컨셉 AMQP (Advanced Message Queuing Protocol)Broker : 메세지 Queue 시스템을 broker라고 하낟.Queue Queue의 주요 속성Ÿ name Ÿ durable 속성 : 메세지를 디스크에 저장. memory에 저장하는 것은 transient라고 한다.Ÿ auto-delete : 모든 consumer가 unsubscribe하면, 해당 queue는 자동으로 없어진다.* Queue를 만드는 것을 declare라고 하며, 애플리케이션 코드에서도 쉽게 만들 수 있다. 만약 해당 큐가 이미 존재하고 있다면, 다시 queue를 만들지 않고, queue가 없을..

RabbitMQ - Receive Message

※ simplequeue 라는 이름으로 큐를 먼저 만들고 시작할것package com.terry.rabbitmq.queue; import org.slf4j.Logger;import org.slf4j.LoggerFactory; import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import com.rabbitmq.client.QueueingConsumer; public class MessageReceiver { Logger log = LoggerFactory.getLogger(MessageReceiver.class); public String rec..

RabbitMQ - Send Message

※ simplequeue 라는 이름으로 rabbitmq 콘솔에서 먼저 큐를 만들고 시작할것 package com.terry.rabbitmq.queue; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class MessageSender { Logger log = LoggerFactory.getLogger(MessageSender.class); public boolean sendMessage(String uri, String q..