MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有IBM WEBSPHERE MQ。
目录
1. MQ的特点(opengoss)2. 使用场景3. RabbitMQ是什么4. RabbitMQ安装5. 编写RabbitMQ生产者客户端6. 编写消费者客户端7. RabbitMQ的几个概念8. RabbitMQ消息持久化
1. MQ的特点(opengoss)MQ的消费-生产者模型的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似,但不同的是JMS是SUN JAVA消息中间件服务的一个标准和API定义,而MQ则是遵循了AMQP协议的具体实现和产品。
2. 使用场景最近在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。
3. RabbitMQ是什么rabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。
4. RabbitMQ安装4.1)安装ERLANG
首先,因为RabbitMQ由ERLANG实现,下载ERLANG 源代码。
解压源代码至ERLANG至文件夹$ERLANG
安装依赖包:
Yum install tk
Yum install tcl
Yum install unixODBC
进入$ERLANG.编译ERLANG
./configure –prefix=/usr/local/erlang
./make
./make install
并将erlang bin目录加至PATH
4.2)安装rabbitMQ
下载RabbitMQ ,解压至$RMQ。
启动RabbitMQ
./bin/rabbitmq-server
5. 编写RabbitMQ生产者客户端publicclassMQTestor {
publicstaticvoidmain(String[] args)throwsException {
ConnectionParameters params =newConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory =newConnectionFactory(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();
}
}
6. 编写消费者客户端ConnectionParameters params =newConnectionParameters();
params.setUsername("guest");
params.setPassword("guest");
params.setVirtualHost("/");
params.setRequestedHeartbeat(0);
ConnectionFactory factory =newConnectionFactory(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(newString(res.getBody()));
channel.basicAck(res.getEnvelope().getDeliveryTag(),false);
}else{
System.out.println("No message!");
}
7. RabbitMQ的几个概念Exchange:交换机,决定了消息路由规则;
Queue:消息队列;
Channel:进行消息读写的通道;
Bind:绑定了Queue和Exchange,意即为符合什么样路由规则的消息,将会放置入哪一个消息队列;
8. RabbitMQ消息持久化1) 将交换机置为可持久;
2) 将通道置为可持久
3) 消息发送时设置可持久。
当我们“生产”了一条可持久化的消息,尝试中断MQ服务,启动消费者获取消息,消息依然能够恢复。相反,则抛出异常。