百度认证官方网站2024年1月新冠高峰期

elasticsearch中的数据多是来自数据库，当数据库发生改变时，elasticsearch也必须跟着改变，这个就叫做数据同步。

当我们是进行微服务的时候，同时两个服务不能进行相互调用的时候。就会需要进行数据同步。

方法一：同步调用

当我们进行数据的删除或者新增的时候，先进行数据库的修改，这个时候再调用搜索功能的更新接口，然后再由搜索功能的服务进行elasticsearch的数据更新，当更新之后再进行依次回复。

上述方法问题：数据和业务的耦合，两个业务之间使得功能模块进行了耦合，同时也会出现效率下降的情况。同时当某一模块不可用的时候，会引起业务功能之间不能够使用，使各个模块之间进行了相互依赖，牵一发而动全身。

方法二：异步通知

当启动新增或者删除的业务的时候，数据库的更新操作还是不变，只不过在这个时候对MQ进行发送消息，进行通知，同时让搜索模块的服务监听着MQ的消息，收到消息之后再把elasticsearch进行数据的更新，最终实现异步通知的方法实现了数据的同步

解除了业务之间的耦合，同时也提高了性能。

方法三：监听binlog

在MySQL的主从复制的行为时，可以将binlog进行开启，这样当MySQL进行数据的更改的时候，使用canal中间件进行监听，最后通知搜索服务的elasticsearch的数据更新。