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

深入理解Flink Mailbox线程模型

文章目录

  • 整体设计
  • processMail
    • 1.Checkpoint Tigger
    • 2.ProcessingTime Timer Trigger
  • processInput
  • 兼容SourceStreamTask

整体设计

Mailbox线程模型通过引入阻塞队列配合一个Mailbox线程的方式,可以轻松修改StreamTask内部状态的修改。Checkpoint、ProcessingTime Timer的相关操作(Runnable任务),会以Mail的形式保存到Mailbox内的阻塞队列中。StreamTask在invoke阶段的runMailboxLoop时期,就会轮询Mailbox来处理队列中保存的Mail,Mail处理完毕后才会对DataStream上的数据元素执行处理逻辑。

MailboxProcessor的能力就是负责拉取、处理Mail,以及执行MailboxDefaultAction(默认动作,即processInput()方法中对DataStream上的普通消息的处理逻辑,包括:处理Event、barrier、Watermark等)

/*** 开始轮询Mailbox内的Mail,Checkpoint和ProcessingTime Timer的触发事件会以Runnable的形式(作为Mail)添加到Mailbox的队列中,等待“Mailbox线程”去处理*/
public void runMailboxLoop() throws Exception {// 获取最新的TaskMailbox:主要用于存储提交的Mail,并提供获取接口。// TaskMailbox有2个队列://        1.queue:阻塞队列,通过ReentrantLock控制队列中的读写操作//        2.batch:非阻塞队列,调用createBatch()方法会将queue中的Mail转存到batch中,这样读操作就能通过tryTakeFromBatch()方法从batch队列中批量获取Mail,且只能被Mailbox线程消费final TaskMailbox localMailbox = mailbox;// 检查当前线程是否为Mailbox线程,即StreamTask运行时所在的主线程Preconditions.checkState(localMailbox.isMailboxThread(),"Method must be executed by declared mailbox thread!");// 确认Mailbox的状态:必须为OPENassert localMailbox.getState() == TaskMailbox.State.OPEN : "Mailbox must be opened!";// 创建MailboxController实例:可以控制Mailbox的循环、临时暂停和恢复MailboxDefaultAction(默认动作)final MailboxController defaultActionContext = new MailboxController(this);/*** 核心:事件循环* processMail()方法会检测Mailbox中是否还有Mail需要处理,新Mail会(在ReentrantLock的保护下)被添加到queue队列并转存到batch队列中。* MailboxProcessor处理完batch队列中的全部Mail后(执行作为Mail的Runnable#run()方法),才会进入到while循环内,执行MailboxDefaultAction的默认动作,* 即调用StreamTask#processInput()方法,对读取到的数据(Event、Barrier、Watermark等)进行处理*/while (processMail(localMailbox)) {mailboxDefaultAction.runDefaultAction(defaultActionContext); // lock is acquired inside default action as needed}
}

可以看出,对Mail和MailboxDefaultAction的处理,是由唯一的Mailbox线程负责的。

processMail

在while轮询时,首先会processMail

/*** 处理Mailbox中的Mail:Checkpoint、ProcessingTime Timer的触发事件,会以Runnable的形式作为Mail保存在Mailbox的queue队列中,* 并在ReentrantLock的保护下,将queue队列中的新Mail转移到batch队列中。MailboxProcessor会根据queue队列、batch队列内的Mail情况,* 决定处理Mail or processInput。只有当TaskMailbox内的所有Mail全都处理完毕后,MailboxProcessor才会去processInput()*/
private boolean processMail(TaskMailbox mailbox) throws Exception {/*** 新Mail写入queue队列,TaskMailbox会将queue队列中的新Mail转移到batch队列中,MailboxProcessor会根据queue队列、batch队列内的Mail情况,* 判断执行Mail的run() or processInput()。只有当TaskMailbox内的所有Mail全部处理完成后,MailboxProcessor才会去processInput()。*/if (!mailbox.createBatch()) {return true;}Optional<Mail> maybeMail;/*** 能走到这,说明queue队列中的Mail已被全部转移至batch队列。现在要从batch队列中获取到Mail并执行(它作为Runnable的run()方法),* 直到batch队列中的所有Mail全都处理完毕*/while (isMailboxLoopRunning() && (maybeMail = mailbox.tryTakeFromBatch()).isPresent()) {maybeMail.get().run();}/**如果默认操作处于Unavailable状态,那就先阻塞住,直到它重新回归available状态*/while (isDefaultActionUnavailable() && isMailboxLoopRunning()) {mailbox.take(MIN_PRIORITY).run();}// 返回Mailbox是否还在Loopreturn isMailboxLoopRunning();
}

很核心的一个点就是Mailbox要去createBatch,TaskMailboxImpl提供了具体的实现逻辑。Mailbox引入了2个队列,新Mail被add到Mailbox内的queue队列中(此过程受ReentrantLock保护)。同时为了减少读取queue队列时的同步开销,Mailbox还构建了一个batch队列专门用来后续消费(避免加锁操作)。

/*** 对Deque<Mail>队列的读写,通过ReentrantLock加以保护*/
private final ReentrantLock lock = new ReentrantLock();/*** Internal queue of mails.* 使用Deque(内部队列)保存所有的Mail*/
@GuardedBy("lock")
private final Deque<Mail> queue = new ArrayDeque<>();
/*** 为了减少读取queue队列所造成的同步开销,TaskMailbox会创建一个batch队列,queue队列中的Mail会被转移到batch队列中,* 有效避免了后续消费时的加锁操作*/
private final Deque<Mail> batch = new ArrayDeque<>();@Override
public boolean createBatch() {checkIsMailboxThread();/*** 如果queue队列中没有新Mail,那就要看batch队列是否为空。* 1.如果batch也是空的(Mailbox里已经没有任何Mail了,需要去processInput()了),那processMail()也会return true,* MailboxProcessor就会进入到while循环内部,执行processInput()来处理DataStream上的数据;* 2.如果batch不空,说明MailboxProcessor还需要继续processMail(),即取出Mail执行它(作为Runnable)的run()方法;* 由此可见,Mailbox中的batch队列中的Mail最终一定会被Mailbox线程消耗殆尽(轮询、处理),然后才会去processInput()*/if (!hasNewMail) { // 只要queue队列里还有Mail,hasNewMail就为truereturn !batch.isEmpty();}/**能走到这说明queue队列中仍有新Mail,接下来需要将它的新Mail向batch队列转移,该过程受ReentrantLock保护*/final ReentrantLock lock = this.lock;// 获取锁lock.lock();try {Mail mail;/**每次循环都将queue队列中的First Mail,转移到batch队列中,直至queue队列被消耗殆尽。此时一定return true*/while ((mail = queue.pollFirst()) != null) {batch.addLast(mail);}// 此时queue队列内的所有Mail都被转移到batch队列中了,queue中没有新Mail了hasNewMail = false;// 此时根据batch队列是否为空,MailboxProcessor会判断执行Mail的run() or processInput()return !batch.isEmpty();} finally {// 最终释放锁lock.unlock();}
}

如果Mailbox内的queue队列中仍有新Mail,那就在ReentrantLock的加持下将queue内的Mail全都转移到batch队列中;如果Mailbox内的queue队列中没有新Mail,那就看batch队列的情况了。决断权交给外层的MailboxProcessor,总的来看:

  • 如果batch队列中有Mail,MailboxProcessor会从Mailbox内的batch队列中逐个pollFirst,然后执行(它作为Runnable#run()方法),直到batch队列中的所有Mail全都被“消耗殆尽”为止
  • 如果batch队列中没有Mail,MailboxProcessor此时就没有Mail可处理了,那就直接processInput

1.Checkpoint Tigger

对Checkpoint的触发,是通过MailboxExecutor向Mailbox提交Mail的

/*** 触发执行StreamTask中的Checkpoint操作:异步的通过MailboxExecutor,将“执行Checkpoint”的请求封装成Mail后,* 提交到TaskMailbox中,最终由MailboxProcessor来处理*/
@Override
public Future<Boolean> triggerCheckpointAsync(CheckpointMetaData checkpointMetaData,CheckpointOptions checkpointOptions,boolean advanceToEndOfEventTime) {// 通过MailboxExecutor,将“触发执行Checkpoint”的具体逻辑封装成Mail,提交到Mailbox中,后期会被MailboxProcessor执行return mailboxProcessor.getMainMailboxExecutor().submit(// 触发Checkpoint的具体逻辑() -> triggerCheckpoint(checkpointMetaData, checkpointOptions, advanceToEndOfEventTime),"checkpoint %s with %s",checkpointMetaData,checkpointOptions);
}

triggerCheckpoint操作会被封装成Mail,添加到Mailbox中等待被处理。

@Override
public void execute(@Nonnull final RunnableWithException command,final String descriptionFormat,final Object... descriptionArgs) {try {mailbox.put(new Mail(command, priority, actionExecutor, descriptionFormat, descriptionArgs));} catch (IllegalStateException mbex) {throw new RejectedExecutionException(mbex);}
}

当然,Checkpoint的完成操作,也是同样的套路。

2.ProcessingTime Timer Trigger

/*** 借助Mailbox线程模型,由MailboxExecutor负责将"ProcessingTime Timer触发的消息"封装成Mail提交到TaskMailbox中,后续由MailboxProcessor处理*/
public ProcessingTimeService getProcessingTimeService(int operatorIndex) {Preconditions.checkState(timerService != null, "The timer service has not been initialized.");MailboxExecutor mailboxExecutor = mailboxProcessor.getMailboxExecutor(operatorIndex);// 通过MailboxExecutor将Mail提交到Mailbox中等待处理return new ProcessingTimeServiceImpl(timerService, callback -> deferCallbackToMailbox(mailboxExecutor, callback));
}private ProcessingTimeCallback deferCallbackToMailbox(MailboxExecutor mailboxExecutor, ProcessingTimeCallback callback) {return timestamp -> {mailboxExecutor.execute(() -> invokeProcessingTimeCallback(callback, timestamp),"Timer callback for %s @ %d",callback,timestamp);};
}

processInput

StreamInputProcessor会对输入的数据进行处理、输出,包含:StreamTaskInput + OperatorChain + DataOutput。每次processInput都相当于是在处理一个有界流(外层MailboxProcessor在不断地的轮询),处理完DataStream上的StreamRecord后,会返回InputStatus的枚举值,根据InputStatus值来决定下一步该“何去何从”。

/*** StreamTask的执行逻辑:处理输入的数据,返回InputStatus状态,并根据InputStatus决定是否需要结束当前Task。* 该方法会通过MailboxProcessor调度、执行(作为MailboxProcessor的默认动作),底层调用StreamInputProcessor#processInput()方法*/
protected void processInput(MailboxDefaultAction.Controller controller) throws Exception {/*** 核心:借助StreamInputProcessor完成数据的读取,并交给算子处理,处理完毕后会返回InputStatus。* 每次触发,相当于处理一个有界流,在外层Mailbox拉取Mail才是while循环无限拉取*/InputStatus status = inputProcessor.processInput();/*** case 1:上游如果还有数据 && RecordWriter是可用的,立即返回。意为:继续处理!*/if (status == InputStatus.MORE_AVAILABLE && recordWriter.isAvailable()) {return;}/*** case 2:当状态为END_OF_INPUT,说明本批次的有界流数据已经处理完毕,* 通过MailboxCollector来告诉Mailbox*/if (status == InputStatus.END_OF_INPUT) {controller.allActionsCompleted();return;}/*** case 3:当前有界流中没有数据,但未来可能会有。此时处理线程会被挂起:直到有新的可用数据到来 && RecordWriter可用* 此时会先临时暂停对MailboxDefaultAction的处理,等啥时候又有新数据了,再重新恢复MailboxDefaultAction的处理。*/CompletableFuture<?> jointFuture = getInputOutputJointFuture(status);// 通过MailboxCollector让Mailbox线程暂时停止对MailboxDefaultAction的处理MailboxDefaultAction.Suspension suspendedDefaultAction = controller.suspendDefaultAction();// 等啥时候又有了input、output,RecordWriter也变得可用了以后,再重新继续执行默认操作jointFuture.thenRun(suspendedDefaultAction::resume);
}

MailboxController是MailboxDefaultAction和Mailbox之间交互的桥梁,在StreamTask处理DataStream元素的过程中,会利用MailboxController将处理状态及时通知给Mailbox。如果这批有界流处理完毕,就会通过MailboxController通知Mailbox(本质就是向Mailbox发送一个Mail),进行下一轮的处理。

private void sendControlMail(RunnableWithException mail, String descriptionFormat, Object... descriptionArgs) {mailbox.putFirst(new Mail(mail,Integer.MAX_VALUE /*not used with putFirst*/,descriptionFormat,descriptionArgs));
}

兼容SourceStreamTask

作为DataStream Source是专门用来生产无界流数据的,并不能穿插兼顾Mailbox内Mail的检测。如果仅有一个线程生产无界流数据的话,那将永远无法检测Mailbox内的Mail。作为StreamTask的子类,SourceStreamTask会额外启动另一个独立的LegacySourceFunctionThread线程来执行SourceFunction中的循环(生产无界流),Mailbox线程(主线程)依然负责处理Mail和默认操作。

/*** 专门为Source源生产数据的线程*/
private class LegacySourceFunctionThread extends Thread {private final CompletableFuture<Void> completionFuture;LegacySourceFunctionThread() {this.completionFuture = new CompletableFuture<>();}@Overridepublic void run() {try {// CheckpointLock保证线程安全headOperator.run(getCheckpointLock(), getStreamStatusMaintainer(), operatorChain);completionFuture.complete(null);} catch (Throwable t) {// Note, t can be also an InterruptedExceptioncompletionFuture.completeExceptionally(t);}}public void setTaskDescription(final String taskDescription) {setName("Legacy Source Thread - " + taskDescription);}CompletableFuture<Void> getCompletionFuture() {return isFailing() && !isAlive() ? CompletableFuture.completedFuture(null) : completionFuture;}
}

负责为Source生产无界流数据的LegacySourceFunctionThread线程启动后,不管是启动成功 or 出现异常,都会封装对应的Mail并发送给Mailbox,而Mailbox线程的processMail一直在等待处理Mail。

/*** SourceStreamTask中,一个Thread负责专门生产无界流,另一个MailBox Thread处理Checkpoint、ProcessingTime Timer等事件Mail*/
@Override
protected void processInput(MailboxDefaultAction.Controller controller) throws Exception {/*** 通过MailboxDefaultAction.Controller告诉Mailbox:让MailboxThread先暂停处理MailboxDefaultAction。* TaskMailbox收到该消息后,就会在processMail()中一直等待并处理Mail(在MailboxThread中会一直处理Mail)*/controller.suspendDefaultAction();/**启动LegacySourceFunctionThread线程:专门生产Source无界流数据的,和MailboxThread线程一起运行*/sourceThread.setTaskDescription(getName());sourceThread.start();/**LegacySourceFunctionThread线程启动后,会通知Mailbox,Mailbox会在processMail()中一直等待并处理mail(不会返回,即Mailbox线程会一直处理mail)*/sourceThread.getCompletionFuture().whenComplete((Void ignore, Throwable sourceThreadThrowable) -> {/**LegacySourceFunctionThread线程启动过程中发生的任何异常、以及启动成功,都会以Mail的形式发送给Mailbox*/if (isCanceled() && ExceptionUtils.findThrowable(sourceThreadThrowable, InterruptedException.class).isPresent()) {mailboxProcessor.reportThrowable(new CancelTaskException(sourceThreadThrowable));} else if (!isFinished && sourceThreadThrowable != null) {mailboxProcessor.reportThrowable(sourceThreadThrowable);} else {mailboxProcessor.allActionsCompleted();}});
}

Mailbox主线程和LegacySourceFunctionThread线程线程都在运行,通过CheckpointLock锁来保证线程安全。

相关文章:

深入理解Flink Mailbox线程模型

文章目录 整体设计processMail1.Checkpoint Tigger2.ProcessingTime Timer Trigger processInput兼容SourceStreamTask 整体设计 Mailbox线程模型通过引入阻塞队列配合一个Mailbox线程的方式&#xff0c;可以轻松修改StreamTask内部状态的修改。Checkpoint、ProcessingTime Ti…...

Docker搭建LNMP运行Wordpress平台

一、项目1.1 项目环境1.2 服务器环境1.3 任务需求 二、Linux 系统基础镜像三、Nginx1、建立工作目录2、编写 Dockerfile 脚本3、准备 nginx.conf 配置文件4、生成镜像5、创建自定义网络6、启动镜像容器7、验证 nginx 四、Mysql1、建立工作目录2、编写 Dockerfile3、准备 my.cnf…...

10个常见渐变交互效果

1、透明度渐变背景交互 <div class"fade-background"></div> Copy .fade-background {width: 200px;height: 200px;background: linear-gradient(to bottom, rgba(255, 0, 0, 0), rgba(255, 0, 0, 1));transition: background 0.5s ease; }.fade-backgro…...

[线程/C]基础

文章目录 1. 线程介绍2. 创建线程2.1 线程函数2.2 创建线程 3. 线程退出4. 线程回收4.1 线程函数4.2 回收子线程数据4.2.1 使用子线程栈4.2.2 使用全局变量4.2.3 使用主线程栈 5. 线程分离6. 其他线程函数6.1 线程取消6.2 线程ID的比较 1. 线程介绍 线程是轻量级的进程&#x…...

Spring Clould 负载均衡 - Ribbon

视频地址&#xff1a;微服务&#xff08;SpringCloudRabbitMQDockerRedis搜索分布式&#xff09; Ribbon-负载均衡原理&#xff08;P14&#xff09; 具体实现时通过LoaBalanced注解实现&#xff0c;表示RestTemplate要被Ribbon拦截处理 orderservice调用user时候&#xff0c…...

活用DNS技术实现相同IP的不同端口映射不同域名

WindowsDNS基本配置 在内网的 Windows 服务器环境中&#xff0c;你可以通过配置 DNS 服务和 Web 服务器来实现所需的域名解析和端口转发。如下是一些基本的步骤来实现配置&#xff1a; 1&#xff0c;配置 Windows DNS 服务 在你的 Windows 服务器上配置 DNS 服务&#xff0c…...

AutoHotkey:定时删除目录下指定分钟以前的文件,带UI界面

删除指定目录下&#xff0c;所有在某个指定分钟以前的文件&#xff0c;可以用来清理经常生成很多文件的目录&#xff0c;但又需要保留最新的一部分文件 支持拖放目录到界面 能够记忆设置&#xff0c;下次启动后不用重新设置&#xff0c;可以直接开始 应用场景比如&#xff1a…...

一文学会sklearn中的交叉验证的方法

前言 在机器学习中&#xff0c;我们经常需要评估模型的性能。而为了准确评估模型的性能&#xff0c;我们需要使用一种有效的评估方法。五折交叉验证&#xff08;5-fold cross-validation&#xff09;就是其中一种常用的模型评估方法&#xff0c;用于评估机器学习模型的性能和泛…...

【MySQL面试题(66道)】

文章目录 MySQL面试题(66道)基础1.什么是内连接、外连接、交叉连接、笛卡尔积呢&#xff1f;2.那 MySQL 的内连接、左连接、右连接有有什么区别&#xff1f;3.说一下数据库的三大范式&#xff1f;4.varchar 与 char 的区别&#xff1f;5.blob 和 text 有什么区别&#xff1f;6.…...

CSSCI、北核期刊投稿指南(2023年更新)

该数据为经管类的期刊投稿指南&#xff0c;包含发表难度&#xff0c;文章数量&#xff0c;影响因子&#xff0c;用户评价等指标。共5份文件&#xff0c;分别为国内所有期刊信息库、投稿指南&#xff08;CSSCI版本、CSSCI扩展版本、北大核刊版本、建议期刊版本&#xff09; 一、…...

构建 NodeJS 影院微服务并使用 docker 部署它(02/4)

一、说明 构建一个微服务的电影网站&#xff0c;需要Docker、NodeJS、MongoDB&#xff0c;这样的案例您见过吗&#xff1f;如果对此有兴趣&#xff0c;您就继续往下看吧。 图片取自网络 — 封面由我制作 这是✌️“构建 NodeJS 影院微服务”系列的第二篇文章。 二、对第一部分的…...

HTML <style> 标签

实例 <html> <head> <style type="text/css"> h1 {color:red} p {color:blue} </style> </head><body> <h1>Header 1</h1> <p>A paragraph.</p> </body> </html>定义和用法 <style>…...

设计模式——迪米特法则

文章目录 基本介绍应用实例应用实例改进迪米特法则注意事项和细节 基本介绍 一个对象应该对其他对象保持最少的了解类与类关系越密切&#xff0c;耦合度越大迪米特法则(Demeter Principle)又叫最少知道原则&#xff0c;即一个类对自己依赖的类知道的越少越好。也就是说&#x…...

区块链基本概念与当前生态简介

区块链是一种去中心化的分布式账本技术&#xff0c;它通过将数据按照时间顺序链接成区块&#xff0c;并使用密码学算法确保数据的安全性和完整性。每个区块包含一定数量的交易记录&#xff0c;而且每个区块都包含了前一个区块的哈希值&#xff0c;这样形成了一个不可篡改的链式…...

mac安装lrzsz出错Command failed with exit 128: git

终端检查电脑是否安装了rz和sz which sz若报错&#xff0c;则需要下载。由于网络和代理的原因&#xff0c;以下命令会报错&#xff1a; brew install lrzsz是因为brew和git配置的代理存在冲突&#xff0c;对于无外网链接功能&#xff0c;无特殊配置的git而言&#xff0c;需要…...

“深入探索JVM内部机制:揭秘Java虚拟机“

标题&#xff1a;深入探索JVM内部机制&#xff1a;揭秘Java虚拟机 摘要&#xff1a;本文将深入探索Java虚拟机&#xff08;JVM&#xff09;的内部机制&#xff0c;从内存管理、垃圾回收、即时编译等方面进行详细剖析。通过了解JVM的工作原理&#xff0c;我们可以更好地理解Jav…...

lvs-DR

lvs-DR数据包流向分析 client向目标VIP发出请求。 DIR根据负载均衡算法一台active的RS&#xff08;RIR1&#xff09;&#xff0c;将RIP1所在的网卡的mac地址作为目标的mac地址&#xff0c;发送到局域网里。 RIRI在局域网中的收到这个帧&#xff0c;拆开后发现目标&#xff08…...

Vue 项目运行 npm install 时,卡在 sill idealTree buildDeps 没有反应

解决方法&#xff1a;切换到淘宝镜像。 以下是之前安装的 xmzs 包&#xff0c;用于控制切换淘宝镜像。 该截图是之前其他项目切换淘宝镜像的截图。 切换镜像后&#xff0c;顺利执行 npm install 。...

ShardingSphere介绍

ShardingSphere从4.X到5.X的内容发生了很多的改变&#xff0c;感兴趣的伙伴可以到ShardingSphere的博客查看各个版本的新特性。https://blog.csdn.net/ShardingSphere?typeblog 此次使用最新版本 shardingShpere5.4.0&#xff0c;实现数据库读写分离、数据分片、分布式事务等…...

【SA8295P 源码分析】44 - 如何替换 NON-HLOS.bin 中的 Wifi Firmware 固件

【SA8295P 源码分析】44 - 如何替换 NON-HLOS.bin 中的 Wifi Firmware 固件 1、提取 NON-HLOS.bin 中的 Wifi Firmware 出来2、把提取出来的 wifi 固件放到代码中3、重新打包生成 NON-HLOS.bin4、将生成的 NON-HLOS.bin 与 老的 NON-HLOS.bin 对比5、使用fastboot 下载测试wifi…...

树莓派超全系列教程文档--(61)树莓派摄像头高级使用方法

树莓派摄像头高级使用方法 配置通过调谐文件来调整相机行为 使用多个摄像头安装 libcam 和 rpicam-apps依赖关系开发包 文章来源&#xff1a; http://raspberry.dns8844.cn/documentation 原文网址 配置 大多数用例自动工作&#xff0c;无需更改相机配置。但是&#xff0c;一…...

DeepSeek 赋能智慧能源:微电网优化调度的智能革新路径

目录 一、智慧能源微电网优化调度概述1.1 智慧能源微电网概念1.2 优化调度的重要性1.3 目前面临的挑战 二、DeepSeek 技术探秘2.1 DeepSeek 技术原理2.2 DeepSeek 独特优势2.3 DeepSeek 在 AI 领域地位 三、DeepSeek 在微电网优化调度中的应用剖析3.1 数据处理与分析3.2 预测与…...

视频字幕质量评估的大规模细粒度基准

大家读完觉得有帮助记得关注和点赞&#xff01;&#xff01;&#xff01; 摘要 视频字幕在文本到视频生成任务中起着至关重要的作用&#xff0c;因为它们的质量直接影响所生成视频的语义连贯性和视觉保真度。尽管大型视觉-语言模型&#xff08;VLMs&#xff09;在字幕生成方面…...

Spring AI 入门:Java 开发者的生成式 AI 实践之路

一、Spring AI 简介 在人工智能技术快速迭代的今天&#xff0c;Spring AI 作为 Spring 生态系统的新生力量&#xff0c;正在成为 Java 开发者拥抱生成式 AI 的最佳选择。该框架通过模块化设计实现了与主流 AI 服务&#xff08;如 OpenAI、Anthropic&#xff09;的无缝对接&…...

Xen Server服务器释放磁盘空间

disk.sh #!/bin/bashcd /run/sr-mount/e54f0646-ae11-0457-b64f-eba4673b824c # 全部虚拟机物理磁盘文件存储 a$(ls -l | awk {print $NF} | cut -d. -f1) # 使用中的虚拟机物理磁盘文件 b$(xe vm-disk-list --multiple | grep uuid | awk {print $NF})printf "%s\n"…...

网站指纹识别

网站指纹识别 网站的最基本组成&#xff1a;服务器&#xff08;操作系统&#xff09;、中间件&#xff08;web容器&#xff09;、脚本语言、数据厍 为什么要了解这些&#xff1f;举个例子&#xff1a;发现了一个文件读取漏洞&#xff0c;我们需要读/etc/passwd&#xff0c;如…...

七、数据库的完整性

七、数据库的完整性 主要内容 7.1 数据库的完整性概述 7.2 实体完整性 7.3 参照完整性 7.4 用户定义的完整性 7.5 触发器 7.6 SQL Server中数据库完整性的实现 7.7 小结 7.1 数据库的完整性概述 数据库完整性的含义 正确性 指数据的合法性 有效性 指数据是否属于所定…...

日常一水C

多态 言简意赅&#xff1a;就是一个对象面对同一事件时做出的不同反应 而之前的继承中说过&#xff0c;当子类和父类的函数名相同时&#xff0c;会隐藏父类的同名函数转而调用子类的同名函数&#xff0c;如果要调用父类的同名函数&#xff0c;那么就需要对父类进行引用&#…...

《Docker》架构

文章目录 架构模式单机架构应用数据分离架构应用服务器集群架构读写分离/主从分离架构冷热分离架构垂直分库架构微服务架构容器编排架构什么是容器&#xff0c;docker&#xff0c;镜像&#xff0c;k8s 架构模式 单机架构 单机架构其实就是应用服务器和单机服务器都部署在同一…...

DiscuzX3.5发帖json api

参考文章&#xff1a;PHP实现独立Discuz站外发帖(直连操作数据库)_discuz 发帖api-CSDN博客 简单改造了一下&#xff0c;适配我自己的需求 有一个站点存在多个采集站&#xff0c;我想通过主站拿标题&#xff0c;采集站拿内容 使用到的sql如下 CREATE TABLE pre_forum_post_…...