비동기 메시지 처리 시스템(3) - RabbitMQ toturial(1)


RabbitMQ toturials는 rabbitmq 에 잘 정리되어 있음.

eclipse & maven 기반으로 toturials을 실행하기 위해서 먼저 아래와 같이 dependancy를 pom.xml파일에 추가한다.

1. maven dependancy
    <dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.2.2</version>
</dependency>

2. 첫번째 샘플인 Sending & Receiving 부터 마지막 RPC 예제 소스를 다운받아 eclipse에서 실행해보면 기본적인 이용방법을 알수 있다. http://www.rabbitmq.com/tutorials/tutorial-one-java.html



3. 예제를 실행하면 rabbitmq의 관리페이지에서 다양한 view를 확인할 수 있다.





댓글

댓글 쓰기

이 블로그의 인기 게시물

Charset 변환 ( EUC-KR, UTF-8, MS949, CP933 )

1. 개요 국제화를 고려한 사이트이여야 하나 국내는 반드시 EUC-KR을 사용해야 함에 따라 아래 문제를 해결해야 함 1) EUC-KR을 UTF-8, MS949, CP933 으로 변환해야 한다.  2) 변환후 글자는 깨질수 있으나 byte length는 변하지 않아야 한다.  2. 변환 유틸 import java.io.ByteArrayOutputStream; import java.io.IOException; public class EncodingTest3 { static String convert(String str, String encoding) throws IOException { ByteArrayOutputStream requestOutputStream = new ByteArrayOutputStream(); requestOutputStream.write(str.getBytes(encoding)); return requestOutputStream.toString(encoding); } static String testEncoding(String str, String encoding) throws IOException { String result = convert(str, encoding); System.out.println(result + "=>encoding=" + encoding + ",length=(" + result.getBytes(encoding).length + ")"); return result; } public static void main(String args[]) throws Exception { System.out.println("==== file.encoding===" + System.getProperty("file.encoding")); String
자세한 내용 보기

GZipUtils- gzip을 통한 압축시 charset처리

import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.Reader; import java.io.Writer; import net.sf.jazzlib.GZIPInputStream; import net.sf.jazzlib.GZIPOutputStream; public class GZipUtils { /** * 지정된 폴더를 Zip 파일로 압축한다. * * @param sourceFileName * - 압축 대상 파일 * @param outputFileName * - 확장자가 gz * @param encoding 파일의 encoding EUC-KR, UTF-8 등.. * @throws Exception */ public static void zip(String sourceFileName, String outputFileName,String encoding) throws Exception { Reader reader = null; Writer writer = null; try { InputStream inputStream = new FileInputStream(sourceFileName); reader = new BufferedReader(new InputStreamReader(inputStrea
자세한 내용 보기

비동기 메시지 처리 시스템(1)-JMS, RabbitMQ

1.개요 ㅇ비동기/병렬처리( QUEUE ):대량 메시지 처리성능을 위해 반드시 적용 ㅇ동기처리시 문제.. -트랜잭션이 늘어나면 대기하는 요청들이 늘어나 정체 -> 서버다운 -병렬 처리 못함 -> 응답시간 지연. ㅇSpring Integration:비동기 병렬처리를 손쉽게 구현. - spring 기반의 bean들과 설정들을 그대로 사용할 수 있어 매력적임 - Task-executor를 이용한 단순한 구조였음에도 훌륭한 성능. ㅇ 개선점 ( In memory channel 기반 시스템의..) - decoupling : .producer와 consumer간 직접연결로 인한 확장성 문제. .주소가 바뀌거나 , 서버이전하거나..( Physical decoupling) .어느 한쪽의 logic이 변경되면......( Logical decoupling ) - 시스템 에러시 queue에 있는 데이타는 유실 - load balancing, clustring .. - 큐의 상태에 대한 모니터링 도구가 없음. ㅇ 보다 견고한 시스템 구성이 필요 -> jms, mq 등의 시스템 구성.. 2. JMS vs RabbitMQ ㅇJMS : 메시지 처리에 대한 J2EE API. OpenMQ, HornetQ, ActiveMQ가 이에 해당하는 제품들임 ㅇRabbitMQ : AMQP 프로토콜을 지원하는 오픈소스 메시징 시스템 (AMQP란 -> http://killins.egloos.com/m/3025514 ) ㅇ둘의 차이점 [원본] http://java.dzone.com/articles/jms-vs-rabbitmq 1) Messaging Model
자세한 내용 보기