大家好，又见面了，我是你们的朋友全栈君。
RabbitMQ简介
RabbitMQ是一个受欢迎的消息代理，通常用于应用程序之间或者程序的不同组件之间通过消息来进行集成。具有高可用高并发的优点，适合集群服务器。采用 Erlang实现, 对主要的编程语言都有客户端支持。
RabbitMQ环境配置
linux下环境配置
我用的是centos 6.5版本。
先从这个地址下载安装包
下载地址
代码语言：javascript复制$ tar -zxvf otp_src_18.3.tar.gz
$ cd otp_src_18.3
$ ./configure --prefix=/usr/local/erlang --with-ssl -enable-threads -enable-smmp-support -enable-kernel-poll --enable-hipe --without-javac
$ make
$ sudo make install配置环境变量
vim /etc/profile
在文件末尾添加下面文字:
代码语言：javascript复制ERLANG_HOME=/usr/local/erlang
PATH=$ERLANG_HOME/bin:$PATH
export ERLANG_HOME
export PATH使环境变量生效
代码语言：javascript复制source /etc/profile然后下载RabbitMQ，下载地址
先安装依赖
代码语言：javascript复制$ sudo yum install xmlto$ xz -d rabbitmq-server-generic-unix-3.6.1.tar.xz
$ tar -xvf rabbitmq-server-generic-unix-3.6.1.tar
# 移动目录
$ sudo cp -rf ./rabbitmq_server-3.6.1/ /usr/local/
$ cd /usr/local
#改名字
$ mv rabbitmq_server-3.6.1 rabbitmq-3.6.1
# 安装web管理插件
$ cd sbin/
$ ./rabbitmq-plugins enable rabbitmq_management启动和关闭服务
代码语言：javascript复制$ ./rabbitmq-server
# 后台启动
$ ./rabbitmq-server -detached
# 关闭
$ ./rabbitmqctl stop登录web管理端
启动rabbitmq,然后浏览器输入 http://10.0.0.221:15672/
这个ip地址是你实际安装的主机的ip，请根据实际情况修改。
下面配置登录账号
代码语言：javascript复制$ ./rabbitmqctl add_user pony 123456
Creating user "pony" ...
$ ./rabbitmqctl set_user_tags pony administrator
Setting tags for user "pony" to [administrator] ...刷新下，用刚才创建的账号登录，如下:
有一点要注意，如果主机配有防火墙，要把用到的端口都打开
代码语言：javascript复制-A INPUT -p tcp -m state --state NEW -m tcp --dport 15672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 25672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 5672 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 4369 -j ACCEPT
-A INPUT -p tcp -m state --state NEW -m tcp --dport 5671 -j ACCEPTwindows下环境配置
erlang下载地址
rabbitmq下载地址
可以根据需要下载自己所需要的版本，我这里下载的分别是:
otp_win64_18.3.exe和rabbitmq-server-3.6.9.exe
默认方式安装otp_win64_18.3.exe，完成后，配置环境变量
代码语言：javascript复制ERLANG_HOME C:Program Fileserl7.3添加到PATH
代码语言：javascript复制%ERLANG_HOME%bin;默认方式安装rabbitmq-server-3.6.9.exe，完成后，配置环境变量
代码语言：javascript复制RABBITMQ_SERVER C:Program FilesRabbitMQ Serverrabbitmq_server-3.6.9添加到PATH
代码语言：javascript复制%RABBITMQ_SERVER%sbin;进入sbin目录打开一个控制台，安装web管理插件
代码语言：javascript复制C:Program FilesRabbitMQ Serverrabbitmq_server-3.6.9sbin>rabbitmq-plugins.bat enable rabbitmq_management然后重启下服务使上面的配置生效(注意这里要使用管理员打开cmd命令行，路径无影响)，
代码语言：javascript复制C:WINDOWSsystem32>net stop RabbitMQ && net start RabbitMQ
RabbitMQ 服务正在停止.
RabbitMQ 服务已成功停止。
RabbitMQ 服务正在启动 .
RabbitMQ 服务已经启动成功。
C:WINDOWSsystem32>打开浏览器，输入http://localhost:15672/，可以正常访问。由于我是在本机安装，所以这里是localhost。
接下来配置一个账号并赋予管理员权限(当然要确保是启动状态)，
代码语言：javascript复制C:Program FilesRabbitMQ Serverrabbitmq_server-3.6.9sbin>rabbitmqctl.bat add_user pony 123456
Creating user "pony" ...
C:Program FilesRabbitMQ Serverrabbitmq_server-3.6.9sbin>rabbitmqctl.bat set_user_tags pony administrator
Setting tags for user "pony" to [administrator] ...在web端用这个账号登录，可以成功！
java调用示例
我的开发环境是myeclipse win10，windows环境下已经按照前面章节配置好了rabbitmq服务。**然后保持启动状态。**java要使用rabbitmq需要依赖一个客户端。下载地址
如果用maven的话就不用下载，配置文件加上依赖描述即可。
我这里新建两个工程，分别为RabbitMQDemo-P(表示生产者)和RabbitMQDemo-C(表示消费者)，两个工程运行起来后就代表两个独立的进程通过消息队列通信。生产者不断的往消息队列发送消息，而消费者不断的从队列取消息。工程中导入前面下载的客户端依赖包。
源码来自:rabbitmq-tutorials
eclipse工程源码下载地址
先生产者的代码:
代码语言：javascript复制private final static String QUEUE_NAME = "hello";
public static void main(String[] args) throws Exception{
// TODO Auto-generated method stub
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");//因为两个进程在同一个机器上
Connection connection = null;
Channel channel = null;
connection = factory.newConnection();
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(" [Producer] Sent '" message "'");
channel.close();
connection.close();
}比较简单，涉及到的API具体说明可以自行搜索学习。运行一次就往名为hello的队列上发布一条消息:“Hello World”，然后进程结束。
消费者稍微复杂一点，
代码语言：javascript复制private final static String QUEUE_NAME = "hello";
public static void main(String[] args) 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");
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(" [Consumer] Received '" message "'");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
}Channel.basicConsume方法将Consumer与消息队列绑定,它的定义如下:
代码语言：javascript复制String basicConsume(String queue, boolean autoAck, Consumer callback) throws IOException 第一个参数是Consumer绑定的队列名，第二个参数是自动确认标志，如果为true，表示Consumer接受到消息后，会自动发确认消息(Ack消息)给消息队列，消息队列会将这条消息从消息队列里删除，第三个参数就是Consumer对象，用于处理接收到的消息。
第三个参数其实是个回调，当消费者收到消息时，会调用Consumer对象的handleDelivery方法。我们这里重写了这个方法，收到消息之后打印出来。
先运行消费者，如下:
代码语言：javascript复制 [*] Waiting for messages. To exit press CTRL C开始等待消息。
再运行生产者，如下:
代码语言：javascript复制 [Producer] Sent 'Hello World!'再次看下消费者的控制台信息，接收到消息:
代码语言：javascript复制 [*] Waiting for messages. To exit press CTRL C
[Consumer] Received 'Hello World!'版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
