rabbitmq Java教程
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</groupId>
<artifactId>amqp-client</artifactId>
<version>3.6.0</version>
</dependency>
8、添加消息生产者，代码如下
package cn.sw.study.common.test.rabbitmq;
import com.rabbitmq.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.rabbitmq.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正常使用了
