1、在官网上分别下载Erlang和RabbitMQ安装文件，下载完成先安装Erlang，这里演示的是在windows上安装，双击exe安装包文件，接着默认点击下一步就可以了，最后配置下环境变量
2、下面安装RabbitMQ，双击exe安装包文件，接着默认点击下一步就可以了，再配置下环境变量
3、启动RabbitMQ，运行rabbitmq-server.bat文件，如果出现ERROR: node with name "rabbit" already running on "landlord_pc"错误，则在开始程序中找到RabbitMQ Service - stop，先停止服务，再运行rabbitmq-server.bat文件
4、此时可以通过浏览器访问http://127.0.0.1:15672/地址来访问管理界面，默认的guest用户，密码也为guest的帐号登录，也可以创建新用户，输入命令（rabbitmqctl.bat add_user shao shao）
5、授予管理员权限，输入命令（rabbitmqctl.bat set_user_tags shao administrator）再输入（rabbitmqctl.bat set_permissions -p / shao".*" ".*" ".*"），再输入（rabbitmqctl.bat list_users）查看用户列表
6、这个可以用新建的用户进行登录了，登录之后的界面如下
7、下面开始介绍java中使用，首先java项目中添加依赖jar包<dependency> <groupId>com.rabbitmq</group朐袁噙岿Id> <artifactId>amqp-client</artifactId> <version>3.6.0</version> </dependency>
8、添加消息生产者，代码如下package cn.sw.study.common.test.rabbitmq;import com.rabbit罪焐芡拂mq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;/*** 消息生产者* Created by shaowei on 2017/8/17.*/public class MsgProducter { private final static String QUEUE_NAME = "test"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); // 设置RabbitMQ地址 factory.setHost("127.0.0.1"); // 创建一个新的连接 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("UTF-8")); System.out.println("MsgProducter Sent '" + message + "'"); // 关闭频道和连接 channel.close(); connection.close(); }}
9、添加消息消费者，代码如下package cn.sw.study.common.test.rabbitmq;import com.rabbit罪焐芡拂mq.client.*;import java.io.IOException;/*** 消费者* Created by shaowei on 2017/8/17.*/public class MsgConsumer { private final static String QUEUE_NAME = "test"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); // 设置RabbitMQ地址 factory.setHost("127.0.0.1"); // 创建一个新的连接 Connection connection = factory.newConnection(); // 创建一个频道 Channel channel = connection.createChannel(); // 声明要关注的队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.out.println("MsgConsumer Waiting for messages. To exit press CTRL+C"); // DefaultConsumer类实现了Consumer接口，通过传入一个频道，告诉服务器我们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDelivery 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("MsgConsumer Received '" + message + "'"); } }; // 自动回复队列应答 -- RabbitMQ中的消息确认机制 channel.basicConsume(QUEUE_NAME, true, consumer); }}
10、分别运行生产者和消费者，打印结果如下图，从打印结果中可以看到，消息正常发送和接收到了，说明RabbitMQ正常使用了
