AMQ Broker 入门

流程

1. 在 Web 浏览器中，导航到 https://access.redhat.com/downloads/ 并登录。

   此时会显示产品下载页。

2. 在 JBoss 集成和自动化 部分中，点击 Red Hat AMQ Broker 链接。

   此时会显示 Software Downloads 页面。

3. 从 Version 下拉菜单中选择所需的 AMQ Broker 版本。
4. 在 Releases 选项卡中，点您要下载的特定 AMQ Broker 文件的 Download 链接。

流程

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 实例创建一个目录。

   如果使用…​	这些以下操作
   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 命令创建代理。

   如果使用…​	这些以下操作
   Red Hat Enterprise Linux	切换到安装期间创建的用户帐户。 $ su - amq-broker 更改到您刚才为代理实例创建的目录。 $ cd /var/opt/amq-broker 从 broker 实例的目录中，创建 broker 实例。 $ <install_dir>/bin/artemis create mybroker
   Windows	从您刚才为代理实例创建的目录打开命令提示符。 从 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）的连接。每个协议也都有单独的端口。

   • Web 控制台位于 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

2. 使用 Web 控制台查看存储在代理中的消息。

   1. 在 Web 浏览器中，导航到 http://localhost:8161

   2. 使用您在创建代理实例时创建的默认用户名和密码登录控制台。

      此时会显示 Attributes 选项卡。

   3. 在 Attributes 选项卡上，导航到 地址 → helloworld → 队列 → "anycast" → helloworld。

      在上一步中，您发送了消息到 helloworld 地址。这会使用队列（也称为 helloworld ）创建新的任播 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. 在 Web 控制台中，验证 Message 计数 现在是否为 50。

   50 个消息被使用，保留 50 个消息存储在 helloworld 队列中。

5. 停止代理，并验证剩余的 50 个消息仍然存储在 helloworld 队列中。

   1. 在代理运行的终端中，按 Ctrl+C 以停止代理。

   2. 重新启动代理。

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

   3. 在 Web 控制台中，导航到 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. 在 Web 控制台中，验证 Message count 是否为 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