一、SpringAMQP简介

SpringAMQP是基于RabbitMQ封装的一套模板，并且还利用SpringBoot对其实现了自动装配，使用起来非常方便。

SpringAmqp的官方地址：https://spring.io/projects/spring-amqp

SpringAMQP提供了三个功能：

• 自动声明队列、交换机及其绑定关系

• 基于注解的监听器模式，异步接收消息

• 封装了RabbitTemplate工具，用于发送消息

二、SpringAMQP的使用步骤

1.在消息发送者和消费者服务的父工程中导入依赖

<!--AMQP依赖，包含RabbitMQ-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.在消息发送者和消息消费者中配置MQ地址

spring:
  rabbitmq:
    host: 192.168.119.129 # rabbitMQ的ip地址
    port: 5672 # 端口
    username: buliangshuai
    password: 123456
    virtual-host: /

3.编写消息发送类和消息消费类 

在消息发送类服务中编写测试类SpringAmqpTest，并利用RabbitTemplate实现消息发送：

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMessage2SimpleQueue() {
        //队列名称
        String queueName = "simple.queue";
        //消息
        String message = "hello, spring amqp!";
        //发送消息
        rabbitTemplate.convertAndSend(queueName, message);
    }
}

在消息消费服务中新建一个类SpringRabbitListener，代码如下：

@Component
public class SpringRabbitListener {

   @RabbitListener(queues = "simple.queue")
   public void listenSimpleQueue(String msg) {
       System.out.println("消费者接收到simple.queue的消息：【" + msg + "】");
     }
}

三、使用JSON格式来传数据

我们希望消息体的体积更小、可读性更高，因此可以使用JSON方式来做序列化和反序列化。

在消息发送者和消息消费者两个服务中都引入依赖：

<dependency>
    <groupId>com.fasterxml.jackson.dataformat</groupId>
    <artifactId>jackson-dataformat-xml</artifactId>
    <version>2.9.10</version>
</dependency>

配置消息转换器。在启动类中添加一个Bean即可：

@Bean
public MessageConverter jsonMessageConverter(){
    return new Jackson2JsonMessageConverter();
}