# Rabbitmq的使用

1. 添加依赖

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

2. 队列绑定

3. 发送消息

   @RestController
   public class Controller {
   
       private final String routeKey="routeKey";
       @Autowired
       private RabbitTemplate rabbitTemplate;
   
       @GetMapping("/send")
       public String send(String msg) {
           rabbitTemplate.convertAndSend("change", routeKey,msg );
           return "ok";
       }
   
   }
   

   1
   2
   3
   4
   5
   6
   7
   8
   9
   10
   11
   12
   13
   14
   

4. 接受消息

@Component
@Slf4j
public class MqChangeHander {
    @RabbitListener(queues = "test")
    public void ok(@Payload String msg, Channel channel, @Headers Map<String, Object> headers) {
        log.info("receive mg msg = {}", msg);
    }
}