MQ之Spring AMQP学习

news2025/4/7 19:55:26

Spring AMQP学习

Spring AMQP

AMQP是Advanced Message Queuing Protocol的缩写。AMQP是用于在应用程序之间传递消息的开放标准，该协议与语言和平台无关，更符合微服务中独立性的要求。
Spring AMQP是基于AMQP协议定义的一套API规范，提供了模版来发送和接收消息，包含两部分，其中spring-amqp是基础抽象，spring-rabbit是底层的默认实现。

SpringAMQP提供了三个功能：

  • 自动声明队列、交换机及其绑定关系
  • 基于注解的监听器模式，异步接收消息
  • 封装了RabbitTemplate工具，用于发送消息

Spring AMQP使用

首先需要引入依赖

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

RabbitMQ配置：

spring:
  rabbitmq:
    port: 5672  # mq server 端口号，注意：部署15672
    virtual-host: /test  #虚拟主机
    host: 192.168.200.215  # mq server ip
    username: testuser1   # mq管理后台用户名
    password: testuser1  # mq管理后台密码

简单队列

work queue（工作队列）

work queue简单来说就是让多个消费者绑定到一个队列，共同消费队列中的消息。
当消息处理比较耗时的时候，可能生产消息的速度会远远大于消费的速度。如果一直这样，消息就会堆积越来越多，无法及时处理。
此时就可以使用work模型，多个消费者共同处理消息，这样消费速度就能大大提高了。

work queu默认是采用预取模式去消费消息的，也就是如果有多个消费者，则会先预分配给每个消费一个消息，消费完以后，再给每个消费者继续分配。

消息生产代码如下：

    @RequestMapping("/work-queue")
    public String testWorkQueue() {
        // 消息
        String message = "hello, spring amqp!";

        for (int i = 0; i < 50; i++) {
            // 发送消息
            rabbitTemplate.convertAndSend(SIMPLE_QUEUE_NAME, message + i);
        }

        log.info("消息发送成功: {}", message);
        return "success";
    }

消费者代码如下：

@Component
@Slf4j
public class SimpleQueueListener {

    @RabbitListener(queues = "simple.queue")
    public void listenerWorkQueue1(String message) {
        log.info("消费者1接收到的消息: {}", message);
        Thread.sleep(5);
    }

    @RabbitListener(queues = "simple.queue")
    public void listenerWorkQueue2(String message) {
        log.info("消费者2接收到的消息: {}", message);
        Thread.sleep(200);
    }

}

结果如下图所示，可以看到两个消费者消费消息是均匀分配的。
在这里插入图片描述

如果想实现“能者多劳”，消费消息快的消费者多消费，可以使用下面的配置

  rabbitmq:
    host: 192.168.200.215
    username: testuser1
    password: testuser1
    port: 5672  #这里的端口是5762，不是15762
    virtual-host: /test
    listener:
      simple:
        prefetch: 1 #每次只能得到一条消息，处理完ACK之后，才能获取下一个消息

加入配置以后，可以看到消费者2消费的消息比消费者1多。
在这里插入图片描述

发布订阅

发布订阅的模型如下图所示：
在这里插入图片描述

在订阅模型中，多了一个exchange角色，而且过程略有变化：

  • Publisher：生产者，也就是要发送消息的程序，但是不再发送到队列中，而是发给X（交换机）
  • Exchange：交换机，图中的X。一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange有以下3种类型：
    • Fanout：广播，将消息交给所有绑定到交换机的队列
    • Direct：定向，把消息交给符合指定routing key 的队列
    • Topic：通配符，把消息交给符合routing pattern（路由模式） 的队列
  • Consumer：消费者，与以前一样，订阅队列，没有变化
  • Queue：消息队列也与以前一样，接收消息、缓存消息
Fanout模式示例

声明交换机，绑定队列和交换机。这个代码需要和消息发送者在同一个服务中。

@Configuration
public class FanoutConfiguration {


    /**
     * 声明交换机
     *
     */
    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange("demo.fanout");
    }


    @Bean
    public Queue fanoutQueue1() {
        return new Queue("fanout.queue1");
    }


    /**
     * 绑定队列和交换机
     */
    @Bean
    public Binding bindingQueue1(@Autowired Queue fanoutQueue1, @Autowired FanoutExchange fanoutExchange) {
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }

    /**
     * 第2个队列
     */
    @Bean
    public Queue fanoutQueue2(){
        return new Queue("fanout.queue2");
    }

    /**
     * 绑定队列和交换机
     */
    @Bean
    public Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }

}

发送消息。注意：convertAndSend方法中指定了交换机的名称

    @GetMapping("/fanout")
    public String testFanoutQueue() {
        // 消息
        String message = "hello, fanout queue!";
        //交换机名称
        String exchange  = "demo.fanout";
        rabbitTemplate.convertAndSend(exchange, "", message);

        log.info("消息发送成功: {}", message);
        return "success";
    }

消费者接收消息，接收消息和前面简单队列是一样的。

@Component
@Slf4j
public class SimpleQueueListener {

    @RabbitListener(queues = "fanout.queue1")
    public void fanoutQueue1(String message) throws InterruptedException {
        log.info("消费者1接收到的消息: {}", message);
    }

    @RabbitListener(queues = "fanout.queue2")
    public void fanoutQueue2(String message) throws InterruptedException {
        log.info("消费者2接收到的消息: {}", message);
    }

}

结果如下图所示：
在这里插入图片描述

Topic模式

在fanout模式下，一条消息会被所有订阅的队列消费，但是有时候，我们想让消息被不同的队列消费，这时候就需要用到direct类型的Exchange。
在这里插入图片描述

消息监听，这里使用的注解的方式，使用@Queue指定队列，@Exchange指定交换机，key指定路由的key，数组类型，可以指定多个

    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue1"),
            exchange = @Exchange(name = "direct", type = ExchangeTypes.DIRECT),
    key = {"blue"}))
    public void listenDirectQueue1(String message) {
        log.info("消费者1接收到的消息: {}", message);

    }

    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2"),
            exchange = @Exchange(name = "direct", type = ExchangeTypes.DIRECT), key = {"yellow"}))
    public void listenDirectQueue2(String message) {
        log.info("消费者2接收到的消息: {}", message);
    }

发送消息，发送消息时需要指定路由key，这样消息才能被指定的队列收到

        // 消息
        String message = "hello, direct queue!";
        //交换机名称
        String exchange  = "direct";
        rabbitTemplate.convertAndSend(exchange, "yellow", message);
Topic模式

Topic类型的Exchange与Direct相比，都是可以根据RoutingKey把消息路由到不同的队列。只不过Topic类型Exchange可以让队列在绑定Routing key 的时候使用通配符！

接收消息监听

    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "topic.queue1"),
            exchange = @Exchange(name = "topic", type = ExchangeTypes.TOPIC),
            key = "china.#"
    ))
    public void listenTopicQueue1(String msg){
        System.out.println("消费者接收到topic.queue1的消息：【" + msg + "】");
    }

    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "topic.queue2"),
            exchange = @Exchange(name = "topic", type = ExchangeTypes.TOPIC),
            key = "#.news"
    ))
    public void listenTopicQueue2(String msg){
        System.out.println("消费者接收到topic.queue2的消息：【" + msg + "】");
    }

发送消息，需要匹配通配符，这样才能收到消息

        // 消息
        String message = "hello, topic queue!";
        //交换机名称
        String exchange  = "topic";
        rabbitTemplate.convertAndSend(exchange, "chiana.news", message);

结果如下：

在这里插入图片描述

参考

  • Spring AMQP 官方文档

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

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

相关文章

JavaScript高级（十八）---进程和线程，宏任务和微任务

JavaScript高级（十八）---进程和线程，宏任务和微任务

进程和线程 进程&#xff08;process&#xff09;&#xff1a;计算机已经运行的程序&#xff0c;是操作系统管理程序的一种方式&#xff0c;我们可以认为&#xff0c;启动一个应用程序&#xff0c;就会默认启动一个进程&#xff08;也可能是多个进程&#xff09;。 线程&…
阅读更多...
JDK21虚拟线程

JDK21虚拟线程

目录 虚拟线程 话题 什么是平台线程&#xff1f; 什么是虚拟线程&#xff1f; 为什么要使用虚拟线程&#xff1f; 创建和运行虚拟线程 使用线程类和线程创建虚拟线程。生成器界面 使用Executor.newVirtualThreadPerTaskExecutor&#xff08;&#xff09;方法创建和运行…
阅读更多...
k8s详细教程

k8s详细教程

Kubernetes详细教程 1. Kubernetes介绍 1.1 应用部署方式演变 在部署应用程序的方式上&#xff0c;主要经历了三个时代&#xff1a; 传统部署&#xff1a;互联网早期&#xff0c;会直接将应用程序部署在物理机上 优点&#xff1a;简单&#xff0c;不需要其它技术的参与 缺点…
阅读更多...
Spring Cloud Alibaba微服务从入门到进阶（三）（Spring Cloud Alibaba）

Spring Cloud Alibaba微服务从入门到进阶（三）（Spring Cloud Alibaba）

Spring Cloud Alibaba是spring Cloud的子项目 Spring Cloud Alibaba的主要组件&#xff08;红框内是开源的&#xff09; Spring Cloud是快速构建分布式系统的工具集&#xff0c; Spring Cloud提供了很多分布式功能 Spring Cloud常用子项目 项目整合 Spring Cloud Alibaba …
阅读更多...
VUE-组件间通信（一）props

VUE-组件间通信（一）props

props 1、单向绑定 props是父组件给子组件传输数据 当父组件的属性变化时&#xff0c;将传导给子组件&#xff0c;但是反过来不会 2、使用示例 子组件&#xff08;类似于方法&#xff09; <template> <div><h2>姓名:{{ name }}</h2><h2>性别:{{…
阅读更多...
微信小程序接口请求出错:request:fail url not in domain list:xxxxx

微信小程序接口请求出错:request:fail url not in domain list:xxxxx

一、微信小程序后台和开发者工具配的不一样导致了这个错误 先说结论&#xff1a; 开发者工具配置了https://www.xxx.cn/prod-api/ 微信后台配置了 https://www.xxx.cn 一、最开始 开发者工具配置了https://www.xxx.cn:7500 微信后台配置了 https://www.xxx.cn 报错:reques…
阅读更多...
面试六分钟，难题显真章

面试六分钟，难题显真章

职场&#xff0c;这个充满机遇与挑战的舞台&#xff0c;总会在不经意间上演着意想不到的转折。我从一家小公司转投到另一家&#xff0c;原本期待着新的工作环境和更多的发展机会&#xff0c;然而现实却给了我一个不小的打击。 新公司的加班文化&#xff0c;如同一个巨大的漩涡…
阅读更多...
yolov7 gui 轻松通过GUI来实现YOLOv7对象检测

yolov7 gui 轻松通过GUI来实现YOLOv7对象检测

YOLOv7 GUI 是一款用户友好型图形界面应用程序&#xff0c;专为简化基于YOLOv7&#xff08;You Only Look Once version 7&#xff09;的目标检测流程而设计。该工具允许用户无需深入掌握命令行操作和复杂编程细节&#xff0c;即可方便快捷地运行YOLOv7模型来检测图像或视频中的…
阅读更多...
3.19总结

3.19总结

A计划 题解&#xff1a;这题其实就是一个很简单的三维搜索&#xff0c;有了一个传送门&#xff0c;并且要确定是否传过去的对应位置是墙&#xff0c;防止被装死&#xff0c;同事呢又要在对应的t时间内完成&#xff08;不一定要卡着t时间恰好完成&#xff09; #include<ios…
阅读更多...
【项目实践day06】JWT令牌相关

【项目实践day06】JWT令牌相关

什么是JWT 简洁的、自包含的格式&#xff0c;用于在通信双方以json数据格式安全的传输信息。 由于数字签名的存在&#xff0c;这些信息是可靠的。 jwt就是将原始的json数据格式进行了安全的封装&#xff0c;这样就可以直接基于jwt在通信双方安全的进行信息传输了。简洁&#…
阅读更多...
全栈的自我修养 ———— 让uniapp开发更加舒服！！(与别的博主思路不一样，小编这里只讲实用的，直提重点！)

全栈的自我修养 ———— 让uniapp开发更加舒服！！(与别的博主思路不一样，小编这里只讲实用的，直提重点！)

小编是web的&#xff0c;然后现在开始接手微信小程序&#xff0c;有很多不习惯的的地方&#xff0c;经过一段时间的使用&#xff0c;部分得到了妥善的解决方法 一、用vscode开发小程序二、组件库的选择三、注意 一、用vscode开发小程序 发现用Hbuilder开发小程序有很多不习惯的…
阅读更多...
odoo17开发教程（8）：设置界面UI的字段属性

odoo17开发教程（8）：设置界面UI的字段属性

目录 添加字段 给字段设置只读和不可拷贝 给字段添加默认值 保留字段 本节目标&#xff1a;在本文末尾&#xff0c;售价(selling price)应为只读值&#xff0c;卧室数量(bedrooms)和可用日期(availability date)应为默认值。此外&#xff0c;在复制记录时&#xff0c;售价和…
阅读更多...
day09-Mybatis

day09-Mybatis

一、Mybatis 基础操作 1 需求 功能列表&#xff1a; 查询 根据主键ID查询 条件查询新增更新删除 根据主键ID删除 根据主键ID批量删除 2 准备 实施前的准备工作&#xff1a; 准备数据库表创建一个新的 springboot 工程&#xff0c;选择引入对应的起步依赖&#xff08;mybatis、…
阅读更多...
【DevOps趣味篇】你为什么要数程序员的代码行数？

【DevOps趣味篇】你为什么要数程序员的代码行数？

【DevOps趣味篇】你为什么要数程序员的代码行数&#xff1f; 目录 【DevOps趣味篇】你为什么要数程序员的代码行数&#xff1f;代码行数统计方法手动计数代码行数统计命令使用语句统计代码行数IL指令 需要计算代码行数吗&#xff1f; 推荐超级课程&#xff1a; Docker快速入门…
阅读更多...
「Swift」AttributedString常见使用方法

「Swift」AttributedString常见使用方法

前言&#xff1a;AttributedString是Apple推出的可以实现单个字符或字符范围带相应属性的字符串。属性提供了一些文本特性&#xff0c;可以让文本展示的样式更加丰富。在日常开发过程中&#xff0c;我通常用于同一个Label中包含不同的字体大小或字体颜色的样式编写中。 使用举…
阅读更多...
002——编译鸿蒙（Liteos -a）

002——编译鸿蒙（Liteos -a）

目录 一、鸿蒙是什么 二、Kconfig 2.1 概述 2.2 编译器 2.3 make使用 本文章引用了很多韦东山老师的教程内容&#xff0c;算是我学习过程中的笔记吧。如果侵权请联系我。 一、鸿蒙是什么 这里我补充一下对鸿蒙的描述 这张图片是鸿蒙发布时使用的&#xff0c;鸿蒙是一个很…
阅读更多...
数据预处理：重复值

数据预处理：重复值

数据重复值处理 数据重复值出现情况重复的记录用于分析演变规律重复的记录用于样本不均衡处理重复的记录用于检测业务规则问题 数据重复值出现情况 数据集中的重复值包括以下两种情况&#xff1a; 数据值完全相同的多条数据记录。这是最常见的数据重复情况。数据主体相同但匹…
阅读更多...
ConKI: Contrastive Knowledge Injection for Multimodal Sentiment Analysis

ConKI: Contrastive Knowledge Injection for Multimodal Sentiment Analysis

文章目录 ConKI&#xff1a;用于多模态情感分析的对比知识注入文章信息研究目的研究内容研究方法1.总体结构2.Encoding with Knowledge Injection2.1 Pan-knowledge representations2.2 Knowledge-specific representations 3.Hierarchical Contrastive Learning4.损失函数5.训…
阅读更多...
五个跟进方法，让你的老外客户不再跑路！

五个跟进方法，让你的老外客户不再跑路！

一、不同客户该怎么跟进? 1.已报价的客户 在向客户报过价之后&#xff0c;过几天要记得再询问一下对方是否收到了报价&#xff0c;如果没收到就提醒一下客户必要时将价格再发过去&#xff0c;如果客户已收到还要再进一步了解其对于报价的想法。 如果客户有兴趣也有需要&…
阅读更多...
外包2月，技术倒退警钟长鸣。。。。。

外包2月，技术倒退警钟长鸣。。。。。

曾经的我&#xff0c;作为一名大专生&#xff0c;在湖南某软件公司从事功能测试工作近四年。日复一日的工作让我陷入舒适区&#xff0c;不思进取。直到今年8月&#xff0c;我才意识到自己的技术停滞不前&#xff0c;女友的离开更是让我痛定思痛&#xff0c;决定改变现状&#x…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023