应用接入ES,通用逻辑抽象

接入ES,通用流程

ES安装

docker

操作ES ORM框架

https://www.easy-es.cn/

🚀ElasticSearch搜索引擎ORM框架

Canal数据解析基类

Canal数据封装

@Data
public class BaseCanalData<T> { // 这里使用泛型来替代不同的表实体
  private String type; // 操作类型 INSERET、UPDATE、DELETE
  private String table;
  private String database;
  private List<T> data; // 当前数据
  private List<T> old; // 旧数据
  private Boolean isDdl;
  private String sql;
}

实时数据写入ES

Canal消息处理,写入ES

刷数脚本

抽象刷数逻辑