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

MySQL 和 Elasticsearch 之间的数据同步

news 来源：原创 2025/9/15 11:13:00

MySQL 和 Elasticsearch 之间的数据同步是常见的需求，通常用于将结构化数据从关系型数据库同步到 Elasticsearch 以实现高效的全文搜索、聚合分析和实时查询。以下是几种常用的同步方案及其实现方法：

1. 应用层双写（双写模式）

原理

在业务代码中同时向 MySQL 和 Elasticsearch 写入数据，保证两者数据一致。

实现步骤

在写入 MySQL 的事务中，同步或异步写入 Elasticsearch。
需处理可能的写入失败问题（如 Elasticsearch 宕机），通过重试机制或补偿机制（如消息队列）确保最终一致性。

优点

实现简单，对架构改动较小。
实时性强，写入即生效。

缺点

双写可能引入数据不一致风险（如 MySQL 成功但 Elasticsearch 失败）。
业务逻辑耦合度高，维护成本增加。

适用场景

小规模数据同步，对实时性要求高。
业务逻辑简单，可接受双写风险。

2. 使用 Logstash 定时同步

原理

通过 Logstash 的 jdbc 插件定期轮询 MySQL，将增量或全量数据同步到 Elasticsearch。

实现步骤

配置 Logstash 输入（Input）：使用 jdbc 插件连接 MySQL，定义 SQL 查询（如按时间戳增量拉取）。
配置 Logstash 输出（Output）：将数据写入 Elasticsearch。
定时任务：通过 schedule 参数设置轮询间隔（如每分钟一次）。

示例 Logstash 配置

input {jdbc {jdbc_driver_library => "mysql-connector-java-8.0.26.jar"jdbc_driver_class => "com.mysql.cj.jdbc.Driver"jdbc_connection_string => "jdbc:mysql://localhost:3306/mydb"jdbc_user => "root"jdbc_password => "password"schedule => "* * * * *"  # 每分钟执行一次statement => "SELECT * FROM products WHERE updated_at > :sql_last_value"use_column_value => truetracking_column => "updated_at"tracking_column_type => "timestamp"}
}
output {elasticsearch {hosts => ["http://localhost:9200"]index => "products"document_id => "%{id}"}
}

优点

配置简单，无需修改业务代码。
支持增量同步。

缺点

实时性较差（依赖轮询间隔）。
频繁轮询可能对 MySQL 造成压力。

适用场景

对实时性要求不高（如 T+1 数据同步）。
数据量较小，无需复杂转换的场景。

3. 基于 Binlog 的实时同步

原理

通过解析 MySQL 的 Binlog 日志（记录数据变更），将变更事件实时同步到 Elasticsearch。
常用工具：

Canal（阿里开源工具）
Debezium（基于 Kafka Connect）
Maxwell

实现步骤（以 Canal 为例）

开启 MySQL Binlog：

# 在 MySQL 配置文件中启用 Binlog
server-id = 1
log_bin = /var/log/mysql/mysql-bin.log
binlog_format = ROW  # 必须为 ROW 模式

部署 Canal Server：
- Canal 伪装为 MySQL 从库，订阅 Binlog 变更。
- 解析 Binlog 并转发到消息队列（如 Kafka）或直接调用 Elasticsearch API。
数据消费与写入 Elasticsearch：
- 编写消费者程序（如 Java/Python），将 Binlog 中的增删改事件转换为 Elasticsearch 的写入/更新/删除操作。

优点

实时性高（毫秒级延迟）。
对业务代码无侵入。

缺点

部署复杂度较高，需维护中间件（如 Canal、Kafka）。
需处理数据格式转换（如关系表到 JSON 文档）。

适用场景

大规模数据实时同步。
对数据一致性要求高的场景。

4. 使用消息队列解耦

原理

将 MySQL 的变更事件发送到消息队列（如 Kafka、RabbitMQ），由消费者异步写入 Elasticsearch。

实现步骤

捕获 MySQL 变更：
- 使用 Binlog 工具（如 Debezium）将变更事件发送到 Kafka。
消费 Kafka 消息：
- 编写消费者程序，处理消息并写入 Elasticsearch。

示例架构

MySQL → Debezium → Kafka → Consumer → Elasticsearch

优点

高可靠性，消息队列提供持久化和重试机制。
解耦生产者和消费者，扩展性强。

缺点

架构复杂度高，需维护多个组件。

适用场景

高并发、高可靠性的生产环境。
需要灵活扩展和数据缓冲的场景。

5. 第三方工具

工具推荐

Go-MySQL-Elasticsearch：基于 Go 开发的工具，直接读取 MySQL Binlog 并同步到 Elasticsearch。
Elasticsearch River（已弃用）：旧版 Elasticsearch 插件，不建议使用。

实现步骤（以 Go-MySQL-Elasticsearch 为例）

配置 MySQL 连接信息和 Elasticsearch 地址。
定义表到索引的映射规则。
启动服务，自动监听 Binlog 并同步数据。

优点

开箱即用，无需开发代码。

缺点

灵活性和可定制性较差。

总结与选型建议

方案	实时性	复杂度	可靠性	适用场景
应用层双写	高	低	中	小规模，强实时性
Logstash 定时同步	低	低	中	离线分析，非实时场景
Binlog 同步（Canal）	高	高	高	大规模，实时性要求高
消息队列（Kafka）	高	高	高	高并发，需解耦和扩展
第三方工具	中	中	中	快速实现，无需定制开发

注意事项

数据结构转换：需将 MySQL 的行数据转换为 Elasticsearch 的 JSON 文档，可能涉及嵌套对象或父子关系处理。
幂等性：确保同步操作的幂等性（如通过唯一ID），避免重复写入。
错误处理：监控同步失败的情况，提供重试或人工干预机制。
性能优化：
- 批量写入 Elasticsearch（使用 _bulk API）。
- 调整 Elasticsearch 的刷新间隔（refresh_interval）提升写入性能。

通过合理选择方案并配合监控工具（如 Kibana、Prometheus），可实现高效可靠的 MySQL 到 Elasticsearch 数据同步。

MySQL 和 Elasticsearch 之间的数据同步

MySQL 和 Elasticsearch 之间的数据同步是常见的需求，通常用于将结构化数据从关系型数据库同步到 Elasticsearch 以实现高效的全文搜索、聚合分析和实时查询。以下是几种常用的同步方案及其实现方法： 1. 应用层双写（双写模式） 原…...

编程日记 2025/9/15 11:13:00

【深度学习】矩阵的核心问题解析

一、基础问题 1. 如何实现两个矩阵的乘法？ 问题描述：给定两个矩阵 A A A和 B B B，编写代码实现矩阵乘法。解法： 使用三重循环实现标准矩阵乘法。或者使用 NumPy 的 dot 方法进行高效计算。 def matrix_multiply(A, B):m, n …...

编程日记 2025/9/15 16:27:56

汽车开放系统架构（AUTOSAR）中运行时环境（RTE）生成过程剖析

一、引言在当今高度智能化的汽车电子领域，软件系统的复杂性呈指数级增长。为了应对这一挑战，汽车开放系统架构（AUTOSAR）应运而生，它为汽车电子软件开发提供了标准化的分层架构和开发方法。其中，运行时环境…...

编程日记 2025/9/15 16:26:45

附录E MFC快速参考指南 E.1 创建窗口使用M F C CWnd wnd; W n d . C r e a t e E x ( E xSt y l e , C l a s s N a m e , Wi n d o w N a m e , S t y l e , x , y, Wi d t h , H e i g h t , P a r e n t , M e n u , P a r a m ) ; 使用A P I HWND hwnd=::CreateWi n d …...

编程日记 2025/9/15 16:27:21

Holoens2开发报错记录02_通过主机获取彩色和深度数据流常见错误

01.E1696 E1696 无法打开源文件 “stdio.h” 解决方法： 更新一下SDK 1）打开Visual Studio Installer，点击修改 2）安装详细信息中自己系统对应的SDK，点击修改即可 02.WinError 10060 方法来源解决方法&#xff1a…...

编程日记 2025/9/15 16:21:19

粉色和紫色渐变壁纸怎么设计？

粉色和紫色的渐变壁纸设计可以打造极为浪漫的氛围，这两种颜色的搭配极具梦幻感与浪漫气息，常被用于各种浪漫主题的设计之中。以下是关于粉色和紫色渐变壁纸的设计方法： 一、渐变方向设计横向渐变：从画面左侧的粉色过渡到右侧的紫…...

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

maven Problem shading JAR的几个解决方案

1 现象 Error creating shaded jar: Problem shading JAR ：xxxxxx.jar entry META-INF/versions/11/com/fasterxml/jackson/core/io/doubleparser/BigSignificand.class: java.lang.IllegalArgumentException -> [Help 1] 2 原因这个问题通常是由于 maven-s…...

编程日记 2025/9/15 16:23:56

前缀和代码解析

前缀和是指数组一定范围的数的总和,常见的有两种,一维和二维,我会用两道题来分别解析一维 DP34 【模板】前缀和题目: 题目解析: 暴力解法直接遍历数组,遍历到下标为 l 时,开始进行相加,直到遍历到下标为 r ,最后返回总和.这样做的时间复杂度为: O(n) public class Main …...

编程日记 2025/9/15 16:29:17

CaffeineCache自定义缓存时间

文章目录 1、POM文件依赖2、声明缓存3、缓存使用4、测试缓存5、自定义缓存过期时间6、测试自定义超时时间 1、POM文件依赖 <dependency><groupId>com.github.ben-manes.caffeine</groupId><artifactId>caffeine</artifactId><version>3.1…...

编程日记 2025/9/10 8:05:45

keil中出现Error_Handler错误的解决方法

这个错误表明在代码中使用了 Error_Handler 函数但未定义。以下是完整的修复方案： 步骤 1：在 main.h 中添加函数声明 /* main.h */ void Error_Handler(void);步骤 2：在 main.c 中完善错误处理函数 /* main.c */ void Error_Handler(void) …...

编程日记 2025/9/14 21:54:45

low rank decomposition如何用于矩阵的分解

1. 什么是矩阵分解和低秩分解矩阵分解是将一个矩阵表示为若干结构更简单或具有特定性质的矩阵的组合或乘积的过程。低秩分解（Low Rank Decomposition）是其中一种方法，旨在将原矩阵近似为两个或多个秩较低的矩阵的乘积，从而降低复…...

编程日记 2025/9/15 13:49:10

Cesium@1.126.0,创建3D瓦片，修改样式

第一步：添加3D建筑 Cesium.createOsmBuildingsAsync()这是一个异步方法，所以要写在一个异步函数里创建一个函数 const create3DBuilding async (viewer) > {try {// 添加3D建筑const tileset await Cesium.createOsmBuildingsAsync();viewer.scen…...

编程日记 2025/9/13 4:54:38

MFC学习笔记-1

一、编辑框和按钮 //.h文件private:CString str;//给窗口类加了一个变量（定义一个成员变量），关联到IDC_EDIT1中（要在实现中关联，源文件文件夹中）CString str2;//接收button2，和IDC_EDIT2绑定 p…...

编程日记 2025/8/28 1:50:11

Bugku CTF CRYPTO

Bugku CTF CRYPTO 文章目录 Bugku CTF CRYPTO聪明的小羊ok[-<>]散乱的密文.!? 聪明的小羊描述: 一只小羊翻过了2个栅栏 fa{fe13f590lg6d46d0d0} 分析：栅栏密码，分2栏，一个栏里有11个 ①手动解密 f a { f e 1 3 f 5 9 0 l g 6 d 4 …...

编程日记 2025/9/11 0:22:49

Leetcode2502：设计内存分配器

题目描述： 给你一个整数 n ，表示下标从 0 开始的内存数组的大小。所有内存单元开始都是空闲的。请你设计一个具备以下功能的内存分配器： 分配一块大小为 size 的连续空闲内存单元并赋 id mID 。释放给定 id mID 对应的所有内存单元。 …...

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

BERT模型详解及代码复现

架构设计 BERT模型的架构设计是其成功的关键之一，它巧妙地融合了Transformer架构的优势，并针对自然语言处理任务进行了优化。具体来说，BERT的架构主要由三个模块组成： Embedding模块：负责将输入的文本转换为模型可处理的向量表示。该模块由三种Embedding组成： Token Em…...

编程日记 2025/9/12 13:03:23

面试中自己挖的一些坑

一些面试的细节深度持续更新。。。 1. 这里有4题，单独写成了博客2. 经典的八股文之一 (ArrayList扩容原理)1.博主的回答2.面试官问的一些细节 3.经典的八股文之一 (HashMap扩容原理)1.博主的回答2.面试官问的一些细节 4.SpringBoot的启动原理1. 博主回答2. 面试官问…...

编程日记 2025/9/14 4:26:20

二、环 Ring

文章目录一、环的定义二、环的分类与变种1、交换环2、含单位元的环3、零环4、非交换环5、整环6、域三、环的性质与应用四、环与群和域的对比一、环的定义一个集合 R 被称为一个环，如果它满足以下条件： 对于加法满足： 闭合性&#xff1…...

编程日记 2025/9/14 8:15:12

Python图像处理入门：如何打开图像文件及常见格式

神经网络中的图像处理是一个非常重要的环节，尤其是在计算机视觉领域。作为一名新手，你可能会遇到一个常见的挑战——如何在 Python 中打开并理解图像文件。在本篇文章中，我们将介绍几种常见的图像文件格式，并讲解如何使用 Python …...

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

银河麒麟高级服务器操作系统在线调整/pro/{PID}/limits文件中nofile的软限制和硬限制参数值操作方法

银河麒麟高级服务器操作系统在线调整/pro/{PID}/limits文件中nofile的软限制和硬限制参数值操作方法一系统环境二使用场景三操作步骤一系统环境 [rootlocalhost ~]# nkvers ############## Kylin Linux Version ################# Release: Kylin Linux Advanced Server…...

编程日记 2025/9/15 9:49:58

网络运维学习笔记 018 HCIA-Datacom综合实验02

文章目录综合实验2sw3：sw4：gw：core1（sw1）：core2（sw2）：ISP 综合实验2 sw3： vlan 2 stp mode stp int e0/0/1 port link-type trunk port trunk allow-pass v…...

编程日记 2025/9/15 0:13:22

深度学习进阶：构建多层神经网络

在上一篇文章中，我们从零开始构建了一个简单的两层神经网络，并通过异或问题（XOR）展示了神经网络的强大能力。今天，我们将进一步深入，构建一个更复杂的多层神经网络，并引入更多高级概念&#xff…...

编程日记 2025/9/15 3:13:17

高斯消元法

前置数学知识 n元线性方程是具有如下形式的方程： a 1 x 1 a 2 x 2 a 3 x 3 … a n x n b a_1x_1a_2x_2a_3x_3…a_nx_n b a1x1a2x2a3x3…anxnb 其中， a 1 , a 2 , . . . a_1,a_2,... a1,a2,...以及常数项 b b b均为已知的实数…...

编程日记 2025/9/9 15:17:33

ubuntu 安全策略(等保)

windows 三个帐号屏保设置组策略,密码超时次数/审计记录； linux 应具有登录失败处理功能，应配置并启用结束会话、限制非法登录次数和当登录连接超时自动退出等相关措施。 1、在系统中新建测试用户，使用此用户登录时多次输入错误密码&…...

编程日记 2025/9/14 6:53:24

计算机毕业设计SpringBoot+Vue.js购物推荐系统网站(源码+文档+PPT+讲解)

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

编程日记 2025/9/14 3:26:19

QT线程同步

文章目录前言1. 使用互斥锁（QMutex）2.使用QMutexLocker便利类3. 使用读写锁（QReadWriteLock）4.QReadLocker便利类和QWriteLocker便利类对QReadWriteLock进行加解锁5. 使用信号量（QSemaphore）6. 使用条件变…...

编程日记 2025/9/11 10:13:41

何为第一二三产业？

第一、第二、第三产业的分类是经济学中对经济活动的划分方式，起源于20世纪30年代经济学家费希尔和克拉克的理论。以下是具体说明： 第一产业（Primary Sector） 定义：直接利用自然资源进行生产活动的行业。核心领域&…...

编程日记 2025/9/4 11:09:50

Spring 面试题

Autowired和Resource两个注解的区别 Autowired： 是Spring框架的注解，用于依赖注入。默认按照类型（byType）注入，如果存在多个相同类型的Bean，则会报错。可以通过Qualifier指定具体的Bean名称。如果没有匹…...

编程日记 2025/9/8 15:04:04

Linux设备驱动开发-SPI驱动开发详解（包含设备树处理详细过程）

基础知识及 SPI 相关结构体介绍引脚：MISO（master 输入，slave 输出），MOSI（master 输出，slave 输入），片选引脚，SCK（时钟） 控制寄存器&…...

编程日记 2025/9/10 21:39:24

物联网平台建设方案一

系统概述构建物联网全域支撑服务能力，为实现学院涵盖物联网设备的全面感知、全域互联、全程智控、全域数字基底、全过程统筹管理奠定基础，为打造智能化提供坚实后台基石。物联网平台向下接入各种传感器、终端和网关，向上通过开放的实施分…...

编程日记 2025/9/11 19:46:50

java23种设计模式-桥接模式

桥接模式（Bridge Pattern）学习笔记 🌟 定义桥接模式属于结构型设计模式，将抽象部分与实现部分分离，使它们可以独立变化。通过组合代替继承的方式，解决多维度的扩展问题，防止类爆炸。 &#x…...

编程日记 2025/9/2 16:15:58

springboot实现文件上传到华为云的obs

一、前言有时在项目中需要使用一些存储系统来存储文件，那么当项目要接入obs作为存储系统时，就会利用obs来进行文件的上传下载，具体实现如下。二、如何通过obs实现文件的上传下载？ 1.添加相关的obs的maven依赖。 <dependency…...

编程日记 2025/9/12 20:35:25

【红队利器】单文件一键结束火绒6.0

关于我们 4SecNet 团队专注于网络安全攻防研究，目前团队成员分布在国内多家顶级安全厂商的核心部门，包括安全研究领域、攻防实验室等，汇聚了行业内的顶尖技术力量。团队在病毒木马逆向分析、APT 追踪、破解技术、漏洞分析、红队工具开发等多个…...

编程日记 2025/8/17 21:59:01

DeepSeek 助力 Vue 开发：打造丝滑的滚动动画（Scroll Animations）

前言：哈喽，大家好，今天给大家分享一篇文章！并提供具体代码帮助大家深入理解，彻底掌握！创作不易，如果能帮助到大家或者给大家一些灵感和启发，欢迎收藏关注哦 💕 目录 Deep…...

编程日记 2025/9/13 14:15:51

Compose 动画，让页面动起来

Compose 动画，让页面动起来概述高级别动画APIAnimatedVisibilityMutableTransitionStateModifier.animateEnterExit自定义Enter/Exit动画 AnimatedContentContentTransform自定义动画SizeTranstion定义大小动画定义子元素动画自定义Enter/Exit动画 CrossfadeModifi…...

编程日记 2025/9/9 21:48:27

Windows CMD 命令大全(Complete List of Windows CMD Commands)

Windows CMD 命令大全： Windows CMD 是 Windows 系统内置的命令行工具，用于执行各种命令和管理任务。称为Command Prompt。它提供了一个通过键入命令来与计算机系统进行交互的方式，类似于早期的DOS操作系统。以下是 CMD 的基础知识和常用命…...

编程日记 2025/9/12 11:12:25

DeepSeek在MATLAB上的部署与应用

在科技飞速发展的当下，人工智能与编程语言的融合不断拓展着创新边界。DeepSeek作为一款备受瞩目的大语言模型，其在自然语言处理领域展现出强大的能力。而MATLAB，作为科学计算和工程领域广泛应用的专业软件，拥有丰富的工具包和高效…...

编程日记 2025/9/9 14:54:11

IP代理在网络数据挖掘中的关键作用（AI大模型数据采集版）

在当今人工智能飞速发展的时代，AI大模型的训练需要海量且多样化的数据。然而，在数据采集过程中，常常面临诸多挑战，而IP代理在其中发挥着至关重要的作用。数据采集的多样性是影响AI大模型性能的关键因素。如果数据来源单一&#x…...

编程日记 2025/9/11 11:20:26

pandas数据的导出

数据导出将数据导出到CSV文件数据对象.to_csv(filepath,sep"",indexFalse,encoding)参数1:文件的路径参数2:分隔符，默认是 ,参数3:是否保留索引默认 Ture参数4:文件编码代码 ： # 将数据导出到CSV # 引用 pandas import pandas as pd # 定…...

编程日记 2025/9/15 12:44:33

Claude-3.7-Sonnet：Cursor 的新引擎，解锁编码与推理的未来

引言 claude-3.7-sonnet 是 Anthropic 最新发布的大型语言模型，于 2025 年 2 月 24 日推出，并已集成到 Cursor AI 平台中。Cursor 是一个 AI 驱动的集成开发环境（IDE），旨在通过 AI 增强开发者的生产力。claude-3.7-so…...

编程日记 2025/9/8 5:25:43

JavaScript函数-函数的两种声明方式

在JavaScript中，函数是构建复杂逻辑和实现代码重用的基本单元。了解如何正确地定义和使用函数对于任何JavaScript开发者来说都是至关重要的。本文将详细介绍JavaScript函数的两种主要声明方式：函数声明（Function Declaration）和函…...

编程日记 2025/9/15 15:22:52

微服务即时通信系统---（六）语音识别子服务

目录功能设计模块划分业务接口/功能示意图服务实现流程思想服务代码实现编写proto文件服务端创建子类（SpeechRecognitionServiceImpl）完成RPC服务调用函数重写 SpeechRecognize（语音识别）服务端完成语音识别子服务类（SpeechRecognitionServer）注意 …...

编程日记 2025/9/10 11:42:19

【Java 8】Lambda表达式介绍

目录 1、Lambda简介 2、语法介绍 3、Lambda表达式示例 3.1、无参数的 Lambda 表达式 3.2、单个参数的 Lambda 表达式 3.3、多个参数的 Lambda 表达式 3.4、带语句块的 Lambda 表达式 4、Lambda使用场景 4.1、替代匿名内部类 4.2、集合操作 4.3、排序 4.4、函数式接口…...

编程日记 2025/9/14 2:57:30

2011-2019年各省电视节目综合人口覆盖率数据

2011-2019年各省电视节目综合人口覆盖率数据 1、时间：2011-2019年 2、来源：国家统计局、统计年鉴 3、指标：行政区划代码、地区、年份、电视节目综合人口覆盖率(%) 4、范围：31省 5、指标解释：电视节目综合人口覆盖…...

编程日记 2025/9/9 3:47:48

便捷高效的免费 PDF 文件处理帮手

软件介绍今天要给大家推荐一款超实用的 PDF 工具箱。它的优势十分突出，完全免费且没有任何使用限制。安装起来毫不费力，下载完成后，直接打开就能使用。软件界面简洁大方，操作便捷顺手。其核心功能涵盖三大板块：一…...

编程日记 2025/9/10 10:56:39

DeepSeek引领目标检测新趋势：如何通过知识蒸馏优化模型性能

目录一、知识蒸馏是什么？ 二、知识蒸馏在目标检测中的重要性提升实时性跨任务迁移学习三、如何使用知识蒸馏优化目标检测？ 训练教师模型生成软标签训练学生模型调节温度参数多教师蒸馏（可选） 四、案例分享定…...

编程日记 2025/9/15 13:44:27

“深入解析 SQL Server 子查询：从基础到应用”

目录引言什么是子查询？ 子查询的定义子查询的类型子查询的使用标量子查询多行子查询多列子查询相关子查询子查询的性能优化子查询的实际案例总结引言在 SQL Server 中，子查询是一种强大的工具，允许我们在一个查询中嵌套另一个查询&am…...

编程日记 2025/9/12 19:21:43

375_C++_cloud手机推送，添加人脸告警信息到任务队列中，UploadAlarmPush是典型的工厂模式应用，为什么使用工厂模式完成这部分代码

一：AlarmFaceInfo的应用让我帮你解析这个lambda表达式的实现： // ...................... .h ...........................// struct RsMsgPushTask_S : public Task{AlarmType_E mainAlarmType;unsigned int subAlarmType;DateTime alarmTime...

编程日记 2025/8/22 10:34:14

Vue进阶之AI智能助手项目（二）——项目评审与架构设计

AI智能助手项目基于Vue的最佳实践main.tsApp.vue主应用给子应用下发功能语言language，theme设置及appStore状态管理状态管理router路由index.tspermission.ts基于Vue的最佳实践 src目录概览 api 接口，基于接口可以做状态处理，interceptorassets/public 静态资源component…...

编程日记 2025/9/14 2:33:01

LambdaQueryWrapper在Mybatis-plus中的应用

LambdaQueryWrapper 是 MyBatis-Plus 中非常强大的工具，用于构建类型安全的查询条件。它利用 Java 的 Lambda 表达式，使得查询条件的编写更加简洁和直观。 public R getAppArticleCategoryPage(ParameterObject Page page,ParameterObject AppArticleCa…...

编程日记 2025/9/15 13:29:45

1. 应用层双写（双写模式）

原理

实现步骤

优点

缺点

适用场景

2. 使用 Logstash 定时同步

原理

实现步骤

示例 Logstash 配置

优点

缺点

适用场景

3. 基于 Binlog 的实时同步

原理

实现步骤（以 Canal 为例）

优点

缺点

适用场景

4. 使用消息队列解耦

原理

实现步骤

示例架构

优点

缺点

适用场景

5. 第三方工具

工具推荐

实现步骤（以 Go-MySQL-Elasticsearch 为例）

优点

缺点

总结与选型建议

注意事项

相关文章：