AMQ Broker 入门

步骤

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

   此时会显示 Product Downloads 页面。

2. 在 JBoss Integration and Automation 部分中，点 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

   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

   创建类似于 amq-broker-7.8 的目录。在文档中，此位置被称为 <install-dir>。

步骤

1. 使用 Windows Explorer 在所需驱动器符上创建目录文件夹 \redhat\amq-broker。

   例如：C:\redhat\amq-broker

2. 使用 Windows 资源管理器将安装存档移到您刚才创建的目录中。

3. 在 \redhat\amq-broker 目录中，右键单击安装存档 zip 文件并选择" 提取所有"。

   创建类似于 amq-broker-7.8 的目录。在文档中，此位置被称为 <install-dir>。

步骤

1. 为代理实例创建一个目录。

   Expand

   如果您使用…​	do this…​
   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

   如果您使用…​	do this…​
   Red Hat Enterprise Linux	切换到安装期间创建的用户帐户。 $ su - amq-broker Copy to Clipboard Toggle word wrap 更改到为代理实例创建的目录。 $ cd /var/opt/amq-broker Copy to Clipboard Toggle word wrap 在代理实例的 目录中，创建代理实例。 $ <install-dir>/bin/artemis create mybroker Copy to Clipboard Toggle word wrap
   Windows	从您为代理实例创建的目录中打开命令提示符。 在代理实例的 目录中，创建代理实例。 > <install-dir>\bin\artemis.cmd create mybroker Copy to Clipboard Toggle word wrap

   Show more

3. 按照 artemis create 提示配置代理实例。

   例 4.1. 使用 arte mis 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. 使用 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）的连接。另外，每个协议都有单独的端口。

   • Web 控制台位于 http://localhost:8161。
   • Jolokia 服务(JMX over REST)位于 http://localhost:8161/jolokia

步骤

1. 使用 artemis producer 命令生成一些测试消息，并将它们发送到代理。

   此命令将 100 个消息发送到 helloworld 地址，该地址会在代理上自动创建。制作者使用默认端口 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. 使用 Web 控制台查看代理中存储的信息。

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

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

      此时会显示 Attributes 选项卡。

   3. 在 Attributes 选项卡中，导航到 menu:[addresses > helloworld > queue > "anycast" > helloworld]。

      在上一步中，您会将消息发送到 helloworld 地址。这会创建一个带有队列（也称为 helloworld ）的新广播 helloworld地址。Message count 属性显示发送到 helloworld 的所有 100 消息都存储在此队列中。

      图 4.1. 消息计数

      

      View larger image

      

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

   Copy to Clipboard Toggle word wrap

4. 在 Web 控制台中，验证 消息数 现在是否为 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. 在 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

   Copy to Clipboard Toggle word wrap

7. 在 Web 控制台中，验证 Message 计数 是否为 0。

   helloworld 队列中存储的所有消息都被消耗，队列现在为空。

步骤

1. 进入您要运行的示例目录。

   示例程序位于 <install-dir>/examples 中。例如：

   $ cd <install-dir>/examples/features/standard/queue

   Copy to Clipboard Toggle word wrap

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] ------------------------------------------------------------------------

   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