前面两篇文章windows下RabbitMQ的使用(1)——下载与安装windows下RabbitMQ的使用(2)——安装插件与创建队列RabbitMQ的版本号是4.3.0。在整合之前需要知道一些名词和工作模式。RabbitMQ 就像是一个超级邮差兔不过它不送胡萝卜专门传递消息想象一下• 交换机Exchange邮局的分拣中心负责把信件分到正确的路线• 队列Queue你的专属邮箱消息就在这里等你来取• ️路由键Routing Key信封上的地址标签• 消息Message你要传递的包裹可以是任何数据这只“兔子”有四种工作模式Hello World模式简单直接像扔飞盘一样Work Queues 模式多个工人抢活干卷起来了Publish/Subscribe 模式广播模式一人说话全村听见Routing Topics 模式智能分发精准投喂本文介绍一下如何使用Spring Boot集成RabbitMQ。IDEA版本: 2026.1JDK17Spring Boot3.xRabbitMQ4.3.0先启动RabbitMQ注意本文使用一个Spring Boot项目同时创建生产者和消费者有的项目会用不同的Spring Boot项目创建不同的角色本文为了简单起见使用一个Spring Boot项目同时创建生产者和消费者。1.创建Spring Boot项目打开IDEA,点击“文件”—“新建”——“项目”这里选“Spring Boot”类型然后输入项目的名称语言选“Java”构建类型选“Maven”版本都选17。打包方式选“Jar”配置文件选“YAML”如果没有这个选项问题不大 后期可以自己创建或者你使用“Properties”方式也行。这里的Spring Boot版本号写3.x版本然后往下拉找到Web选项选择“Spring Web”然后点击创建注意要保证maven配置正确创建完毕后默认如下2.构建过程2.1 增加依赖第一步需要添加RabbitMQ的相关依赖!-- SpringBoot 整合 RabbitMQ 核心启动器 --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependencyspring-boot-starter-amqp是Spring Boot 连接 RabbitMQ 的官方工具。可以快速在 Spring Boot 中使用 RabbitMQ提供自动配置和注解支持。我们打开pom.xml文件将上面的依赖填写上填写上以后可以点击下图的“1”处。或者点击“A”,再点击“B”处刷新一下更新依赖。我的pom.xml文件参考如下?xml version1.0 encodingUTF-8?projectxmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.5.14/versionrelativePath/!-- lookup parent from repository --/parentgroupIdcom.guo/groupIdartifactIdRabbitMQ-demo1/artifactIdversion0.0.1-SNAPSHOT/versionnameRabbitMQ-demo1/namedescriptionRabbitMQ-demo1/descriptionurl/licenseslicense//licensesdevelopersdeveloper//developersscmconnection/developerConnection/tag/url//scmpropertiesjava.version17/java.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!-- SpringBoot 整合 RabbitMQ 核心启动器 --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project2.2 修改配置文件修改application.yaml文件增加下面的配置#RabbitMQ 相关配置rabbitmq:host:localhostport:5672username:guestpassword:guest增加完后配置文件如下所示2.3 增加配置类我们在创建一个config文件夹用来存放配置类右击文件夹名字选择“新建—软件包”输入的内容参考下面com.guo.config然后按回车。然后继续右击“config”文件夹选择“新建—Java类”类名输入 RabbitConfig然后按下回车。参考代码如下importorg.springframework.amqp.core.Queue;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;ConfigurationpublicclassRabbitConfig{// 统一队列名publicstaticfinalStringHELLO_QUEUEtestMQ;BeanpublicQueuehelloQueue(){// 简单持久化关闭、hello 标准模式returnnewQueue(HELLO_QUEUE,false);}}这里需要注意的是队列的名字是testMQ这对应我们前面文章中创建的队列的名字如果你使用RabbitMQ创建的队列不是这个名字请一定要统一队列的名字。2.4 增加消费者需要先增加一个文件夹名字是consumer跟刚才的config是同级所以参考下图右击文件夹点击“新建”—“软件包”com.guo.consumer输入后按回车确定。右击consumer文件夹选择“新建”—“Java类”这里消费者的类名为HelloConsumer输入后按回车。参考代码如下importcom.guo.config.RabbitConfig;importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;ComponentpublicclassHelloConsumer{RabbitListener(queuesRabbitConfig.HELLO_QUEUE)publicvoidreceive(Stringmessage){System.out.println(【消费者收到】message);}}2.5 修改启动类打开启动类在上面增加一行注解ComponentScan(basePackagescom.guo)// 扫描com.guo下的所有包注意com.guo改成你实际的包名。然后点击小三角点击“调试xxx” 来启动主程序。这样就能启动消费者来进行监听了。2.6 修改测试类打开默认的测试类增加下面的代码AutowiredprivateRabbitTemplaterabbitTemplate;TestvoidsendHelloMsg()throwsInterruptedException{StringmsgHello World RabbitMQ;rabbitTemplate.convertAndSend(RabbitConfig.HELLO_QUEUE,msg);System.out.println(【测试生产者发送完成】msg);}增加完后代码如下然后点击运行测试方法“sendHelloMsg()”运行测试类后可以在测试类的控制台看到下面发送提示。2.7 查看测试效果根据上面的图我们点击上图中绿色的部分 切换到主程序的控制台就可以看到在主程序中的消费者收到了消息。本文参考代码(1) 百度网盘通过网盘分享的文件RabbitMQ-demo1.zip链接: https://pan.baidu.com/s/1Rj2o8EpGG5pTplsF1lbrfg?pwdmf6d 提取码: mf6d2夸克网盘我用夸克网盘给你分享了「RabbitMQ-demo1.zip」点击链接或复制整段内容打开「夸克APP」即可获取。/62ed3b5dfO链接https://pan.quark.cn/s/7e408612f087?pwdfeYM提取码feYM