Rabbit MQ 가져오기

RabbitMQ를 가져와 비동기 대기열 테스트를 고려하여 가져왔습니다.

전제 조건

전제 조건에 ELAN이 필요하기 때문에 거기서부터 시작합니다.

Erlang의 RPM 확보

wget "http://packages.erlang-solutions.com/site/esl/esl-erlang/FLAVOUR_1_general/esl-erlang_15.b.3-1~fedora~beefymiracle_amd64.rpm"
wget "https://github.com/jasonmcintosh/esl-erlang-compat/blob/master/rpmbuild/RPMS/noarch/esl-erlang-compat-R14B-1.el6.noarch.rpm?raw=true"

yum에서 이걸 가져왔어요. Erlang이 끝났어요.

 yum install esl-erlang_15.b.3-1~fedora~beefymiracle_amd64.rpm
 yum install esl-erlang-compat-R14B-1.el6.noarch.rpm

RabbitMQ 가져오기

yum install http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.4/rabbitmq-server-3.3.4-1.noarch.rpm

RabbitMQ 설정

원형을 복제하다.

흔히 볼 수 있는 모델로 초기 형태가 있기 때문에 먼저 복사 설정을 한다.

cp -a /usr/share/doc/rabbitmq-server-3.3.4/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

운용 시 등급을 변경하고 싶을 수 있으니 아래 내용을 확인하세요.
{log_levels, [{connection, info}]},
로그를 나타내고 info는 수준을 나타냅니다.
로그는/var/log/rabbitmq에 있습니다.

동작 확인

Java의 Center 도구를 가져오고 테스트 도구를 사용하여 작업을 확인합니다.

wget "http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.3.4/rabbitmq-java-client-bin-3.3.4.tar.gz"
tar zxf rabbitmq-java-client-bin-3.3.4.tar.gz

압축이 풀린 폴더에서 PerfTest 확인을 수행합니다.

./runjava.sh com.rabbitmq.examples.PerfTest
starting consumer #0
starting producer #0
time: 1.001s, sent: 4874 msg/s, received: 3028 msg/s, min/avg/max latency: 3132/81769/204803 microseconds
time: 2.001s, sent: 17897 msg/s, received: 6538 msg/s, min/avg/max latency: 216676/503751/640297 microseconds
time: 3.001s, sent: 10706 msg/s, received: 10953 msg/s, min/avg/max latency: 494052/926855/1224386 microseconds

만약 이런 느낌이 든다면Que는 일을 하고 있을 것이다.
-- help로 호출하면 다음과 같은 도움을 받을 수 있다.

 -?,--help                  show usage
 -A,--multiAckEvery <arg>   multi ack every
 -a,--autoack               auto ack
 -b,--heartbeat <arg>       heartbeat interval
 -c,--confirm <arg>         max unconfirmed publishes
 -C,--pmessages <arg>       producer message count
 -D,--cmessages <arg>       consumer message count
 -e,--exchange <arg>        exchange name
 -f,--flag <arg>            message flag
 -h,--uri <arg>             AMQP URI
 -i,--interval <arg>        sampling interval
 -k,--routingKey <arg>      routing key
 -M,--framemax <arg>        frame max
 -m,--ptxsize <arg>         producer tx size
 -n,--ctxsize <arg>         consumer tx size
 -p,--predeclared           allow use of predeclared objects
 -Q,--globalQos <arg>       channel prefetch count
 -q,--qos <arg>             consumer prefetch count
 -r,--rate <arg>            rate limit
 -s,--size <arg>            message size
 -t,--type <arg>            exchange type
 -u,--queue <arg>           queue name
 -x,--producers <arg>       producer count
 -y,--consumers <arg>       consumer count
 -z,--time <arg>            time limit

네트워크 관리 도구

/usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_shovel
/usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management
/usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_shovel_management
/etc/init.d/rabbitmq-server restart

관리 도구를 활성화합니다.

rabbitmqctl -n rabbit@localhost add_user admin admin
rabbitmqctl -n rabbit@localhost set_permissions admin ".*" ".*" ".*"
rabbitmqctl -n rabbit@localhost set_user_tags admin administrator

위의 명령으로 사용자(admin/admin)를 등록하면 다음 URL을 통해 액세스할 수 있습니다.