SpringBoot 引入使用消息队列RabbitMQ通信配置连接无路由模式

news2024/11/24 11:46:58

介绍

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

依赖

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

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

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

创建队列

在这里插入图片描述

配置RabbitMQ连接

application.yml

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

生产者发送消息

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

消息消费者

这是异步的

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