簡書：亞武de小文 【原創(chuàng)：轉(zhuǎn)載請注明出處】

環(huán)境準備與測試

LengToo上學.png

Windows安裝及使用

Mac環(huán)境安裝可參考：Rabbitmq打怪升級之路（五） Mac安裝rabbitmq服務

一湿弦、Erlang的安裝與配置

1. 安裝
   安裝直接Next即可瓤漏，若彈出安裝Microsoft Visual C++ 2013（或者其他版本）的彈框，繼續(xù)點擊Install颊埃。
   

   VisualC++.png

   Erlang下載頁面
   

   Erlang下載.png

2. 配置環(huán)境變量

   • 新建一個系統(tǒng)變量：變量名為ERLANG_HOME蔬充，變量值為安裝Erlang的路徑D:\Program Files\erl10.4（路徑中不要包含bin目錄)
     

     Erl環(huán)境變量1.png

   • 將新建的系統(tǒng)變量添加在Path中：格式為%ERLANG_HOME%\bin
     

     Erl環(huán)境變量2.png

   • 然后我們打開cmd輸入erl查看是Erlan是否安裝好、下圖就表示已經(jīng)安裝好了

     
     
     Erl環(huán)境變量3.png

二班利、RabbitMQ安裝與啟動

1. 下載與安裝

   Installing on Windows — RabbitMQ
   

   RabbitMQ下載.png

2. 配置環(huán)境變量饥漫，

   • 新建系統(tǒng)變量：
     RABBITMQ_SERVER
D:\ProgramFiles\RabbitMQServer\rabbitmq_server-3.7.15
     
     RabbitMQ環(huán)境配置1.png
   • Path中加入%RABBITMQ_SERVER%\sbin;
     
     RabbitMQ環(huán)境配置2.png

3. 開啟后臺管理插件

   • 首先使用終端進入sbin目錄
     D:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.15\sbin
   • 然后輸入: rabbitmq-plugins.bat enable rabbitmq_management 開啟插件
     
     RabbitMQ環(huán)境配置3.png
   • 還是在sbin目下：輸入 rabbitmq-server 啟動RabbitMQ服務
     【若有開始菜單可直接操作對應的服務】
     
     Rabbitmq開始菜單.png

4. 在地址欄輸入如下地址（初始化用戶名和密碼都是guest）
   http://localhost:15672/
【注】第三步插件開啟之后，才能在瀏覽器中看到后臺管理界面】
   

   RabbitMQ后臺登陸頁.png

RabbitMQ_guest賬戶登陸.png

5. 利用官方測試工具進行測試（亦可自己寫個生產(chǎn)者消費者進行測試）
   Getting started with RabbitMQ — RabbitMQ
   官方提供的代碼：

• 發(fā)送端：Send.java

  /**
   * RabbitmMQ官方發(fā)送端
   * @date 2019.06.26
   * @author yawu
   */
  public class Send {
      private final static String QUEUE_NAME = "hello";
      public static void main(String[] argv) throws Exception {
          ConnectionFactory factory = new ConnectionFactory();
          factory.setHost("localhost");
          try (Connection connection = factory.newConnection();
              Channel channel = connection.createChannel()) {
              channel.queueDeclare(QUEUE_NAME, false, false, false, null);
              String message = "Hello World!";
              channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
              System.out.println(" [x] Sent '" + message + "'");
          }
      }
  }
  
  

• 接收端：Recv.java

  /**
   * RabbitmMQ官方接收端
   *
   * @author yawu
   * @date 2019.06.26
   */
  public class Recv {
      private final static String QUEUE_NAME = "hello";
      public static void main(String[] argv) throws Exception {
          ConnectionFactory factory = new ConnectionFactory();
          factory.setHost("localhost");
          Connection connection = factory.newConnection();
          Channel channel = connection.createChannel();
  
          channel.queueDeclare(QUEUE_NAME, false, false, false, null);
          System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
  
          DeliverCallback deliverCallback = (consumerTag, delivery) -> {
              String message = new String(delivery.getBody(), "UTF-8");
              System.out.println(" [x] Received '" + message + "'");
          };
          channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
      }
  }
  
  

6. 運行之后查看rabbitmq后臺頁面，出現(xiàn)如下圖所示证膨，至此鼓黔，RabbitMQ的服務環(huán)境準備完畢

   
   
   rabbitmq隊列消息.png