SpringAMQP使用（1）：消息发送

Spring AMQP 是对 Spring 基于 AMQP 的消息收发解决方案，它是一个抽象层，不依赖于特定的 AMQP Broker 实现和客户端的抽象，所以可以很方便地替换。比如我们可以使用 spring-rabbit 来实现。

基本消息队列的消息发送流程：

• 建立connection
• 创建channel
• 利用channel声明队列
• 利用channel向队列发送消息

基本消息队列的消息接收流程：

• 建立connection
• 创建channel
• 利用channel声明队列（生产者与消费者都需要声明队列，是防止队列不存在，重复声明不会影响）
• 定义consumer的消费行为handleDelivery()
• 利用channel将消费者与队列绑定（回调机制，绑定函数但要收到消息才执行）

1、引入SpringAMQP依赖

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

2、配置SpringAMQP

spring:
  rabbitmq:
    host: 170.106.116.159
    port: 5672
    username: badianboke
    password: 123321
    verify-hostname: /

3、编写测试类使用SpringAMQP

package cn.badianboke.mq.spring;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
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 SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void testSendMessage2SimpleQueue(){
        String queueName = "simple.queue";
        String message = "hello, spring amqp";
        rabbitTemplate.convertAndSend(queueName, message);
    }
}