1  概述

Solr 是一個獨立的企業級搜尋應用伺服器，它對外提供類似於 Web-service 的 API 介面。使用者可以通過 http請求，向搜尋引擎伺服器提交一定格式的 XML 檔案，生成索引；也可以通過 Http Get 操作提出查詢請求，並得到XML 格式的返回結果。這裡主要講解下通過 http Get 請求這種方式。

首先，我們就必須通過 HTTP 請求類似

的連結，對伺服器進行訪問。將最終結果以類似流的方式傳回客戶端。而具體形式是以xml 的形式，類似下圖：

2  SolrJ使用

SolrJ是操作Solr的JAVA客戶端，它提供了增加、修改、刪除、查詢Solr索引的

SolrJ通常向後保持相容性，可以使用新版本的SolrJ訪問較舊的Solr,反之亦然。建議使用同Solr server同版本的SolrJ,

2.1     依賴包引用

使用maven配置：

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

注：由於使用的solr各個版本的api有所不同，所以操作方式有區別，

下面是舊版本向新版本的api改變：

SolrServer -> SolrClient

HttpSolrServer -> HttpSolrClient

CloudSolrServer -> CloudSolrClient

以下測試都將使用新api進行操作。

2.2測試

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.client.solrj.response.UpdateResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
 
/**
 * @ClassName: IndexDemo
 * @Description: solr操作
*/
public class IndexDemo {
    // 單點
    public static final String SOLR_URL = "http://localhost:8983/solr/solr_java";
 
    // 叢集
    // String zkHostString ="zServerA:2181,zServerB:2181,zServerC:2181/solr";
    // SolrClient solr = new
    //CloudSolrClient.Builder().withZkHost(zkHostString).build();
 
    public static void main(String[] args) {
        AddDocs();
//      QueryDocs();
//      delDocs();
 
    }
 
    /**
     * @Description: 刪除索引
     */
    public static void delDocs() {
        try {
            SolrClient solr = new HttpSolrClient.Builder(SOLR_URL).build();
            //根據ID刪除
            solr.deleteById("552199");
            //根據條件刪除(如：刪除所有)
            //solr.deleteByQuery("*:*"); 
            solr.commit();
        } catch (Exception e) {
            System.out.println(e);
        }
        System.out.println("deletesuccess");
    }
   
   
 
    /**
     * @Description: 新增索引
     */
    public static void AddDocs() {
        try {
            SolrClient solr = new HttpSolrClient.Builder(SOLR_URL).build();
            SolrInputDocument document = new SolrInputDocument();
            document.addField("id", "100");
            document.addField("name", "測試");
            document.addField("price", "1000");
            UpdateResponse response = solr.add(document);
            solr.commit();
 
        } catch (Exception e) {
            System.out.println(e);
        }
        System.out.println("addsuccess");
    }
   
   
   
    /**
     * @Description: 查詢索引
     */
    public static void QueryDocs() {
        try {
            //通過Http查詢
            //http://localhost:8983/solr/solr_java/select?q="id:100"
           
            SolrClient solr = new HttpSolrClient.Builder(SOLR_URL).build();
            SolrQuery query = new SolrQuery();
//          query.set("q", "id:*");
            query.set("q", "id:100");
            QueryResponse response = solr.query(query);
            SolrDocumentList list = response.getResults();
            // 搜尋得到的結果數
            System.out.println("Find:" + response.getResults().getNumFound());
           
            for (SolrDocument solrDocument : list) {
                System.out.println(solrDocument.get("name"));
            }
        } catch (Exception e) {
            System.out.println(e);
        }
    }
 
}
 

//批量新增

/**
     * @Description: 批量新增
     */
    public static void bathAddDocs() {
        String[] words = { "中央全面深化改革領導小組", "第四次會議"};
        List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
        for (int i = 0; i < 2; i++) {
            SolrInputDocument doc1 = new SolrInputDocument();
            doc1.addField("id", "id" + i, 1.0f);
            doc1.addField("name", words[i], 1.0f);
            doc1.addField("price", 10 * i);
            docs.add(doc1);
        }
        try {
            SolrClient solr = new HttpSolrClient.Builder(SOLR_URL).build();
            UpdateResponse response = solr.add(docs.iterator());
            //增加後通過執行commit函式commit
            solr.commit();
           
        } catch (Exception e) {
            System.out.println(e);
        }
        System.out.println("addsuccess");
    }