RabbitMQ入门，springboot整合RabbitMQ

news2025/1/9 19:27:54

周末的两天没有写文章，因为项目分离出来了一个权限管理平台，花了一点时间整理项目，同时完成了一些功能的开发。

今天这篇文章介绍一下RabbitMQ这个消息中间件，以及通过springboot整合RabbitMQ。

目录

一、初步了解RabbitMQ

二、windows中安装RabbitMQ

三、启动RabbitMQ

四、springboot整合RabbitMQ

1、创建一个springboot项目

2、pom.xml添加以下依赖

3、修改配置文件application.yml

4、新建RabbitMQ的配置类

5、新建消息生产者

6、创建一个消息消费者

7、创建控制器

8、测试发送消息

一、初步了解RabbitMQ

首先，我们找到RabbitMQ的官网，一般官网会有详细的介绍

RabbitMQ官网https://www.rabbitmq.com/点击以下链接访问rabbitmq官网，rabbitmq的图标是一只兔子头，页面的下方都是介绍rabbitmq多么多么厉害，不用看它ovo（主打一个商业吹捧）

我们点击右上方的菜单Features开始我们今天的兔子MQ学习~

 上面介绍了一下RabbitMQ的特性：

1、异步消息传递：

支持多种消息传递协议、消息队列、传递确认、灵活的队列路由、多种交换类型。

2、开发人员经验：

使用 Kubernetes、BOSH、Chef、Docker 和 Puppet 进行部署。使用最喜欢的编程语言开发跨语言消息传递，如 Java、.NET、PHP、Python、JavaScript、Ruby、Go 等： Java、.NET、PHP、Python、JavaScript、Ruby、Go 等。

3、分布式部署：

以集群形式部署，实现高可用性和高吞吐量；跨多个可用区和区域联合部署。

4、企业和云就绪：

可插入式身份验证和授权，支持 TLS 和 LDAP。轻量级，易于在公共云和私有云中部署。

5、工具和插件：

各种工具和插件支持持续集成、运营指标以及与其他企业系统的集成。灵活的插件方法可扩展 RabbitMQ 功能。

6、管理和监控

用于管理和监控 RabbitMQ 的 HTTPAPI、命令行工具和用户界面。

官网的英文看不懂？推荐全世界最准确的翻译：deepl，作为一个程序员，你不会还连这个都不知道吧？赶紧收藏一下网址~

二、windows中安装RabbitMQ

简单的了解RabbitMQ的特性后，点击右上角的菜单Docs开始学习如何使用RabbitMQ吧。

点击红框内的红色字体下载链接 Downloads and Installation下载RabbitMQ；

点击下图中蓝框内的链接分别下载RabbitMQ和erlang，安装RabbitMQ之前需要先完成erlang的安装。

安装过程就不介绍了，一直下一步、下一步就行了。

安装完成后，可以点开我们的安装目录RabbitMQ Server看一下

有个sbin目录，存放的是一些命令工具，etc点开看一下，有一个readme

In this directory you can find an example configuration file for RabbitMQ.

Note that this directory is *not* where the real RabbitMQ configuration lives.

The default location for the real configuration file is %APPDATA%\RabbitMQ\rabbitmq.config.

%APPDATA% usually expands to C:\Users\%USERNAME%\AppData\Roaming or similar.

这个文件内容告诉了我们RabbitMQ的配置文件的位置

C:\Users\%USERNAME%\AppData\Roaming\RabbitMQ\rabbitmq.config

我们访问这个路径C:\Users\%USERNAME%\AppData\Roaming，发现这个目录下确实存放了一个RabbitMQ目录，目录下有一个advanced.config文件。

三、启动RabbitMQ

好了，接下来我们通过命令启动RabbitMQ，在这之前，需要把erlang的安装目录添加到系统的Path环境变量中。

 然后进到RabbitMQ的安装目录下的sbin目录下，在地址栏输入cmd，打开命令窗口

rabbitmq-plugins enable rabbitmq_management

 如图，只要没报错就是启动成功了

接着，我们通过http://localhost:15672 访问RabbitMQ的控制台，这里的用户名/密码都是guest

登陆进去之后，就能看到这样一个页面

四、springboot整合RabbitMQ

1、创建一个springboot项目

创建一个springboot项目，命名为rabbitmq

2、pom.xml添加以下依赖

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

完整的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 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.3.4.RELEASE</version>
        <relativePath/>
    </parent>

    <groupId>com.example</groupId>
    <artifactId>rabbitmq</artifactId>
    <version>0.0.1-SNAPSHOT</version>

    <properties>
        <java.version>1.8</java.version>
        <lombok.version>1.18.22</lombok.version>
    </properties>

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

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

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>${lombok.version}</version>
        </dependency>

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

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3、修改配置文件application.yml

spring:
  application:
    name: rabbitmq
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtual-host: /

server:
  port: 8088

logging:
  level: 
    com.example.rabbitmq: debug

4、新建RabbitMQ的配置类

项目根目录下创建config包，在config包下创建一个类RabbitMQConfig.java

package com.example.rabbitmq.config;

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

/**
 * @author heyunlin
 * @version 1.0
 */
@Configuration
public class RabbitMQConfig {
    // 声明需要使用的交换机/路由Key/队列的名称
    public static final String DEFAULT_EXCHANGE = "exchange";
    public static final String DEFAULT_ROUTE = "route";
    public static final String DEFAULT_QUEUE = "queue";

    // 声明交换机，需要几个声明几个，这里就一个
    @Bean
    public DirectExchange exchange(){
        return new DirectExchange(DEFAULT_EXCHANGE);
    }

    // 声明队列，需要几个声明几个，这里就一个
    @Bean
    public Queue queue(){
        return new Queue(DEFAULT_QUEUE);
    }

    // 声明路由Key(交换机和队列的关系)，需要几个声明几个，这里就一个
    @Bean
    public Binding binding(){
        return BindingBuilder.bind(queue()).to(exchange())
                .with(DEFAULT_ROUTE);
    }

}

5、新建消息生产者

项目根目录下创建producer包，在producer包下创建一个类RabbitProducer.java

package com.example.rabbitmq.producer;

import com.example.rabbitmq.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author heyunlin
 * @version 1.0
 */
@Component
public class RabbitProducer {
    private final RabbitTemplate rabbitTemplate;

    @Autowired
    public RabbitProducer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    /**
     * 发送消息
     * @param message 消息内容
     */
    public void sendMessage(Object message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.DEFAULT_EXCHANGE, RabbitMQConfig.DEFAULT_ROUTE, message);
    }

}

6、创建一个消息消费者

项目根目录下创建consumer包，在producer包下创建一个类RabbitConsumer.java

package com.example.rabbitmq.consumer;

import com.example.rabbitmq.config.RabbitMQConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author heyunlin
 * @version 1.0
 */
@Slf4j
@Component
@RabbitListener(queues = RabbitMQConfig.DEFAULT_QUEUE)
public class RabbitConsumer {

    @RabbitHandler
    public void receive(Object message) {
        log.debug("收到一条消息：{}", message);
    }

}

7、创建控制器

项目根目录下创建controller包，在controller包下创建一个类MessageController.java，把我们刚刚创建的消息生产者依赖进来。

package com.example.rabbitmq.controller;

import com.example.rabbitmq.producer.RabbitProducer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author heyunlin
 * @version 1.0
 */
@RestController
@RequestMapping(path = "/message", produces = "application/json;charset=utf-8")
public class MessageController {
    private final RabbitProducer producer;

    @Autowired
    public MessageController(RabbitProducer producer) {
        this.producer = producer;
    }

    @RequestMapping(value = "/send", method = RequestMethod.POST)
    public void sendMessage(Object message) {
        producer.sendMessage(message);
    }

}

8、测试发送消息

这里可以使用多种方式测试，为了方便起见，使用postman

一测试居然报错了，查看后台报错信息，说是简单的消息转换器只支持String类型和字节数组的消息

我们回到上面，把消息类型的参数都改成String的，改完再测试一下

这一次控制台打印出来了收到消息的日志，至此，springboot整合RabbitMQ完美完成。

文章涉及的代码已同步到gitee，可按需下载

https://gitee.com/he-yunlin/rabbitmq.giticon-default.png?t=N6B9https://gitee.com/he-yunlin/rabbitmq.git

好了，文章就分享到到这里了，创作不易，如果觉得这篇文章对你有所帮助，不要忘了动动你发财的拇指点赞收藏一下哦~

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/787516.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

学Java有哪些就业方向？

学Java有哪些就业方向？

俗话说&#xff1a;男怕入错行&#xff0c;女怕嫁错郎。众所周知&#xff0c;选工作就是选行业&#xff0c;行业和方向选对了&#xff0c;个人的发展就会随着行业风向青云直上&#xff0c;比同龄人更快的积累到财富。那究竟未来什么会是热门行业呢?这个真的很难预测&#xff0…
阅读更多...
【1++的C++初阶】之模板（二）

【1++的C++初阶】之模板（二）

&#x1f44d;作者主页&#xff1a;进击的1 &#x1f929; 专栏链接&#xff1a;【1的C初阶】 文章目录 一&#xff0c;非类型模板参数二&#xff0c;模板特化三&#xff0c;模板分离编译 一&#xff0c;非类型模板参数 模板参数分为类类型模板参数与非类型模板参数。 类类型形…
阅读更多...
【雕爷学编程】Arduino动手做（167）---MG996R金属齿轮舵机2

【雕爷学编程】Arduino动手做（167）---MG996R金属齿轮舵机2

37款传感器与模块的提法&#xff0c;在网络上广泛流传&#xff0c;其实Arduino能够兼容的传感器模块肯定是不止37种的。鉴于本人手头积累了一些传感器和执行器模块&#xff0c;依照实践出真知&#xff08;一定要动手做&#xff09;的理念&#xff0c;以学习和交流为目的&#x…
阅读更多...
苹果“空间音频导航”专利曝光，提供导航指引，跟声音走就对啦?

苹果“空间音频导航”专利曝光，提供导航指引，跟声音走就对啦?

近日&#xff0c;苹果公司成功申请一项专利&#xff0c;该专利名为“空间音频导航”&#xff0c;该专利详细说明了如何利用双耳音频设备&#xff08;AirPods或Apple Vision Pro&#xff09;为用户提供导航指引。 “空间音频导航”是一种模拟声音来源方向和距离的技术&#xff0…
阅读更多...
STM32MP157驱动开发——按键驱动（POLL 机制）

STM32MP157驱动开发——按键驱动（POLL 机制）

文章目录 “POLL ”机制&#xff1a;APP执行过程驱动使用的函数应用使用的函数pollfd结构体poll函数事件类型实现原理 poll方式的按键驱动程序(stm32mp157)gpio_key_drv.cbutton_test.cMakefile修改设备树文件编译测试 “POLL ”机制&#xff1a; 使用休眠-唤醒的方式等待某个…
阅读更多...
c# Outlook检索设定问题

c# Outlook检索设定问题

基于c# 设定outlook约会予定&#xff0c;时间格式是YYYY-MM-DD HH:mm 的情报。 问题发生&#xff1a; 根据开始时间&#xff08;2023/01/01 7:00&#xff09;条件查询该时间是否存在outlook信息时&#xff0c;明明存在一条数据&#xff0c;就是查询不出来数据 c#代码 Strin…
阅读更多...
单源最短路的扩展应用

单源最短路的扩展应用

AcWing 1137. 选择最佳线路 有一天&#xff0c;琪琪想乘坐公交车去拜访她的一位朋友。 由于琪琪非常容易晕车&#xff0c;所以她想尽快到达朋友家。 现在给定你一张城市交通路线图&#xff0c;上面包含城市的公交站台以及公交线路的具体分布。 已知城市中共包含 n 个车站…
阅读更多...
解决 Visual Studio Code 编译器代码自动格式化

解决 Visual Studio Code 编译器代码自动格式化

首先找到.vscode下的settings.json配置文件 将vue3snippets.enable-compile-vue-file-on-did-save-code更改为false
阅读更多...
多个HttpSecurity配置（局部AuthenticationManager）

多个HttpSecurity配置（局部AuthenticationManager）

前言 项目用的ruoyi的扩展版本(ts版本)&#xff0c;如果有缺失类&#xff0c;可以自行下载或补充------》个人理解 实现多端token&#xff0c;多端httpSecurity&#xff0c;并且相互隔离&#xff08;局部AuthenticationManager管理认证及授权&#xff09; 在最近的项目中遇到一…
阅读更多...
[元带你学: eMMC协议 28] eMMC 上电时序 | eMMC 上电指南

[元带你学: eMMC协议 28] eMMC 上电时序 | eMMC 上电指南

依JEDEC eMMC及经验辛苦整理，原创保护，禁止转载。 专栏 《元带你学：eMMC协议》 内容摘要 全文 1500 字， 主要内容 eMMC 上电规范 和 eMMC 上电指南， 这部分内容偏向电气特性，如果不是硬件的同学只要特别浅的了解， 一带而过。 eMMC 上电规范 eMMC 电压 VCCQ指的是接口…
阅读更多...
min_free_kbytes

min_free_kbytes

转自&#xff1a;技术分享 | MemAvailable 是怎么计算的-腾讯云开发者社区-腾讯云 背景 前两天安装 OceanBase 时遇到一个小问题&#xff1a; 很明显&#xff0c;安装OB时要求服务器可用内存至少 8G&#xff0c;不达标就无法安装。为了凑这3台10G内存的服务器我已经费了不少劲…
阅读更多...
springMVC快速入门

springMVC快速入门

springMVC快速入门 简介 MVC是一种软件架构的思想&#xff0c;将软件按照模型、视图、控制器类划分。 M(model)&#xff1a;模型层&#xff0c;指工程中的javaBean,作用是处理数据 javaBean分为两类&#xff1a; 一类称为实体类Bean&#xff08;专门存储业务数据&#xff0c;如…
阅读更多...
unity 控制text根据字数自动扩展大小，并扩展UI背景

unity 控制text根据字数自动扩展大小，并扩展UI背景

需求&#xff1a;文字内容位置保持不变&#xff0c;向下增加&#xff0c;背景框随之同步扩展。 1.UGUI 九宫格 拉伸 对背景框图片资源处理&#xff0c;避免图片拉伸。 (10条消息) unity UGUI 九宫格 拉伸_unity九宫格拉伸_野区捕龙为宠的博客-CSDN博客 2.背景框添加组件 3.…
阅读更多...
Linux 学习记录55(ARM篇)

Linux 学习记录55(ARM篇)

Linux 学习记录55(ARM篇) 本文目录 Linux 学习记录55(ARM篇)一、使用C语言封装GPIO函数1. 封装GPIO组寄存器2. 封装GPIO模式以及相关配置3. 封装GPIO初始化结构体4. 使用自己的封装配置GPIO 一、使用C语言封装GPIO函数 1. 封装GPIO组寄存器 #define GPIOA ((GP…
阅读更多...
断路器分合闸线圈低电压试验

断路器分合闸线圈低电压试验

试验目的 断路器的分、 合闸线圈动作电压是保证断路器有效进行分合闸操作的一项重要参 数, 其分、 合闸电压的大小应符合规程要求。 分闸线圈的最低可靠动作值应在额定电 压的 30% ~ 65% , 合闸线圈的最低可靠动作值应在额定电压的 30% ~ 85% , 才能保证 断路器有效进行分合闸…
阅读更多...
代码随想录算法训练营第二十二天 | 读PDF复习环节2

代码随想录算法训练营第二十二天 | 读PDF复习环节2

读PDF复习环节2 本博客的内容只是做一个大概的记录&#xff0c;整个PDF看下来&#xff0c;内容上是不如代码随想录网站上的文章全面的&#xff0c;并且PDF中有些地方的描述&#xff0c;是很让我疑惑的&#xff0c;在困扰我很久后&#xff0c;无意间发现&#xff0c;其网站上的讲…
阅读更多...
vue3中使用wavesurfer插件 动态生成id

vue3中使用wavesurfer插件 动态生成id

需求最终实现的是对话这种&#xff0c;音频文字的对话 使用方法&#xff1a; npm install wavesurfer.js --save官方文档&#xff1a; https://wavesurfer-js.org/ 参数&#xff0c;方法可以去文档查看 直接放封装组件代码 开发背景vue3ts WaveSurfer.vue <template&…
阅读更多...
Java学习笔记----Day11（多线程）

Java学习笔记----Day11（多线程）

多线程 1. 进程、线程2. 实现线程的三种方式3. 线程的生命周期4. 线程里常用的方法5. 线程的调度&#xff08;了解&#xff09;6. 多线程并发环境下&#xff0c;数据的安全问题7. Java三大变量&#xff08;线程同步机制synchronized&#xff09;【重要的内容】8. 死锁9. 开发中…
阅读更多...
【正点原子H750MiniPro H750】按键以及时钟

【正点原子H750MiniPro H750】按键以及时钟

文章目录 前言1.CubeMx的配置步骤1.配置RCC2.配置按键IO口 3.测试代码 总结 前言 H750的最高主频可以达到480Mhz但是一开始在CubeMx配置过程中发现主频达到480Mhz时会报错&#xff0c;以下将会介绍解决办法以及按键移植。 1.CubeMx的配置步骤 1.配置RCC 完成上述步骤配置时钟…
阅读更多...
【Ajax】笔记-Axios与函数发送AJAX请求

【Ajax】笔记-Axios与函数发送AJAX请求

Axios 和 Ajax 的区别 1、Axios是一个基于Promise的HTTP库&#xff0c;而Ajax是对原生XHR的封装&#xff1b; 2、Ajax技术实现了局部数据的刷新&#xff0c;而Axios实现了对ajax的封装。 优缺点&#xff1a; ajax&#xff1a; 本身是针对MVC的编程,不符合现在前端MVVM的浪潮 基…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023