Rabbitmq打怪升级之路（四）win环境准备与测试

简书：亚武de小文 【原创：转载请注明出处】

环境准备与测试

LengToo上学.png

Windows安装及使用

Mac环境安装可参考：Rabbitmq打怪升级之路（五） Mac安装rabbitmq服务

一、Erlang的安装与配置

1. 安装
   安装直接Next即可，若弹出安装Microsoft Visual C++ 2013（或者其他版本）的弹框，继续点击Install。
   

   VisualC++.png

   Erlang下载页面
   

   Erlang下载.png

2. 配置环境变量

   • 新建一个系统变量：变量名为ERLANG_HOME，变量值为安装Erlang的路径D:\Program Files\erl10.4（路径中不要包含bin目录)
     

     Erl环境变量1.png

   • 将新建的系统变量添加在Path中：格式为%ERLANG_HOME%\bin
     

     Erl环境变量2.png

   • 然后我们打开cmd输入erl查看是Erlan是否安装好、下图就表示已经安装好了

     
     Erl环境变量3.png

二、RabbitMQ安装与启动

1. 下载与安装

   Installing on Windows — RabbitMQ
   

   RabbitMQ下载.png

2. 配置环境变量，

   • 新建系统变量：
     RABBITMQ_SERVER
D:\ProgramFiles\RabbitMQServer\rabbitmq_server-3.7.15
     RabbitMQ环境配置1.png
   • Path中加入%RABBITMQ_SERVER%\sbin;
     RabbitMQ环境配置2.png

3. 开启后台管理插件

   • 首先使用终端进入sbin目录
     D:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.15\sbin
   • 然后输入: rabbitmq-plugins.bat enable rabbitmq_management 开启插件
     RabbitMQ环境配置3.png
   • 还是在sbin目下：输入 rabbitmq-server 启动RabbitMQ服务
     【若有开始菜单可直接操作对应的服务】
     Rabbitmq开始菜单.png

4. 在地址栏输入如下地址（初始化用户名和密码都是guest）
   http://localhost:15672/
【注】第三步插件开启之后，才能在浏览器中看到后台管理界面】
   

   RabbitMQ后台登陆页.png

RabbitMQ_guest账户登陆.png

5. 利用官方测试工具进行测试（亦可自己写个生产者消费者进行测试）
   Getting started with RabbitMQ — RabbitMQ
   官方提供的代码：

• 发送端：Send.java

  /**
   * RabbitmMQ官方发送端
   * @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后台页面，出现如下图所示，至此，RabbitMQ的服务环境准备完毕

   
   rabbitmq队列消息.png