Solr7.4.0的API（Solrj）操作

一.SolrJ的概念

solr單機版服務搭建：https://www.cnblogs.com/frankdeng/p/9615253.html

solr集群版服務搭建：https://www.cnblogs.com/frankdeng/p/9597680.html

        SolrJ是一個API，它使用Java（或任何基於JVM的語言）編寫的應用程序可以輕松地與Solr交談。SolrJ隱藏了許多連接到Solr的細節，並允許您的應用程序通過簡單的高級方法與Solr交互。SolrJ支持大多數Solr API，並且具有高度可配置性。

官方API參考文檔： http://lucene.apache.org/solr/guide/7_4/using-solrj.html#using-solrj

這里使用Maven構建項目，請將以下內容放入pom.xml：

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

為了方便測試，導入單元測試依賴和日志依賴

<dependency>
   <groupId>junit</groupId>
   <artifactId>junit</artifactId>
   <version>4.12</version>
    <scope>test</scope>
</dependency>

<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-nop</artifactId>
    <version>1.7.25</version>
</dependency>

二.SolrJ的單機連接

SolrClient是一個抽象類，下邊有很多被實現的子類，HttpSolrClient - 面向以查詢為中心的工作負載，但也是一個很好的通用客戶端。直接與單個Solr節點通信。

不同solr版本solrj 的創建方式有所不同

//solr4創建方式
SolrServer solrServer = new HttpSolrServer(solrUrl); 
//solr5創建方式,在url中指定core名稱：core1 
HttpSolrClient solrClient = new HttpSolrClient(solrUrl); 
//solr7創建方式,在url中指定core名稱：core1 
HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();

例如：

package com.xyg.solr;

import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.junit.Test;

/**
 * Author: Mr.Deng
 * Date: 2018/9/10
 * Desc: 測試連接客戶端
 */
public class testConnectionClient {

    @Test
    public void testConnectionClient(){
        //設置solr客戶端url地址
        String solrUrl = "http://node21:8080/solr/new_core";
        //創建solrClient同時指定超時時間，不指定走默認配置
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl)
                .withConnectionTimeout(10000)
                .withSocketTimeout(60000)
                .build();
        System.out.println(solrClient);
    }
}

三.SolrJ的集群連接

 CloudSolrClient - 面向與SolrCloud部署的通信。使用已記錄的ZooKeeper狀態來發現並將請求路由到健康的Solr節點。

package com.xyg.solrCloud;

import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.junit.Test;

/**
 * Author: Mr.Deng
 * Date: 2018/9/10
 * Desc: 測試連接客戶端
 */
public class ConnectionCloudSolrClient {

    @Test
    public void connectionCloudSolrClient(){
        // 第一種方式：使用運行中的某一台solr節點
        //final String solrUrl = "http://192.168.100.21:8983/solr";
        //CloudSolrClient solrClient = new CloudSolrClient.Builder().withSolrUrl(solrUrl).build();

        // 第二種方式：使用zookeeper節點連接（推薦）
        final String zkHost = "node21:2181,node22:2181,node23:2181/solr";
        CloudSolrClient solrClient = new CloudSolrClient.Builder().withZkHost(zkHost).build();
        System.out.println(solrClient);
    }
}

四.SolrJ的增刪改查

這里測試單機版APi操作

1.創建索引

1）指定id單條創建索引 

@Test
public void addIndexById() throws IOException, SolrServerException {
    String solrUrl = "http://node21:8080/solr/new_core";
    HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
    //創建索引文檔對象
    SolrInputDocument doc = new SolrInputDocument();
    // 第一個參數：域的名稱，域的名稱必須是在schema.xml中定義的
    // 第二個參數：域的值,注意：id的域不能少
    doc.addField("id","1");
    doc.addField("name","紅豆");
    doc.addField("price","1.2");
    //3.將文檔寫入索引庫中
    solrClient.add(doc);
    solrClient.commit();
}

2）批量創建索引 

@Test
public void addIndexByListId() throws Exception {
    String solrUrl = "http://node21:8080/solr/new_core";
    HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
    //創建索引文檔對象
    SolrInputDocument doc1 = new SolrInputDocument();
    doc1.addField( "id", "2");
    doc1.addField( "name", "綠豆");
    doc1.addField( "price", 1.8 );
    SolrInputDocument doc2 = new SolrInputDocument();
    doc2.addField( "id", "3" );
    doc2.addField( "name", "黑豆" );
    doc2.addField( "price", 2.6 );
    Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
    docs.add(doc1);
    docs.add(doc2);
    //3.將文檔寫入索引庫中
    solrClient.add(docs);
    solrClient.commit();
}

2.查詢索引

1）匹配查詢

    @Test
    public void findIndex1() throws IOException, SolrServerException {
        String solrUrl = "http://node21:8080/solr/new_core";
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
        // 創建搜索對象
        SolrQuery query = new SolrQuery();
        // 設置搜索條件
        query.set("q","*:*");
        //設置每頁顯示多少條
        query.setRows(2);
        //發起搜索請求
        QueryResponse response = solrClient.query(query);
        // 查詢結果
        SolrDocumentList docs = response.getResults();
        // 查詢結果總數
        long cnt = docs.getNumFound();
        System.out.println("總條數為"+cnt+"條");
        for (SolrDocument doc : docs) {
          System.out.println("id:"+ doc.get("id") + ",name:"+ doc.get("name") + ",price:"+ doc.get("price"));
        }
        solrClient.close();
    }

2）條件過濾查詢

 @Test
    public void findIndex2() throws IOException, SolrServerException {
        String solrUrl = "http://node21:8080/solr/new_core";
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
        //2 封裝查詢參數
        Map<String, String> queryParamMap = new HashMap<String, String>();
        queryParamMap.put("q", "*:*");
        //3 添加到SolrParams對象,SolrParams 有一個 SolrQuery 子類，它提供了一些方法極大地簡化了查詢操作
        MapSolrParams queryParams = new MapSolrParams(queryParamMap);
        //4 執行查詢返回QueryResponse
        QueryResponse response = solrClient.query(queryParams);
        //5 獲取doc文檔
        SolrDocumentList docs = response.getResults();
        // 查詢結果總數
        long cnt = docs.getNumFound();
        System.out.println("總條數為" + cnt + "條");
        //[6]內容遍歷
        for (SolrDocument doc : docs) {
            System.out.println("id:" + doc.get("id") + ",name:" + doc.get("name") + ",price:" + doc.get("price"));
        }
        solrClient.close();
    }

3.更新索引

    @Test
    public void updateIndex() throws IOException, SolrServerException {
        String solrUrl = "http://node21:8080/solr/new_core";
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
        //創建索引文檔對象
        SolrInputDocument doc = new SolrInputDocument();
        //把紅豆價格修改為1.5
        doc.addField("id","1");
        doc.addField("name","紅豆");
        doc.addField("price","1.5");
        //3.將文檔寫入索引庫中
        solrClient.add(doc);
        solrClient.commit();
        //提交
        solrClient.commit();

    }

4.刪除索引 

1）單一條件刪除

    @Test
    public void deleteIndexById() throws IOException, SolrServerException {
        String solrUrl = "http://node21:8080/solr/new_core";
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
        //全刪
        //solrClient.deleteByQuery("*:*");
        //模糊匹配刪除（帶有分詞效果的刪除）
        solrClient.deleteByQuery("name:紅");
        //指定id刪除
        //solrClient.deleteById("1");
        solrClient.commit();
    }

2）批量條件刪除

    @Test
    public void deleteIndexByListId() throws IOException, SolrServerException {
        String solrUrl = "http://node21:8080/solr/new_core";
        HttpSolrClient solrClient = new HttpSolrClient.Builder(solrUrl).build();
        //通過id刪除
        ArrayList<String> ids = new ArrayList<String>();
        ids.add("2");
        ids.add("3");
        solrClient.deleteById(ids);
        //[3]提交
        solrClient.commit();
        //[4]關閉資源
        solrClient.close();
    }

五.代碼報錯問題

1.代碼添加索引報405問題

解決方法：

在使用Tomcat部署Solr后，new_core的地址為：http://node21:8080/solr/#/new_core，但使用SolrJ進行索引的時候，應該使用http://node21:8080/solr/new_core，即無中間的#號。

2.自定義索引字段

上圖報錯提示未識別索引字段

 

參考文檔：

https://www.w3cschool.cn/solr_doc/solr_doc-g1az2fmd.html

https://www.cnblogs.com/gaogaoyanjiu/p/7815558.html

https://www.jianshu.com/p/11fb9cfdb2fd