spring boot 中使用 RabbitMQ 教程一 简单的

RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而群集和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。
以上简介来自维基百科。

简单介绍：RabbitMQ是一个消息代理软件，它可以接受和转发消息。你可以把它想象成是一个邮局，当你把一封信放入邮箱，你可以确定邮递员可以把这封信交给收信人。以此类推RabbitMQ就是一个邮局，一个邮箱和一个快递员。与以上不同的是RabbitMQ使用二进制的形式进行数据的接收、储存、转发。用专业术语解释下这个接收、储存、转发。

1. 转发也就是发送，发送是程序的生产者（produce）。
2. 储存（queue）相当于邮箱，生产者发送消息到queue，那么消费者（consumers）也能试着从queue中接收消息。
3. 消费者（consumers）相当于接收，消费者主要等待接收队列中的消息。
   生产者、消费者和代理不必要在同一台服务器上
   生产者->队列->消费者

• 要在spring boot中使用RabbitMQ十分简单，只要引入一个spring-boot-starter-amqp包即可。来这里初始化一个项目。
  

  引入 AMQP

• 其次需要安装RabbitMQ server 具体安装方式请参照官网。点击这里我们走着。开启后是这个样子的。开启后我们就能愉快的撸代码了。
  

  启动 rabbitmq server

接下来我们来完成第一个例子。

• 先配置一个队列，给队列起名字

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/**
 * @author 张博
 */
@Configuration
public class RabbitConfig {
    @Bean
    public Queue dateQueue() {
        return new Queue("date");
    }
    
    @Bean
    public Queue objQueue() {
        return new Queue("object");
    }
}

• 生产者，发送消息。可以看下方法convertAndSend源码。默认使用的交换机类型是direct直连。交换机类型一共四种分别为direct, topic, headers, fanout以后再说。

import com.zb.rabbitMQtest.model.User;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Queue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author 张博
 */
@Component
public class HelloSender {

    @Autowired
    private Queue dateQueue;
    @Autowired
    private Queue objQueue;
    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "now date ".concat(new SimpleDateFormat("yyyy-MM-dd HH:mm:dd").format(new Date()));
        System.out.println("Sender : " + context);
        rabbitTemplate.convertAndSend(dateQueue.getName(), context);
    }

    public void sendObj(User user) {
        System.out.println("Sender : " + user);
        rabbitTemplate.convertAndSend(objQueue.getName(), user);
    }
}

• 消费者，接收消息。注意queues中的值表示你想接受哪个队列中的消息。

import com.zb.rabbitMQtest.model.User;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author 张博
 */
@Component
public class HelloReceiver {

    @RabbitListener(queues = "date")
    public void processDate(String date) {
        System.out.println("Receiver ==================: " + date);
    }

    @RabbitListener(queues = "object")
    public void processObj(User user) {
        System.out.println("Receiver ==================: " + user);
        System.out.println("Receiver ==================: " + user.getName());
        System.out.println("Receiver ==================: " + user.getSex());
    }
}

• application.properties配置文件

spring.application.name=rabbitMQ-test
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

• 编写测试。 User实体我就不放了。记得进行序列化！

import com.zb.rabbitMQtest.model.User;
import com.zb.rabbitMQtest.send.HelloSender;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitMqTestApplicationTests {

    @Autowired
    private HelloSender helloSender;

    @Test
    public void hello() throws Exception {
        helloSender.send();
    }

    @Test
    public void object() throws Exception {
        User user = new User();
        user.setName("张博");
        user.setSex("男");
        helloSender.sendObj(user);
    }
}

• 运行结果

方法1结果
Sender : now date 2018-02-07 23:21:07
Receiver ==================: now date 2018-02-07 23:21:07

方法2结果
Sender : com.zb.rabbitMQtest.model.User@716a7124
Receiver ==================: com.zb.rabbitMQtest.model.User@e2b4d7a
Receiver ==================: 张博
Receiver ==================: 男

怎么样很简单吧，不仅可以传递字符串，也可以轻松传递对象。具体自定义消息转换可以查看。
马上更新 spring boot 中使用 RabbitMQ 二。