SpringBoot怎樣整合RabbitMQ？ | 帶你讀《SpringBoot實戰教程》之三十六

上一篇：SpringBoot怎樣整合ActiveMQ？ | 帶你讀《SpringBoot實戰教程》之三十五 下一篇：Kafka概述及安裝 | 帶你讀《SpringBoot實戰教程》之三十七

本文來自于千鋒教育在阿裡雲開發者社群學習中心上線課程《SpringBoot實戰教程》，主講人楊紅豔，

點選檢視視訊内容

。

SpringBoot整合RabbitMQ

添加相應依賴：

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

全局配置：

spring.application.name=sbrabbitmq
spring.rabbitmq.addresses=192.168.25.129:5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin
spring.rabbitmq.publisher-confirms=true           

建立消息發送接收包：com.qianfeng.mq

@Component
public class MySender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {

      this.rabbitTemplate.convertAndSend("hel", "你好！！！");
      return "發送成功";
    }
}

@Component
public class MyReceiver {

    @RabbitHandler
    @RabbitListener(queues="hel")
    public void receive(String text) {
        System.out.println("收到消息："+text);
    }
}           

建立com.qianfeng.controller：

@Controller
public class TestController {

    @Autowired
    private MySender mySender;

    @RequestMapping("/send")
    @ResponseBody
    public String test() {

        mySender.send();
        return "ok";
    }
}           

在啟動類中添加所有需要掃描的包：

@SpringBootApplication(scanBasePackages="com.qianfeng")           

執行結果：

配套視訊