前言

    叢集搭建好了，現在需要管理叢集，我們使用solrj，用java程式碼操作solr叢集。

匯入jar包

    引入solr-solrj.jar（solr-4.10.3的dist目錄下）

操作資料

1、新增資料

public void addDocument() throws Exception{
    //建立一個叢集的連線，應該使用CloudSolrServer建立
    CloudSolrServer solrServer = new CloudSolrServer("192.168.25.163:2181,192.168.25.163:2182,192.168.25.163:2183");
    //zkHost：zookeeper的地址列表
    //設定一個defaultCollection物件
    solrServer.setDefaultCollection("collection2");
    //建立一個文件物件
    SolrInputDocument document = new SolrInputDocument();
    //向文件中新增域
    document.setField("id", "solrcloud01");
    document.setField("item_title", "測試商品01");
    document.setField("item_price", 100);
    //把檔案寫入到索引庫
    solrServer.add(document);
    //提交
    solrServer.commit();
}
 

2、查詢資料

public void queryDoucment() throws Exception{
    //建立一個CloudSolrServer物件
    CloudSolrServer cloudSolrServer = new CloudSolrServer("192.168.25.163:2181,192.168.25.163:2182,192.168.25.163:2183");
    //設定預設的Collection
    cloudSolrServer.setDefaultCollection("collection2");
    //建立一個查詢物件
    SolrQuery query = new SolrQuery();
    //設定查詢條件
    query.setQuery("*:*");
    //執行查詢
    QueryResponse queryResponse = cloudSolrServer.query(query);
    //取查詢結果
    SolrDocumentList solrDocumentList = queryResponse.getResults();
    System.out.println("總記錄數：" + solrDocumentList.getNumFound());
    //列印
    for (SolrDocument solrDocument : solrDocumentList) {
        System.out.println(solrDocument.get("id"));
        System.out.println(solrDocument.get("title"));
        System.out.println(solrDocument.get("item_title"));
        System.out.println(solrDocument.get("item_price"));
    }
}
 

總結

    使用java程式碼操作solr叢集完成。