同步方案

Mysql数据发生改变时，ElasticSearch也必须跟着改变，这个就是ElasticSearch与Mysql之间的数据同步。

同步调用

  1. 就是Mysql更新/新增/删除数据时，同步调用ElasticSearch接口。
  2. 基本步骤如下：
    • hotel-demo对外提供接口，用来修改elasticsearch中的数据。
    • 酒店管理服务在完成数据库操作后，直接调用hotel-demo提供的接口。

  1. 优点：实现简单，粗暴；缺点：业务耦合度高。

异步通知

  1. 就是Mysql更新/新增/删除数据时，把数据放入MQ中，消费线程再调用ElasticSearch接口。
  2. 基本流程：
    • hotel-admin对mysql数据库数据完成增、删、改后，发送MQ消息。
    • hotel-demo监听MQ，接收到消息后完成elasticsearch数据修改。

  1. 优点：低耦合，实现难度一般；缺点：依赖mq的可靠性。

监听binlog

  1. 监听 Mysql 的 binlog日志：
    • 给mysql开启binlog功能。
    • mysql完成增、删、改操作都会记录在binlog中。
    • hotel-demo基于canal监听binlog变化，实时更新elasticsearch中的内容。

  1. 优点：完全解除服务间耦合；缺点：开启binlog增加数据库负担、实现复杂度高。

canal部署

  1. 参看github完整的部署文件https://github.com/helium-chain/canal-es。