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

Spring Cloud Stream实现数据流处理

news 来源：原创 2025/7/5 5:17:52

1.什么是Spring Cloud Stream？

Spring Cloud Stream的核心是Stream，准确来讲Spring Cloud Stream提供了一整套数据流走向（流向）的API，它的最终目的是使我们不关心数据的流入和写出，而只关心对数据的业务处理我们举一个例子：你们公司有一套系统，这套系统由多个模块组成，你负责其中一个模块。数据会从第一个模块流入，处理完后再交给下一个模块。对于你负责的这个模块来说，它的功能就是接收上一个模块处理完成的数据，自己再加工加工，扔给下一个模块。
在这里插入图片描述
我们很容易总结出每个模块的流程：

1、从上一个模块拉取数据
2、处理数据
3、将处理完成的数据发给下一个模块

其中流程1和3代表两个模块间的数据交互，这种数据交互往往会采用一些中间件（middleware）。比如模块1和模块2间数据可能使用的是kafka，模块1向kafka中push数据，模块2向kafka中poll数据。而模块2和模块3可能使用的是rabbitMQ。很明显，它们的功能都是一样的：提供数据的流向，让数据可以流入自己同时又可以从自己流出发给别人。但由于中间件的不同，需要使用不同的API。为了消除这种数据流入（输入）和数据流出（输出）实现上的差异性，因此便出现了Spring Cloud Stream。

2.环境准备

采用docker-compose搭建kafaka环境

version: '3'networks:kafka:ipam:driver: defaultconfig:- subnet: "172.22.6.0/24"services:zookepper:image: /zookeeper:latestcontainer_name: zookeeper-serverrestart: unless-stoppedvolumes:- "/etc/localtime:/etc/localtime"environment:ALLOW_ANONYMOUS_LOGIN: yesports:- "2181:2181"networks:kafka:ipv4_address: 172.22.6.11kafka:image: /kafka:3.4.1container_name: kafkarestart: unless-stoppedvolumes:- "/etc/localtime:/etc/localtime"environment:ALLOW_PLAINTEXT_LISTENER: yesKAFKA_CFG_ZOOKEEPER_CONNECT: zookepper:2181KAFKA_CFG_ADVERTISED_LISTENERS: PLAINTEXT://10.11.68.77:9092ports:- "9092:9092"depends_on:- zookeppernetworks:kafka:ipv4_address: 172.22.6.12kafka-map:image: /kafka-mapcontainer_name: kafka-maprestart: unless-stoppedvolumes:- "./kafka/kafka-map/data:/usr/local/kafka-map/data"environment:DEFAULT_USERNAME: adminDEFAULT_PASSWORD: 123456ports:- "9080:8080"depends_on:                         - kafkanetworks:kafka:ipv4_address: 172.22.6.13

run

docker-compose -f docker-compose-kafka.yml -p kafka up -d

3.代码工程

实验目标

1、生成UUID并将其发送到Kafka主题batch-in。
2、从batch-in主题接收UUID的批量消息，移除其中的数字，并将结果发送到batch-out主题。
3、监听batch-out主题并打印接收到的消息。

pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>springcloud-demo</artifactId><groupId>com.et</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>spring-cloud-stream-kafaka</artifactId><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target></properties><dependencies><!-- Spring Boot Starter Web --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Spring Boot Starter Test --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-stream-kafka</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies></project>

处理流

package com.et;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;import java.util.List;
import java.util.UUID;
import java.util.function.Function;
import java.util.function.Supplier;@SpringBootApplication
public class CloudStreamsFunctionBatch {public static void main(String[] args) {SpringApplication.run(CloudStreamsFunctionBatch.class, args);}@Beanpublic Supplier<UUID> stringSupplier() {return () -> {var uuid = UUID.randomUUID();System.out.println(uuid + " -> batch-in");return uuid;};}@Beanpublic Function<List<UUID>, List<Message<String>>> digitRemovingConsumer() {return idBatch -> {System.out.println("Removed digits from batch of " + idBatch.size());return idBatch.stream().map(UUID::toString)// Remove all digits from the UUID.map(uuid -> uuid.replaceAll("\\d","")).map(noDigitString -> MessageBuilder.withPayload(noDigitString).build()).toList();};}@KafkaListener(id = "batch-out", topics = "batch-out")public void listen(String in) {System.out.println("batch-out -> " + in);}}

定义一个名为stringSupplier的Bean，它实现了Supplier接口。这个方法生成一个随机的UUID，并打印到控制台，表示这个UUID将被发送到batch-in主题。
定义一个名为digitRemovingConsumer的Bean，它实现了Function<List, List<Message>>接口。这个方法接受一个UUID的列表，打印出处理的UUID数量，然后将每个UUID转换为字符串，移除其中的所有数字，最后将结果封装为消息并返回。
使用@KafkaListener注解定义一个Kafka监听器，监听batch-out主题。当接收到消息时，调用listen方法并打印接收到的消息内容。

配置文件

spring:cloud:function:definition: stringSupplier;digitRemovingConsumerstream:bindings:stringSupplier-out-0:destination: batch-indigitRemovingConsumer-in-0:destination: batch-ingroup: batch-inconsumer:batch-mode: truedigitRemovingConsumer-out-0:destination: batch-outkafka:binder:brokers: localhost:9092bindings:digitRemovingConsumer-in-0:consumer:configuration:# Forces consumer to wait 5 seconds before polling for messagesfetch.max.wait.ms: 5000fetch.min.bytes: 1000000000max.poll.records: 10000000

参数解释
1、spring.cloud.function.definition：定义了两个函数，stringSupplier和digitRemovingConsumer。这两个函数将在应用程序中被使用。

spring:cloud:function:definition: stringSupplier;digitRemovingCon

2、stream.bindings.stringSupplier-out-0.destination：将stringSupplier函数的输出绑定到Kafka主题batch-in。

stream:bindings:stringSupplier-out-0:destination: batch-in

3、stream.bindings.digitRemovingConsumer-in-0.destination：将digitRemovingConsumer函数的输入绑定到Kafka主题batch-in。

digitRemovingConsumer-in-0:destination: batch-ingroup: batch-inconsumer:batch-mode: true

4、group: batch-in：指定消费者组为batch-in，这意味着多个实例可以共享这个组来处理消息。

5、consumer.batch-mode: true：启用批处理模式，允许消费者一次处理多条消息。

6、stream.bindings.digitRemovingConsumer-out-0.destination：将digitRemovingConsumer函数的输出绑定到Kafka主题batch-out。

digitRemovingConsumer-out-0:destination: batch-out

4.测试

启动弄Spring Boot应用，可以看到控制台输出日志如下：

291ea6cc-1e5e-4dfb-92b6-5d5ea43d4277 -> batch-in
c746ba4e-835e-4f66-91c5-7a5cf8b01068 -> batch-in
a661145b-2dd9-4927-8806-919ad258ade5 -> batch-in
db150918-0f0b-49f6-b7bb-77b0f580de4c -> batch-in
b0d4917b-6777-4d96-a6d0-bb96715b5b20 -> batch-in
Removed digits from batch of 5
batch-out -> eacc-ee-dfb-b-dead
batch-out -> cbae-e-f-c-acfb
batch-out -> ab-dd—adade
batch-out -> db-fb-f-bbb-bfdec
batch-out -> bdb–d-ad-bbbb

Spring Cloud Stream实现数据流处理

1.什么是Spring Cloud Stream？ Spring Cloud Stream的核心是Stream，准确来讲Spring Cloud Stream提供了一整套数据流走向（流向）的API， 它的最终目的是使我们不关心数据的流入和写出，而只关心对数据的业务处…...

编程日记 2025/7/5 5:17:52

DETR：End-to-End Object Detection with Transformers

【DETR 论文精读【论文精读】-哔哩哔哩】 https://b23.tv/Iy9k4O2 【DETR源码解读4-哔哩哔哩】 https://b23.tv/Qp1uH5v 摘要： 将目标检测看作一个集合预测的问题任务：给定一张图片，预测一组框，每个框需要得到坐标信息和包含的…...

编程日记 2025/7/4 14:09:26

【C++/Qt 】使用QCustomplot类打造一款数学函数图像生成工具（支持latex公式渲染+Python连接AI大模型）

✨✨ Rqtz 个人主页 : 点击✨✨ 🌈Qt系列专栏:点击软件介绍基于Qt的开源项目QCustomplot类的一款在线的数学函数图像生成工具，涉及到了数学的latex公式渲染，如何将latex语法转换为Python的函数，和如何在Qt中使用QCustomplot类进…...

编程日记 2025/7/5 3:39:04

Hackathon靶机系列Hackathon2

扫描ip： 获得靶机的ip：192.168.108.134 扫描端口： 获得80端口，7223的ssh和一个ftp服务器服务器中存在两个文件： 先看ftp： 默认用户名为ftp： 下载两个文件： 和打开flag1.txt: 获得…...

编程日记 2025/7/3 21:32:13

Mybatis 复习

1 什么是MyBatis MyBatis是一个优秀的持久层框架，它对JDBC操作数据库的过程进行封装，使开发者只需要关注 SQL 本身，而不需要花费精力去处理例如注册驱动、创建connection、创建statement、手动设置参数、结果集检索等JDBC繁杂的过程代码。…...

编程日记 2025/7/5 4:06:24

BurpSuite安装教程（详细！！附带下载链接）

声明学习内容来自 B 站UP主泷羽sec，如涉及侵权马上删除文章。笔记的只是方便各位师傅学习知识，以下网站只涉及学习内容，其他的都与本人无关，切莫逾越法律红线，否则后果自负。 ✍🏻作者简介：致…...

编程日记 2025/7/5 3:26:13

Istio_05_Istio架构

Istio_05_Istio架构 ArchitectureControl PlanePilotCitadelGalley Data PlaneSidecarIstio-proxyPilot-agentMetadta Exchange Ambient Architecture 如: Istio的架构(控制面、数据面) Gateway: Istio数据面的出/入口网关 Gateway分为: Ingress-gateway、Egress-gateway外部访…...

编程日记 2025/7/5 4:09:31

R语言结构方程模型（SEM）在生态学领域中的应用

目录专题一、R/Rstudio简介及入门专题二、结构方程模型（SEM）介绍专题三：R语言SEM分析入门：lavaan VS piecewiseSEM 专题四：SEM全局估计（lavaan）在生态学领域高阶应用专题五&#xff1…...

编程日记 2025/7/5 3:49:37

node.js基础学习-fs模块-文件操作（六）

一、前言 fs模块是 Node.js 内置的文件系统（File System）模块，它提供了一系列用于与文件系统进行交互的方法。通过fs模块，可以对文件或目录进行读取、写入、删除、重命名、查询状态等操作，这使得 Node.js 能够很好地处…...

编程日记 2025/7/5 4:18:15

EXCEL截取某一列从第一个字符开始到特定字符结束的字符串到新的一列

使用EXCEL中的公式进行特定截取假设列A是一组产品的编码，我们需要的数据是“-”之前的字段。我们需要在B1单元格输入公式“LEFT(A1,SEARCH("-",A1)-1)”然后选中B1至B4单元格，按“CTRLD”向下填充，就可以得出其它几行“-”之前的…...

编程日记 2025/7/5 4:35:12

JVM的垃圾回收算法有哪些

标记清除算法标记清除算法，是将垃圾回收分为2个阶段，分别是标记和清除根据可达性分析算法得出的垃圾进行标记对这些标记为可回收的内容进行垃圾回收优点:标记和清除速度较快缺点:碎片化较为严重，内存不连贯的标记整理算法优缺点同标记…...

编程日记 2025/7/3 7:33:19

看华为，引入IPD的正确路径

目录前言引发重视作者简介前言华为将 IPD 的引入过程归结为三步： 先僵化、后优化、再固化。如果只是单纯模仿，在不清楚底层逻辑的情况下， 就开始走先僵化的流程，去搞削足适履式的引入。开始执行后，你就…...

编程日记 2025/7/5 3:37:18

2024142读书笔记|《别无归处是归处》——一壶酒，一竿身，世上如侬有几人

2024142读书笔记|《别无归处是归处》——一壶酒，一竿身，世上如侬有几人《别无归处是归处：吴镇的“渔父”画题（文人画的真性）》作者朱良志。诗词与古画并存的一本书，古画是比较偏复古黯淡微黄及墨色的&…...

编程日记 2025/7/5 3:46:03

think php处理异步 url 请求记录

1、需求某网站需要 AI生成音乐，生成mp3文件的时候需要等待，需要程序中实时监听mp3文件是否生成 2、用的开发框架为php 3、文件结构配置路由设置 Route::group(/music, function () {Route::post(/musicLyrics, AiMusic/musicLyrics);//Ai生成歌词流式…...

编程日记 2025/7/5 3:49:37

PostgreSQL详细安装教程

#安装PostgreSQL的yum仓库 sudo yum install -y https://download.postgresql.org/pub/repos/yum/reporpms/EL-7-x86_64/pgdg-redhat-repo-latest.noarch.rpm#安装PostgreSQL 15版本 sudo yum install -y postgresql15-server#初始化数据库（若要自定义数据库存储目录…...

编程日记 2025/7/5 3:37:19

电子电气架构 --- 车载网关GW连接外部IP Tester

我是穿拖鞋的汉子，魔都中坚持长期主义的汽车电子工程师。老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师：所谓鸡汤，要么蛊惑你认命，要么怂恿你拼命，但都是回避问题的根源，以现象替代逻辑，以情绪代替思考，把消极接受现实的懦弱，伪装成乐观面对不幸的…...

编程日记 2025/6/29 21:30:25

开发一套ERP 第八弹 RUst 插入数据

更全面的报错,方便检查错误在哪里,现代高级语言越来越智能还是得看下原文档怎么操作的 src 目录为crate 的根目录想在crate 中模块相互引入需要在 main 中声明,各个模块,然后才能在各个模块中相互引入和使用原始工程引入,避免直接使用 lib.rs 回合cargo 中的一些工程管理出…...

编程日记 2025/7/5 4:47:55

RFdiffusion Diffuser类解读

Diffuser 类是一个封装类，调用EuclideanDiffuser和IGSO3类，用于执行扩散模型的核心功能，主要针对分子或蛋白质结构的旋转（SO(3) 群上的扩散）和位移（欧几里得空间中的扩散）。源代码： class Diffuser:# wrapper for yielding diffused coordinatesdef __init__(self,T…...

编程日记 2025/7/5 1:29:01

【pdf密码】为什么我的PDF文件不能复制文字？

大家现在接触PDF文件越来越多，有的时候在网上下载的PDF文件打开之后，发现选中文字之后无法复制。甚至其他功能也都无法使用，这是怎么回事？该怎么办？ 当我们发现文件打开之后，编辑功能无法使用，很…...

编程日记 2025/7/5 4:49:50

C#学写了一个程序记录日志的方法（Log类）

1.错误和警告信息单独生产文本进行记录； 2.日志到一定内存阈值可以打包压缩，单独存储起来，修改字段MaxLogFileSizeForCompress的值即可； 3.Log类调用举例：Log.Txt(JB.信息,“日志记录内容”,"通道1"); usi…...

编程日记 2025/7/5 5:11:40

Android Framework禁止弹出当前VOLTE不可用的提示窗口

文章目录 VoLTE简介VoLTE 的优势当前VOLTE不可用的弹窗弹窗代码定位屏蔽弹出窗口 VoLTE简介 VoLTE（Voice over LTE）是一种基于4G LTE网络的语音通话技术。它允许用户在4G网络上进行高质量的语音通话和视频通话，而不需要回落到2G或3G网络。V…...

编程日记 2025/7/3 12:36:39

Maven Surefire 插件简介

Maven Surefire 插件是 Maven 构建系统中的一个关键组件，专门用于在构建生命周期中执行单元测试。它通常与 Maven 构建生命周期的测试阶段绑定，确保所有单元测试在项目编译后和打包前被执行。最新版本 Maven Surefire 插件的最新版本为 3.5.2。使…...

编程日记 2025/6/27 22:08:36

vue3-新增API组件

shallowRef 创建一个响应式数据，但只对顶层属性进行响应式处理,只跟踪引用值的变化，不关心值内部的属性变化 import {shallowRef} from "vue" import UserInfo from "/components/UserInfo.vue";let name shallowRef("vue&quo…...

编程日记 2025/7/5 3:40:43

Linux随记（十三）

一、jstack随记运行cmd cd C:\icp-agent\jdk_min\bin 执行 jstack PID > thread_dump.txt （查看PID：tasklist |findstr javaw 查看第二列） thread_dump.txt 取给研发二、让普通用户test，有权限使用docker指令 1、查看当前用…...

编程日记 2025/7/5 3:57:40

AI数据分析工具（一）

Looker Studio（谷歌）-免费优点免费使用：对于中小型企业和个人用户来说，没有任何费用压力，可以免费享受到数据可视化和报表创建的功能。与Google服务集成：特别适合使用Google产品生态的企业，…...

编程日记 2025/7/5 4:40:42

dhcp服务

安装dhcp-libs和dhcp-common软件包是配置DHCP服务器的前提，但仅仅安装这两个软件包并不能直接开启DHCP服务器。您还需要进行以下步骤来完整配置和启动DHCP服务器： 安装DHCP服务器软件包： 除了dhcp-libs和dhcp-common，您还需要安装…...

编程日记 2025/7/2 3:57:14

RSA算法和AES算法，哪种更安全

目录一、RSA (非对称加密算法) 二、AES (对称加密算法) 三、对比总结四、更安全的选择五、结合使用：RSA AES RSA 和 AES 是两种不同类型的加密算法，适用于不同的场景，因此它们的安全性不能直接比较，而是取决于具体的应用…...

编程日记 2025/7/3 18:38:25

反向代理模块开发

1 概念 1.1 反向代理概念反向代理是指以代理服务器来接收客户端的请求，然后将请求转发给内部网络上的服务器，将从服务器上得到的结果返回给客户端，此时代理服务器对外表现为一个反向代理服务器。对于客户端来说，反向代理就相当于…...

编程日记 2025/7/5 4:07:05

（微信小程序）基于Spring Boot的校园失物招领平台的设计与实现（vue3+uniapp+mysql）

💗博主介绍💗：✌在职Java研发工程师、专注于程序设计、源码分享、技术交流、专注于Java技术领域和毕业设计✌ 温馨提示：文末有 CSDN 平台官方提供的老师 Wechat / QQ 名片 :) Java精品实战案例《700套》 2025最新毕业设计选题推荐…...

编程日记 2025/7/5 3:45:18

1-7 GD32函数指针应用

前言： 本博客仅在应用函数指针与回调函数相关的知识，通过实践巩固所学知识，也是对相关知识点的回顾。函数指针与回调函数：1-6 GD32函数指针与回调函数-CSDN博客目录前言： 1.0 程序架构思想 2.0 构建串口结构体 …...

编程日记 2025/7/2 1:30:08

前端js面试知识点思维导图（脑图）

如果看着不清晰可以去https://download.csdn.net/download/m0_73761441/90058523访问下载，无需积分使用百度脑图制作，可以一键导入下面的文本生成自己的脑图 js相关面试题、知识点数据类型 1. 数据类型分类？分别包含&#xff…...

编程日记 2025/7/5 5:06:30

使用 F5 TTS 文字转音频

F5 TTS 支持 ZeroShot 音频克隆，只有将需要音频传给模型，模型既可以生成以对应声音生成的音频，F5 最强大的地方就是可以使用定制的人声。F5 使用了 DIT 架构进行训练，结构如下： 本地使用 F5 TTS F5 使用很简单&#x…...

编程日记 2025/7/5 4:49:49

【笔记】自动驾驶预测与决策规划_Part8_数据驱动的规划方法

文章目录 0. 前言1.生成模型1.1 Diffusion-ES1. Diffusion-ES算法介绍2. Diffusion-ES算法具体流程Diffusion Model 是什么？Diffusion-ES: Evolutionary StrategiesDiffusion-ES MethodDiffusion-ES Mapping Language instructions to reward functions with LLM pr…...

编程日记 2025/7/3 22:24:31

多视图几何中向量叉乘的矩阵转换 Matrix Transformation for Cross Product in MVG

Title: 多视图几何中向量叉乘的矩阵转换 Matrix Transformation for Cross Product in MVG 文章目录 I. 向量叉乘的矩阵转换恒等式II. 符号计算 Maxima 程序推导III. 推论和关联公式的说明1. 推论2. 应用于对极几何中基本矩阵推导3. 应用于基本矩阵与单应矩阵关系4. 与刚体运动…...

编程日记 2025/7/2 4:28:27

面向多用户场景的恢复机制驱动的无线组密钥生成协议

中文标题：面向多用户场景的恢复机制驱动的无线组密钥生成协议英文标题：A Recovery Mechanism-driven Wireless Group Key Generation Protocol for Multi-User Scenarios 作者信息： Huaicong Zhang, Yawen Huang, Jiabao Yu, Boqian Liu, …...

编程日记 2025/7/2 8:05:47

ROS2教程 - 2 环境安装

更好的阅读体验：https://www.foooor.com 2 环境安装下面以 ROS2 的 humble 版本为例，介绍 ROS2 的安装。 ROS1 只能在 ubuntu 系统上安装，ROS2全面支持三种平台：Ubuntu、MAC OS X、Windows10，下面在 Ubuntu22.04 …...

编程日记 2025/7/1 23:29:48

力扣200 岛屿数量 Java版本

文章目录题目描述代码题目描述给你一个由 ‘1’（陆地）和 ‘0’（水）组成的的二维网格，请你计算网格中岛屿的数量。岛屿总是被水包围，并且每座岛屿只能由水平方向和/或竖直方向上相邻的陆地连接形成。 …...

编程日记 2025/7/4 0:57:12

每日速记10道java面试题03

其他资料每日速记10道java面试题01-CSDN博客每日速记10道java面试题02-CSDN博客目录一、你使用过java的反射机制吗？如何应用反射？ 二、什么是泛型？泛型的作用是什么？ 三、java的泛型擦除是什么？ 四、Java 中…...

编程日记 2025/7/4 16:49:13

力扣刷题TOP101：6.BM7 链表中环的入口结点

目录： 目的思路复杂度记忆秘诀 python代码目的 {1,2},{3,4,5}, 3 是环入口。思路这个任务是找到带环链表的环入口。可以看作是上一题龟兔赛跑（Floyd 判圈算法）的延续版：乌龟愤愤不平地举报兔子跑得太快，偷偷…...

编程日记 2025/6/29 20:40:15

智慧防汛平台在城市生命线安全建设中的应用

随着城市化进程的加快，城市基础设施的复杂性和互联性不断增强，城市生命线的安全管理面临前所未有的挑战。智慧防汛平台作为城市生命线安全建设的重要组成部分，通过现代信息技术提升城市防汛应急管理的智能化水平，保障城市安全。 …...

编程日记 2025/7/2 23:08:53

高德应用OceanBase云数据库的升级选型与迁移干货

业务背景高德，DAU已在亿级，时时刻刻都持续不断地产生着庞大的数据。随着数据量的迅猛增长，对现有的业务数据存储能力构成日益严峻的挑战。以我所在部门中的某一大型服务为例，其存储在XDB中的数据量往往达到数百TB之巨&#xf…...

编程日记 2025/7/3 16:43:42

Flink cdc同步增量数据timestamp字段相差八小时（分析｜解决）不是粘贴复制的！

问题我使用flink cdc同步mysql到mysql遇到了timestamp字段缺少八小时的问题。很少无语，flink ,cdc,debezium时区都设置了，没有任何效果！ 分析问题出现在mysql binlog身上！！！ 因为默认mysql会使用UTC来…...

编程日记 2025/7/3 4:46:09

用shell脚本写一个通用的监听程序异常并重启脚本

进来服务器的程序php-fpm时常在并发下时常挂掉，而且时常在凌晨2点以后，通过排查是因为php配置需要调整并发，同时，为了不影响我休息（以前老师说：能用机器和程序解决问题的坚决不用人去操作，这样才…...

编程日记 2025/7/3 4:28:56

使用 Go 语言中的 Context 取消协程执行

使用 Go 语言中的 Context 取消协程执行在 Go 语言中，协程（goroutine）是一种轻量级的线程，非常适合处理并发任务。然而，如何优雅地取消正在运行的协程是一个常见的问题。本文将通过一个具体的例子来展示如何使用 con…...

编程日记 2025/7/1 15:57:27

使用经典的Java，还是拥抱新兴的Rust？

在当代互联网时代的企业级开发中，技术栈的选择往往牵动着每个团队的神经。随着Rust语言的崛起，许多开发团队开始重新思考：是继续坚持使用经典的Java，还是拥抱新兴的Rust？这个问题背后，折射出的是对技术演进…...

编程日记 2025/6/29 19:55:21

《算法导论》英文版前言To the teacher第3段研习录：题海战术有没有？

【英文版】 We have included 957 exercises and 158 problems. Each section ends with exercises, and each chapter ends with problems. The exercises are generally short questions that test basic mastery of the material. Some are simple self-check thought exer…...

编程日记 2025/7/2 7:39:16

1.什么是Spring Cloud Stream？

2.环境准备

3.代码工程

4.测试

相关文章：