Windows10搭建Solr7.4集群(基于solr7.4内嵌的jetty容器)及Java客户端测试集群

川长思鸟来 2022-05-14 11:39 198阅读 0赞

SolrCloud是 Solr 提供的分布式搜索方案，当你需要大规模，容错，分布式索引和检索能力时使用 SolrCloud。当一个系统的索引数据量少的时候是不需要使用 SolrCloud的，当索引量很大，搜索请求并发很高，这时需要使用 SolrCloud 来满足这些需求。  
SolrCloud 是基于 Solr 和Zookeeper的分布式搜索方案，它的主要思想是使用 Zookeeper作为集群的配置信息中心。  
它有几个特色功能：  
1）集中式的配置信息  
2）自动容错  
3）近实时搜索  
4）查询时自动负载均衡

Collection 在 SolrCloud 集群中是一个逻辑意义上的完整的索引结构。它常常被划分为一个或多个 Shard（分片），它们使用相同的配置信息。  
每个 Core 是 Solr 中一个独立运行单位，提供 索引和搜索服务。一个 shard 需要由一个Core 或多个 Core 组成。

接下来搭建四个solr节点的集群  
把之前配置好的solr复制四份,我就存储在D:\\server\\solr-cluster中

到D:\\server\\solr-cluster\\solr-1\\bin  
打开`solr.in.cmd`  
windows设置集群的zookeeper有问题,linux就没有问题  
set ZK\_HOST=”127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183”  
![这里写图片描述][70]  
故设置为单一的zookeeper,并指定IP和端口号

set ZK_HOST="127.0.0.1:2181"
    set SOLR_HOST="127.0.0.1"
    set SOLR_PORT=8983

到D:\\server\\solr-cluster\\solr-1\\server\\solr目录下  
打开`solr.xml`  
修改如下两行的内容.指定ip和端口号

<solrcloud>
        <str name="host">${host:127.0.0.1}</str>
        <int name="hostPort">${jetty.port:8983}</int>

其他三个类似.修改端口为8984 8985 8986

启动四个solr节点

接下来创建collection  
访问`http://127.0.0.1:8983/solr/admin/collections?action=CREATE&name=collection5&numShards=2&replicationFactor=2`  
其中参数的意思：  
name:将被创建的集合的名字  
numShards:集合创建时需要创建逻辑碎片的个数  
replicationFactor:分片的副本数。  
出现success则为创建成功

![这里写图片描述][70 1]  
访问一个节点  
出现了Cloud,查看Cloud的Graph可以清楚的看到分片和主从备份的关系  
![这里写图片描述][70 2]  
![这里写图片描述][70 3]  
同时可以看到 出现了Core Selector的上分片

![这里写图片描述][70 4]  
删除collection  
访问`http://127.0.0.1:8983/solr/admin/collections?action=DELETE&name=collection1`  
引入依赖,注意solrj的版本

<dependency>
                <groupId>org.apache.solr</groupId>
                <artifactId>solr-solrj</artifactId>
                <version>5.5.5</version>
            </dependency>

代码很简单,注释写的很清楚了

public class TestSolr { 
    
        private String ZK_HOST="127.0.0.1:2181";
    
        @Test
        public void test1() throws IOException, SolrServerException {
            // 路径是zookeeper的服务的路径
            CloudSolrServer server = new CloudSolrServer("127.0.0.1:2181");
    
            // 设置默认的collection
            server.setDefaultCollection("collection2");
    
            //添加集合
                SolrInputDocument doc = new SolrInputDocument();
                doc.addField("id", UUID.randomUUID().toString());
                doc.addField("username", "lhc");
                doc.addField("content", "lhc0512");
                doc.addField("title", "lhc");
                server.add(doc);
    
            //提交事物
            server.commit();
            System.out.println("------------------------添加索引---------------------");
        }
    
        @Test
        public void test2() throws IOException, SolrServerException {
            CloudSolrServer server = new CloudSolrServer(ZK_HOST);
    
            // 设置默认的collection
            server.setDefaultCollection("collection2");
    
            //清空数据
            server.deleteByQuery("*:*");
    
            //提交事物
            server.commit();
    
            System.out.println("------------------------数据清空---------------------");
        }
    
        @Test
        public void test3() throws IOException, SolrServerException {
            CloudSolrServer server = new CloudSolrServer(ZK_HOST);
    
            // 设置默认的collection
            server.setDefaultCollection("collection2");
            SolrQuery query = new SolrQuery();
            query.add("q","title:lhc");
            query.setStart(0);
            query.setRows(10);
            QueryResponse resp = server.query(query);
            SolrDocumentList docs = resp.getResults();
            System.out.printf("查询到了%d条数据\r\n",docs.getNumFound());;
        }
    
    
    
    }

[70]: /images/20220514/6a5e9e77c2eb4bc2908c2e39ac66633e.png
[70 1]: /images/20220514/530d6aca1e3e4d308806fbb3b301cf1e.png
[70 2]: /images/20220514/dd97e61e66cd4defa1c760a2903ddc6b.png
[70 3]: /images/20220514/6bed3c7c81bb45cdb1ed082cdf0e769b.png
[70 4]: /images/20220514/31c57cc5ee6c4b9682840c95eaaaabe6.png