Solr(四)——Java使用solrj管理solr集群

缺乏、安全感 2021-09-23 03:52 278阅读 0赞

## 一.solrj使用步骤 ##

第一步：把solrJ相关的jar包添加到工程中。  
第二步：创建一个SolrServer对象，需要使用CloudSolrServer子类。构造方法的参数是zookeeper的地址列表。  
第三步：需要设置DefaultCollection属性。  
第四步：创建一SolrInputDocument对象。  
第五步：向文档对象中添加域  
第六步：把文档对象写入索引库。  
第七步：提交。

@Test
    	public void testSolrCloudAddDocument() throws Exception {
    		// 第一步：把solrJ相关的jar包添加到工程中。
    		// 第二步：创建一个SolrServer对象，需要使用CloudSolrServer子类。构造方法的参数是zookeeper的地址列表。
    		//参数是zookeeper的地址列表，使用逗号分隔
    		CloudSolrServer solrServer = new CloudSolrServer("192.168.25.154:2181,192.168.25.154:2182,192.168.25.154: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对象，其他处理和单机版一致。 ##

## 把搜索功能切换到集群版 ##

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans4.2.xsd
    	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context4.2.xsd
    	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx4.2.xsd
    	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util4.2.xsd">
    
    	
    	
    	
    	<bean id="cloudSolrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer">
    		<constructor-arg name="zkHost" value="192.168.25.154:2181,192.168.25.154:2182,192.168.25.154:2183"></constructor-arg>	
    		<property name="defaultCollection" value="collection2"></property>
    	</bean>
    </beans>