SpringBoot怎样整合RabbitMQ? | 带你读《SpringBoot实战教程》之三十六-阿里云开发者社区

开发者社区> 开发者学习资源库> 正文

SpringBoot怎样整合RabbitMQ? | 带你读《SpringBoot实战教程》之三十六

简介: 本节介绍了SpringBoot集成RabbitMQ实现消息的发送,接收。

上一篇: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")

执行结果:
image.png
image.png

配套视频

版权声明:本文中所有内容均属于阿里云开发者社区所有,任何媒体、网站或个人未经阿里云开发者社区协议授权不得转载、链接、转贴或以其他方式复制发布/发表。申请授权请邮件developerteam@list.alibaba-inc.com,已获得阿里云开发者社区协议授权的媒体、网站,在转载使用时必须注明"稿件来源:阿里云开发者社区,原文作者姓名",违者本社区将依法追究责任。 如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:developer2020@service.aliyun.com 进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:

开发者免费资源中心,技术电子书、会议PPT、论文资料持续供应中

官方博客
官网链接