SpringAMQP Work Queue 工作队列

devtools/2024/9/23 1:06:12/

消息模型:

代码模拟:

相较于之前的基础队列,该队列新增了消费者 不再是一个,所以我们通过代码模拟出两个consumer消费者。在原来的消费者类里写两个方法 其中消费者1效率高 消费者2效率低

@RabbitListener(queues = "simple.queue")public void lintestWorkQueue50(String mes) throws InterruptedException {System.out.println("消费者1接收到了消息:" + mes +"     "+ LocalDateTime.now());Thread.sleep(20);}@RabbitListener(queues = "simple.queue")public void lintestWorkQueue10(String mes) throws InterruptedException {System.err.println("消费者2接收到了消息:" + mes + "     "+LocalDateTime.now());Thread.sleep(200);}

在publisher提供者编写测试方法 一次发送50条消息 

发送后让观察控制台消费者处理情况 会发现两者处理的效率不一样但是处理的消息是平均分配的,一人25条,这是因为Rabbit有个预取机制,不管执行消费者效率,消费者都会提前在队列里预取一个消息,最后效果就是平均分配。

这个预取机制可以在yml配置里修改。


http://www.ppmy.cn/devtools/40014.html

相关文章

GT2512-STBA 三菱触摸屏12.1寸型

T2512-STBA参数说明:12.1"、SVGA 800*600、65536色、TFT彩色液晶显示屏、AC电源、32MB内存 三菱触摸屏GT2512-STBA性能规格详细说明: [显示部] 显示软元件:TFT彩色液晶显示屏 画面尺寸:12.1寸 分辨率:SVGA 80…

手写Spring Ioc 循环依赖底层源码剖析

手写Spring Ioc 循环依赖底层源码剖析 前言 Spring Ioc 是一个非常重要的框架,它的核心是依赖注入(DI)和控制反转(IOC)。在使用 Spring Ioc 的过程中,我们经常会遇到循环依赖的问题。本文将介绍手写 Spri…

iOS 安装cocoapds

注意 CocoaPods安装是基于ruby环境的,所以要安装CocoaPods先要安装Ruby环境,国内不能直接安装,只能通过VPN或淘宝的Ruby镜像来访问。 安装过程 gem sources --remove https://rubygems.org/ ** (注意是两个“-”,否则会移除失败) …

PHP类和对象扩展[构造函数,析构函数]

构造函数 特性:实例化对象时调用 作用:通常用于 初始化属性值 或 执行启动时所需的操作 用法: function __construct($parameter){ $this->attribute $parameter; echo 对象已创建并,初始化attribute属性值为parameter; …

苹果平板HOME键成历史,全面屏时代到来?2024平板电脑市场趋势分析

近期苹果公司在“放飞吧”发布会上推出了新款iPad Pro和iPad Air平板电脑,并下架了最后一款带有实体Home按键的iPad 9。这一变化标志着Home键在苹果iPad产品线中成为了历史,引起了不少网友的怀念和感慨。 与此同时,今年3月线上平板电脑市场迎…

Git === Git概述 Git安装

第1章 Git概述 Git是一个免费的、开源的分布式版本控制系统,可以快速高效地处理从小型到大型的各种项目。 Git易于学习,占地面积小,性能极快。 它具有廉价的本地库,方便的暂存区域和多个工作流分支等特性。其性能优于Subversion…

关于Matplotlib如何在网页中使用?

目录 一、如何在网页中使用matplotlib 二、如何使用mpld3在网页中显示图表 三、如何使用matplotlibflask在网页中显示图表 一、如何在网页中使用matplotlib Matplotlib是Python中一个非常流行的可视化库。然而,Matplotlib主要是为桌面应用程序设计的,…

【Chisel】chisel中怎么处理类似verilog的可变位宽和parameter

在 Chisel 中处理可变位宽和参数的方式与 Verilog 有一些不同,因为 Chisel 是建立在 Scala 语言之上的。以下是如何在 Chisel 中处理这些概念的方法: 参数化(Parameters) 在 Chisel 中,参数化是通过在模块构造函数中定…