Solr4.8.0源码分析(24)之SolrCloud的Recovery策略(五)
题记:关于SolrCloud的Recovery策略已经写了四篇了,这篇应该是系统介绍Recovery策略的最后一篇了。本文主要介绍Solr的主从同步复制。它与前文<Solr4.8.0源码分析(22)之SolrCloud的Recovery策略(三)>略有不同,前文讲到的是SolrCloud的leader与replica之间的同步,不需要通过配置solrconfig.xml来实现。而本文主要介绍单机模式下,利用solrconfig.xml来实现主从服务器的同步。
分布式环境下,由于高并发的问题,通常我们需要部署多台服务器来负载均衡,从而避免,单点访问的热点问题,或者因负载过高而造成服务器瘫痪的问题等等。 solr4.x之后推出了solrcloud的分布式集群方案,与4.x之前的Master/Slave集群模式,架构上发生了重大变化,solrcloud不仅仅解决了,高并发的负载均衡问题,也解决了海量数据的检索性能问题,对一份巨大的索引,采用分而治之的方法索引到多个独立的节点上,但是这样并不代表,4.x之前的Master/Slave架构就被淘汰出局了,其实solrcloud里面也是综合运用了主从的方式,来解决并发的问题。 如果数据量不是很大的情况下,没必要采用solrcloud方案,但这时候,又需要解决高并发问题,或者服务器单点故障问题怎么办? 答案还是采取经典的主从架构模式来解决,
1. 配置
- master 模式
<requestHandler name="/replication" class="solr.ReplicationHandler" >
<lst name="master">
<!--什么时候出发同步,参数名replicateAfter,取值可以是startup commit optimize -->
<str name="replicateAfter">startup</str>
<str name="replicateAfter">commit</str> <!--数据备份 参数名backupAfter 同样可以似乎startup commit optimize -->
<!-- <str name="backupAfter">optimize</str> --> <!--配置要同步的配置文件 -->
<str name="confFiles">schema.xml,stopwords.txt,elevate.xml</str>
<!--提交同步时间间隔,默认是10秒,一般不用改动 -->
<str name="commitReserveDuration">00:00:10</str>
14 <!--备份的个数-->
15 <str name="maxNumberOfBackups">1</str>
16 </lst>
17 </requestHandler>
参数说明:
- 如果commit比较频繁,或者网络比较慢,则需要微调, <str name="commitReserveDuration">00:00:10</str>.这是大致的master下载5M大小的数据到slave所花的时间,默认是10.
- 如果你设置replicateAfter为startup,如果需要在以后触发commit/optimize,那么同样需要设置commit/optimize。如果只设置了startup,那么在启动的时候触发过replication之后不会在随后的commit/optimize中触发。
- slave 模式
<requestHandler name="/replication" class="solr.ReplicationHandler" >
<lst name="slave"> <!--主服务的同步地址-->
<str name="masterUrl">http://master_host:port/corename/replication</str> <!--同步轮询的时间间隔,是应用还击而定 -->
<str name="pollInterval">00:00:20</str>
<str name="compression">internal</str>
<!--Http相关参数设置-->
<str name="httpConnTimeout">5000</str>
<str name="httpReadTimeout">10000</str> <!-- 如果主服务设置认证,在此设置登录用户名密码 -->
<str name="httpBasicAuthUser">username</str>
<str name="httpBasicAuthPassword">password</str>
</lst>
</requestHandler>
参数说明:
- Compression 设置可以设为internal或者external,该设置是用于传输文件时候是否需要进行压缩。如果设为external,则是压缩传输,设为internal则正常传输。除非网络带宽喜爱,否则不要设置external,因为会影响replication。
- Repeater模式
如果是一个master,多个slave时候,当多个slave从master下载文件时候对master的负荷会特别大。为了避免这种情况,可以使用repeater模式来改善,即一个节点即当master又当slave:
- 同样在solrconfig.xml上配置
- 即使在repeater上的master设置了replicateAfter为optimize,也需要设置commit。这是因为在slave中optimize是无效的。
- 在repeater中Compression还是有效的
<requestHandler name="/replication" class="solr.ReplicationHandler">
<lst name="master">
<str name="replicateAfter">commit</str>
<str name="confFiles">schema.xml,stopwords.txt,synonyms.txt</str>
</lst>
<lst name="slave">
<str name="masterUrl">http://master.solr.company.com:8080/solr</str>
<str name="pollInterval">00:00:60</str>
</lst>
</requestHandler>
- 可以通过以下配置来开启repeater中的master或者slave。开启了之后会在相应的core里面solrcore.properties 的文件中保持信息
<requestHandler name="/replication" class="solr.ReplicationHandler" >
<lst name="master">
<str name="enable">${enable.master:false}</str>
<str name="replicateAfter">commit</str>
<str name="confFiles">schema.xml,stopwords.txt</str>
</lst>
<lst name="slave">
<str name="enable">${enable.slave:false}</str>
<str name="masterUrl">http://master_host:8983/solr</str>
<str name="pollInterval">00:00:60</str>
</lst>
</requestHandler>
#solrcore.properties in master
enable.master=true
enable.slave=false #solrcore.properties in slave
enable.master=false
enable.slave=true
2. 工作原理
- 当master发生commit或者optimize时候,ReplicationHandle会获取到这个commit点的文件名字,然后根据replicateAfter参数来决定将这些文件存放与lucene还是进行提取。
- master并不知道有多少slave,Slave周期性轮询(pollInterval)来检查Master的版本,如果Master有新版本,那么就开始同步复制。步骤为以下:
- Slave发出一个filelist命令来收集文件列表。这个命令将返回一系列元数据(size,lastmodified,alias等等).
- Slave查看它本地是否有这些文件,然后它会开始下载缺失的文件(使用命令filecontent)。如果连接失败,则会从失败的点重新开始下。它将重试5次,如果仍然失败则放弃。
- 文件被下载到了一个临时目录。因此,下载中途出错不会影响到slave。
- 完成下载后,所有新的文件会被移动到正在工作的目录内,而文件的timestamp会被匹配成master的timestamp。
- 一个commit命令被ReplicationHandler执行,然后新的索引被加载进来。
- 配置文件的replication步骤是如下的:
- 需要被复制的文件必须明确的用confFiles标记。
- 只有是Solr实例的conf目录下的文件才能被复制。
- 配置文件是跟着新的index一起进行复制的,也就是说即使master的配置文件被修改了也不会立马进行复制,只有当master的optimize或者commit被触发了。
- 不同于index文件通过timestamp来进行文件的匹配比较,配置文件是通过他们的checksum来进行匹配比较的,checksum相同则文件相同。
- 配置文件下载好之后会放入临时目录,然后旧的配置文件被重命名但是仍然放在原始目录下,ReplicationHandle并不会去删除它,然后再把新的文件移动到工作目录下。
- 如果有配置文件下来了,slave会进行reload。
- 如果向slave添加数据或者slave的索引坏掉了怎么办?
- 如果master那边没有新的index 数据,那么Slave不会与master进行同步。当master发生commit时候,master的index version不再与slave相同了。slave就会从master抓取这些文件,然后发现自己本地的文件与master不同,他就会复制所有master的index文件到新的目录下,然后要求Solr更新索引的目录。
3. Http API
总结:
本节主要介绍了Replication的主从复制的配置,实现过程,以及HTTP API。从实现过程中看,跟前文讲的还是保持一致的。到目前为止终于把SolrCloud的recovery的策略这一系列写完了。下一个系列想学习下SolrCloud的OverSee,感觉网上将OverSee的不怎么多,正好来学习下这个。