RabbitMQ的安装以及使用（Windows环境)

1、RabbitMQ介绍

一、RabbitMQ简介

RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。全部主要的编程语言均有与代理接口通信的客户端库。

二、RabbitMQ简介（白话）

上述简介摘自百度百科，相关术语自行百度吧。。。反正我也看不懂，太深奥。
作个比喻：
快递员A须要将一个快递给客户B。
本来：A亲手将快递交给B。
问题：B如今有不少事要作，A只能等着B处理完事情，才能把快递交给他，A就很难受了，送不了几个快递，无法赚钱了。
解决：设置一个快递柜，A把快递放进快递柜，就能够送下一个快递了，B啥时候有空了，去快递柜拿就好了。
总结：快递就是消息，快递柜就是消息队列。快递柜有不少种，菜鸟，丰巢等，RabbitMQ就是其中一种快递柜。
放在程序里举例：
客户提交订单，支付系统——>订单系统，支付系统可能很快就执行完了，可是订单系统要好久才能执行完，每次支付系统都要等待订单系统，服务端速度就会很慢，如今使用RabbitMQ，支付系统支付成功后，发送一个支付成功消息到RabbitMQ，就能够返回前端了，订单系统在获取到消息后，慢慢再执行订单修改的程序。(固然，要考虑到某个系统出了异常怎么办，这个入门先无论，只管正常状况。)

2、RabbitMQ的安装

一、Erlang的安装

由于RabbitMQ是用Erlang语言编写的，因此要安装RabbitMQ先要安装Erlang。
下载地址: http://www.erlang.org/downloads
根据须要选择版本
选择 Windows 64-bit版，下载完成后直接安装，一直NEXT。（路径自行选择）（官网下载速度会比较慢）

 

 

二、RabbitMQ安装程序

注意：请确认计算机名为英文，中文可能会致使RabbitMQ启动失败。若是启动失败，请改为英文后，卸载并从新安装

 

 

 

下载地址： http://www.rabbitmq.com/install-windows.html
根据须要选择版本（注意：RabbitMQ和Erlang版本可能存在不匹配状况）
选择Bintray版本，下载完成后直接安装，一直NEXT。（路径自行选择）

 

 

三、自定义环境变量

（1）erl环境变量配置

 

 

ERLANG_HOME=D:\Program\erl9.2

在Path中加入

%ERLANG_HOME%\bin;

（2）RabbitMQ环境变量配置

这里注意，看好你RabbitMQ的安装位置，以及安装的版本，个人版本为3.7.3

 

 

 

RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.3

在Path中加入

%RABBITMQ_SERVER%\sbin;

四、激活rabbitmq_management

在CMD中进入如下目录，键入以下命令，不出错便可

 

 

 

rabbitmq-plugins.bat enable rabbitmq_management

五、启动RabbitMQ服务

须要以管理员方式启动CMD

 

 在命令行界面键入以下命令

net start RabbitMQ

由于RabbitMQ默认启动的，当键入启动命令时，会出现以下状况，直接关闭RabbitMQ服务，再启动就行。

 

 

 关闭RabbitMQ服务命令以下：

net stop RabbitMQ

3、RabbitMQ测试

测试地址 http://localhost:15672/
默认的用户名：guest
默认的密码为：guest

4、Java客户端测试（maven）

一、maven项目中添加RabbitMQ依赖

直接在项目的pom.xml文件中添加以下依赖

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

二、新建SendMQ类，发送端

import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import java.io.IOException; public class SendMQ { private final static String QUEUE_NAME = "Hello"; public static void main(String[] args) throws IOException, Exception { // connection是socket链接的抽象，而且为咱们管理协议版本协商（protocol version negotiation）， // 认证（authentication ）等等事情。这里咱们要链接的消息代理在本地，所以咱们将host设为“localhost”。 // 若是咱们想链接其余机器上的代理，只须要将这里改成特定的主机名或IP地址。
        ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); factory.setPort(5672); //默认端口号
        factory.setUsername("guest");//默认用户名
        factory.setPassword("guest");//默认密码
        Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); // 接下来，咱们建立一个channel，绝大部分API方法须要经过调用它来完成。 // 发送以前，咱们必须声明消息要发往哪一个队列，而后咱们能够向队列发一条消息：
        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 + "'"); channel.close(); connection.close(); } }

三、新建RecvMQ类，接收端

import com.rabbitmq.client.*; import java.io.IOException; public class RecvMQ { private final static String QUEUE_NAME = "Hello"; public static void main(String[] args) throws IOException, Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); factory.setPort(5672); factory.setUsername("guest"); factory.setPassword("guest"); 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"); Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume(QUEUE_NAME, true, consumer); } }

四、运行两个类测试