当前位置: 首页 > news >正文

消息队列知识点详解

消息队列场景

什么是消息队列

可以把消息队列理解一个使用队列来通信的组件,它的本质是交换机+队列的模式,实现发送消息,存储消息,消费消息的过程。

 我们通常说的消息队列,MQ其实就是消息中间件,业界中比较常用的消息中间件有:RabbiyMQ、RockMQ、Kafka等

消息队列的选型

选型的时候我们需要根据业务的场景,结合上述特性来进行选型。

消息队列的使用场景

  • 解耦:在分布式系统中,可以通过消息队列进行异步通信,不再使用OpenFeign等HTTP的网络之间进行通信,这样项目中就不会存在耦合,系统也不会有太大的影响,即使一个系统挂了,请求消息也只是堆积在消息队列中,不会对其他系统造成影响。
  • 异步:加入一个操作涉及到了好几个不同的步骤或者是分布式系统,这些不需要同步执行,那么可以考虑消息队列进行异步操作。假设用于有一个创建订单操作,其中涉及到客户轨迹添加,更新库存,创建订单,拉起支付等功能。那么如果我们使用OpenFeign等网络调用链进行调用,那么此时会产生大量的时间,客户是无法接受的。并且其中像客户轨迹添加这样的操作是不需要同步的,如果使用MQ将客户创建订单时,将后面的所有操作全部放到MQ进行异步操作,随后返回成功信息,这样就可以加快系统的访问速度。
  • 削峰:一个系统访问有流量高峰期,也有流量低峰期,假设12306的购票活动,需要用户创建订单->锁定余票库存->拉起支付->更新记录等,但是此时如果有几千万人次进行抢票,我们的支付服务可能受不了这么大的并发,可能会直接挂掉,所以这里可以加一个MQ,将微服务调用链发给支付服务的所有请求堆在MQ中,在支付服务的最大限度内进行处理,这样就会避免服务崩溃的问题。

消息重复的消费怎么做

生产端为了保证数据的发送成功,可能会重复推送消息直到收到成功ACK(网络、消息队列异常),这样就会在队列内产生重复的消息,一个成熟的MQ框架会有自己的解决方案,比如用空间换时间,存储已经处理过的message_id,给生产者提供一个可靠的发送消息的接口。

但是消费者段却无法根本的解决这个问题,在不高并发的要求下,拉取消息+处理业务逻辑+提交消费者偏移量需要事务做处理,且消费者端可能会挂掉,很可能导致拉取到重复的消息。

这种解决办法也就只有在业务层面做控制,对于已经成功的消息,本地数据库或者缓存来存储业务标识,每次处理前先进行校验,保证幂等性。

消息丢失怎么解决

使用一个消息队列,其实就分为三大块:生产者,中间件,消费者,如果要保证数据的不丢失,就要保证这三个部分不会出问题。

  • 消息生产阶段:生产者会不会丢失消息,取决于消息生产者对异常的处理是否合理。丛消息被生产出来,然后提交给MQ的过程中,只要能正常收到MQ消息队列的ack确认消息,就表示发送成功,所以只要处理好返回值和异常,如果返回错误,就进行重发,那么这个阶段是不会出现问题的。
  • 消息存储阶段:这里使用kafka为例,kafka一般是使用集群部署的,生产者在发送消息时,消息队列一般会写多个节点,一般是多个节点,可以理解为多个备份,即便一个节点挂了,也会保证数据不丢失。
  • 消息消费阶段:消费者接受到消息+处理完毕后,并回复ack的话,那么消息消费阶段就不会消失,这样一来即使其中一个节点挂了,也可以保证数据不丢失

以上三点只要有一个疏漏就会导致消息的丢失

消息队列的可靠性是怎么保证的

  • 消息持久化:确保消息能够持久化是非常关键的,在系统掉点、系统崩溃重启后仍然可以读取持久化的消息并放到消息队列中
  • 消息确认机制:消费者在成功消费消息后,应该向消息队列发送确认,消息队列只有收到确认后才会将消息丛队列中移除。如果没有收到确认,则会在一定时间内重发该消息。在kafka中,消费者通过commitasync提交便宜量,从而确认消息。
  • 消息重试策略:当消费者处理消息失败时,需要有合理的重试策略,可以设置重试次数以及重试间隔时间。

消息队列的顺序性怎么保证的

以kafka为例,可以将顺序的消息发送到同一个主题的同一个分区来保证消息是有序的,但是这个可能会影响消费者的并行处理速度,并且消费者进行消费的时候必须单线程处理顺序消息。

如何保证幂等性写

幂等性写指的是同一操作的多次执行的结果和一次执行的结果相同。假设支付宝付款操作,多次执行但是只会扣一次钱。

  • 唯一标识:为每一个请求生成全局唯一的id,服务端校验该id是否已处理,适用于场景接口调用,消息消费等。
  • 乐观锁:通过版本号或者时间戳等方式控制并发更新,确保多次更新等同于单次操作,适用于场景数据库记录的更新
  • 数据库唯一约束:使用数据库的唯一索引来限制重复的插入,适用于插入的场景
  • 分布式锁:通过锁机制保证一个时刻只有一个请求执行关键操作,适用于高并发场景下的资源争夺。

如何保证数据的一致性,事务消息如何实现。

这里直接举一个用户发起创建订单的例子

假设用户点击支付后,首先创建订单(包含订单表写入、库存表更新等数数据库更新操作),事务完成后拉起支付服务(下游服务),此时我们的需求是,当事务执行出错(发生rollback),不再调用下游服务,当事务执行成功并commit,必须拉起下游服务执行支付操作,但是此时万一发送消息不成功,下游操作就无法感知这个操作,出现数据不一致。

  • 生产者产生消息,发送一条半事务消息到MQ服务器
  • MQ收到消息后,将消息持久化道存储系统,这条消息是待发送的状态
  • MQ服务器返回ACK给生产者,将消息持久化到存储系统,这条消息不会触发推送事件
  • 生产者执行本地事务
  • 如果本地事务执行成功,即commit执行结果到MQ服务器,如果执行失败,发送rollback
  • 如果是正常的commit,MQ服务器更新消息状态为可发送,如果是rollback则删除消息
  • 如果消息更新为可推送,则MQ服务器直接将消息push给消费者,消费者消费完返回ACK
  • 如果MQ服务器长时间收不到生产者的commit或者rollback,他会反查生产者。

kafka

kafka的特点

  • 高吞吐量,低延迟:kafka每秒可以处理几十万条消息,他的最低延迟也只有几毫米,每个topic可以分为对歌partition,consumer group对partition进行consumer操作
  • 可扩展性:kafka集群支持扩展
  • 持久性:消息被持久化到本地磁盘,并且支持数据备份
  • 容错性:允许集群中及节点失败
  • 高并发:数千个客户端同时读写

kafka为什么这么快?

  • 顺序写入优化:kafka将消息顺序写入磁盘,减少了磁盘的寻道时间,这种方式比随机读写效率更高
  • 批处理技术:kafka支持批量发送消息,这意味着生产者在发送消息的时候可以等待到有足够数据量囤积的时候再发送,这种方法减少了网络和磁盘的开销
  • 零拷贝技术:kafka使用零拷贝技术,可以直接将数据从磁盘里发送到网络套接字,避免了再用户空间和内核空间之间相互转换
  • 压缩技术:kafka支持消息压缩,这不仅减少了网络的传输的数据量,提高整体的吞吐量

介绍下Kafka的模型,kafka是推送还是拉取

消费者模型

推送模型(push)

  • 基于推送模型的消息系统,由消息代理记录消费者的状态
  • 消息代理在将消息推送到消费者后,标记这条消息已经消费,但是这种方法无法很好的保证数据被处理
  • 如果要保证数据被处理,需要消息代理记录消息的所有状态,这种太消耗资源,不可取
  • push模式是设置MQ中的,他无法适应消费者的速率,过快会导致消费者拒绝服务,过慢会导致队列内消息积压

拉取模型(pull)

kafka采用的是拉取模型,由消费者自己记录消费的状态,每个消费者顺序的拉取每个分区的消息

  • 两个消费者拉取同一主题的消息,消费者A的消费进度是3,B的进度为6,也叫偏移量
  • 消费者拉取的最大上限称为最高水位,生产者最新写入的消息如果还没有到达备份的数量,那么这个消息对消费者不可见
  • 这种优点是:消费者可以任意控制偏移量来消费任意时刻的消息。

消费者组

kafka中的消费者是以消费者组的形式工作,由一个或者多个消费者构成消费者组,共同消费一个topic,但是每一个分区在同一时刻只能被同一消费者组中的一个消费者消费,但是不同消费者组可以在同一时刻消费一个分区。

消费方式

kafka采用拉取pull的方式从broker中读取数据

优点是pull模式可以根据consumer的消费能力进行拉取

缺点是如果此时kafka中没有数据,消费者可能会陷入循环,一致在拉取null数据,针对这一点kafka的消费者在消费数据时会传入一个时常参数,如果没有数据,consumer会等待一段时间返回,时常为timeout

kafka为什么一个分区只能由消费者组的一个消费者消费

如果两个消费者负责同一个分区,那么就意味着两个消费者同时读取分区的消息,由于消费者自己可以控制读取消息的offset,可能c1才读到2,c2读到1,那么当c1没读完的时候,c2已经读到3了,这样会造成消息浪费,相当于多线程同时读取一个消息,这是没意义的

消息中间件是如何做到高可用的

消息中间件如何保证高可用呢,单机是没有高可用可言的,高可用都是对集群来说的。

kafka的基础架构,由多个broker组成,每个broker都是一个节点,当你创建一个topic时,他可以划分为partion,而每个partion只放一部分数据,分别存在不同的broker上,也就是说,一个topic数据是分散在不同的broker上的,每个及其存放一部分数据

那么是不是broker挂了partion就挂了?其实在kafka0.8之后提供了副本机制来保证高可用,即每个partion的数据会同步到其他的机器上,形成副本,然后所有副本会选取一个leader出来,让leader和生产者和消费者打交道,其他副本都是follower。写数据时,leader负责把数据同步给所有的follower,读消息时,直接读leader上的数据即可。如果某个broker挂掉了,那么这个broker的partion在其他机器上都有副本的,如果挂的是leader,那么会从follower会重新选择一个leader

相关文章:

消息队列知识点详解

消息队列场景 什么是消息队列 可以把消息队列理解一个使用队列来通信的组件,它的本质是交换机队列的模式,实现发送消息,存储消息,消费消息的过程。 我们通常说的消息队列,MQ其实就是消息中间件,业界中比较…...

AI 赋能 3D 创作!Tripo3D 全功能深度解析与实操教程

大家好,欢迎来到本期科技工具分享! 今天要给大家带来一款革命性的 AI 3D 模型生成平台 ——Tripo3D。 无论你是游戏开发者、设计师,还是 3D 建模爱好者,只要想降低创作门槛、提升效率,这款工具都值得深入了解。 接下…...

DeepSeek赋能Nuclei:打造网络安全检测的“超级助手”

引言 各位少侠,周末快乐,幸会幸会! 今天唠一个超酷的技术组合——用AI大模型给Nuclei开挂,提升漏洞检测能力! 想象一下,当出现新漏洞时,少侠们经常需要根据Nuclei模板,手动扒漏洞文章…...

【MySQL】表的约束(主键、唯一键、外键等约束类型详解)、表的设计

目录 1.数据库约束 1.1 约束类型 1.2 null约束 — not null 1.3 unique — 唯一约束 1.4 default — 设置默认值 1.5 primary key — 主键约束 自增主键 自增主键的局限性:经典面试问题(进阶问题) 1.6 foreign key — 外键约束 1.7…...

学习深度学习是否要先学习机器学习?工程师的路径选择策略

深度学习与机器学习的关系,如同摩天大楼与地基——前者是后者的高阶延伸,但能否绕过地基直接造楼?本文从技术本质、学习曲线、应用场景三个维度剖析这一关键问题。 一、技术血脉的承继关系 概念体系同源: 损失函数、梯度下降、过拟…...

高防服务器适合哪些行业使用

在当今数字化的时代,网络安全就如同城堡的城墙,而高防服务器则是这道城墙中的坚固堡垒。那么,究竟哪些行业特别需要高防服务器这位“守护天使”的庇佑呢? 首先,金融行业绝对是高防服务器的“头号粉丝”。想象一下&…...

【Docker-16】Docker Volume存储卷

Docker Volume(存储卷) 概念比喻镜像程序的光盘(安装包)容器安装并运行后的 App卷独立的文件夹或硬盘,用来保存数据宿主机装着 Docker 的电脑或服务器,是一切的基础 一、什么是存储卷? 存储卷就是将宿主机的本地文件系统中存在…...

后端如何生成验证码

目录 🔐 一、验证码类型与用途 📸 二、图形验证码的原理(Image Captcha) 🔧 核心流程 🛠️ 示例:用 Python Pillow 生成图形验证码 📱 三、数字验证码(短信/邮箱&a…...

微服务架构下数据库范式的失效与反范式设计的崛起

在传统单体应用中,关系型数据库范式设计被认为是数据库建模的黄金标准。然而,随着企业架构向分布式系统,特别是微服务架构演进,范式化数据库设计的有效性和适应性正受到前所未有的挑战。本文将深入剖析范式设计的设计哲学&#xf…...

Redis专题

前言 一:看到你的简历上写了你的项目里面用到了redis,为啥用redis? 因为传统的关系型数据库如Mysql,已经不能适用所有的场景,比如秒杀的库存扣减,APP首页的访问流量高峰等,都很容易把数据库打崩&#xff0…...

Vue的模板语法——指令语法

2025/4/21 向全栈工程师迈进&#xff01; 一、插值语法 之前通过插值语法&#xff0c;其显示的效果如下。 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widt…...

【Java面试笔记:基础】1.谈谈你对Java平台的理解?

前言 Java 是历史悠久且主流的编程语言&#xff0c;拥有庞大的开发者群体和广泛的应用领域。通过系统学习和实践&#xff0c;构建扎实的 Java 知识体系&#xff0c;提升面试成功率 笔记核心内容 1. Java 平台的核心特性 跨平台特性&#xff1a;Java 的核心特性之一是“Writ…...

NestJS-Knife4j

文章目录 前言✅ 一、什么是 Knife4j&#xff1f;✅ 二、Knife4j 与 Swagger 对比✅ 三、NestJS-Knife4j 集成1. 安装依赖2. 配置 Swagger 与 Knife4j3. 启动应用并访问接口文档 ✅ 四、功能增强1. **接口分组**2. **请求/响应示例**3. **接口文档的美化** ✅ 五、总结 前言 N…...

Linux环境准备(安装VirtualBox和Ubuntu,安装MySQL,MySQL启动、重启和停止)

目录 安装VirtualBox和Ubuntu 安装VirtualBox 安装Ubuntu 下载Ubuntu操作系统的镜像文件 创建虚拟机 虚拟机设置 启动虚拟机&#xff0c;安装Ubuntu系统 Ubuntu基础设置 设置系统为中文 设置中文输入法为拼音 修改分辨率 设置缩放比例 设置息屏时间 设置root用户…...

Nebula图数据库

Nebula 通常指 Nebula Graph&#xff0c;是一款开源的分布式图数据库系统1。以下是其相关介绍1&#xff1a; 特点 高性能&#xff1a;能处理千亿顶点和万亿边的超大规模数据集&#xff0c;提供毫秒级查询延迟&#xff0c;在处理大规模数据时&#xff0c;也能维持低时延的读写和…...

基于 Vue,使用Vuex 或事件总线实现跨组件通信

在基于 Vue Element UI 的 RuoYi 系统中&#xff0c;如果需要在一个界面&#xff08;界面 A&#xff09;执行某个操作后&#xff0c;通知另一个界面&#xff08;界面 B&#xff09;刷新&#xff0c;可以通过 Vuex 或事件总线&#xff08;Event Bus&#xff09;来实现跨组件通信…...

【C++篇】string类的终章:深浅拷贝 + 模拟实现string类的深度解析(附源码)

&#x1f4ac; 欢迎讨论&#xff1a;在阅读过程中有任何疑问&#xff0c;欢迎在评论区留言&#xff0c;我们一起交流学习&#xff01; &#x1f44d; 点赞、收藏与分享&#xff1a;如果你觉得这篇文章对你有帮助&#xff0c;记得点赞、收藏&#xff0c;并分享给更多对C感兴趣的…...

线性DP:最短编辑距离

Dp 状态表示 f&#xff08;i&#xff0c;j&#xff09; 集合所有将A[1~i]变成B[1~j]的操作方式属性min 状态计算 &#xff08;划分&#xff09; 增f(i,j)f(i,j-1)1//A[i]元素要增加&#xff0c;说明A前i位置与B前j-1相同删f(i,j)f(i-1,j)1//A[i]元素要删除&#xff0c;说明A前i…...

【全网最全】23种设计模式思维导图详解 | 含React/Vue/Spring实战案例

【全网最全】23种设计模式思维导图详解 | 含React/Vue/Spring实战案例 导图概述 本文通过高清思维导图系统梳理了23种设计模式&#xff0c;分为创建型、结构型、行为型三大类&#xff0c;并标注了各模式在主流框架&#xff08;如React、Vue、Spring&#xff09;中的典型应用场…...

8086微机原理与接口技术复习(1)存储器(2)接口

8086微机原理与接口技术复习&#xff08;1&#xff09;存储器&#xff08;2&#xff09;接口 存储器8086的存储空间存储器的拓展存储器的分类 接口8086I/O82558253串行通信 存储器 我们上的是嵌入式与接口技术这门课&#xff0c;存储器章节重点在于理解8086CPU的存储体结构&am…...

第 6 篇:衡量预测好坏 - 评估指标

第 6 篇&#xff1a;衡量预测好坏 - 评估指标 上一篇&#xff0c;我们小试牛刀&#xff0c;用朴素预测、平均法、移动平均法和季节性朴素预测这几种简单方法对未来进行了预测。我们还通过可视化将预测结果与真实值进行了对比。 但光靠眼睛看图来判断“哪个预测更好”往往是不…...

极刻AI搜v1.0 问一次问题 AI工具一起答

软件名&#xff1a;极刻AI搜 版本&#xff1a;v1.0 功能&#xff1a;囊括了互联网上比较好用的一些支持”搜索“的网站或者工具 开发平台&#xff1a;nodepythonweb 分类有&#xff1a; AI搜索&#xff08;支持智能问答的AI搜索引擎&#xff09; 常规搜索&#xff1a;&#xff…...

单片机 + 图像处理芯片 + TFT彩屏 进度条控件

进度条控件使用说明 概述 本进度条控件基于单片机 RA8889/RA6809 TFT开发&#xff0c;提供了简单易用的进度显示功能。控件支持多个进度条同时显示、自定义颜色、边框和标签等特性&#xff0c;适用于需要直观显示进度信息的各类应用场景。 特性 支持多个进度条同时显示可…...

RHCSA Linux系统 用户和组的管理

用户管理&#xff1a;增useradd 删userdel 改usermod 查id 组的管理&#xff1a;增groupadd 删groupdel 改groupmod 查groups /etc/default/useradd 即定义useradd默认参数&#xff0c;也定义了/etc/passwd &#xff0c;/etc/shadow&#xff0c;/etc/group&#…...

2025年pta团队设计天梯赛题解

题解不全&#xff0c;望见谅 L1-1 珍惜生命 题目 前辈工程师 Martin Golding 教育我们说&#xff1a;“Always code as if the guy who ends up maintaining your code will be a violent psychopath who knows where you live.”&#xff08;写代码的时候&#xff0c;总是要…...

Vue---vue2和vue3的生命周期

核心生命周期对比 生命周期阶段Vue 2 钩子Vue 3 Composition API​​初始化​​beforeCreate无&#xff08;使用 setup() 替代&#xff09;​​初始化完成​​created无&#xff08;使用 setup() 替代&#xff09;​​挂载前​​beforeMountonBeforeMount​​挂载完成​​moun…...

C#常用LINQ

在开发时发现别人的代码使用到了LINQ十分便捷且清晰&#xff0c;这里记录一下常用LINQ和对应的使用。参考链接&#xff1a;LINQ 菜鸟教程 使用的学生类和字符串用于测试 public class Student {public int StudentID;public string StudentName;public int Age; }Student[] st…...

Java--数组的应用

一、数组的地址值 数组的地址值表示数组在内存中的位置。 [I1eb44e46 [ &#xff1a;表示当前是一个数组I&#xff1a;表示当前数组是int类型&#xff1a;表示一个间隔符号&#xff08;固定格式&#xff09;1eb44e46&#xff1a;数组真正的地址值&#xff08;十六进制&#…...

PostgreSQL基础

一、PostgreSQL介绍 PostgreSQL是一个功能强大的 开源 的关系型数据库。底层基于C实现。 PostgreSQL的开源协议和Linux内核版本的开源协议是一样的。。BDS协议&#xff0c;这个协议基本和MIT开源协议一样&#xff0c;说人话&#xff0c;就是你可以对PostgreSQL进行一些封装&a…...

Linux系统管理与编程13:基于CentOS7.x的LAMP环境部署

兰生幽谷&#xff0c;不为莫服而不芳&#xff1b; 君子行义&#xff0c;不为莫知而止休。 一、实验目标 1.理解Apache服务器原理 2.掌握Apache服务器的配置文件 3.具备安装Mysql数据库能力 4.具备安装Apache服务器能力 5.具备PHP与数据库连接能力 6.具备Apache、Mysql、…...

浅谈AI致幻

文章目录 当前形势下存在的AI幻觉&#xff08;AI致幻&#xff09;什么是AI幻觉AI幻觉的类型为什么AI会产生幻觉AI幻觉的危害与影响当前应对AI幻觉的技术与方法行业与学术界的最新进展未来挑战与展望结论 当前形势下存在的AI幻觉&#xff08;AI致幻&#xff09; 什么是AI幻觉 …...

【架构】-- StarRocks 和 Doris 介绍与选型建议

StarRocks 和 Doris 的介绍 随着大数据分析需求的不断增长,企业对高性能、低延迟的分析型数据库提出了更高的要求。StarRocks 和 Apache Doris 是当前主流的开源 MPP(Massively Parallel Processing)数据库系统,广泛应用于实时分析、报表生成和数据仓库等场景。本文将从架…...

【SF顺丰】顺丰开放平台API对接(注册、API测试篇)

1.注册开发者账号 注册地址&#xff1a;顺丰企业账户中心 2.登录开发平台 登录地址&#xff1a;顺丰开放平台 3.开发者对接 点击开发者对接 4.创建开发对接应用 开发者应用中“新建应用”创建应用&#xff0c;最多创建应用限制数量5个 注意&#xff1a;需要先复制保存生产校验…...

C语言高频面试题——常量指针与指针常量区别

1. 常量指针&#xff08;Pointer to Constant&#xff09; 定义&#xff1a; 常量指针是指向一个常量数据的指针&#xff0c;即指针指向的内容不能通过该指针被修改。 语法&#xff1a; const int* ptr;或者&#xff1a; int const* ptr;解释&#xff1a; const修饰的是指…...

Novartis诺华制药社招入职综合能力测评真题SHL题库考什么?

一、综合能力测试 诺华制药的入职测评中&#xff0c;综合能力测试是重要的一部分&#xff0c;主要考察应聘者的问题解决能力、数值计算能力和逻辑推理能力。测试总时长为46分钟&#xff0c;实际作答时间为36分钟&#xff0c;共24题。题型丰富多样&#xff0c;包括图形变换题、分…...

网页下载的m3u8格式文件使用FFmpeg转为MP4

FFmpeg 是一个强大的开源音视频处理工具&#xff0c;可以直接将 M3U8 合并并转换为 MP4。 1.步骤&#xff1a; 下载 FFmpeg 官网&#xff1a;https://ffmpeg.org/ Windows 用户可以直接下载 静态构建版本&#xff08;Static Build&#xff09;&#xff0c;解压后即可使用。 2…...

Java 并发包核心机制深度解析:锁的公平性、异步调度、AQS 原理全解

&#x1f9e0; Java 并发包核心机制深度解析&#xff1a;锁的公平性、异步调度、AQS 原理全解 Java 并发编程的地基是 java.util.concurrent&#xff0c;但真正驱动这个系统的&#xff0c;是它背后隐藏的三根支柱&#xff1a; ReentrantLock 的公平/非公平调度策略Completabl…...

μC/OS 版本演进过程 | uC/OS-II 和 uC/OS-III 有什么区别?

uC/OS 系列是由 Jean J. Labrosse 开发的一套嵌入式实时操作系统&#xff08;RTOS&#xff09;&#xff0c;以其高质量源码和清晰的结构&#xff0c;在嵌入式教学和某些工业项目中有着广泛影响。该系统主要包含两个版本&#xff1a;uC/OS-II 和 uC/OS-III。 本文将带你了解这两…...

永磁同步电机参数辨识算法--递推最小二乘法辨识

一、原理介绍 最小二乘法大约是1795年高斯在其著名的星体运动轨道预报研究工作中提出的。后来&#xff0c;最小二乘法成为了估计理论的基石。最小二乘法由于原理简明、收敛较快、易于编程实现等特点&#xff0c;在系统参数估计中应用相当广泛。 其基本原理为&#xff1a; 改写…...

树莓派5+L298N控制电机

准备工作: 树莓派5开发板L298N 控制板电机1个12v的电池1个杜邦线若干L298N 引脚介绍 (1)图中标注的1和2都是都在输出引脚,可以各接入一个电机,电机不分正负极,随便接 (2)图中3这里是控制板的电源输入正负极,可以输入5v和12v,我这里输入的是12v电源,使用的时候应该把…...

UofTCTF-2025-web-复现

感兴趣朋友可以去我博客里看&#xff0c;画风更好看 UofTCTF-2025-web-复现 文章目录 scavenger-huntprismatic-blogscode-dbprepared-1prepared-2timeless scavenger-hunt 国外的一些ctf简单题就喜欢把flag藏在注释里&#xff0c;开源代码找到第一部分的flag 抓个包返回数据…...

记录seatunnel排查重复数据的案例分析

文章目录 背景分析检查现象检查B集群是否有异常&#xff0c;导致重复消费的分析同步任务 修复问题发现flink job 一直报异常修复问题 背景 使用seatunnel 同步数据从A 集群kafka 同步到B集群kafka,现象是发现两边数据不一致&#xff0c;每天10w级别会多几十条数据 分析 检查…...

技术速递|Agent 模式:对所有用户开放,并支持 MCP

作者&#xff1a;Isidor Nikolic 翻译/排版&#xff1a;Alan Wang Agent 模式正在向所有 VS Code 用户推广&#xff01;它充当一个自主的配对编程助手&#xff0c;能够根据你的指令执行多步编码任务&#xff0c;例如分析代码库、提出文件修改建议以及运行终端命令。它能够响应编…...

实验四 Java图形界面与事件处理

实验四 Java图形界面与事件处理 ###实验目的 掌握Java语言中AWT和Swing组件的基本用法掌握Java语言中的事件处理方法掌握Java语言中事件源、监视器和处理事件的接口的概念 ###实验内容 图形用户界面设计程序(ArtFont.java)&#xff08;90分&#xff09; 要求&#xff1a;设…...

day2 python训练营

浙大疏锦行 python训练营介绍...

Linux下 REEF3D及DIVEMesh 源码编译安装及使用

目录 软件介绍 基本依赖 一、源码下载 1、REEF3D 2、DIVEMesh 二、解压缩 三、编译安装 1、REEF3D 2、DIVEMesh 四、算例测试 软件介绍 REEF3D是一款开源流体动力学框架&#xff0c;提供计算流体力学及波浪模型。软件采用高效并行化设计&#xff0c;可以在大规模处理器…...

堡垒机和跳板机之区别(The Difference between Fortress and Springboard Aircraft)

堡垒机和跳板机之区别 在网络安全、安全运维领域&#xff0c;堡垒机和跳板机是两个常被提及且功能相似的概念&#xff0c;但它们在实际应用、功能定位以及技术实现上存在着明显的差异。本文将对堡垒机和跳板机进行详细的解析与比较&#xff0c;帮助读者更好地理解这两种网络安…...

《Android 应用开发基础教程》——第五章:RecyclerView 列表视图与适配器机制

目录 第五章&#xff1a;RecyclerView 列表视图与适配器机制 5.1 为什么要使用 RecyclerView&#xff1f; 5.2 基本结构图 5.3 RecyclerView 使用步骤 1️⃣ 添加 RecyclerView 依赖&#xff08;Android Studio&#xff09; 2️⃣ 布局文件&#xff08;activity_main.xml&…...

【第四章】19-匹配规则定义

在优化Web服务器性能与增强其功能性的过程中,深入理解Nginx的location匹配规则显得尤为关键。它不仅决定了如何高效地路由不同类型的客户端请求,而且是实现精准响应的基础。通过掌握精确匹配、前缀匹配及正则表达式匹配等规则,管理员能够灵活配置以支持复杂的业务需求,同时…...

[PTA]2025CCCC-GPLT天梯赛 现代战争

来源&#xff1a;L1-112 现代战争-Pintia题意&#xff1a;给定 n m n\times m nm 的矩阵&#xff0c;进行 k k k 次操作&#xff0c;每次操作清除矩阵当前最大值所在行和所在列的全部元素&#xff0c;求最终矩阵。关键词&#xff1a;模拟(签到)题解&#xff1a;非常水的模拟…...