事务回滚-ES处理
2026-02-09 15:17:57 0 举报在某些关键业务场景中，数据的一致性是至关重要的。核心内容围绕着“事务回滚-ES处理”，这一过程确保了在发生意外故障或异常情况时，系统能够完整地将业务操作撤销，且这些改变不会影响到后端的数据完整性。文件类型，如日志记录、配置文件或状态快照，通常被用于跟踪和存储必须被回滚的操作细节。通过这样的机制，修饰语如“一致”和“安全”被用来描述这一处理流程的特性——它保障了数据状态的准确性和操作的安全性。这样的ES处理确保了事务的原子性，保护了数据一致性，强化了整个信息系统的健壮性和可信度。
作者其他创作
大纲/内容
根据SQL操作类型，操作es索引数据。
Kafka队列
更新异常表
记录异常表
根据表名tableName得到对应的esClient
消费
AbstractUndoExecutorseata事务架构重写类，单独实现executeOn方法
job
xxl-job
增加异常次数/删除已处理成功的数据
gxyj-componentes_sync_log
监听Kafka队列消息，进行消息消费；分片：3
EsUndo
异常
client.delete
client.index
交易-es-sync服务
*回滚ES核心方法 * market 回滚的前置条件：model类 的路径是 按照规范创建的，否则无法被初始化到DaoMap 中 * @param uuid 主键uuid * @param tableName 表名称，注意，在开发过程中， 需保证表名的唯一性； * @param type SQL 的操作类型；
增加字段：int warpType;//使用场景类型；默认0-未知；1-宽表补偿；2-业务表回滚补偿
交易-业务微服务
0 条评论
下一页
为你推荐
查看更多
