正文 

当前位置： 首页 > 知识 > java教程

万字长文图文详解springboot集成rabbitmq（直连模式，工作队列模式，发布订阅模式，路由模式，通配符模式）(代码片段)

java小丑 java小丑     2023-01-12     278

关键词：

文章目录

前言

提示：Springboot集成Rabbitmq实战案例，通过接口调用的方式演示。

提示：以下是本篇文章正文内容，下面案例可供参考

一、集成步骤

一、生产者：

  1. 创建生产者SpringBoot工程

  2. 引入pom依赖

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

  3. 编写rabbitmq配置消息

  4. 定义交换机，队列以及绑定关系的配置类

  5. 注入RabbitTemplate，调用方法，完成消息发送

二、消费者：

  1. 创建生产者SpringBoot工程

  2. 引入pom依赖

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

  3. 编写rabbitmq配置消息

  4. 定义监听类，使用@RabbitListener注解完成队列监听。

二、实现步骤

1.项目架构图

2.创建项目

代码如下（示例）：

1.pom依赖

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.5</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.sky</groupId>
    <artifactId>springboot-rabbitmq-module</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-rabbitmq-module</name>
    <description>springboot-rabbitmq-module</description>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

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

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

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <finalName>springboot_rabbitmq</finalName>
        <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
            <plugins>
                <plugin>
                    <artifactId>maven-clean-plugin</artifactId>
                    <version>3.1.0</version>
                </plugin>
                <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging -->
                <plugin>
                    <artifactId>maven-resources-plugin</artifactId>
                    <version>3.0.2</version>
                </plugin>
                <plugin>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>3.8.0</version>
                </plugin>
                <plugin>
                    <artifactId>maven-surefire-plugin</artifactId>
                    <version>2.22.1</version>
                </plugin>
                <plugin>
                    <artifactId>maven-war-plugin</artifactId>
                    <version>3.2.2</version>
                </plugin>
                <plugin>
                    <artifactId>maven-install-plugin</artifactId>
                    <version>2.5.2</version>
                </plugin>
                <plugin>
                    <artifactId>maven-deploy-plugin</artifactId>
                    <version>2.8.2</version>
                </plugin>
            </plugins>
        </pluginManagement>
    </build>

</project>

2.application.properties配置

server.port=8080
#spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.addresses=110.42.239.246
spring.rabbitmq.virtual-host=springboot

#spring.rabbitmq.addresses=110.42.239.246:5672,110.42.239.247:5672,110.42.239.248:5672

说明：这里免费提供rabbitmq连接方式给大家使用学习

3.config配置

HelloWorldConfig

package com.sky.springbootrabbitmqmodule.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * HelloWorld rabbitmq课上讲解的第一个工作模式
 * 直连模式只需要声明队列，所有消息都通过队列转发。
 * 无需设置交换机
 */
@Configuration
public class HelloWorldConfig 

	@Bean
	public Queue setQueue() 
		return new Queue("helloWorldqueue");

FanoutConfig

package com.sky.springbootrabbitmqmodule.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Fanout模式需要声明exchange，并绑定queue，由exchange负责转发到queue上。
 * 广播模式 交换机类型设置为：fanout
 */
@Configuration
public class FanoutConfig 

	//声明队列
	@Bean
	public Queue fanoutQ1() 
		return new Queue("fanout.q1");
	
	@Bean
	public Queue fanoutQ2() 
		return new Queue("fanout.q2");
	


	//声明exchange
	@Bean
	public FanoutExchange setFanoutExchange() 
		return new FanoutExchange("fanoutExchange");
	


	//声明Binding,exchange与queue的绑定关系
	@Bean
	public Binding bindQ1() 
		return BindingBuilder.bind(fanoutQ1()).to(setFanoutExchange());
	
	@Bean
	public Binding bindQ2() 
		return BindingBuilder.bind(fanoutQ2()).to(setFanoutExchange());

WorkConfig

package com.sky.springbootrabbitmqmodule.config;



import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class WorkConfig 


    //声明队列
    @Bean
    public Queue workQ1() 
        return new Queue("work_sb_mq_q");

DirectConfig

package com.sky.springbootrabbitmqmodule.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/*
   路由模式|Routing模式   交换机类型：direct
*/
@Configuration
public class DirectConfig 

	//声明队列
	@Bean
	public Queue directQ1() 
		return new Queue("direct_sb_mq_q1");
	
	@Bean
	public Queue directQ2() 
		return new Queue("direct_sb_mq_q2");
	


	//声明exchange
	@Bean
	public DirectExchange setDirectExchange() 
		return new DirectExchange("directExchange");
	

	//声明binding，需要声明一个routingKey
	@Bean
	public Binding bindDirectBind1() 
		return BindingBuilder.bind(directQ1()).to(setDirectExchange()).with("directBind.one");
	
	@Bean
	public Binding bindDirectBind2() 
			return BindingBuilder.bind(directQ2()).to(setDirectExchange()).with("directBind.two");

TopicConfig

package com.sky.springbootrabbitmqmodule.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/*
Topics模式  交换机类型 topic
* */
@Configuration
public class TopicConfig 

	//声明队列
	@Bean
	public Queue topicQ1() 
		return new Queue("topic_sb_mq_q1");
	
	@Bean
	public Queue topicQ2() 
		return new Queue("topic_sb_mq_q2");
	


	//声明exchange
	@Bean
	public TopicExchange setTopicExchange() 
		return new TopicExchange("topicExchange");
	

	//声明binding，需要声明一个roytingKey
	@Bean
	public Binding bindTopicHebei1() 
		return BindingBuilder.bind(topicQ1()).to(setTopicExchange()).with("directBind.*");
	
	@Bean
	public Binding bindTopicHebei2() 
		return BindingBuilder.bind(topicQ2()).to(setTopicExchange()).with("#.two");

4.消费端component

package com.sky.springbootrabbitmqmodule.component;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

@Component
public class ConcumerReceiver 

	//直连模式的多个消费者，会分到其中一个消费者进行消费。类似task模式
	//通过注入RabbitContainerFactory对象，来设置一些属性，相当于task里的channel.basicQos
	@RabbitListener(queues="helloWorldqueue")
	public void helloWorldReceive(String message) 
	     System.out.println("helloWorld模式 received message : " +message);
	

	//工作队列模式
    @RabbitListener(queues="work_sb_mq_q")
    public void wordQueueReceiveq1(String message) 
		System.out.println("工作队列模式1 received message : " +message);
    

    @RabbitListener(queues="work_sb_mq_q")
    public void wordQueueReceiveq2(String message) 
		System.out.println("工作队列模式2 received message : " +message);
    


	//pub/sub模式进行消息监听
	@RabbitListener(queues="fanout.q1")
	public void fanoutReceiveq1(String message) 
	    System.out.println("发布订阅模式1received message : " +message);
	
	@RabbitListener(queues="fanout.q2")
	public void fanoutReceiveq2(String message) 
	    System.out万字长文图文详解spring整合rabbitmq（简单模式，广播模式，路由模式，通配符模式，消息可靠性投递，ttl）(代码片段)

文章目录前言一、项目代码1.生产者1.项目架构图：2.pom.xml依赖：3.spring-rabbitmq-producer.xml：4.rabbitmq.properties：5.ProducerTest：2.消费者1.项目架构图2.pom.xml依赖：3.spring-rabbitmq-consumer.xm  查看详情  

                

springboot使用redistemplatecluster集群的正确姿势（万字图文）


...chaitou/leilema.git）：Redis常见功能Redis高可用分布式Springboot集成RedisTemplate的正确姿势集成Spring  查看详情  

                

vector的底层实现！（万字长文详解！）(代码片段)


vector的底层简单实现！vector的成员变量template<classT>classvectortypedefT*iterator;//迭代器	typedefconstT*const_iterator;private:	iterator_start;	iterator_finish;	iterator_endofstorage;;reservevoidreserve(size_  查看详情  

                

万字长文详解hivesql执行计划(代码片段)


HiveSQL的执行计划描述SQL实际执行的整体轮廓，通过执行计划能了解SQL程序在转换成相应计算引擎的执行逻辑，掌握了执行逻辑也就能更好地把握程序出现的瓶颈点，从而能够实现更有针对性的优化。此外还能帮助开发者识别看...  查看详情  

                

万字长文详解hivesql执行计划(代码片段)


HiveSQL的执行计划描述SQL实际执行的整体轮廓，通过执行计划能了解SQL程序在转换成相应计算引擎的执行逻辑，掌握了执行逻辑也就能更好地把握程序出现的瓶颈点，从而能够实现更有针对性的优化。可以说执行计划...  查看详情  

                

springboot项目集成xxljob全纪录（图文详解）(代码片段)


目录xxljob介绍优点特性如下：代码配置过程1.引入xxl-job的依赖2.编写配置文件3.编写配置类4.新建Job文件夹，将自己写的类放到此文件夹下5.编写业务代码登录xxl-Job并配置1.执行器管理--新增执行器 2.任务管理--新增任务 ...  查看详情  

                

万字长文详解yolov1-v5系列模型(代码片段)


一，YOLOv1Abstract1.Introduction2.UnifiedDetectron2.1.NetworkDesign2.2Training2.4.Inferences4.1ComparisontoOtherReal-TimeSystems5，代码实现思考二，YOLOv2摘要YOLOv2的改进1，中心坐标位置预测的改进2，1个gird只能对应一个目标的改进3，backbone的改进4，  查看详情  

                

2万字长文深入详解kafka，从源码到架构全部讲透(代码片段)


????????关注后回复 “进群” ，拉你进程序员交流群????????作者：erainmhttps://blog.csdn.net/eraining/article/details/115860664-   消息队列的核心价值  - 解耦合。异步处理例如电商平台，秒杀活动。一般流程会分为：1: 风...  查看详情  

                

c++知识分享：socket编程详解，万字长文(代码片段)


 介绍Socket编程让你沮丧吗？从manpages中很难得到有用的信息吗？你想跟上时代去编Internet相关的程序，但是为你在调用connect()前的bind()的结构而不知所措？等等…好在我已经将这些事完成了，我将和所有人共...  查看详情  

                

万字长文！深入详解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的基础命令在已存在目录中初始化...  查看详情  

                

万字长文详解大数据应用实战案例-万亿级大数据监控平台建设方案


前言随着互联网业务的迅速发展，用户对系统的要求也越来越高，而做好监控为系统保驾护航，能有效提高系统的可靠性、可用性及用户体验。监控系统是整个运维环节乃至整个项目及产品生命周期中最重要的一环。百分点大数...  查看详情  

                

近九万字图文详解rabbitmq


文章目录一、RabbitMQ的基本概念，以及6种工作模式，消息确认机制二、6种工作模式一、理论二、代码三、消息确认机制：confirm状态和return状态一、理论二、代码二、Spring整合RabbitMQ（简单模式，广播模式，路由模式，通配符模...  查看详情  

                

「万字图文」史上最姨母级java继承详解(代码片段)


...发周期，降低开发费用。本文分享自华为云社区《「万字图文」史上最姨母级Java继承详解丨【奔跑吧！JAVA】》，原文作者：bigsai。课程导学在Java课堂中，所有老师不得不提到面向对象（ObjectO  查看详情  

                

图文并茂，springbootstarter万字详解。还有谁不会？(代码片段)


一、SpringBoot的starter简介1.1什么是starter（场景启动器）在SpringBoot出现之前，如果我们想使用SpringMVC来构建我们的web项目，必须要做的几件事情如下：首先项目中需要引入SpringMVC的依赖在web.xml中注册SpringMVC的Dis...  查看详情  

                

万字长文基于springboot整合springsecurity的认证授权(角色+权限)真案列有数据库有源码(代码片段)


...权和认证的。嗯后面会讲的，在这之前读者需要具有SpringBoot基础、以及能够使用SpringBoot连接数据库进行操作，源码下载链接在文末先来说说  查看详情