一、添加

@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"));
    }
}

三、參考

　　http://www.cnblogs.com/fangwu/p/8652945.html

solrj 操作 solr 集群版