Solr7.4.0的API操作Solrj

一.SolrJ的概念

        ofollow,noindex" target="_blank">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的單機連線

//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);
}
}

360.png"/>

三.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