关键词：
前言
本文通过实战代码，Spring整合RabbitMQ，项目分二个模块，consumer和produle。
提示：以下是本篇文章正文内容，下面案例可供参考
一、项目代码
1.生产者
1.项目架构图：
代码如下（示例）：
2.pom.xml依赖：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.sky</groupId>
<artifactId>spring-rabbitmq-produle</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>2.1.8.RELEASE</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
3.spring-rabbitmq-producer.xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
https://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
<!--加载配置文件-->
<context:property-placeholder location="classpath:rabbitmq.properties"/>
<!-- 定义rabbitmq connectionFactory -->
<rabbit:connection-factory id="connectionFactory" host="$rabbitmq.host"
port="$rabbitmq.port"
username="$rabbitmq.username"
password="$rabbitmq.password"
virtual-host="$rabbitmq.virtual-host"/>
<!--定义管理交换机、队列-->
<rabbit:admin connection-factory="connectionFactory"/>
<!--定义持久化队列，不存在则自动创建；不绑定到交换机则绑定到默认交换机
默认交换机类型为direct，名字为：""，路由键为队列的名称
-->
<!--
id：bean的名称
name：queue的名称
auto-declare:自动创建
auto-delete:自动删除。 最后一个消费者和该队列断开连接后，自动删除队列
durable：是否持久化
-->
<rabbit:queue id="spring_queue" name="spring_queue" auto-declare="true"/>
<!-- ~~~~~~~~~~~~~~~~~~~~~~~~~~~~广播；所有队列都能收到消息~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
<!--定义广播交换机中的持久化队列，不存在则自动创建-->
<rabbit:queue id="spring_fanout_queue_1" name="spring_fanout_queue_1" auto-declare="true"/>
<!--定义广播交换机中的持久化队列，不存在则自动创建-->
<rabbit:queue id="spring_fanout_queue_2" name="spring_fanout_queue_2" auto-declare="true"/>
<!--定义广播类型交换机；并绑定上述两个队列-->
<rabbit:fanout-exchange id="spring_fanout_exchange" name="spring_fanout_exchange" auto-declare="true">
<rabbit:bindings>
<rabbit:binding queue="spring_fanout_queue_1" />
<rabbit:binding queue="spring_fanout_queue_2"/>
</rabbit:bindings>
</rabbit:fanout-exchange>
<!-- 定义队列-->
<rabbit:queue id="spring_direct_queue" name="spring_direct_queue" auto-declare="true"/>
<!--
定义 Routing 路由模式 交互机
-->
<rabbit:direct-exchange name="spring_direct_exchange" >
<rabbit:bindings>
<!--direct 类型的交换机绑定队列 key ：路由key queue：队列名称-->
<rabbit:binding queue="spring_direct_queue" key="direct"></rabbit:binding>
</rabbit:bindings>
</rabbit:direct-exchange>
<!-- ~~~~~~~~~~~~~~~~~~~~~~~~~~~~通配符；*匹配一个单词，#匹配多个单词 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
<!--定义广播交换机中的持久化队列，不存在则自动创建-->
<rabbit:queue id="spring_topic_queue_one" name="spring_topic_queue_one" auto-declare="true"/>
<!--定义广播交换机中的持久化队列，不存在则自动创建-->
<rabbit:queue id="spring_topic_queue_two" name="spring_topic_queue_two" auto-declare="true"/>
<!--定义广播交换机中的持久化队列，不存在则自动创建-->
<rabbit:queue id="spring_topic_queue_three" name="spring_topic_queue_three" auto-declare="true"/>
<!--
声明 topic 类型的交换机
-->
<rabbit:topic-exchange id="spring_topic_exchange" name="spring_topic_exchange" auto-declare="true">
<rabbit:bindings>
<rabbit:binding pattern="one.*" queue="spring_topic_queue_one"/>
<rabbit:binding pattern="two.#" queue="spring_topic_queue_two"/>
<rabbit:binding pattern="three.#" queue="spring_topic_queue_three"/>
</rabbit:bindings>
</rabbit:topic-exchange>
<!--定义rabbitTemplate对象操作可以在代码中方便发送消息-->
<rabbit:template id="rabbitTemplate" connection-factory="connectionFactory"/>
</beans>
4.rabbitmq.properties：
rabbitmq.host=110.42.239.246
rabbitmq.port=5672
rabbitmq.username=guest
rabbitmq.password=guest
rabbitmq.virtual-host=spring
说明：这里免费提供rabbitmq连接方式给大家使用学习
5.ProducerTest：
package com.sky.springrabbitmqprodule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring-rabbitmq-producer.xml")
public class ProducerTest
@Autowired
private RabbitTemplate rabbitTemplate;
/**
* 简单模式发消息
*/
@Test
public void testHelloWorld()
rabbitTemplate.convertAndSend("spring_queue","hello world spring....");
/**
* 广播模式发消息
*/
@Test
public void testFanout()
rabbitTemplate.convertAndSend("spring_fanout_exchange","","spring fanout....");
/**
* 路由模式发消息
*/
@Test
public void testDirect()
rabbitTemplate.convertAndSend("spring_direct_exchange","direct","spring Direct....");
/**
* 通配符模式发消息
*/
@Test
public void testTopics()
rabbitTemplate.convertAndSend("spring_topic_exchange","one.onekey","spring topic one....");
rabbitTemplate.convertAndSend("spring_topic_exchange","two.twokey.topic","spring topic two....");
rabbitTemplate.convertAndSend("spring_topic_exchange","three.threekey.topic","spring topic three....");
2.消费者
1.项目架构图
代码如下（示例）：
2.pom.xml依赖：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.sky</groupId>
<artifactId>spring-rabbitmq-consumer</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>2.1.8.RELEASE</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
3.spring-rabbitmq-consumer.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
https://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
<!--加载配置文件-->
<context:property-placeholder location="classpath:rabbitmq.properties"/>
<!-- 定义rabbitmq connectionFactory -->
<rabbit:connection-factory id="connectionFactory" host="$rabbitmq.host"
port="$rabbitmq.port"
username="$rabbitmq.username"
password="$rabbitmq.password"
virtual-host="$rabbitmq.virtual-host"/>
<!--简单模式-->
查看详情
万字长文图文详解springboot集成rabbitmq（直连模式，工作队列模式，发布订阅模式，路由模式，通配符模式）(代码片段)
文章目录前言一、集成步骤一、生产者：二、消费者：二、实现步骤1.项目架构图2.创建项目1.pom依赖2.application.properties配置3.config配置HelloWorldConfigFanoutConfigWorkConfigDirectConfigTopicConfig4.消费端component5.生产者controller三、演示... 查看详情
近九万字图文详解rabbitmq(代码片段)
...验。博主：java_wxid社区：幕后大佬文章目录一、RabbitMQ的基本概念，以及6种工作模式，消息确认机制二、6种工作模式一、理论二、代码三、消息确认机制：confirm状态和return状态一、理论二、代码二、Spring整合... 查看详情
mq4万字保姆教程|rabbitmq知识点整理与springboot整合附demo（图文并茂）(代码片段)
...读【4万字保姆级教程】本文详细的从应用层面上讲解了RabbitMQ的使用以及整合Springboot；对于其概念进行讲解，提供了可以完成日常开发的接口与demo；文章目录导读工作队列1.workQueues轮询分发消息2.消息应答概念自动... 查看详情
vector的底层实现！（万字长文详解！）(代码片段)
vector的底层简单实现！vector的成员变量template<classT>classvectortypedefT*iterator;//迭代器 typedefconstT*const_iterator;private: iterator_start; iterator_finish; iterator_endofstorage;;reservevoidreserve(size_ 查看详情
万字长文详解hivesql执行计划(代码片段)
HiveSQL的执行计划描述SQL实际执行的整体轮廓，通过执行计划能了解SQL程序在转换成相应计算引擎的执行逻辑，掌握了执行逻辑也就能更好地把握程序出现的瓶颈点，从而能够实现更有针对性的优化。此外还能帮助开发者识别看... 查看详情
万字长文书写rabbitmq最全见解！以后再也不用到处去搜索了呀！(代码片段)
典型应用场景1、跨系统的异步通信人民银行二代支付系统，使用重量级消息队列IBMMQ，异步，解耦，削峰都有体现。2、应用内的同步变成异步秒杀：自己发送给自己3、基于Pub/Sub模型实现的事件驱动放款失败... 查看详情
万字长文详解hivesql执行计划(代码片段)
HiveSQL的执行计划描述SQL实际执行的整体轮廓，通过执行计划能了解SQL程序在转换成相应计算引擎的执行逻辑，掌握了执行逻辑也就能更好地把握程序出现的瓶颈点，从而能够实现更有针对性的优化。可以说执行计划... 查看详情
万字长文详解yolov1-v5系列模型(代码片段)
一，YOLOv1Abstract1.Introduction2.UnifiedDetectron2.1.NetworkDesign2.2Training2.4.Inferences4.1ComparisontoOtherReal-TimeSystems5，代码实现思考二，YOLOv2摘要YOLOv2的改进1，中心坐标位置预测的改进2，1个gird只能对应一个目标的改进3，backbone的改进4， 查看详情
c语言学习笔记-入门整合篇(十万字长文)(代码片段)
（该篇学习内容全部来自于C语言中文网,本篇内容仅仅是简易学习笔记,以自己的理解+网站部分描述结合+个人补充，并不适合编程初学者观看!!!需要有一定的编程基础）数据在内存中存储内存条包含了上亿个电... 查看详情
2万字长文深入详解kafka，从源码到架构全部讲透(代码片段)
????????关注后回复 “进群” ，拉你进程序员交流群????????作者：erainmhttps://blog.csdn.net/eraining/article/details/115860664- 消息队列的核心价值 - 解耦合。异步处理例如电商平台，秒杀活动。一般流程会分为：1: 风... 查看详情
c++知识分享：socket编程详解，万字长文(代码片段)
介绍Socket编程让你沮丧吗？从manpages中很难得到有用的信息吗？你想跟上时代去编Internet相关的程序，但是为你在调用connect()前的bind()的结构而不知所措？等等…好在我已经将这些事完成了，我将和所有人共... 查看详情
rabbitmq消息队列详解——springboot整合(代码片段)
SpringBoot整合依赖：<!--加入rabbitmq--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>配置 查看详情
万字长文！深入详解java垃圾回收（gc）机制(代码片段)
一、为什么需要垃圾回收如果不进行垃圾回收，内存迟早都会被消耗空，因为我们在不断的分配内存空间而不进行回收。除非内存无限大，我们可以任性的分配而不回收，但是事实并非如此。所以，垃圾回收... 查看详情
flink从入门到精通100篇（二十一）-万字长文详解flink中的copyonwritestatetable
前言现如今想阅读HashMap源码实际上比较简单，因为网上一大堆博客去分析HashMap和ConcurrentHashMap。本文详细分析CopyOnWriteStateTable源码，阅读复杂集合类源码的过程是相当有挑战的，博主在刚开始阅读也遇到很多疑问，最后一一解... 查看详情
leetcode0707.设计链表：c++小详解，万字小长文：分别借助和不借助stl解决(代码片段)
【LetMeFly】707.设计链表：C++小详解，万字小长文：分别借助和不借助STL解决力扣题目链接：https://leetcode.cn/problems/design-linked-list/设计链表的实现。您可以选择使用单链表或双链表。单链表中的节点应该具有... 查看详情
来都来了，你确定不看看，git从零开始的详细使用教程，你一定能学废！！（万字长文图文并茂版！！！！）(代码片段)
Git详细使用教程！！！认识GitWindows安装GitGit环境配置用户名与邮箱地址的设置Git中实用的自定义配置Git忽略某个或某类文件强制添加被忽略的文件偷懒大法：配置别名配置文件Git的基础命令在已存在目录中初始化... 查看详情
万字长文详解大数据应用实战案例-万亿级大数据监控平台建设方案
前言随着互联网业务的迅速发展，用户对系统的要求也越来越高，而做好监控为系统保驾护航，能有效提高系统的可靠性、可用性及用户体验。监控系统是整个运维环节乃至整个项目及产品生命周期中最重要的一环。百分点大数... 查看详情