docker run \
 -e RABBITMQ_DEFAULT_USER=itcast \
 -e RABBITMQ_DEFAULT_PASS=123321 \
 --name mq \
 --hostname mq1 \
 -p 15672:15672 \
 -p 5672:5672 \
 -d \
 rabbitmq:3-management

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

spring:
  rabbitmq:
    host: ip #（填寫自己的ip）
    port: 5672
    username: itcast
    password: 123321
    virtual-host: /

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {
?
    @Autowired
    private RabbitTemplate rabbitTemplate;
?
    @Test
    public void testSendMessage2SimpleQueue(){
        String queueName = "simple.queue";
        String message = "Hello World!spring amqp!!";
        rabbitTemplate.convertAndSend(queueName, message);
    }
}

 String queueName = "simple.queue";
    String message = "Hello World!spring amqp!!";
    rabbitTemplate.convertAndSend(queueName, message);

spring:
  rabbitmq:
    host: ip
    port: 5672
    username: itcast
    password: 123321
    virtual-host: /

@Component
public class SpringRabbitListener {
    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg){
        System.out.println("消費(fèi)者接收到simple.queue的消息：{"+msg+"}");
    }
}

@Test
public void testSendMessage2WorkQueue() throws InterruptedException {
    String queueName = "simple.queue";
    String message = "Hello World!spring amqp!!__";
    for (int i = 1; i < 50; i++) {
        rabbitTemplate.convertAndSend(queueName, message+i);
        Thread.sleep(20);
    }
}

@RabbitListener(queues = "simple.queue")
public void listenWorkQueue1(String msg) throws InterruptedException {
    System.out.println("消費(fèi)者1接收到simple.queue的消息：{"+msg+"}"+ LocalTime.now());
    Thread.sleep(20);
}
@RabbitListener(queues = "simple.queue")
public void listenWorkQueue2(String msg) throws InterruptedException {
    System.out.println("消費(fèi)者2接收到simple.queue的消息：{"+msg+"}"+ LocalTime.now());
    Thread.sleep(50);
}

@Configuration
public class FanoutConfig {
    //itcast.fanout(交換機(jī))
    @Bean
    public FanoutExchange fanoutExchange(){
        return new FanoutExchange("itcast.fanout");
    }
    //itcast.queue1（隊(duì)列一）
    @Bean
    public Queue fanoutQueue1(){
        return new Queue("fanout.queue1");
    }
    //綁定隊(duì)列1到交換機(jī)
    @Bean
    public Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange){
        return BindingBuilder
                .bind(fanoutQueue1).
                to(fanoutExchange);
    }
    //itcast.queue2（隊(duì)列二）
    @Bean
    public Queue fanoutQueue2(){
        return new Queue("fanout.queue2");
    }
    //綁定隊(duì)列2到交換機(jī)
    @Bean
    public Binding fanoutBinding2(Queue fanoutQueue2, FanoutExchange fanoutExchange){
        return BindingBuilder
               .bind(fanoutQueue2).
                to(fanoutExchange);
    }
}

@RabbitListener(queues = "fanout.queue1")
public void listenFanoutQueue1(String msg){
    System.out.println("消費(fèi)者2接收到fanout.queue1的消息：{"+msg+"}");
}
@RabbitListener(queues = "fanout.queue2")
public void listenFanoutQueue2(String msg){
    System.out.println("消費(fèi)者2接收到fanout.queue2的消息：{"+msg+"}");
}

    @Test
    public void testSendFanoutExchange(){
        //交換機(jī)名稱
        String exchangeName = "itcast.fanout";
        //消息
        String message = "hello,every one!";
        //發(fā)送消息，參數(shù)分別是：交換機(jī)名稱，RoutingKey(暫時(shí)為空)，消息
        rabbitTemplate.convertAndSend(exchangeName, "", message);
    }

@RabbitListener(bindings = @QueueBinding(
        //隊(duì)列
        value = @Queue(name = "direct.queue1"),
        //交換機(jī)
        exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),
        //邦定機(jī)置
        key = {"red","blue"}
))
public void listenDirectQueue1(String msg){
    System.out.println("消費(fèi)者接收到direct.queue1的消息：{"+msg+"}");
}
@RabbitListener(bindings = @QueueBinding(
        //隊(duì)列
        value = @Queue(name = "direct.queue2"),
        //交換機(jī)
        exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),
        //邦定機(jī)置
        key = {"red","yellow"}
))
public void listenDirectQueue2(String msg){
    System.out.println("消費(fèi)者接收到direct.queue2的消息：{"+msg+"}");
}

@Test
public void testSendDirectExchange(){
    //交換機(jī)名稱
    String exchangeName = "itcast.direct";
    //消息
    String message = "hello,blue one!";
    //發(fā)送消息，參數(shù)分別是：交換機(jī)名稱，RoutingKey("red")，消息
    rabbitTemplate.convertAndSend(exchangeName, "red", message);
}

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "topic.queue1"),
        exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),
        key = "china.#"
))
public void listenTopicQueue1(String msg){
    System.out.println("消費(fèi)者接收到topic.queue1的消息：{"+msg+"}");
}
@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "topic.queue2"),
        exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),
        key = "#.news"
))
public void listenTopicQueue2(String msg){
    System.out.println("消費(fèi)者接收到topic.queue2的消息：{"+msg+"}");
}

@Test
public void testSendTopicExchange(){
    //交換機(jī)名稱
    String exchangeName = "itcast.topic";
    //消息
    String message = "中國的新聞!";
    //發(fā)送消息，參數(shù)分別是：交換機(jī)名稱，RoutingKey，消息
    rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
}

<!--rabbitmq使用json序列化-->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

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

@Test
public void testSendObjectQueue(){
    Map<String,Object> msg = new HashMap<>();
    msg.put("name","留言");
    msg.put("age",21);
    rabbitTemplate.convertAndSend("object.queue",msg);
}

<!--rabbitmq使用json序列化-->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

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

@RabbitListener(queues = "object.queue")
public void listenObjectQueue(Map<String,Object> msg){
    System.out.println("消費(fèi)者接收到object.queue的消息：{"+msg+"}");
}