《BroadLeaf项目搜索功能改进》一文中介绍了 BroadLeaf 项目中如何改进搜索引擎这一块的代码，其中使用的是单节点的 solr 服务器，这篇文章主要介绍 BroadLeaf 项目如何集成 SolrCloud 集群。
1、SolrCloud环境搭建
参考 《Apache SolrCloud安装》，搭建Solr集群环境，将 Demosite 所用的 Solr 配置文件 solrconfig.xml 和 schema.xml 上传到 zookeeper 集群中，保证成功启动 Solr 集群。
2、扩展SearcheService类
扩展SearchService类的步骤与单节点集成一致，此处不再叙述。
3、修改Solr相关配置文件
a) 删除site模块中的site/src/main/webapp/WEB-INF/applicationContext.xml中的以下代码：
<bean id="solrEmbedded" class="java.lang.String">
<constructor-arg value="solrhome"/>
</bean>
<bean id="blSearchService" class="org.broadleafcommerce.core.search.service.solr.SolrSearchServiceImpl">
<constructor-arg name="solrServer" ref="${solr.source}" />
<constructor-arg name="reindexServer" ref="${solr.source.reindex}" />
</bean>
b)删除site模块的site/src/main/resources/runtime-properties/common.properties中以下代码：
solr.source=solrEmbedded
solr.source.reindex=solrEmbedded
c)在core模块中core/src/main/resources/applicationContext.xml添加如下代码：
<bean id="solrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer">
<constructor-arg value="${solr.url}"/>
<property name="defaultCollection" value="product" />
<property name="zkClientTimeout" value="20000" />
<property name="zkConnectTimeout" value="1000" />
</bean>
<bean id="solrReindexServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer">
<constructor-arg value="${solr.url.reindex}" />
<property name="defaultCollection" value="product" />
<property name="zkClientTimeout" value="20000" />
<property name="zkConnectTimeout" value="1000" />
</bean>
<bean id="blSearchService" class="org.broadleafcommerce.core.search.service.solr.ExtSolrSearchServiceImpl">
<constructor-arg name="solrServer" ref="${solr.source}" />
<constructor-arg name="reindexServer" ref="${solr.source.reindex}"/>
</bean>
注：上述配置中的defaultCollection的值product对应solr集群的collection名字，根据实际情况修改此处的值。
d) 在 core模块中core/src/main/resources/runtime-properties/common-shared.properties添加如下代码：
solr.url=192.168.56.121\:2181,192.168.56.122\:2181,1192.168.56.123\:2181
solr.url.reindex=192.168.56.121\:2181,192.168.56.122\:2181,1192.168.56.123\:2181
solr.source=solrServer
solr.source.reindex=solrReindexServer
4、重写rebuildIndex方法
在core模块的org.broadleafcommerce.core.search.service.solr包下添加LLSolrIndexServiceImpl，重写源码broadleaf-framework/SolrIndexServiceImpl中的rebuildIndex()方法，屏蔽如下代码：
// // Swap the active and the reindex cores
// shs.swapActiveCores();
// // If we are not in single core mode, we delete the documents for the unused core after swapping
// if (!SolrContext.isSingleCoreMode()) {
// deleteAllDocuments();
// }
5、修改定时任务
web系统启动时候，会查询数据库中商品，然后重建索引。该功能在applicationContext.xml中已经定义了定时任务，修改rebuildIndexJobDetail中的targetObject，对应rebuildIndex所在的服务类，如下：
~~~xml
如果需要手动创建索引，则需要取消applicationContext.xml中定义的定时任务，步骤如下：
a）去掉如下代码：
~~~xml
<bean id="rebuildIndexJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="blSearchService" />
<property name="targetMethod" value="rebuildIndex" />
</bean>
<bean id="rebuildIndexTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail" ref="rebuildIndexJobDetail" />
<property name="startDelay" value="${solr.index.start.delay}" />
<property name="repeatInterval" value="${solr.index.repeat.interval}" />
</bean>
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="rebuildIndexTrigger" />
</list>
</property>
</bean>
b）编写main方法，打成jar包，然后编写shell脚本，用于手动重建索引或者设置定时任务。该类需要获取一个名称为blSearchService的bean，然后调用该bean的rebuildIndex方法，主要代码如下：
@Resource(name = "blSearchService")
private SearchService extSolrSe earchService;
public void doRebuild(){
extSolrSearchService.rebuildIndex();
}
6、扩展CatalogService
添加如下代码：
@Resource(name = "blSearchService")
private ExtSolrSearchService extSolrSearchService;
修改该类的saveProduct方法如下：
@Override
@Transactional("blTransactionManager")
public Product saveProduct(Product product) {
Product dbProduct = catalogService.saveProduct(product);
try {
extSolrSearchService.addProductIndex(dbProduct);
} catch (ServiceException e) {
e.printStackTrace();
throw new RuntimeException(e);
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
return dbProduct;
}