java，solrj连接solr集群SolrCloud

刺骨的言语ヽ痛彻心扉 2022-05-21 10:18 279阅读 0赞

[上一篇][Link 1]，[连接单机版solr][Link 1]的时候，我们是用子类HttpSolrServer来连接，现在连接集群版的就有所不同了。

之前是直接连solr服务，现在连接的是zookeeper。

使用步骤：

第一步：把solrJ相关的jar包添加到工程中。

创建一个SolrServer对象，需要使用子类CloudSolrServer。构造方法的参数（zkhost）是zookeeper的地址列表。

第三步：需要设置SolrServer的DefaultCollection属性给它一个collection名。

第四步：创建一SolrInputDocument文档对象。

第五步：向文档对象中添加域

第六步：把文档对象写入索引库。

第七步：提交。

添加例子：

@Test
    	public void testSolrCloudAddDocument() throws Exception {
    		// 第一步：把solrJ相关的jar包添加到工程中。
    		// 第二步：创建一个SolrServer对象，需要使用CloudSolrServer子类。构造方法的参数是zookeeper的地址列表。
    		//参数是zookeeper的地址列表，使用逗号分隔
    		CloudSolrServer solrServer = new CloudSolrServer("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183");
    		// 第三步：需要设置DefaultCollection属性。
    		solrServer.setDefaultCollection("collection2");
    		// 第四步：创建一SolrInputDocument对象。
    		SolrInputDocument document = new SolrInputDocument();
    		// 第五步：向文档对象中添加域
    		document.addField("item_title", "测试商品");
    		document.addField("item_price", "100");
    		document.addField("id", "test001");
    		// 第六步：把文档对象写入索引库。
    		solrServer.add(document);
    		// 第七步：提交。
    		solrServer.commit();
    
    	}

可以看出，除了连接方式（CloudSolrServer对象）不同以外，其他处理和单机版一致。

配置文件的设置例子：

<bean id="cloudSolrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer"> <constructor-arg name="zkHost" value="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"></constructor-arg> <property name="defaultCollection" value="collection2"></property> </bean>
    </beans>

[Link 1]: https://blog.csdn.net/qq_40550973/article/details/80914582