1.Spring-AMQP概念

• 什么是Spring-AMQP
  • Spring框架的AMQP消息解决方案，提供模板化的发送和接收消息的抽象层，提供基于消息驱动的POJO的消息监听等
  • 提供不依赖于任何特定的AMQP代理实现或客户端库通用的抽象，最终用户代码将很容易实现更易替换、添加和删除AMQP，因为它可以只针对抽象层来开发
  • 总之就是提高我们的框架整合消息队列的效率，springboot为更方便开发RabbitMQ推出了starter
  • 我们使用spring-boot-starter-amqp进行开发

2.springboot整合RabbitMQ实战

• 创建web项目，引入依赖

  <!--RabbitMQ AMQP-->
  <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
  </dependency>
  <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  

• yml配置文件

  spring:rabbitmq:host: 192.168.101.128port: 5672virtual-host: /devpassword: Gen123username: admin
  

• RabbitMQConfig文件

  package com.gen.config;import org.springframework.amqp.core.*;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;@Configuration
  public class RabbitMQConfig {public static final String EXCHANGE_NAME = "order_exchange";public static final String QUEUE_NAME = "order_queue";/*** 交换机** @return*/@Beanpublic Exchange orderExchange() {return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();}/*** 队列** @return*/@Beanpublic Queue orderQueue() {return QueueBuilder.durable(QUEUE_NAME).build();}/*** 交换机与队列进行绑定** @param orderQueue* @param orderExchange* @return*/@Beanpublic Binding orderBinding(Queue orderQueue, Exchange orderExchange) {return BindingBuilder.bind(orderQueue).to(orderExchange).with("order.#").noargs();}
  }
  

• 消息生产者-测试类

  package com.gen;import com.gen.config.RabbitMQConfig;
  import org.junit.jupiter.api.Test;
  import org.springframework.amqp.rabbit.core.RabbitTemplate;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
  class GenRabbitmqApplicationTests {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testvoid send() {this.rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, "order.new", "您有新订单");}
  }
  

• 消息消费者

  package com.gen.listener;import com.gen.config.RabbitMQConfig;
  import org.springframework.amqp.core.Message;
  import org.springframework.amqp.rabbit.annotation.RabbitHandler;
  import org.springframework.amqp.rabbit.annotation.RabbitListener;
  import org.springframework.stereotype.Component;@Component
  @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
  public class OrderMQListener {/*** RabbitHandler会自动匹配消息类型（消息自动确认）** @param msg* @param message*/@RabbitHandlerpublic void orderConsumer(String msg, Message message) {System.out.println(msg);System.out.println(message);}
  }