介绍

:::tips BasicQueue简单队列模型就是消息生产者直接把消息发送给队列，且队列中只有一个消息消费者
image.png :::

引入依赖

:::tips 在父工程中引入SpringAMQP的依赖（在消息生产者和消息消费者中都引入依赖） :::

  1. <!-- SpringAMQP依赖 -->
  2. <dependency>
  3.     <groupId>org.springframework.boot</groupId>
  4.     <artifactId>spring-boot-starter-amqp</artifactId>
  5. </dependency>

发送消息

添加配置

:::tips 在消息生产者的配置文件中添加配置 :::

  1. spring:
  2.     rabbitmq:
  3.         #RabbitMQ服务的IP地址
  4.         host: IP地址
  5.         #RabbitMQ服务的端口号
  6.         port: 端口号
  7.         #RabbitMQ的虚拟主机
  8.         virtual-host: /
  9.         #RabbitMQ服务的用户名
  10.         username: 用户名
  11.         #RabbitMQ服务的密码
  12.         password: 密码

编写代码

:::tips 在消息生产者中需要发送消息的类里面注入RabbitTemplate对象，然后调用这个对象的convertAndSend方法（参数一是队列名称，参数二是消息内容）来发送消息 :::

  1. @SpringBootTest
  2. public class MyTest{
  4.     //注入RabbitTemplate对象
  5.     @Autowired
  6.     private RabbitTemplate rabbitTemplate;
  8.     @Test
  9.     public void test() {
  10.         //指定队列名称
  11.         String queueName = "simple.queue";
  12.         //构建消息
  13.         String message = "这是一条测试消息";
  14.         //发送消息
  15.         rabbitTemplate.convertAndSend(queueName, message);
  16.     }
  18. }

接收消息

添加配置

:::tips 在消息消费者的配置文件中添加配置 :::

  1. spring:
  2.     rabbitmq:
  3.         #RabbitMQ服务的IP地址
  4.         host: IP地址
  5.         #RabbitMQ服务的端口号
  6.         port: 端口号
  7.         #RabbitMQ的虚拟主机
  8.         virtual-host: /
  9.         #RabbitMQ服务的用户名
  10.         username: 用户名
  11.         #RabbitMQ服务的密码
  12.         password: 密码

编写代码

:::tips 在消息消费者中新建一个listener包，然后在listener包下创建一个类，类上需要打上@Component注解将其注册到Spring容器中，否则无法接收消息

在这个类里面创建一个方法，方法上打上@RabbitListener注解，用来监听消息

  • 指定@RabbitListener注解的queuesToDeclare属性为@Queue注解
    • 指定@Queue注解的value属性为需要监听的队列名，如果此队列不存在会自动创建

在方法中添加一个形参，形参的类型需要和消息生产者发送消息的类型保持一致，那么这个方法就会持续监听指定队列的消息，如果监听到消息，就会将消息传递给形参 :::

  1. //将这个类注册到Spring容器中
  2. @Component
  3. public class RabbitMqListener{
  5.     //queuesToDeclare属性用于监听指定队列的消息（可以指定多个队列），如果队列不存在会自动创建
  6.     @RabbitListener(queuesToDeclare = @Queue(value = "simple.queue"))
  7.     public void listen(String msg) throws InterruptedException {
  8.         System.out.println("接收到消息：" + msg);
  9.     }
  11. }