配置Elasticsearch集群读写分离

场景描述

读写分离支持将写入主集群（Leader）的数据自动同步到从集群（Follower），实现主集群承担写入任务，从集群承担查询任务。读写分离可以将读写压力分开，提高查询的性能，还能支持在主集群无法提供服务时降级，使用从集群提供写入和查询服务。

图1 读写分离特性的两种使用场景

场景一（图左）：主集群写入，从集群查询，分离读写压力。

场景二（图右）：主集群故障时，从集群升级，正常提供服务，避免业务中断。

约束限制

• 仅Elasticsearch 7.6.2、Elasticsearch 7.10.2集群支持读写分离。
• 主集群和从集群的版本必须保持一致，否则服务可能异常。

前提条件

已创建两个版本一致的集群，一个作为主集群，另一个作为从集群。从集群必须能访问主集群的REST接口（默认端口为9200）。

连接主从集群

1. 登录云搜索服务管理控制台。
2. 在“集群管理”页面选择从集群，单击操作列“Kibana”，登录Kibana页面。
3. 单击左侧导航栏的“Dev Tools”进入操作页面
4. 执行如下命令，在从集群配置主集群的信息。

   PUT /_cluster/settings
   {
     "persistent" : {
       "cluster" : {
         "remote.rest" : {
           "leader1" : {
             "seeds" : [
               "http://10.0.0.1:9200",
               "http://10.0.0.2:9200",
               "http://10.0.0.3:9200"
             ] ,
               "username": "elastic",
               "password": "*****"
           }
         }
       }
     }
   }

   表1 请求体参数说明

   参数名	说明
   leader1	主集群配置任务的名称，由用户自定义，在后续读写分离配置时会用到该名称。
   seeds	主集群的访问地址。当集群开启HTTPS访问时，URI schema需要对应使用https。
   username	主集群的用户名，仅主集群是安全集群时才需要配置。
   password	主集群的密码，仅主集群是安全集群时才需要配置。

   返回示例：

   {
     "acknowledged" : true,  // 是否成功
     "persistent" : {
       "cluster" : {
         "remote" : {
           "rest" : {
             "leader1" : {
               "seeds" : [
               "http://10.0.0.1:9200",
               "http://10.0.0.2:9200",
               "http://10.0.0.3:9200"
               ]
             }
           }
         }
       }
     },
     "transient" : { }
   }

5. 配置完成后，在从集群执行如下命令确认从集群和主集群的连接状况。

   GET _remote/rest/info

   返回示例：

   {
     "leader1" : {
       "connected" : true  //表示连接正常
     }
   }

索引同步

索引同步有2种方式：指定索引同步和匹配索引同步。

开启索引同步后，从集群的索引会变为只读状态，并且定时与主集群索引同步。同步周期默认30秒，如果需要修改请参见修改同步周期。

停止索引同步

在从集群执行如下命令，终止索引名称对应的同步任务，后续主集群对该索引的修改不会被同步到从集群，并且从集群中该索引的只读状态解除，支持新数据的写入。

PUT log*/stop_remote_sync

“log*”表示索引名称，支持指定多个索引（多个索引之间用英文逗号分隔）和使用通配符，此例是停止以“log”开头的索引的同步任务。

查询并删除集群匹配模式

1. 在从集群执行如下命令，查询已创建的匹配模式。
   • 列表查询

     GET auto_sync/pattern

   • 指定名称查询

     GET auto_sync/pattern/{PATTERN}

   接口返回示例如下：

   {
     "patterns" : [
       {
         "name" : "pattern1",
         "pattern" : {
           "remote_cluster" : "leader",
           "remote_index_patterns" : [
             "log*"
           ],
           "local_index_pattern" : "{{remote_index}}-sync",
           "settings" : { }
         }
       }
     ]
   }

2. 在从集群执行如下命令，指定模式名称删除模式。

   DELETE auto_sync/pattern/{PATTERN}

开启强制同步

• 开启强制同步

  插件默认根据主集群索引的文档数是否发生变化来决定是否要同步元数据，当主集群只对文档进行更新且文档数不变时，插件不会同步该更新到从集群。支持修改配置，开启后，每个同步周期从集群都会强制同步主机群的索引元数据。

  请求示例如下（开启强制同步）：

  PUT _cluster/settings
  {
    "persistent": {
      "remote_sync.force_synchronize": true
    }
  }

修改同步周期

• 修改同步周期

  同步周期默认30秒，支持修改。

  请求示例如下（修改同步周期为2秒）：

  PUT {index_name}/_settings
  {
    "index.remote_sync.sync_interval": "2s"
  }

查询同步状态

• 获取自动同步状态

  该接口可以获取匹配索引同步的状态。

  请求示例如下：

  GET auto_sync/stats

  接口返回示例如下：

  {
    "success_count" : 3,
    "failed_count" : 0,
    "failed_remote_cluster_state_requests_count" : 0,
    "last_fail_exception" : { },
    "last_fail_remote_cluster_requests_exception" : { }
  }

• 获取指定索引的自动同步状态

  请求示例如下：

  GET {index_name}/sync_stats

  接口返回示例如下：

  {
    "indices" : {
      "data1_follower" : {
        "shards" : {
          "0" : [
            {
              "primary" : false,
              "total_synced_times" : 27,
              "total_empty_times" : 25,
              "total_synced_files" : 4,
              "total_synced_bytes" : 3580,
              "total_paused_nanos" : 0,
              "total_paused_times" : 0,
              "current" : {
                "files_count" : 0,
                "finished_files_count" : 0,
                "bytes" : 0,
                "finished_bytes" : 0
              }
            },
            {
              "primary" : true,
              "total_synced_times" : 28,
              "total_empty_times" : 26,
              "total_synced_files" : 20,
              "total_synced_bytes" : 17547,
              "total_paused_nanos" : 0,
              "total_paused_times" : 0,
              "current" : {
                "files_count" : 0,
                "finished_files_count" : 0,
                "bytes" : 0,
                "finished_bytes" : 0
              }
            }
          ]
        }
      }
    }
  }

主从切换

当主集群出现故障时，支持通过主从切换保证业务正常进行。

1. 判断主从集群的索引同步方式。查询从集群是否有索引同步的匹配模式，命令参考查询并删除集群匹配模式。
   • 如果没有匹配模式，则表示主从集群是指定索引同步关系，则执行3。
   • 如果有匹配模式，则表示主从集群是模式匹配索引同步关系，则执行2。
2. 删除从集群的索引同步的匹配模式，命令参考查询并删除集群匹配模式。
3. 从集群停止索引同步，将读写流量切换到从集群。如果主从集群是匹配索引同步关系，停止索引同步命令使用通配符匹配索引。
4. 当主集群恢复后，通过索引同步将从集群数据向主集群同步，完成主从切换。