RabbitMQ使用实践

RabbitMQ使用实践

参考网站：

http://blog.chinaunix.net/topic/surpershi/

http://blog.csdn.net/lwkcn/article/details/25086467

http://snoopyxdy.blog.163.com/blog/static/60117440201352615631930/

1、简介

MQ（Message Queue）消息队列，用于应用系统解耦、消息异步分发。

RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。

其优点如下。

1)Reliability-可靠性高。

2)Flexible Routing-路由灵活。

3)Clustering-支持集群。

4)Federation-支持互联。

5)Tracing-便于追踪。

本文档是关于RabbitMQ的安装与使用实践。

实践环境：Window7 x64系统。

2、Erlang安装

RabbitMQ由ERLANG实现，故需要安装Erlang。

1)下载Erlang

下载官网：http://www.erlang.org/download.html。

实践安装版本：otp_win32_17.4.exe。

2)安装Erlang

运行Exe按照提示一路Next安装下来。

3)配置Erlang

本机安装目录：C:\Program Files (x86)\erl6.3。

环境变量Path中添加C:\Program Files (x86)\erl6.3\bin。

4)检测Erlang

命令行中输入erl命令可检测Erlang是否安装成功。

3、RabbitMQ安装

对应RabbitMQ的版本为V3.4.3。

1)下载RabbitMQ

对应官网：http://www.rabbitmq.com/download.html。

下载安装包：rabbitmq-server-3.4.3.exe。

2)安装RabbitMQ

运行Exe，一路Next安装完毕。

3)安装完成查看

4、RabbitMQ启动

1)启动管理插件

运行RabbitMQ Command Prompt(sbin dir)。

输入rabbitmq-plugins enable rabbitmq_management，启动管理插件。

2)启动管理服务

运行RabbitMQ Service - start。

3)登录管理界面

浏览器输入：http://localhost:15672/#/。

用户名：guest，密码guest。

5、消息发送代码

示例代码采用Java，对应IDE为Eclipse。

Java需要用到RabbitMQ的jar包。

jar包下载地址：http://www.rabbitmq.com/java-client.html。

对应版本与Rabbit Server一致V3.4.3。

发送代码见Send.java。

import java.io.IOException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;  

public class Send {
    private final static String QUEUE_NAME = "rabbit";

    public static void main(String[] args) throws IOException {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
        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);
        String message = "Hello Rabbit!";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
        System.out.println(" [x] Sent '" + message + "'");

        channel.close();
        connection.close();
    }
}

运行结束结果。

打印出： [x] Sent ‘Hello Rabbit!‘。

进入管理界面，可以看到已经创建了一个名叫rabbit的消息队列，，消息Ready标志为1。

6、消息接受代码

对应程序代码Recv.java。

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;  

public class Reqv {
    private final static String QUEUE_NAME = "rabbit";

    public static void main(String[] argv) throws 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);
        QueueingConsumer consumer = new QueueingConsumer(channel);
        channel.basicConsume(QUEUE_NAME, true, consumer);

        while (true) {
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            String message = new String(delivery.getBody());
            System.out.println(" [x] Received '" + message + "'");
        }
    }
}

运行结果，打印如下。

[x] Received ‘Hello Rabbit!‘

进入管理端界面查看，消息Ready标志为0。

7、总结

通过实践，感觉RabbitMQ简单易用，支持消息的异步发送，可以解耦两个强关联的应用系统。