介绍

请先对Rabbitmq的用户和权限配置好在进行往下的操作

依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

下面将演示最简单的例子不过路由

生产者 -> 消息队列-> 消费者

创建队列

配置RabbitMQ连接

application.yml

spring:rabbitmq:host: 101.73.160.188port: 5673 #通信端口virtual-host: /csdn #虚拟主机名称username: csdnpassword: 123456

生产者发送消息

java">@RequiredArgsConstructor
@RequestMapping("/record")
@RestController
public class UserController {private  final RabbitTemplate rabbitTemplate;@GetMapping("/putRecord") //插入记录public Result userMessage(){rabbitTemplate.convertAndSend("insert.queue","我是发送者");return  Result.success("操作成功",null);}
}

消息消费者

这是异步的

java">@Component
public class RecordQueues {@RabbitListener(queues ="insert.queue")//insert.queue 为监听的队列名称public  void  insertUserMessage(String msg){ //消息消费System.out.println(msg);//....其他业务逻辑}
}