elasticsearch中的数据多是来自数据库,当数据库发生改变时,elasticsearch也必须跟着改变,这个就叫做数据同步。
当我们是进行微服务的时候,同时两个服务不能进行相互调用的时候。就会需要进行数据同步。
方法一:同步调用
当我们进行数据的删除或者新增的时候,先进行数据库的修改,这个时候再调用搜索功能的更新接口,然后再由搜索功能的服务进行elasticsearch的数据更新,当更新之后再进行依次回复。
上述方法问题:数据和业务的耦合,两个业务之间使得功能模块进行了耦合,同时也会出现效率下降的情况。同时当某一模块不可用的时候,会引起业务功能之间不能够使用,使各个模块之间进行了相互依赖,牵一发而动全身。
方法二:异步通知
当启动新增或者删除的业务的时候,数据库的更新操作还是不变,只不过在这个时候对MQ进行发送消息,进行通知,同时让搜索模块的服务监听着MQ的消息,收到消息之后再把elasticsearch进行数据的更新,最终实现异步通知的方法实现了数据的同步
解除了业务之间的耦合,同时也提高了性能。
方法三:监听binlog
在MySQL的主从复制的行为时,可以将binlog进行开启,这样当MySQL进行数据的更改的时候,使用canal中间件进行监听,最后通知搜索服务的elasticsearch的数据更新。