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

003 SpringBoot集成Kafka操作

news 来源：原创 2025/9/11 12:22:43

4.SpringBoot集成Kafka

文章目录

4.SpringBoot集成Kafka
- - 1.入门示例
  - 2.yml完整配置
  - 3.关键配置注释说明
  - - 1. 生产者优化参数
    - 2. 消费者可靠性配置
    - 3. 监听器高级特性
    - 4. 安全认证配置
  - 4.配置验证方法
  - 5.不同场景配置模板
  - - 场景1：高吞吐日志收集
    - 场景2：金融级事务消息
    - 场景3：跨数据中心同步
- 5.高级配置
- - 1.事务支持
  - 2.消息重试与死信队列

来源参考的deepseek，如有侵权联系立删

1.入门示例

1.pom依赖

<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId>
</dependency>

2.KafkaProducer消息生产者配置

@Component
@Slf4j
public class KafkaProducer {private HashMap map=new HashMap<>();@Autowiredprivate KafkaTemplate<Integer,String> kafkaTemplate;public void send(String topic,String msg){log.info("开始发送消息，topic：{};message：{}",topic,msg);ListenableFuture<SendResult<Integer,String>> send=kafkaTemplate.send(topic, msg);//消息确认机制send.addCallback(new ListenableFutureCallback<SendResult<Integer,String>>(){@Overridepublic void onSuccess(SendResult<Integer, String> result) {log.info("消息发送成功，topic：{};message：{}",topic,msg);}@Overridepublic void onFailure(Throwable ex) {//落库操作map.put(topic,msg);}});}
}

springboot3.x写法

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;
import lombok.RequiredArgsConstructor;@Service
@RequiredArgsConstructor
public class KafkaProducerService {private final KafkaTemplate<String, String> kafkaTemplate;// 同步发送（阻塞等待确认）public void sendMessageSync(String topic, String key, String value) {kafkaTemplate.send(topic, key, value).whenComplete((result, ex) -> {if (ex == null) {System.out.printf("发送成功：topic=%s, partition=%d, offset=%d%n",result.getRecordMetadata().topic(),result.getRecordMetadata().partition(),result.getRecordMetadata().offset());} else {System.err.println("发送失败：" + ex.getMessage());}});}// 异步发送（默认方式）public void sendMessageAsync(String topic, String message) {kafkaTemplate.send(topic, message);}
}

Spring Boot 2.x：send() 返回 ListenableFuture<SendResult>，支持 addCallback() 回调。
Spring Boot 3.x：send() 返回 CompletableFuture<SendResult>，弃用 ListenableFuture，因此需要使用 CompletableFuture 的 API（如 whenComplete）。

3.KafkaConsumer消息消费

@Component
@Slf4j
public class KafkaConsumer {private List<String> exist=new ArrayList<>();@KafkaListener(topics = {"lx"},groupId = "lx")public void consumer(ConsumerRecord<Integer,String> record){if (exist.contains(record.value())){log.error("不满足幂等校验！！！");}log.info("消息消费成功，topic：{}，message：{}", record.topic(), record.value());exist.add(record.value());}
}

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.stereotype.Component;@Component
public class KafkaConsumerService {// 单个消息消费（手动提交偏移量）@KafkaListener(topics = "test-topic", groupId = "spring-group")public void listenMessage(String message, Acknowledgment ack) {System.out.println("收到消息：" + message);ack.acknowledge(); // 手动提交}// 批量消费（需配置 listener.type=batch）@KafkaListener(topics = "batch-topic", groupId = "spring-group")public void listenBatch(List<String> messages, Acknowledgment ack) {messages.forEach(msg -> System.out.println("批量消息：" + msg));ack.acknowledge();}
}

4.yml配置文件

生产者配置

#kafka配置
spring:kafka:#kafka集群地址# bootstraps-server: 192.168.25.100:9092bootstrap-servers: 47.122.26.22:9092producer:#批量发送的数据量大小batch-size: 1#可用发送数量的最大缓存buffer-memory: 33554432#key序列化器key-serializer: org.apache.kafka.common.serialization.StringSerializer#value序列化器value-serializer: org.apache.kafka.common.serialization.StringSerializer#达到多少时间后，会发送properties:linger.ms: 1# 禁止生产者触发 Topic 创建请求allow.auto.create.topics: false#代表集群中从节点都持久化后才认为发送成功acks: -1

消费者配置

spring:kafka:#kafka集群地址bootstraps-server: 192.168.25.100:9092consumer:enable-auto-commit: falsekey-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializerproperties:session.timeout.ms: 15000# 禁用生产者触发 Topic 元数据请求时自动创建allow.auto.create.topics: falsegroup-id: testauto-offset-reset: earliestlistener:ack-mode: manual_immediate # 精准控制offset提交concurrency: 3 # 并发消费者数type: batch

5.实体类

@Data
public class KafkaRequest {/*** 主题*/private String topic;/*** 消息*/private String message;
}

6.消息发送

@RestController
@Slf4j
public class KafkaController {private final String topic="lx";private int temp=1;@Autowiredprivate KafkaProducer producer;/*** 下单** @param kafkaRequest* @return null*/@RequestMapping("/test01")public void test01(KafkaRequest kafkaRequest){log.info("test01测试成功！topic:{};message:{}",kafkaRequest.getTopic(), kafkaRequest.getMessage());producer.send(kafkaRequest.getTopic(), kafkaRequest.getMessage());}@RequestMapping("/test02")public void test02(KafkaRequest kafkaRequest){log.info("test02测试成功！topic:{};message:{}",topic, temp);producer.send(topic, String.valueOf(temp));temp++;}
}

kafka启动方式

./kafka-server-start.sh  ../config/server.properties

2.yml完整配置

spring:kafka:# 基础配置（必填项）bootstrap-servers: localhost:9092  # Kafka集群地址，多节点用逗号分隔 client-id: spring-boot-app         # 客户端标识（日志追踪用）# 生产者配置 producer:key-serializer: org.apache.kafka.common.serialization.StringSerializer   # 键序列化器value-serializer: org.apache.kafka.common.serialization.StringSerializer  # 值序列化器acks: all                         # 消息确认机制：all表示所有副本确认（最高可靠性）retries: 5                        # 发送失败重试次数（需配合幂等性使用）batch-size: 16384                 # 批量发送缓冲区大小（单位：字节）linger-ms: 50                     # 发送延迟等待时间（毫秒，提高吞吐量）buffer-memory: 33554432           # 生产者内存缓冲区大小（默认32MB）compression-type: snappy          # 消息压缩算法（可选gzip/lz4/zstd）transaction-id-prefix: tx-        # 开启事务时需配置前缀（需配合@Transactional）# 消费者配置 consumer:group-id: app-consumer-group      # 消费者组ID（同一组共享分区）auto-offset-reset: earliest       # 无Offset时策略：earliest（从头）/latest（最新）enable-auto-commit: false         # 关闭自动提交Offset（推荐手动提交）key-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializermax-poll-records: 500             # 单次poll最大消息数（避免OOM）fetch-max-wait-ms: 500            # 消费者等待broker返回数据的最长时间isolation-level: read_committed   # 事务消息隔离级别（read_committed/read_uncommitted）# 监听器配置（高级优化）listener:type: single                      # 监听器类型：single（单条）/batch（批量）ack-mode: manual                  # Offset提交模式：manual（手动）/batch（批量提交）concurrency: 3                    # 消费者线程数（建议等于分区数）poll-timeout: 3000                # poll方法超时时间（毫秒）# 消息重试与死信队列（容错机制）retry:topic:attempts: 3                     # 最大重试次数initial-interval: 1000          # 初始重试间隔（毫秒）multiplier: 2.0                 # 重试间隔倍数（指数退避）dead-letter-topic: dlq-${topic}   # 死信队列命名规则（自动创建）# 安全协议（企业级场景）properties:security.protocol: SASL_PLAINTEXT  # 安全协议（如PLAINTEXT/SASL_SSL）sasl.mechanism: PLAIN             # SASL认证机制ssl.truststore.location: /path/to/truststore.jks# 自定义业务配置（非Kafka标准参数）app:kafka:topics:input-topic: user-events        # 业务输入Topicoutput-topic: processed-events  # 业务输出Topic

3.关键配置注释说明

1. 生产者优化参数

参数	说明	推荐值
`acks=all`	确保所有ISR副本写入成功，防止数据丢失	高可靠性场景必选
`compression-type=snappy`	减少网络带宽占用，提升吞吐量	消息体>1KB时启用
`transaction-id-prefix`	支持跨分区原子性写入（需配合@Transactional注解）	金融交易类业务必配

2. 消费者可靠性配置

参数	说明	注意事项
`enable-auto-commit=false`	避免消息处理失败但Offset已提交导致数据丢失	需手动调用`ack.acknowledge()`
`isolation-level=read_committed`	只消费已提交的事务消息	需与生产者事务配置联动

3. 监听器高级特性

参数	使用场景	示例
`type=batch`	批量消费（提升吞吐量）	适用于日志处理等实时性要求低的场景
`concurrency=3`	并发消费者数	需与Topic分区数一致，避免资源浪费

4. 安全认证配置

spring:kafka:properties:security.protocol: SASL_SSLsasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="secret";

企业级必配：生产环境需启用SSL加密+SASL认证

4.配置验证方法

启动检查：添加@ConfigurationProperties(prefix = "spring.kafka")绑定配置到Bean，通过单元测试验证注入值
日志监控：开启DEBUG日志观察生产者/消费者连接状态

   logging:level:org.springframework.kafka: DEBUG

AdminClient 工具：通过编程方式检查Topic元数据

@Autowired
private KafkaAdminClient adminClient;public void checkTopic() {Map<String, TopicDescription> topics = adminClient.describeTopics("user-events");topics.values().forEach(topic -> System.out.println(topic));
}

5.不同场景配置模板

场景1：高吞吐日志收集

producer:compression-type: lz4batch-size: 65536linger-ms: 100
consumer:auto-offset-reset: latestenable-auto-commit: true  # 允许少量数据丢失以换取性能

场景2：金融级事务消息

producer:acks: allretries: 10transaction-id-prefix: fin-tx-
consumer:isolation-level: read_committedenable-auto-commit: false

场景3：跨数据中心同步

spring:kafka:bootstrap-servers: kafka-dc1:9092,kafka-dc2:9092properties:client.dns.lookup: use_all_dns_ips  # 支持多IP解析reconnect.backoff.ms: 1000          # 断线重连策略

5.高级配置

1.事务支持

// 配置事务管理器
@Bean
public KafkaTransactionManager<String, String> transactionManager(ProducerFactory<String, String> producerFactory) {return new KafkaTransactionManager<>(producerFactory);
}// 使用事务发送
@Transactional
public void sendWithTransaction() {kafkaTemplate.send("topic1", "msg1");kafkaTemplate.send("topic2", "msg2");
}

2.消息重试与死信队列

spring:kafka:listener:retry:max-attempts: 3backoff:initial-interval: 1000multiplier: 2.0dead-letter-topic: my-dlt-topic # 死信队列

003 SpringBoot集成Kafka操作

4.SpringBoot集成Kafka 文章目录 4.SpringBoot集成Kafka1.入门示例2.yml完整配置3.关键配置注释说明1. 生产者优化参数2. 消费者可靠性配置3. 监听器高级特性4. 安全认证配置 4.配置验证方法5.不同场景配置模板场景1：高吞吐日志收集场景2：金融级事务消息…...

编程日记 2025/9/11 12:22:43

【工具篇】【深度解析：2025 AI视频工具的全面指南】

随着人工智能技术的飞速发展，AI视频工具已经成为内容创作者、营销人员、教育工作者以及普通用户的得力助手。这些工具不仅简化了视频制作流程，还提供了前所未有的创意可能性。本文将详细介绍各类AI视频工具，帮助你找到最适合自己需求的工具。 1. 文生视频工具智谱清影：这…...

编程日记 2025/9/7 15:57:06

前端面试真题 2025最新版

文章目录写在前文CSS怪异盒模型JS闭包闭包的形成闭包注意点 CSS选择器及优先级优先级说说flex布局及相关属性Flex 容器相关属性：Flex 项目相关属性响应式布局如何实现是否用过tailwindcss，有哪些好处好处缺点说说对象的 prototype属性及原型说说 pro…...

编程日记 2025/9/11 12:20:37

数据结构课程设计(java实现）---九宫格游戏,也称幻方

【问题描述】九宫格，一款数字游戏，起源于河图洛书，与洛书是中国古代流传下来的两幅神秘图案，历来被认为是河洛文化的滥觞，中华文明的源头，被誉为"宇宙魔方"。九宫格游戏对人们的思维锻炼有着极大…...

编程日记 2025/9/11 12:22:42

一文掌握Charles抓包工具的详细使用

Charles是一款强大的HTTP代理/HTTP监视器/反向代理工具，广泛用于开发和测试网络应用程序。在爬虫开发中，Charles可以帮助开发者拦截、查看和修改HTTP/HTTPS请求和响应，从而更好地理解网络通信过程，分析和调试爬虫程序。本文将详细介绍Charles的安装、配置、基本使用方法以及…...

编程日记 2025/9/11 12:19:54

Ollama下载安装+本地部署DeepSeek+UI可视化+搭建个人知识库——详解！（Windows版本）

目录 1️⃣下载和安装Ollama 1. 🥇官网下载安装包 2. 🥈安装Ollama 3.🥉配置Ollama环境变量 4、🎉验证Ollama 2️⃣本地部署DeepSeek 1. 选择模型并下载 2. 验证和使用DeepSeek 3️⃣使用可视化工具 1. Chrome插件-Page …...

编程日记 2025/9/11 12:17:35

Rk3568驱动开发_点亮led灯(手动挡)_5

1.MMU简介完成虚拟空间到物理空间的映射内存保护设立存储器的访问权限，设置虚拟存储空间的缓冲特性 stm32点灯可以直接操作寄存器，但是linux点灯不能直接访问寄存器，linux会使能mmu linux中操作的都是虚拟地址，要想访问物理地…...

编程日记 2025/9/11 12:17:49

【服务治理中间件】consul介绍和基本原理

目录一、CAP定理二、服务注册中心产品比较三、Consul概述 3.1 什么是Consul 3.2 Consul架构 3.3 Consul的使用场景 3.4 Consul健康检查四、部署consul集群 4.1 服务器部署规划 4.2 下载解压 4.3 启动consul 五、服务注册到consul 一、CAP定理 CAP定理&#xff…...

编程日记 2025/9/11 12:17:50

Docker下ARM64架构的源码编译Qt5.15.1,并移植到开发板上

Docker下ARM64架构的源码编译Qt5.15.1,并移植到开发板上 1、环境介绍 QT版本：5.15.1 待移植环境： jetson nano 系列开发板 aarch64架构（arm64） 编译环境： 虚拟机Ubuntu18.04（x86_64） 2、…...

编程日记 2025/9/6 11:56:35

对话Stack Overflow，OceanBase CTO 杨传辉谈分布式数据库的“前世今生”

近日， OceanBase CTO 杨传辉受邀出席全球知名开发者论坛 Stack Overflow 的最新一期播客节目，与 Stack Overflow 高级内容创作官 Ryan Donovan 展开对话。双方围绕分布式数据库的可靠性、一致性保障、HTAP 架构以及 AI 时代分布式数据库的发展趋势等热点…...

编程日记 2025/9/7 3:41:29

ds回答-开源llm应用开发平台

以下是几个著名的开源 LLM 应用开发平台，涵盖不同场景和技术特点： 1. Dify 特点：低代码 / 无代码开发、支持 RAG 检索、Agent 智能体、模型管理、LLMOps 全流程优化。核心功能：可视化工作流编排、数百种模型兼容（如 GP…...

编程日记 2025/9/11 12:21:48

C++ Qt常见面试题（4）：Qt事件过滤器

在 Qt 中，事件过滤器（Event Filter）提供了一种机制，可以拦截并处理对象的事件（如鼠标事件、键盘事件等），在事件到达目标对象之前对其进行预处理。事件过滤器通常用于以下场景：捕获和处理特定的事件（如鼠标点击、按键等）；对事件进行筛选或修改；实现全局的事件监听功…...

编程日记 2025/9/6 21:00:46

CF 109A.Lucky Sum of Digits(Java实现)

题目分析给定一个值，判断这个值能否被4和7组成，如果能就输出最小的组合。不能就输出-1。思路分析由于是最小组合，即判断4能最多有多少个。但是如果一个值能完全被7整除，那就不需要4了，只用7组合的话位数会更短。(例…...

编程日记 2025/9/8 1:12:40

计算机毕业设计Python+DeepSeek-R1大模型游戏推荐系统 Steam游戏推荐系统游戏可视化游戏数据分析(源码+文档+PPT+讲解)

温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 作者简介：Java领…...

编程日记 2025/9/7 18:57:11

生鲜行业智能化供应链解决方案技术白皮书

行业痛点与技术挑战损耗控制难题行业平均损耗率达18%-25%，需构建动态定价模型与智能分拣系统冷链管理复杂度全程温控数据采集点超过23个/车次，异常响应延迟需压缩至90秒内供需预测偏差传统模式预测准确率不足65%，亟需AI驱动需求预测体…...

编程日记 2025/9/10 19:33:45

《每天搞懂一道Hard》之数独终结者（LeetCode 37）

📌《每天搞懂一道Hard》之数独终结者（LeetCode 37） 🔗原题链接：https://leetcode.com/problems/sudoku-solver/ 今天我们来解剖一个经典回溯算法问题——数独求解器！这道题在算法面试中出现频率高达35%&a…...

编程日记 2025/9/7 1:08:46

论文笔记-NeurIPS2017-DropoutNet

论文笔记-NeurIPS2017-DropoutNet: Addressing Cold Start in Recommender Systems DropoutNet：解决推荐系统中的冷启动问题摘要1.引言2.前言3.方法3.1模型架构3.2冷启动训练3.3推荐 4.实验4.1实验设置4.2在CiteULike上的实验结果4.2.1 Dropout率的影响4.2.2 实验结…...

编程日记 2025/9/9 6:10:21

【后端开发面试题】每日 3 题（四）

✍个人博客：Pandaconda-CSDN博客 📣专栏地址：https://blog.csdn.net/newin2020/category_12903849.html 📚专栏简介：在这个专栏中，我将会分享后端开发面试中常见的面试题给大家~ ❤️如果有收获的话&#x…...

编程日记 2025/9/8 17:22:07

使用AoT让.NetFramework4.7.2程序调用.Net8编写的库

1、创建.Net8的库，双击解决方案中的项目，修改如下，启用AoT： <Project Sdk"Microsoft.NET.Sdk"><PropertyGroup><OutputType>Library</OutputType><PublishAot>true</PublishAot>&…...

编程日记 2025/9/9 20:43:50

c++中的静态多态和动态多态简介

在 C 中，多态性（Polymorphism） 分为静态多态（Static Polymorphism） 和动态多态（Dynamic Polymorphism），二者通过不同的机制实现代码的灵活性。以下是详细对比和核心要点&#xff1…...

编程日记 2025/9/10 7:55:52

FastExcel与Reactor响应式编程深度集成技术解析

一、技术融合背景与核心价值在2025年企业级应用开发中，大规模异步Excel处理与响应式系统架构的结合已成为技术刚需。FastExcel与Reactor的整合方案，通过以下技术协同实现突破性性能： 内存效率革命：FastExcel的流式字节操作与Re…...

编程日记 2025/9/1 0:20:14

【MySQL篇】数据类型

目录前言： 1，数据类型的分类编辑 2 ，数值类型 2.1 tinyint类型 2.2 bit类型 2.3 小数类型 2.3.1 float类型 2.3.2 decimal类型 3，字符串类型 3.1 char 3.2 varchar 3.3 char与varchar的比较 3.4日期和时间类型 3.5 …...

编程日记 2025/9/10 22:12:51

haclon固定相机位标定

什么是标定？ 工业应用中相机拍到一个mark点的坐标为C1（Cx,Cy），C1点对应的龙门架/机械手等执行端对应的坐标是多少？ 标定就是解决这个问题，如相机拍到一个点坐标C1（Cx,Cy）&#xff0c…...

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

Token相关设计

文章目录 1. 双Token 机制概述1.1 访问令牌（Access Token）1.2 刷新令牌（Refresh Token） 2. 双Token 认证流程3. Spring Boot 具体实现3.1 生成 Token（使用 JWT）3.2 解析 Token3.3 登录接口（返回…...

编程日记 2025/9/7 10:06:48

vue3:四嵌套路由的实现

一、前言 1、嵌套路由的含义嵌套路由的核心思想是：在某个路由的组件内部，可以定义子路由，这些子路由会渲染在父路由组件的特定位置（通常是 <router-view> 标签所在的位置）。通过嵌套路由，你可以实…...

编程日记 2025/9/7 8:19:21

在 Element Plus 的＜el-select＞组件中，如果需要将＜el-option＞的默认值设置为 null。用于枚举传值

文章目录引言轻松实现 `<el-option>` 的默认值为 `null`I 实现方式监听清空事件【推荐】使用 v-model 绑定 null添加一个值为 null 的选项处理 null 值的显示引言背景：接口签名规则要求空串参与，空对象不参与签名计算 // 空字符串“” 参与签名组串，null不参与签…...

编程日记 2025/9/7 1:39:37

List（3）

前言上一节我们讲解了list主要接口的模拟实现，本节也是list的最后一节，我们会对list的模拟实现进行收尾，并且讲解list中的迭代器失效的情况，那么废话不多说，我们正式进入今天的学习 list的迭代器失效之前在讲解vec…...

编程日记 2025/9/6 18:58:15

算法-二叉树篇23-二叉搜索树中的插入操作

二叉搜索树中的插入操作力扣题目链接题目描述给定二叉搜索树（BST）的根节点 root 和要插入树中的值 value ，将值插入二叉搜索树。返回插入后二叉搜索树的根节点。输入数据保证 ，新值和原始二叉搜索树中的任意节点值都不同…...

编程日记 2025/9/7 1:39:37

React底层常见的设计模式

在React中，常见的设计模式为开发者提供了结构化和可重用的解决方案，有助于提高代码的可维护性和可扩展性。以下是对React中几种常见设计模式的详细解析，并附上示例代码和注释： 1. 容器组件与展示组件模式（Container/P…...

编程日记 2025/9/11 8:29:09

【PHP脚本语言详解】为什么直接访问PHP文件会显示空白？从错误示例到正确执行！

前言作为一名开发者，你是否曾经遇到过这样的问题：写了一个PHP脚本，放到服务器根目录后，直接通过file:///路径访问却显示空白页面？而换成http://localhost却能正常显示？这篇文章将带你深入理解PHP脚本语言…...

编程日记 2025/9/9 11:51:40

小程序性能优化-预加载

在微信小程序中，数据预加载是提升用户体验的重要优化手段。以下是处理数据预加载的完整方案： 一、预加载的适用场景跳转页面前的数据准备如从列表页进入详情页前，提前加载详情数据首屏加载后的空闲时间在首页加载完成后，预加载…...

编程日记 2025/9/8 0:37:55

Docker 数据卷管理及优化

Docker 数据卷是一个可供容器使用的特殊目录，它绕过了容器的文件系统，直接将数据存储在宿主机上。通过数据卷，可以实现数据的持久化、共享以及独立于容器生命周期的管理。 1.1 为什么要用数据卷 Docker 分层文件系统的特点性能差&#xff…...

编程日记 2025/9/10 6:44:59

MySQL实现文档全文搜索，分词匹配多段落重排展示，知识库搜索原理分享

一、背景在文档搜索场景中，高效精准的搜索功能至关重要，能提升检索效率，为用户提供精准、快速的信息获取体验，提高工作效率。在文档管理系统里，全文搜索是非常重要的功能之一。随着文档数量增长，如何快速…...

编程日记 2025/9/10 18:09:05

C#内置委托(Action)(Func)

概述在 C# 中，委托是一种类型，它表示对具有特定参数列表和返回类型的方法的引用。C# 提供了一些内置委托，使得开发者可以更方便地使用委托功能，无需手动定义委托类型。本文将详细介绍 Action 和 Func 这两个常用的内置委托。 A…...

编程日记 2025/9/8 4:19:12

OpenCV计算摄影学（3)CUDA 图像去噪函数fastNlMeansDenoising()

操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述使用非局部均值去噪算法（Non-local Means Denoising algorithm）执行图像去噪，该算法来源于 http://www.ipol.…...

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

Kafka生产者相关

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

编程日记 2025/9/9 0:29:11

【容器化】低版本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/8/16 12:16:01

一、路由添加 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/8/19 22:04:23

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

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

编程日记 2025/9/6 19:47:50

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

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

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

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

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

编程日记 2025/9/6 13:27:33

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/10 0:16:08

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

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

编程日记 2025/9/10 1:00:32

Servlet简介

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

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

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

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

编程日记 2025/9/10 11:39:01

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