AMQ Broker 시작하기

프로세스

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

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

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

   소프트웨어 다운로드 페이지가 표시됩니다.

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

프로세스

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

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

   Copy to Clipboard Toggle word wrap

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

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

5. 새로운 amq-broker 사용자로 unzip 명령을 사용하여 내용을 추출합니다.

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

   Copy to Clipboard Toggle word wrap

   apache-artemis-2.33.0.redhat-00016 과 유사한 이름의 디렉터리가 생성됩니다. 문서에서 이 위치를 < install_dir>이라고 합니다.

프로세스

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

   예: C:\redhat\amq-broker

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

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

   apache-artemis-2.33.0.redhat-00016 과 유사한 이름의 디렉터리가 생성됩니다. 문서에서 이 위치를 < install_dir>이라고 합니다.

프로세스

1. 브로커 인스턴스의 디렉터리를 생성합니다.

   Expand

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

   Show more

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

   Expand

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

   Show more

3. Artemis 에서 브로커 인스턴스를 구성하는 프롬프트를 따릅니다.

   예 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

   Copy to Clipboard Toggle word wrap

프로세스

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

   $ su - amq-broker

   Copy to Clipboard Toggle word wrap

2. broker 인스턴스를 시작하려면 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
   ...

   Copy to Clipboard Toggle word wrap

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

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

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

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

   • 웹 콘솔은 http://localhost:8161 에서 사용할 수 있습니다.
   • Jolokia 서비스 (JMX over REST)는 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

   Copy to Clipboard Toggle word wrap

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

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

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

      특성 탭이 표시됩니다.

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

      이전 단계에서 helloworld 주소로 메시지를 전송했습니다. 그러면 큐( helloworld 라고도 함)가 포함된 새 anycast helloworld주소가 생성되었습니다. Message count 속성은 helloworld 로 전송된 모든 100개의 메시지가 현재 이 큐에 저장되어 있음을 보여줍니다.

      그림 4.1. 메시지 수

      

      View larger image

      

3. artemis 소비자 명령을 사용하여 브로커에 저장된 메시지 중 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

   Copy to Clipboard Toggle word wrap

4. 웹 콘솔에서 메시지 수가 현재 50개인지 확인합니다.

   50개의 메시지가 사용되어 helloworld 큐에 저장된 메시지가 50개 남아 있었습니다.

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

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

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

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

      Copy to Clipboard Toggle word wrap
   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

   Copy to Clipboard Toggle word wrap

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

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

프로세스

1. 실행하려는 예제의 디렉터리로 이동합니다. 다음 예제에서는 예제를 amq-broker-examples 라는 디렉터리에 다운로드했다고 가정합니다.

   $ cd amq-broker-examples/examples/features/standard/queue

   Copy to Clipboard Toggle word wrap

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

   Maven은 브로커를 시작하고 example 프로그램을 실행합니다. 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] ------------------------------------------------------------------------

   Copy to Clipboard Toggle word wrap
   참고

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

   $ sudo route add -net 224.0.0.0 netmask 240.0.0.0 dev lo

   Copy to Clipboard Toggle word wrap