solrj 操作 solr 集群版

@Test
public void testAddDocument() throws Exception{
    //创建一个集群的连接，应该使用 CloudSolrServer,//zkHost:zookeeper 的地址表
    String zkHost = "192.168.25.129:2181,192.168.25.129:2182,192.168.25.129:2183";
    CloudSolrServer solrServer = new CloudSolrServer(zkHost);
    //设置一个 defaultCollection 属性
    solrServer.setDefaultCollection("collection2");

    //创建一个文档对象
    SolrInputDocument document = new SolrInputDocument();
    //向文档中添加域
    document.setField("id", "01");
    document.setField("name", "jack");

    //创建一个文档对象
    SolrInputDocument document2 = new SolrInputDocument();
    //向文档中添加域
    document2.setField("id", "02");
    document2.setField("name", "rose");

    //把文档写入索引库
    solrServer.add(document);
    solrServer.add(document2);
    //提交
    solrServer.commit();
    
}

@Test
public void testQuerryDocument() throws Exception{
    //创建一个集群的连接，应该使用 CloudSolrServer,//zkHost:zookeeper 的地址表
    String zkHost = "192.168.25.129:2181,192.168.25.129:2182,192.168.25.129:2183";
    CloudSolrServer solrServer = new CloudSolrServer(zkHost);
    //设置一个 defaultCollection 属性
    solrServer.setDefaultCollection("collection2");
    
    //创建一个查询对象
    SolrQuery query = new SolrQuery();
    //设置查询条件
    query.setQuery("*:*");
    //执行查询
    QueryResponse response = solrServer.query(query);
    //获取查询结果
    SolrDocumentList list = response.getResults();
    
    System.out.println("总记录数"+ list.getNumFound());
    
    for (SolrDocument solrDocument : list) {
        System.out.println(solrDocument.get("id"));
        System.out.println(solrDocument.get("name"));
    }
}