感谢支持
我们一直在努力

RabbitMQ初探

1.  MQ是什么
 
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有IBM WEBSPHERE MQ。
 
2.  MQ的特点
 
MQ的消费-生产者模型的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似,但不同的是JMS是SUN Java消息中间件服务的一个标准和API定义,而MQ则是遵循了AMQP协议的具体实现和产品。
 
3.  使用场景
 
最近在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。
 
4.  RabbitMQ是什么
 
rabbitMQ是一个在AMQP基础上完整的,可服用的企业消息系统。他遵循Mozilla Public License开源协议。
 
5.  RabbitMQ安装
 
5.1) 安装ERLANG

在CentOS上编译安装Erlang R15B http://www.linuxidc.com/Linux/2012-03/57663.htm

在 CentOS 5.7 上通过 YUM 安装 Erlang 过程 http://www.linuxidc.com/Linux/2012-12/75622.htm

CentOS 5.5 下源代码编译安装 Erlang http://www.linuxidc.com/Linux/2011-07/39156.htm
 
首先,因为RabbitMQ由ERLANG实现,下载ERLANG(http://www.erlang.org/download.html)源代码。
 
解压源代码至ERLANG至文件夹$ERLANG
 
安装依赖包:
 
Yum install tk
 
Yun install tcl
 
Yum install unixODBC
 
进入$ERLANG.编译ERLANG
 
./configure –prefix=/usr/local/erlang
 
./make
 
./make install
 
并将erlang bin目录加至PATH
 
5.2) 安装rabbitMQ
 
下载RabbitMQ(http://www.rabbitmq.com/download.html),解压至$RMQ。
 
启动RabbitMQ
 
./bin/rabbitmq-server
 
 
 
6.  编写RabbitMQ生产者客户端
 
package org.corey.mq;
 
 
 
import com.rabbitmq.client.Channel;
 
import com.rabbitmq.client.Connection;
 
import com.rabbitmq.client.ConnectionFactory;
 
import com.rabbitmq.client.ConnectionParameters;
 
import com.rabbitmq.client.MessageProperties;
 
 
 
public class MQTestor {
 
    public static void main(String[] args) throws Exception {
 
      ConnectionParameters params = new ConnectionParameters();
 
      params.setUsername(“guest”);
 
      params.setPassword(“guest”);
 
      params.setVirtualHost(“/”);
 
      params.setRequestedHeartbeat(0);
 
      ConnectionFactory factory = new ConnectionFactory(params);
 
      Connection conn = factory.newConnection(“192.168.1.101”, 5672);
 
      Channel channel = conn.createChannel();
 
      channel.exchangeDeclare(“ex1”, “direct”, true);
 
      channel.queueDeclare(“q1”,true);
 
      channel.queueBind(“q1”, “ex1”, “m1”);
 
      byte[] msg = “hello world”.getBytes();
 
      channel.basicPublish(“ex1”, “m1”, MessageProperties.PERSISTENT_TEXT_PLAIN, msg);
 
      channel.close();
 
      conn.close();
 
    }
 
}
 
 
 
7.  编写消费者客户端
 
ConnectionParameters params = new ConnectionParameters();
 
      params.setUsername(“guest”);
 
      params.setPassword(“guest”);
 
      params.setVirtualHost(“/”);
 
      params.setRequestedHeartbeat(0);
 
      ConnectionFactory factory = new ConnectionFactory(params);
 
      Connection conn = factory.newConnection(“192.168.1.101”, 5672);
 
      Channel channel = conn.createChannel();
 
      GetResponse res=channel.basicGet(“q1”, false);
 
      if(res!=null){
 
          System.out.println(new String(res.getBody()));
 
          channel.basicAck(res.getEnvelope().getDeliveryTag(), false);
 
      }else{
 
          System.out.println(“No message!”);
 
      }
 
8.  RabbitMQ的几个概念
 
Exchange:交换机,决定了消息路由规则;
 
Queue:消息队列;
 
Channel:进行消息读写的通道;
 
Bind:绑定了Queue和Exchange,意即为符合什么样路由规则的消息,将会放置入哪一个消息队列;
 
9.  RabbitMQ消息持久化
 
1)  将交换机置为可持久;
 
2)  将通道置为可持久
 
3)  消息发送时设置可持久。
 
 
当我们“生产”了一条可持久化的消息,尝试中断MQ服务,启动消费者获取消息,消息依然能够恢复。相反,则抛出异常。

CentOS 5.6 安装RabbitMQ http://www.linuxidc.com/Linux/2013-02/79508.htm

RabbitMQ客户端C++安装详细记录 http://www.linuxidc.com/Linux/2012-02/53521.htm

用Python尝试RabbitMQ http://www.linuxidc.com/Linux/2011-12/50653.htm

RabbitMQ集群环境生产实例部署 http://www.linuxidc.com/Linux/2012-10/72720.htm

Ubuntu下PHP + RabbitMQ使用 http://www.linuxidc.com/Linux/2010-07/27309.htm

在CentOS上安装RabbitMQ流程 http://www.linuxidc.com/Linux/2011-12/49610.htm

RabbitMQ 的详细介绍:请点这里
RabbitMQ 的下载地址:请点这里

本文永久更新链接地址:http://www.linuxidc.com/Linux/2014-06/103384.htm

赞(0) 打赏
转载请注明出处:服务器评测 » RabbitMQ初探
分享到: 更多 (0)

听说打赏我的人,都进福布斯排行榜啦!

支付宝扫一扫打赏

微信扫一扫打赏