码迷,mamicode.com
首页 > 其他好文 > 详细

RabbitMQ使用实践

时间:2015-01-28 16:00:20      阅读:373      评论:0      收藏:0      [点我收藏+]

标签:rabbitmq java

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简单易用,支持消息的异步发送,可以解耦两个强关联的应用系统。

RabbitMQ使用实践

标签:rabbitmq java

原文地址:http://blog.csdn.net/segen_jaa/article/details/43230431

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!