AMQ Broker 시작하기

절차

1. 웹 브라우저에서 https://access.redhat.com/downloads/ 으로 이동하여 로그인합니다.

   제품 다운로드 페이지가 표시됩니다.

2. JBoss Integration and Automation 섹션에서 Red Hat AMQ Broker 링크를 클릭합니다.

   Software Downloads 페이지가 표시됩니다.

3. 버전 드롭다운 메뉴에서 원하는 AMQ Broker 버전을 선택합니다.
4. 릴리스 탭에서 다운로드 하려는 특정 AMQ Broker 파일에 대한 다운로드 링크를 클릭합니다.

절차

1. amq-broker 라는 새 사용자를 생성하고 암호를 제공합니다.

   $ sudo useradd amq-broker
   $ sudo passwd amq-broker

2. /opt/redhat/amq-broker 디렉터리를 만들고 새 amq-broker 사용자 및 그룹을 소유자로 설정합니다.

   $ sudo mkdir /opt/redhat
   $ sudo mkdir /opt/redhat/amq-broker
   $ sudo chown -R amq-broker:amq-broker /opt/redhat/amq-broker

3. 아카이브의 소유자를 새 사용자로 변경합니다.

   $ sudo chown amq-broker:amq-broker amq-broker-7.x.x-bin.zip

4. 방금 만든 디렉터리로 설치 아카이브를 이동합니다.

   $ sudo mv amq-broker-7.x.x-bin.zip /opt/redhat/amq-broker

5. 새 amq-broker 사용자로 unzip 명령을 사용하여 콘텐츠를 추출합니다.

   $ su - amq-broker
   $ cd /opt/redhat/amq-broker
   $ unzip <archive_name>.zip
   $ exit

   amq-broker-7.11 과 유사한 이름을 가진 디렉토리가 생성됩니다. 문서에서 이 위치는 < install_dir>이라고 합니다.

절차

1. Windows Explorer를 사용하여 원하는 드라이브 문자에 디렉터리 폴더 \redhat\amq-broker 를 생성합니다.

   예: C:\redhat\amq-broker

2. Windows Explorer를 사용하여 방금 만든 디렉터리로 설치 아카이브를 이동합니다.

3. \redhat\amq-broker 디렉터리에서 설치 아카이브 zip 파일을 마우스 오른쪽 버튼으로 클릭하고 Extract All.

   amq-broker-7.11 과 유사한 이름을 가진 디렉토리가 생성됩니다. 문서에서 이 위치는 < install_dir>이라고 합니다.

절차

1. broker 인스턴스에 사용할 디렉터리를 생성합니다.

   If you are using…​	이 작업을 수행합니다.
   Red Hat Enterprise Linux	broker 인스턴스의 위치로 사용할 새 디렉터리를 생성합니다. $ sudo mkdir /var/opt/amq-broker 설치 중에 생성한 사용자를 할당합니다. $ sudo chown -R amq-broker:amq-broker /var/opt/amq-broker
   Windows	Windows Explorer를 사용하여 브로커 인스턴스의 위치로 사용할 새 폴더를 만듭니다.

2. artemis create 명령을 사용하여 브로커를 생성합니다.

   If you are using…​	이 작업을 수행합니다.
   Red Hat Enterprise Linux	설치 중에 생성한 사용자 계정으로 전환합니다. $ su - amq-broker 브로커 인스턴스에 대해 방금 생성한 디렉터리로 변경합니다. $ cd /var/opt/amq-broker broker 인스턴스의 디렉터리에서 broker 인스턴스를 생성합니다. $ <install_dir>/bin/artemis create mybroker
   Windows	broker 인스턴스에 대해 방금 생성한 디렉터리에서 명령 프롬프트를 엽니다. broker 인스턴스의 디렉터리에서 broker 인스턴스를 생성합니다. > <install_dir>\bin\artemis.cmd create mybroker

3. artemis create 프롬프트에 따라 브로커 인스턴스를 구성합니다.

   예 4.1. artemis create를 사용하여 브로커 인스턴스 구성

   $ /opt/redhat/amq-broker/bin/artemis create mybroker
   
   Creating ActiveMQ Artemis instance at: /var/opt/amq-broker/mybroker
   
   --user: is mandatory with this configuration:
   Please provide the default username:
   admin
   
   --password: is mandatory with this configuration:
   Please provide the default password:
   
   --role: is mandatory with this configuration:
   Please provide the default role:
   amq
   
   --allow-anonymous | --require-login: is mandatory with this configuration:
   Allow anonymous access? (Y/N):
   Y
   
   Auto tuning journal ...
   done! Your system can make 19.23 writes per millisecond, your journal-buffer-timeout will be 52000
   
   You can now start the broker by executing:
   
   "/var/opt/amq-broker/mybroker/bin/artemis" run
   
   Or you can run the broker in the background using:
   
   "/var/opt/amq-broker/mybroker/bin/artemis-service" start

절차

1. 설치 중에 생성한 사용자 계정으로 전환합니다.

   $ su - amq-broker

2. artemis run 명령을 사용하여 브로커 인스턴스를 시작합니다.

   $ /var/opt/amq-broker/mybroker/bin/artemis run
   
             __  __  ____    ____            _
       /\   |  \/  |/ __ \  |  _ \          | |
      /  \  | \  / | |  | | | |_) |_ __ ___ | | _____ _ __
     / /\ \ | |\/| | |  | | |  _ <| '__/ _ \| |/ / _ \ '__|
    / ____ \| |  | | |__| | | |_) | | | (_) |   <  __/ |
   /_/    \_\_|  |_|\___\_\ |____/|_|  \___/|_|\_\___|_|
   
   Red Hat JBoss AMQ 7.2.1.GA
   
   10:53:43,959 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
   10:53:44,076 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging)
   10:53:44,099 INFO  [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
   ...

   브로커는 다음 정보를 사용하여 로그 출력을 시작하고 표시합니다.

   • 트랜잭션 로그 및 클러스터 구성의 위치입니다.
   • 메시지 지속성(이 경우 AIO)에 사용되는 저널 유형입니다.

   • 클라이언트 연결을 허용할 수 있는 URI입니다.

     기본적으로 포트 61616은 지원되는 모든 프로토콜(CORE, MQTT, AMQP, STOMP, HORNETQ 및 OPENWIRE)의 연결을 허용할 수 있습니다. 또한 각 프로토콜마다 별도의 개별 포트도 있습니다.

   • 웹 콘솔은 http://localhost:8161 에서 사용할 수 있습니다.
   • Jolokia 서비스(RR을 통한 JMX)는 http://localhost:8161/jolokia 에서 사용할 수 있습니다.

절차

1. artemis producer 명령을 사용하여 몇 가지 테스트 메시지를 생성하고 브로커로 보냅니다.

   이 명령은 브로커에서 자동으로 생성된 helloworld 주소로 100개의 메시지를 보냅니다. 생산자는 지원되는 모든 메시징 프로토콜을 허용하는 기본 포트 61616을 사용하여 브로커에 연결합니다.

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis producer --destination helloworld --message-count 100 --url tcp://localhost:61616
   Producer ActiveMQQueue[helloworld], thread=0 Started to calculate elapsed time ...
   
   Producer ActiveMQQueue[helloworld], thread=0 Produced: 100 messages
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in second : 1 s
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in milli second : 1289 milli seconds

2. 웹 콘솔을 사용하여 브로커에 저장된 메시지를 확인합니다.

   1. 웹 브라우저에서 http://localhost:8161 로 이동합니다.

   2. 브로커 인스턴스를 만들 때 생성한 기본 사용자 이름 및 기본 암호를 사용하여 콘솔에 로그인합니다.

      특성 탭이 표시됩니다.

   3. Attributes 탭에서 address → helloworld → 대기열 → "anycast" → helloworld 로 이동합니다.

      이전 단계에서는 메시지를 helloworld 주소로 전송했습니다. 이로 인해 큐( helloworld 라고도 함)를 사용하여 새 anycast helloworld주소가 생성되었습니다. Message count 특성은 helloworld 로 전송된 100개의 모든 메시지가 현재 이 큐에 저장됨을 보여줍니다.

      그림 4.1. 메시지 수

      

3. artemis consumer 명령을 사용하여 브로커에 저장된 메시지의 50개를 사용합니다.

   이 명령은 이전에 브로커에 보낸 메시지의 50개를 사용합니다.

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

4. 웹 콘솔에서 Message count 가 이제 50인지 확인합니다.

   50개의 메시지가 사용되었으며, 이 경우 helloworld 큐에 저장된 50개의 메시지가 남습니다.

5. 브로커를 중지하고 나머지 50개의 메시지가 여전히 helloworld 큐에 저장되었는지 확인합니다.

   1. 브로커가 실행 중인 터미널에서 Ctrl+C 를 눌러 브로커를 중지합니다.

   2. 브로커를 다시 시작합니다.

      $ /var/opt/amq-broker/mybroker/bin/artemis run

   3. 웹 콘솔에서 helloworld 대기열로 돌아가 큐에 아직 50개의 메시지가 저장되어 있는지 확인합니다.

6. 나머지 50개의 메시지를 사용합니다.

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

7. 웹 콘솔에서 메시지 수가 0인지 확인합니다.

   helloworld 큐에 저장된 모든 메시지가 사용되었으며 대기열이 비어 있습니다.

절차

1. 실행할 예제의 디렉터리로 이동합니다.

   예제 프로그램은 < install_dir> /examples 에 있습니다. 예를 들면 다음과 같습니다.

   $ cd <install_dir>/examples/features/standard/queue

2. mvn clean verify 명령을 사용하여 예제 프로그램을 실행합니다.

   Maven은 브로커를 시작하고 예제 프로그램을 실행합니다. 예제 프로그램을 처음 실행할 때 Maven은 실행하는데 시간이 걸릴 수 있는 누락된 종속성을 다운로드합니다.

   이 경우 큐 예제 프로그램이 실행되어 생산자를 생성하고 테스트 메시지를 보낸 다음 메시지를 수신하는 소비자를 생성합니다.

   $ mvn clean verify
   [INFO] Scanning for projects...
   [INFO]
   [INFO] -------------< org.apache.activemq.examples.broker:queue >--------------
   [INFO] Building ActiveMQ Artemis JMS Queue Example 2.6.1.amq-720004-redhat-1
   [INFO] --------------------------------[ jar ]---------------------------------
   ...
   server-out:2018-12-05 16:37:57,023 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.6.1.amq-720004-redhat-1 [0.0.0.0, nodeID=06f529d3-f8d6-11e8-9bea-0800271b03bd]
   [INFO] Server started
   [INFO]
   [INFO] --- artemis-maven-plugin:2.6.1.amq-720004-redhat-1:runClient (runClient) @ queue ---
   Sent message: This is a text message
   Received message: This is a text message
   [INFO]
   [INFO] --- artemis-maven-plugin:2.6.1.amq-720004-redhat-1:cli (stop) @ queue ---
   server-out:2018-12-05 16:37:59,519 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: Apache ActiveMQ Artemis Message Broker version 2.6.1.amq-720004-redhat-1 [06f529d3-f8d6-11e8-9bea-0800271b03bd] stopped, uptime 3.734 seconds
   server-out:Server stopped!
   [INFO] ------------------------------------------------------------------------
   [INFO] BUILD SUCCESS
   [INFO] ------------------------------------------------------------------------
   [INFO] Total time:  48.681 s
   [INFO] Finished at: 2018-12-05T16:37:59-05:00
   [INFO] ------------------------------------------------------------------------

   참고

   일부 예제 프로그램은 UDP 클러스터링을 사용하며 기본적으로 사용자 환경에서 작동하지 않을 수 있습니다. 이 예제를 성공적으로 실행하려면 224.0.0.0으로 전송된 트래픽을 루프백 인터페이스로 리디렉션합니다.

   $ sudo route add -net 224.0.0.0 netmask 240.0.0.0 dev lo