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

Kafka生产者相关

news 来源：原创 2025/9/11 14:36:08

windows中kafka集群部署示例-CSDN博客

先启动集群或者单机也OK

引入依赖

    <dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>3.9.0</version></dependency>

关于主题创建

理论来讲创建主题(Topic是Kafka的内部操作),无论生产者或是消费者都不能主动创建主题.

没有主题就不能生产数据

但是往往看到生产者可以创建主题,原因是kafka的内部自动创建主题机制,当生产者中有个管理员,没有该主题就会自动创建

auto.create.topics.enable 默认是true 如果改成false 那么生产者就无法创建了

因此主题是kafka的自动创建主题的机制来实现的,而非生产者创建主题

生产者利用kafka自动创建主题的机制来创建主题...........................................................................

/*** @author hrui* @date 2025/2/26 12:53*/
public class AdminTopicTest {public static void main(String[] args) {Map<String,Object> confMap=new HashMap<>();//例如我的集群是9091  9092 9093  这里无需关心具体连接哪个端口  随意一个端口confMap.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9091");//管理员对象Admin admin=Admin.create(confMap);/*** 构建主题的三个参数* 第一个参数:主题名称* 第二个参数:分区数量* 第三个参数:副本数量(short类型)*/NewTopic newTopic=new NewTopic("test1",1, (short) 1);//创建主题CreateTopicsResult topics = admin.createTopics(Arrays.asList(newTopic));//关闭管理者对象admin.close();}
}

NewTopic("test1",这里可以传个Map);可以自定义主题分区副本策略不指定就默认

生产者流程图

生产者大致代码

public class KafkaProducerTest {public static void main(String[] args) {//创建配置对象Map<String,Object> configMap=new HashMap<>();//如果是集群随意指定一个configMap.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");//对Key Value进行序列化操作configMap.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());configMap.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());//创建生产者对象KafkaProducer<String,String> kafkaProducer=new KafkaProducer<>(configMap);for(int i=0;i<10;i++){//key的作用是通过某种算法,放到topic的某个分区中ProducerRecord<String, String> record = new ProducerRecord<>("test", "key1","hello kafka" + i);kafkaProducer.send(record);}//关闭生产者对象kafkaProducer.close();}
}

生产者拦截器

可以对照流程图,看下生产者拦截器在什么位置,一般是对Key value的整理转换,对生产的数据做统一规范化处理,可以配置多个

可以点进去

大致就是这么个过程

遍历拦截器并调用每个拦截器的onSend方法

可以看到每个拦截器都是ProducerInterceptor类型

自定义生产者拦截器

自定义一个类实现ProducerInterceptor

在创建生产者时候添加拦截器配置

生产者拦截器

package com.hrui.interceptor;import org.apache.kafka.clients.producer.ProducerInterceptor;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;import java.util.Map;/*** @author hrui* @date 2025/2/26 14:20*/
public class ValueInterceptor implements ProducerInterceptor<String,String> {@Override//发送数据的时候,会调用public ProducerRecord<String, String> onSend(ProducerRecord<String, String> producerRecord) {System.out.println("拦截器拦截到消息："+producerRecord.value());return new ProducerRecord<>(producerRecord.topic(),producerRecord.key(),producerRecord.value()+"-拦截器");}@Override//发送数据完毕,服务器返回的响应,会调用此方法public void onAcknowledgement(RecordMetadata recordMetadata, Exception e) {}@Override//生产者对象关闭时候,会调用此方法public void close() {}@Override//创建生产者对象时候调用public void configure(Map<String, ?> map) {}
}

启动下

生产者数据发送同步或异步

如果需要同步

ACKS数据接收应答处理机制

指的是:

生产者发送数据到 Kafka Broker 时，Kafka 如何处理消息的接收确认。通过设置 ACKS 参数，你可以控制 Kafka 如何在生产者发送消息后确认数据是否成功写入。

ACKS三个配置

ACKS=0 生产者发送数据之后,不等待任何确认,发送了就认为你可能收到了,丢失不管

ACKS=1 生产者会等待 分区的主副本（Leader）确认消息已经写入到其磁盘中，主副本发送成功确认后，生产者就认为消息已经成功发送。如果主副本挂了消息仍可能丢失，除非有副本在进行同步

ACKS=all(或ACKS=-1) 等待所有副本确认消息保证不会丢失性能会较低，因为生产者需要等待所有副本确认

默认ACKS=-1

生产者数据重试(重发)功能

例如ACKS=1的情况下 Leader还没来的及将数据保存到磁盘

Broker挂了,此时生产者在等待回调但是一直没回复,超过等待时间

Kafka退出超时重试机制 retry

可以配置retry重试机制

重试机制带来了好处,也有坏处

例如 broker并没有挂只是因为网络不稳定这就产生了数据重复和乱序现象

如何避免数据重复

如果ACSK 1或者-1(就是ALL)就是为了数据不丢失,增强可靠性

如果你禁用重试肯定是不行的

但是重试又会导致数据重复和乱序现象

Kafka提供了生产者幂等性操作:所谓生产者幂等性操作就是生产者的消息无论向Kafka发送多少次,

Kafka的Leader只会保存一条,默认的幂等性是不起作用的

开启

要启用生产者的幂等性，必须设置以下两个配置：

acks=all（或 acks=-1）：这要求生产者等待所有副本确认消息已成功写入，确保数据的持久性和一致性。
enable.idempotence=true：启用幂等性保证。
且要开启重试处理
在途请求缓冲区数量指的是 Kafka 生产者在发送消息时，等待确认的消息数量默认是5 不能超过5

在途请求缓冲区的数量:max.in.flight.requests.per.connection

幂等性 确保了相同分区内的消息不会重复，但在 多个分区 的情况下，跨分区的消息仍然无法避免乱序

生产者事务操作

事务可以保证生产者 ID 唯一解决跨会话每次重启生产者ID会变化加了事务可以保持不变

package com.hrui;import com.hrui.interceptor.KafkaProducerInterceptorTest;
import com.hrui.interceptor.ValueInterceptor;
import org.apache.kafka.clients.producer.*;
import org.apache.kafka.common.serialization.StringSerializer;import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;/*** @author hrui* @date 2025/2/26 13:36*/
public class KafkaProducerTest {public static void main(String[] args) throws ExecutionException, InterruptedException {//创建配置对象Map<String,Object> configMap=new HashMap<>();//如果是集群随意指定一个configMap.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");//对Key Value进行序列化操作configMap.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());configMap.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());configMap.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, ValueInterceptor.class.getName());//可以配置ACKSconfigMap.put(ProducerConfig.ACKS_CONFIG,"-1");//配置幂等性configMap.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG,true);//配置重试次数configMap.put(ProducerConfig.RETRIES_CONFIG,3);//配置超时configMap.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG,3000);//配置事务 事务基于幂等性configMap.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG,"my-tx-id");//创建生产者对象KafkaProducer<String,String> kafkaProducer=new KafkaProducer<>(configMap);//初始化事务kafkaProducer.initTransactions();try {//开启事务kafkaProducer.beginTransaction();for(int i=0;i<10;i++){//key的作用是通过某种算法,放到topic的某个分区中//可以不设置key 默认是按照轮询的方式ProducerRecord<String, String> record = new ProducerRecord<>("test", "key1","hello kafka" + i);//发送数据  send方法还可以接收一个参数,就是回调函数  kafkaProducer.send(record);是异步的Future<RecordMetadata> send = kafkaProducer.send(record, new Callback() {@Overridepublic void onCompletion(RecordMetadata recordMetadata, Exception e) {if (e != null) {// 处理发送失败的情况e.printStackTrace();} else {// 处理发送成功的情况System.out.println("发送成功:" + recordMetadata);}}});send.get();}//提交事务kafkaProducer.commitTransaction();}catch (Exception e){e.printStackTrace();//中止事务kafkaProducer.abortTransaction();}finally {//关闭生产者对象kafkaProducer.close();}}
}

添加事务后生产者默认会创建一个事务topic 默认50个分区

Kafka生产者相关

windows中kafka集群部署示例-CSDN博客先启动集群或者单机也OK 引入依赖 <dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>3.9.0</version></dependency>关于主题创建理论…...

编程日记 2025/9/11 14:36:08

【容器化】低版本docker拉取ubuntn 22.04镜像启动容器执行apt update提示 NO_PUBKEY 871920D1991BC93C

前置信息宿主机信息 [root@localhost ~]# cat /etc/os-release NAME="CentOS Linux" VERSION="7 (Core)" ID="centos" ID_LIKE="rhel fedora" VERSION_ID="7" PRETTY_NAME="CentOS Linux 7 (Core)" ANSI_COLOR…...

编程日记 2025/9/11 1:25:29

如何流畅访问github

1.传输数据原理本地计算机通过本地网接入运营骨干网，经过DNS域名解析，将输入的字符解析为要连接的真实IP地址，服务器返还一个数据包(github)给计算机 2.原因 DNS域名污染-DNS解析出现问题，导致访问一个不存在的服务器 3.解决…...

编程日记 2025/9/11 14:33:05

一、路由添加 1、官网地址带参数的动态路由匹配 | Vue Routerhttps://router.vuejs.org/zh/guide/essentials/dynamic-matching.html 2、复制核心语句 { path: /:pathMatch(.*)*, name: NotFound, component: NotFound } 3、粘贴到路由index.js中 4、建立页面在view文件夹…...

编程日记 2025/9/11 14:34:23

纯c#字体处理库（FontParser） -- 轻量、极速、跨平台、具有字体子集化功能

关于字体库与 FontParser 的开发历程　　字体库是用于处理和渲染字体的软件工具，其功能通常涵盖字体文件的加载、解析、字形渲染和文本布局等核心模块。在众多字体库中，FreeType 是被广泛应用且极具影响力的开源项目，已成为事实上的行业标准…...

编程日记 2025/9/11 14:36:08

云和恩墨亮相PolarDB开发者大会，与阿里云深化数据库服务合作

2025年2月26日，备受瞩目的阿里云PolarDB开发者大会于北京嘉瑞文化中心盛大举行，众多行业精英齐聚一堂，共襄技术盛会。云和恩墨作为阿里云重要的生态合作伙伴受邀参会。云和恩墨联合创始人兼技术研究院总经理杨廷琨与阿里云智能数据库产品事业…...

编程日记 2025/9/9 0:16:16

【通俗讲解电子电路】——从零开始理解生活中的电路(二)

电路分析：看懂简单的“电路图” ——从“路线图”到“工具箱”，掌握电路的底层逻辑 1. 欧姆定律：电的“交通规则” 公式解析：V I R 电压（V）：推动电流的动力（如电池电压&#xff…...

编程日记 2025/9/11 14:36:08

Spring DIIoC

一.IoC 1.简介什么是IoC？IoC，全称 Inversion of Control，控制反转。IoC是Spring的核心思想，Spring是⼀个“控制反转”的容器。如果我们需要一个对象，正常来说我们是通过new一个对象，这个时候我们依赖的…...

编程日记 2025/9/6 1:39:03

基于javaweb的SSM+Maven幼儿园管理系统设计和实现(源码+文档+部署讲解）

技术范围：SpringBoot、Vue、SSM、HLMT、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、小程序、安卓app、大数据、物联网、机器学习等设计与开发。主要内容：免费功能设计、开题报告、任务书、中期检查PPT、系统功能实现、代码编写、论文编写和辅导、论…...

编程日记 2025/9/5 1:06:15

C++22——哈希

目录 1.unordered_map的文档介绍 2.unordered_set的文档介绍 3.底层结构 3.1哈希的概念 3.2哈希冲突 3.3哈希函数 3.4哈希冲突解决 3.4.1闭散列 3.4.2开散列 1.unordered_map的文档介绍 unordered_map在线文档说明 unordered_map是存储<key，value>键值…...

编程日记 2025/9/11 14:34:22

使用Spring Boot与达梦数据库(DM)进行多数据源配置及MyBatis Plus集成

使用Spring Boot与达梦数据库(DM)进行多数据源配置及MyBatis Plus集成在现代企业级应用开发中，处理多个数据源是一个常见的需求。本文将详细介绍如何使用Spring Boot结合达梦数据库（DM），并通过MyBatis Plus来简化数据库操作&…...

编程日记 2025/9/11 14:34:23

Servlet简介

Servlet是sun公司提供的一门用于开发动态web资源的技术。 Sun公司在其API中提供了一个servlet接口，用户若想用发一个动态web资源(即开发一个Java程序向浏览器输出数据)，需要完成以下2个步骤： 编写一个Java类，实现servlet接口。 …...

编程日记 2025/9/5 14:46:10

智能合约安全 | 合约无效化攻击

目录： 智能合约安全合约无效化攻击合约自毁函数 selfdestruct 攻击实现漏洞防御总结智能合约安全合约无效化攻击合约无效化攻击类同于web安全中的逻辑漏洞中的一种我们这里拿一个典型的例子来讲解有这样一份智能合约, 每个人可以向其中发送1 eth 第七个…...

编程日记 2025/9/11 14:34:23

20250226-代码笔记05-class CVRP_Decoder

文章目录前言一、class CVRP_Decoder(nn.Module):__init__(self, **model_params)函数功能函数代码二、class CVRP_Decoder(nn.Module):set_kv(self, encoded_nodes)函数功能函数代码三、class CVRP_Decoder(nn.Module):set_q1(self, encoded_q1)函数功能函数代码四、class…...

编程日记 2025/9/10 13:44:09

【开源免费】基于SpringBoot+Vue.JS网络海鲜市场系统（JAVA毕业设计）

本文项目编号 T 222 ，文末自助获取源码 \color{red}{T222，文末自助获取源码} T222，文末自助获取源码目录一、系统介绍二、数据库设计三、配套教程3.1 启动教程3.2 讲解视频3.3 二次开发教程四、功能截图五、文案资料5.1 选题背景5.2 国内…...

编程日记 2025/9/10 22:43:55

【LeetCode: SQL专题 : SQL132 每个题目和每份试卷被作答的人数和次数 + 合并查询】

🚀 算法题 🚀 🌲 算法刷题专栏 | 面试必备算法 | 面试高频算法 🍀 🌲 越难的东西,越要努力坚持，因为它具有很高的价值，算法就是这样✨ 🌲 作者简介：硕风和炜，…...

编程日记 2025/9/9 9:54:36

【软考-架构】1.2、指令系统-存储系统-cache

GitHub地址：https://github.com/tyronczt/system_architect ✨资料&文章更新✨ 指令系统计算机指令执行过程：取指令一一分析指令一一执行指令三个步骤，首先将程序计数器PC中的指令地址取出，送入地址总线，CPU依据…...

编程日记 2025/9/9 16:47:36

Uniapp开发微信小程序插件的一些心得

一、uniapp 开发微信小程序框架搭建 1. 通过 vue-cli 创建 uni-ap // nodejs使用18以上的版本 nvm use 18.14.1 // 安装vue-cli npm install -g vue/cli4 // 选择默认模版 vue create -p dcloudio/uni-preset-vue plugindemo // 运行 uniapp2wxpack-cli npx uniapp2wxpack --…...

编程日记 2025/9/11 14:33:05

C++-第十八章：线程相关内容

目录第一节：thread的主要内容 1-1.创建子线程 1-2.回收子线程 1-3.获得子线程的id 1-4.获得当前线程id 1-5.子线程传引用 1-6.线程的先创建后使用第二节：mutex的主要内容 2-1.mutex的作用 2-2.智能锁第三节：condition_variable的主要内…...

编程日记 2025/9/11 14:34:23

纯函数（Pure Function）概念

纯函数（Pure Function）概念纯函数是函数式编程中的核心概念，满足以下两个条件： 确定性：相同的输入永远得到相同的输出，不依赖外部状态或随机性。无副作用：不会修改外部变量、参数、I/O设备或…...

编程日记 2025/9/11 3:52:08

【网络安全】敏感字段扫描工具（可用于漏洞挖掘、代码审计）

原创文章，禁止转载。读者可对脚本进行二次创作，以适配个人需求。文章目录 ScanSensitiveInfo.py效果图ScanSensitiveInfo.py 该脚本用于扫描敏感字段、代码中可能引入的第三方JS链接/服务以及可能涉及信息泄露的请求方法。 1、脚本采用单线程处理，避免多线程导致的混行问…...

编程日记 2025/9/11 14:33:05

介绍下pdf打印工具类 JasperPrint

JasperPrint 工具类深度解析 JasperPrint 是 JasperReports 框架中实现 PDF 打印的核心载体类，其本质是填充数据后的可打印报表对象，承担着从模板编译、数据填充到格式输出的全流程控制。以下从 7 个维度展开深度解析： 一、核心定位与生命周…...

编程日记 2025/9/11 14:34:24

Deepseek Api Function Calling解析（tools、tool_calls）Deepseek函数调用流程图、Python代码示例

文章目录 Function Calling介绍**核心原理**1. **动态扩展模型能力**2. **JSON结构化交互** **实现步骤**（以支持Function Calling的模型为例）1. **定义可用函数**2. **模型匹配与生成**3. **开发者执行函数**4. **结果反馈给模型** **DeepSeek R1的当前…...

编程日记 2025/9/11 14:33:05

分享一套适合做课设的SpringBoot商城系统

开学季到了，不少同学都进入了学习的状态中去了，趁着今天有空来分享一套商城系统，这套代码实现了商城的前后台，整体界面和代码非常简洁，熟悉项目之后可以根据需求进行二次开发，也适合用来做毕设、课设&#…...

编程日记 2025/9/7 0:30:30

C语言自定义类型：联合和枚举

在C语言中，联合（Union）和枚举（Enum）是两种重要的的自定义数据类型。它们分别适用于不同的场景，能够提升代码的效率和可维护性。。本文将结合代码示例，详细讲解它们的声明、特点及使用方法。一、…...

编程日记 2025/9/8 6:24:39

Redis SCAN 命令详解：安全遍历海量键的利器

一、SCAN 命令的核心价值 Redis 的 KEYS * 命令虽然可以遍历所有键，但在生产环境中直接使用可能导致服务阻塞（时间复杂度 O(n)）。SCAN 命令通过游标分批次迭代，实现非阻塞式遍历，成为处理百万级键的安全选择。二、命…...

编程日记 2025/9/6 22:14:28

文字滚动效果组件和按钮组件

今天和大家分享一个vue中好用的组件，是我自己写的，大家也可以自己改，就是文字的循环滚动效果，如下图，文字会向左移动，结束之后也会有一个循环，还有一个按钮组件，基本框架写的差不多了…...

编程日记 2025/9/10 3:46:48

Sqlserver安全篇之_TLS的证书概念

证书的理解参考Sqlserver的官方文档https://learn.microsoft.com/zh-cn/sql/database-engine/configure-windows/certificate-overview?viewsql-server-ver16 TLS(Transport Layer Security)传输层安全和SSL(Secure Sockets Layer)安全套接字层协议位于应用程序协议层和TCP/…...

编程日记 2025/9/9 22:27:31

VS Code 如何搭建CC++开发环境

VS Code 如何搭建C/C开发环境文章目录 VS Code 如何搭建C/C开发环境1. VS Code是什么2. VS Code的下载和安装2.1 下载和安装2.2 环境的介绍 3. VS Code配置C/C开发环境3.1 下载和配置MinGW-w64编译器套件3.2 安装C/C插件3.3 重启VS Code 4. 在VS Code上编写C语言代码并编译成功…...

编程日记 2025/9/10 0:57:07

计算机网络之传输层（传输层的功能）

一、数据分段与重组传输层从会话层接收数据，并将其分割成较小的数据段，以适应网络层的最大传输单元（MTU）限制。在目的端，传输层负责将这些数据段重新组合成原始数据，确保数据的完整性和正确性。二、端口…...

编程日记 2025/9/10 20:10:31

中科大计算机网络原理 1.5 Internt结构和ISP

一、互联网的层次化架构 ‌覆盖范围分层‌ ‌主干网（Tier-1级）‌ 国家级或行业级核心网络，承担跨区域数据传输和全球互联功能。例如中国的四大主干网（ChinaNET、CERNET等）以及跨国运营商（如AT&T、Deuts…...

编程日记 2025/9/10 20:23:36

【网络安全 | 渗透工具】小程序反编译分析源码 | 图文教程

未经许可，禁止转载。本文仅供学习使用，严禁用于非法渗透测试，笔者不承担任何责任。文章目录 1、下载Proxifier2、下载反编译工具unveilr3、寻找小程序文件包4、对文件包进行反编译5、对源码进行分析6、渗透思路6.1、查找敏感信息泄露6.2、解析加解密逻辑6.3、枚举 API 接口…...

编程日记 2025/9/4 1:36:52

在鸿蒙HarmonyOS手机上安装hap应用

一、下载工具安装hap包需要用到小工具。二、解压到目录后，进入该文件夹，打开命令行，如下图三、将下载好的hap包放入刚才解压的文件夹内（假设hap包文件名为app.hap） 四、连接好手机和电脑，手机需要打…...

编程日记 2025/9/5 4:41:02

SQLAlchemy系列教程：SQLAlchemy快速入门示例项目

SQLAlchemy是与数据库交互的Python开发人员不可或缺的库。这个强大的ORM允许使用python结构进行简单的数据库操作。设置过程很简单，并且允许可扩展的数据库应用程序开发。本文通过入门项目完整介绍SQLAlchemy的应用过程，包括安装依赖包，创建连…...

编程日记 2025/9/7 9:45:37

【大模型系列篇】DeepSeek开源周，解锁AI黑科技

🔥 Day1：FlashMLA —— GPU推理加速器专为处理长短不一的AI推理请求而生，就像给Hopper GPU装上了智能导航，让数据在芯片上跑出3000GB/s的"磁悬浮"速度。✅ 已支持BF16格式｜580万亿次浮点运算/秒FlashMLA G…...

编程日记 2025/9/9 17:41:53

【Java 基础（人话版）】Java SE vs Java EE

Java SE vs Java EE：有什么区别？ 最近在学习 Java 的时候，总是会看到 Java SE 和 Java EE 这两个概念。刚开始有点迷糊，后来查了资料、做了一些实验，终于弄清楚了它们的区别。这里记录一下，希望对以后复习…...

编程日记 2025/9/7 23:11:56

Nmap使用指南

Nmap使用指南 Nmap (网络映射器) 是一款强大的应用网络扫描和安全核查工具，适合于网络管理和安全专家。本文将介绍Nmap的基本使用方法，包括基本命令和常用功能。 1. 基本使用方式 Nmap的基本命令格式如下： nmap [选项] 目标地址目标地址可…...

编程日记 2025/9/8 5:52:36

C#-委托

Action 无返回值，多线程常用 Action<string> action1 (name) > Console.WriteLine($"hello {name}"); action1("tom"); Func 有返回值，扩展方法常用，最后一个参数是输出参数 Func<int, int, double>…...

编程日记 2025/8/16 12:40:21

Qt中如果槽函数运行时间久，避免阻塞主线程的做法

Qt中如果槽函数运行时间久，避免阻塞主线程的做法一、解决步骤创建一个工作线程类：继承自QObject，并在其中实现槽函数的逻辑。将工作线程类的实例移动到单独的线程中：通过moveToThread()方法将对象移动到新线程。启动线程&…...

编程日记 2025/9/7 9:12:29

SQLark 数据迁移｜断点续迁已上线（Oracle-达梦）

数据迁移是 SQLark 最受企业和个人用户欢迎的功能之一，截止目前已帮助政府、金融、能源、通信等 50 家单位完成从 Oracle、MySQL 到达梦的全量迁移，自动化迁移成功率达 96% 以上。在 Oracle 到达梦数据库迁移过程中，SQLark V3.3 新增断点续…...

编程日记 2025/9/9 18:45:41

【学术会议论文投稿】Spring Boot实战：零基础打造你的Web应用新纪元

第七届人文教育与社会科学国际学术会议（ICHESS 2024）_艾思科蓝_学术一站式服务平台更多学术会议请看：https://ais.cn/u/nuyAF3 目录一、Spring Boot简介 1.1 Spring Boot的诞生背景 1.2 Spring Boot的核心特性二、搭建开发环境 2.1…...

编程日记 2025/9/7 11:20:41

【Multipath网络层协议】MPTCP工作原理

常见网络层多路径协议介绍 MPTCP（Multipath TCP） MPTCP 是在传统 TCP 基础上进行扩展的协议，它允许在源端和目的端之间建立多个 TCP子流，这些子流可以通过不同的网络路径传输数据。例如，一台笔记本电脑同时连接了 W…...

编程日记 2025/9/9 0:31:45

【网络安全】从NA到P1，我是如何扩大思路的？

未经许可，不得转载。本文涉及漏洞均已修复。文章目录正文正文在这篇文章中，我将向大家展示一个我发现的漏洞，该漏洞利用了一个硬编码的 Basic 认证头，获取了管理员权限。首先，假设公司域名为“target.com”。第一步是使用多种工具（如 Amass、subfinder、findoma…...

编程日记 2025/9/11 3:15:03

使用 Postman 访问 Keycloak 端点

1. 引言在本教程中，我们将首先快速回顾 OAuth 2.0、OpenID 和 Keycloak。然后，我们将了解 Keycloak REST API 以及如何在 Postman 中调用它们。 2. OAuth 2.0 OAuth 2.0 是一个授权框架，它允许经过身份验证的用户通过令牌向第三方授予访问…...

编程日记 2025/9/10 11:44:12