SolrJ管理SolrCloud

灰太狼 2022-05-15 09:40 195阅读 0赞

### 添加文档 ###

操作步骤

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

package com.taotao.solrj;
    
    import org.apache.solr.client.solrj.impl.CloudSolrServer;
    import org.apache.solr.common.SolrInputDocument;
    import org.junit.Test;
    
    public class TestSolrCloud { 
    
        @Test
        public void testSolrCloudAdDocument() throws Exception {
            //创建一个CloudSolrServer对象，构造方法中需要制定zookeeper的地址列表
            CloudSolrServer cloudSolrServer = new CloudSolrServer("192.168.163.200:2181,192.163.200.154:2182,192.168.163.200:2183");
            //需要设置默认的Collection
            cloudSolrServer.setDefaultCollection("collection2");
            //创建一个文档对象
            SolrInputDocument document = new SolrInputDocument();
            //向文档中添加域
            document.addField("id", "test001");
            document.addField("item_title", "测试商品名称");
            document.addField("item_price", 100);
            //把文档写入索引库
            cloudSolrServer.add(document);
            //提交
            cloudSolrServer.commit();
    
        }
    }

### 查询、删除文档 ###

操作与单机版Solr操作一样  
唯一不同的地方

//创建一个CloudSolrServer对象，构造方法中需要制定zookeeper的地址列表
    CloudSolrServer cloudSolrServer = new CloudSolrServer("192.168.163.200:2181,192.163.200.154:2182,192.168.163.200:2183");
    //需要设置默认的Collection
    cloudSolrServer.setDefaultCollection("collection2");