RabbitMQ入门(一) —— 基本概念

RabbitMQ都安装了好一阵子，但一直没有时间去学习。今天正式开始进入RabbitMQ的学习，通过博文把自己的一些学习心得记录下来，以备以后查阅。由于自己也是从零开始入门，所以这里不会涉及到很深的理论知识，毕竟先要学会如何使用。关于RabbitMQ是什么，有哪些用处，大家可以自行Google。

首先，我们来看一张RabbitMQ最简单的流程图，也是我们平时使用最多的几个组件。


exchange：交换器。RabbitMQ里面有很多交换器，我们也可以创建自己的交换器。当我们向RabbitMQ发送一条消息时，我们必须指定对应的exchange，然后这条消息就会到达我们指定的exchange。
queue：队列。RabbitMQ是一款消息服务器，也称消息队列。我们发送给RabbitMQ的消息最后都会到达各种queue，并且存储在其中(如果路由找不到相应的queue则数据会丢失)，等待消费者来取。
routing key：路由键。用来建立queue和exchange之间的对应关系。当消息到达exchange之后，exchange怎么知道应该把这个消息放到哪个queue呢？其实不同类型的exchange会根据不同的匹配规则去匹配绑定在它身上的routing key，找到了就把这个消息放到routing key对应的queue里。
这三个组件是我们以后用得最多，也是RabbitMQ最基础的组件。在后面的文章中还会有更详细说明。

下面我们来看RabbitMQ官方给我们提供的一个简单的producer-consumer例子，我简单的修改了下，通过这个例子我们可以了解RabbitMQ的基本用法。

package com.jaeger.helloworld;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import org.junit.Test;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

public class HelloWorldTest {
private static final String QUEUE_NAME = "hello_queue";
private static final String HOST = "172.19.64.21";
private static final String USER = "jaeger";
private static final String PASSWORD = "root";
private static final int PORT = 5672;

@Test
public void send() {
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost(HOST);
connectionFactory.setUsername(USER);
connectionFactory.setPassword(PASSWORD);
connectionFactory.setPort(PORT);

try {
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Hello 世界!";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("utf-8"));
System.out.println("Sent '" + message + "'");
channel.close();
connection.close();
} catch (IOException e) {
e.printStackTrace();
} catch (TimeoutException e) {
e.printStackTrace();
}
}

@Test
public void receive() throws InterruptedException {
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost(HOST);
connectionFactory.setUsername(USER);
connectionFactory.setPassword(PASSWORD);
connectionFactory.setPort(PORT);
try {
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
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("Received '" + message + "'");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
Thread.sleep(1000);  //A
} catch (IOException e) {
e.printStackTrace();
} catch (TimeoutException e) {
e.printStackTrace();
}
}
}

我们先运行send方法，向RabbitMQ里添加一条消息，然后查看下RabbitMQ后台，可以看到这条消息已经添加进去了：



我们再运行receive方法，在A处我们让主线程睡眠下，让handleDelivery这个回调方法有机会执行，不然主线程直接结束了，那回调方法都没机会执行。在实际应用中一般consumer都是单开线程一直监听对应queue。下面是结果：






这个例子只是让我们了解下RabbitMQ的基本用法，其中有很多概念这里并没有说明，我在后面的文章中会有讲解。大家如果着急，可以自己先Google。


本文出自 “銅鑼衛門” 博客，请务必保留此出处http://jaeger.blog.51cto.com/11064196/1762756