当业务量上升后，由于mysql对全文检索或模糊查询支持的能力不强，在系统中查询的地方，往往会出现慢sql等，拖累系统其他模块，造成性能低下。

随着ES使用普及率的升高，ES是mysql的一个有效补充。我们可以将数据发送到搜索引擎（如ES）上，由搜索引擎来提供专业的服务。

接下来，就结合工作中实际用到的场景，对数据从mysql到es的同步进行一些分析。

在实践中我总结出了以下几种方式。

第1种：同步双写

这是一种比较简单的方式，就是在将数据写入到MySQL的时候，同时将数据写入到ES,实现数据的双写。

优点：业务逻辑简单

缺点：1）硬编码，需要写入MySQL的地方都需要添加写入ES的代码。

2）业务耦合性高。

3）存在双写失败丢失数据的风险。

4）性能低，本来MySQL的性能就不算高，再写入ES系统性能必然下降。

双写失败的场景：

1）系统和ES服务器之间网络故障。

2）应用系统重启，导致来不及写入ES。

针对这种情况，有数据强一致性要求的就要把双写操作放到同一事物里面，一旦用上事务，则性能下降更加明显。

第2种：异步双写（MQ方式）

针对第一种同步双写的性能和数据丢失问题，可以考虑引入MQ,从而形成异步双写的方案。

由于MQ的性能基本比mysql高出一个数量级，所以性能可以得到显著的提高。

优点：

性能高；不存在丢数据问题。

缺点：

1）硬编码问题：依然存在业务强耦合：

2）依然存在复杂度增加：

3）系统中增加了mq的代码；

4）可能存在时延问题：程序的写入性能提高了，但是由于MQ的消费可能由于网络或其它原因导致用户写入的数据不一定可以马上看到，造成延时。

第3种：异步双写（Worker方式）

上面两种方案中都存在硬编码问题，也就是有任何对mysq进行增删改查的地方要么植入ES代码，要么替换为MQ代码，代码的侵入性太强。

如果对实时性要求不高的情况下，可以考虑用定时器来处理，具体步骤如下：

数据库的相关表中增加一个字段为timestamp的字段，任何crud操作都会导致该字段的时间发生变化；原来程序中的CURD操作不做任何变化；增加一个定时器程序（京东内部叫Worker），让该程序按一定的时间周期扫描指定的表，把该时间段内发生变化的数据提取出来；逐条写入到ES中。入下图所示

优点：

不改变原来代码，没有侵入性、没有硬编码；

没有业务强耦合；不改变原来程序的性能；

Worker代码编写简单不需要考虑增删改查。

缺点：

时效性较差，由于定时器工作周期不可能设在秒级，所以实时性没有上面2中好；

对数据库有一定的轮询压力，一种改进方法是将轮询放到压力不大的从库上。

第4种：Binlog 同步方式：

上面三种方案要么有代码侵入，要么有硬编码，要么有时延，第4中方案，可以利用mysql的binlog来进行同步

具体步骤如下：

1） 读取mysql的binlog日志，获取指定表的日志信息；

2） 将读取的信息转为MQ；

3） 编写一个MQ消费程序；

4） 不断消费MQ，每消费完一条消息，将消息写入到ES中。

优点：

没有代码侵入、没有硬编码；原有系统不需要任何变化，没有感知；

性能高；

业务解耦，不需要关注原来系统的业务逻辑。

缺点：

构建Binlog系统复杂；

也像方案二，存在MQ延时的风险

参考：https://www.cnblogs.com/zeenzhou/p/12125634.html