Solr

時間 2019-11-16

標籤 solr 简体版

原文原文鏈接

目錄前端

1 Solr簡介 3java

1.1 Solr是什麼 3mysql

1.2 Solr能作什麼 3web

1.3 爲何須要Solr 3spring

1.4 Solr下載路徑 4sql

1.5 Solr目錄結構說明 4數據庫

2 入門示例 5express

2.1 需求 5apache

2.2 配置步驟說明 5json

2.3 配置步驟 5

2.4 第一部分：配置Solr服務器 5

2.4.1 第一步：解壓一個Tomcat 5

2.4.2 第二步：部署Solr服務到Tomcat中 5

2.4.3 第三步：添加Solr運行依賴的jar包 6

2.5 第二部分：配置SolrHome 6

2.5.1 第一步：拷貝到本地，修更名稱爲SolrHome。（見名知意） 7

2.5.2 第二步：配置SolrCore 7

2.6 第三部分：在Solr服務器中加載SolrHome 9

2.6.1 第一步：修改web.xml加載SolrHome 9

2.6.2 第二步：啓動Tomcat測試 10

2.7 第四部分：建立java程序訪問solr服務器 10

2.7.1 第一步：建立項目，導入jar包 11

2.7.2 第二步：建立索引 11

2.7.3 第三步：搜索索引 19

3 solr管理控制檯 21

3.1 查詢界面說明 21

3.2 安裝DataImport插件 24

3.2.1 Dataimport插件說明 24

3.2.2 安裝步驟 25

3.3 Analyzer分析器，配置中文分詞器 27

3.3.1 Solr自帶分詞器的缺陷 27

3.3.2 Solr配置中文分析器 27

4 Solr案例實戰 30

4.1 需求 30

4.2 分析 30

4.2.1 UI分析 30

4.2.2 架構分析 31

4.3 環境準備 31

4.4 功能開發 32

4.4.1 第一步：建立web工程，導入jar包 32

4.4.2 第二步：代碼實現 33

4.4.3 第三步：Spring整合Solr、Springmvc 40

4.5 啓動web應用程序，測試 43

4.5.1 注意事項 43

4.5.2 修改Solr服務器的Tomcat的端口 43

4.5.3 修改Springmvc.xml 43

4.5.4 訪問搜索頁面 44

1 Solr簡介

1.1 Solr是什麼

Solr是一個基於全文檢索的企業級應用服務器。

全文檢索：能夠輸入一段文字，經過分詞檢索數據！！（複習）

應用服務器：它是單獨的服務。

1.2 Solr能作什麼

它就是用於作全文搜索。

1.3 爲何須要Solr

問題：咱們已經學過Lucene，爲何還要學習solr?

答：Lucene是一個工具包，不能單獨運行，須要導入到java代碼中。

Solr能夠獨立運行在tomcat容器中，經過http協議，以接口的方式對外提供服務，java代碼只須要專一於業務的處理就能夠。

1.4 Solr下載路徑

http://archive.apache.org/dist/lucene/solr/

solr是基於lucene實現的，和Lucene同步更新。

1.5 Solr目錄結構說明

下載solr-4.10.3.zip並解壓：

bin：solr的運行腳本

contrib：solr的一些擴展jar包，用於加強solr的功能。

dist：該目錄包含build過程當中產生的war和jar文件，以及相關的依賴文件。

docs：solr的API文檔

example：solr工程的例子目錄：

licenses：solr相關的一些許可信息

2 入門示例

2.1 需求

使用Solr實現電商網站的商品搜索功能。

2.2 配置步驟說明

（1）配置Solr服務器。

（2）配置SolrHome。（Solr服務的主目錄，磁盤）

（3）在Solr服務器中加載SolrHome。

（4）java程序訪問Solr服務器，實現全文搜索。

2.3 配置步驟

2.4 第一部分：配置Solr服務器

--說明：Solr能夠獨立運行，須要servlet容器加載它。本文使用tomcat。

2.4.1 第一步：解壓一個Tomcat

解壓一個新的Tomcat，專門用來加載Solr。

2.4.2 第二步：部署Solr服務到Tomcat中

--在Solr的下載包中，提供了Solr的war包程序。（空的war包程序）

--拷貝solr.war到Tomcat的webapp目錄下。並解壓

2.4.3 第三步：添加Solr運行依賴的jar包

--在Solr的下載包中，提供Solr服務器運行所依賴的jar包。

（1）拷貝/example/lib/ext下的全部包，到solr應用的lib目錄中

（2）拷貝/example/resource/log4j.properties，到solr應用的classes目錄下。

--前提：先在/WEB-INF/目錄下，建立classes目錄。

2.5 第二部分：配置SolrHome

--說明：Solr的下載包中，提供了標準的SolrHome配置。

2.5.1 第一步：拷貝到本地，修更名稱爲SolrHome。（見名知意）

2.5.1.1 SolrHome說明

--SolrHome目錄結構：

（1）SolrHome是Solr配置搜索服務的主目錄。

（2）collection1稱爲Solr服務的一個實例(solrCore)。

（3）一個solr實例對應一個索引庫。

（4）Solr能夠同時配置多個實例。以便爲不一樣的java程序提供搜索服務。

配置solr服務，就是在配置solr實例。

2.5.2 第二步：配置SolrCore

2.5.2.1 Step1：配置SolrCore實例的名稱

--說明：每個實例都有本身的名稱。在core.properties文件中配置

--在這裏，咱們將其修改成：soreCore0719

2.5.2.2 Step2：配置SolrCore所需的jar依賴

--說明：Solr下載包中，提供SolrCore所須要的全部jar依賴。

（1）在SolrHome同級目錄下，建立depJar文件夾。(目的：方便管理jar依賴)

（2）拷貝contrib、dist兩個目錄到depJar目錄下。

（3）修改/collection1/conf目錄下的solrconfig.xml，加載jar包

--說明：solr是經過<lib>標籤，來加載運行所須要的jar包的。

（4）配置索引庫目錄

--說明：solr是經過<dataDir>標籤，來指定索引庫的目錄的。

--默認路徑是在SolrCore目錄下，跟conf目錄同級。首次加載時，將自動建立。

本課程就使用該默認路徑。

2.6 第三部分：在Solr服務器中加載SolrHome

2.6.1 第一步：修改web.xml加載SolrHome

--在solr的應用中，是經過web.xml來加載SolrHome的。

--說明：在這裏是經過修改<env-entry>標籤，來加載SolrHome的。

2.6.2 第二步：啓動Tomcat測試

--訪問地址 http://localhost:8080/solr

--solr服務器配置成功!!!

2.7 第四部分：建立java程序訪問solr服務器

--前提：建立好了數據庫。（導入products-solr.sql文件便可）

--配置步驟說明：

（1）建立項目。

（2）建立索引

（3）搜索索引

2.7.1 第一步：建立項目，導入jar包

--導包說明：

SolrJ核心包 /solr-4.10.3/dist/solr-solrj-4.10.3.jar

SolrJ依賴包 /solr-4.10.3/dist/solrj-lib下的全部包

日誌依賴包 /solr-4.10.3/example/lib/ext目錄下的全部jar包

JDBC驅動包 mysql-connector-java-5.1.10-bin.jar

--拷貝log4j.properties到src目錄下。（或者建立一個Source Folder）

--項目結構：

2.7.2 第二步：建立索引

--步驟說明。（複習回顧）

（1）採集數據。

（2）將數據轉換成Solr文檔。

（3）鏈接solr服務器，將文檔寫入索引庫。

2.7.2.1 Step1：採集數據

--需求採集的字段說明：

參與搜索的字段：名稱、價格、商品類別、描述信息

參與結果展現的字段：商品id、圖片、

（1）建立Product類

public class Product {

private Integer pid;

private String name;

private String catalog_name;

private double price;

private String description;

private String picture;

// 補全get、set方法

}

（2）建立ProductDao類

package cn.gzsxt.solr.dao;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import cn.gzsxt.solr.pojo.Product;

public class ProductDao {

private Connection connection;

private PreparedStatement pst;

private ResultSet rs;

/**

* 採集數據，查詢全部商品

* @return

public List<Product> getAllProducts() {

List<Product> products = new ArrayList<>();

try {

//1、加載驅動

Class.forName("com.mysql.jdbc.Driver");

//2、獲取Connection鏈接

connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/solr", "root", "gzsxt");

//3、獲取PreparedStatement,執行預編譯

pst = connection.prepareStatement("select pid,name, catalog_name,price,description,picture from products");

//4、執行sql搜索

rs = pst.executeQuery();

Product p = null;

while(rs.next()){

p = new Product();

p.setPid(rs.getInt("pid"));

p.setName(rs.getString("name"));

p.setPrice(rs.getFloat("price"));

p.setPicture(rs.getString("picture"));

p.setDescription(rs.getString("description"));

p.setCatalog_name(rs.getString("catalog_name"));

products.add(p);

}

} catch (Exception e) {

e.printStackTrace();

}finally {

if(null!=rs){

try {

rs.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

if(null!=pst){

try {

pst.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

if(null!=connection){

try {

connection.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return products;

}

（3）建立一個測試類ProductDaoTest

--導入junit類庫。（快捷鍵ctrl+1）

package cn.gzsxt.solr.test;

import org.junit.Test;

import cn.gzsxt.solr.dao.ProductDao;

public class ProductDaoTest {

@Test

public void getAllProducts(){

ProductDao dao = new ProductDao();

System.out.println(dao.getAllProducts());

}

--測試結果，採集數據成功!!!

2.7.2.2 Step2：將數據轉換成Solr文檔SolrInputDocument

--說明：solr是經過SolrInputDocument來封裝數據的。部分源碼以下：

public SolrInputDocument(Map fields){

_documentBoost = 1.0F;

_fields = fields;

}

public void addField(String name, Object value){

addField(name, value, 1.0F);

}

問題：咱們在Lucene中知道，域有三大屬性，在建立文檔的時候指定。而Solr的源碼中，只是用一個Map集合來封裝域的信息。那域的三大屬性怎麼定義呢？

答：Solr是經過一個配置文件schema.xml，事先定義域的信息的。

2.7.2.2.1 Solr域的說明

--經過<field>標籤訂義域的名稱等信息

name屬性：域的名稱

type屬性：域的類型（<FieldType>標籤，加載了分詞器，指定了分詞屬性）

indexed屬性：是否索引

stored屬性：是否存儲

multiValued屬性：是否支持多個值

--經過<fieldType>標籤，定義域的類型信息

name屬性：域類型的名稱

class屬性：指定域類型的solr類型。

<analyzer>：指定分詞器。

<analyzer type=」index」>：表示在建立索引時，對域作分詞處理。

<analyzer type=」query」>：表示在檢索索引時，對域作分詞處理。

<tokenizer>標籤：指定分詞器

<filter>標籤：指定過濾器

2.7.2.2.2 Solr域的特色

（1）、Solr的域必須先定義，後使用。（不然報錯：unknown fieldName）

（2）、定義solr域的時候，必須指定是否索引、是否存儲這兩個屬性。<field>

（3）、定義solr域的時候，必須指定域的類型<fieldType>：

由於域的類型肯定了這個域在索引、搜索兩個階段的分詞屬性。

<field>標籤：來指定索引、存儲兩個屬性

<fieldType>標籤：來指定分詞屬性

（4）、每個文檔中，必須包含id這個域，它的值標記文檔的惟一性。

2.7.2.2.3 配置Solr業務域

--商品各字段屬性說明

域	Tokened	Indexed	Stored
商品的id	N	Y	Y
商品的名稱	Y	Y	Y
商品的類別	N	Y	Y
商品的價格	Y	Y	Y
商品的圖片	N	N	Y
商品描述信息	Y	Y	N

--修改schema.xml，添加以下配置。（id域不用配置，直接使用solr的id域）

<field name="id" type="string" indexed="true" stored="true" required="true"

multiValued="false" />

2.7.2.2.4 修改ProductDao，新增getDocuments方法

/**

* 將採集到的商品數據，轉換成solr文檔類型

* @param products

* @return

public List<SolrInputDocument> getDocuments(List<Product> products){

List<SolrInputDocument> docs = new ArrayList<>();

SolrInputDocument doc = null;

for (Product product : products) {

doc = new SolrInputDocument();

doc.addField("id", product.getPid());

doc.addField("product_name", product.getName());

doc.addField("product_price", product.getPrice());

doc.addField("product_catalog_name", product.getCatalog_name());

doc.addField("product_description", product.getDescription());

doc.addField("product_picture", product.getPicture());

docs.add(doc);

}

return docs;

}

2.7.2.3 Step3：鏈接Solr服務器，建立索引

--前提：已經啓動了Tomcat，加載了Solr服務器。（前面給過schema.xml，須要重寫啓動Tomcat）

--修改ProductDaoTest類，新增createIndex方法

@Test

public void createIndex(){

// 1、建立HttpSolrServer對象，經過它和Solr服務器創建鏈接。

// 參數：solr服務器的訪問地址

HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/solrCore0719");

// 2、經過HttpSolrServer對象將SolrInputDocument添加到索引庫。

ProductDao dao = new ProductDao();

try {

server.add(dao.getDocuments(dao.getAllProducts()));

// 3、提交。

server.commit();

System.out.println("建立索引庫成功!!!");

} catch (SolrServerException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

2.7.2.4 Step4：訪問Solr主界面，在Query選項下測試

--建立索引庫成功！！！

2.7.3 第三步：搜索索引

--修改ProductDaoTest類型，新增一個查詢方法

@Test

public void queryIndex() throws Exception {

// 建立HttpSolrServer對象，經過它和Solr服務器創建鏈接。

// 參數：solr服務器的訪問地址

HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/solrCore0719");

// 建立SolrQuery對象

SolrQuery query = new SolrQuery();

// 設置查詢條件,參考主界面

query.set("q", "*:*");

// 調用server的查詢方法，查詢索引庫

QueryResponse response = server.query(query);

// 查詢結果

SolrDocumentList results = response.getResults();

// 查詢結果總數

long cnt = results.getNumFound();

System.out.println("查詢結果總數:" + cnt);

System.out.println("--------------------分隔符-------------------");

for (SolrDocument solrDocument : results) {

System.out.println("商品id:"+solrDocument.get("id"));

System.out.println("商品名稱:"+solrDocument.get("product_name"));

System.out.println("商品價格:"+solrDocument.get("product_price"));

System.out.println("商品類別:"+solrDocument.get("product_catalog_name"));

System.out.println("商品圖片:"+solrDocument.get("product_picture"));

System.out.println("----------------------------------------");

}

--查詢結果，很是成功！！！

3 solr管理控制檯

3.1 查詢界面說明

（1） q - 查詢關鍵字，必須，若是查詢全部文檔時，使用*:*。

（2） fq - （filter query）過慮查詢，能夠有多個。如：價格10到50的記錄。

（3） sort - 排序，格式：sort=<field name>+<desc|asc>。如：按價格升序

（4） start - 分頁顯示使用，開始記錄下標，從0開始

（5） rows - 指定返回結果最多有多少條記錄，配合start來實現分頁。

（6） fl - 指定返回那些字段內容，用逗號或空格分隔多個。

（7） df-指定一個默認搜索的Field

（8） wt - (writer type)指定輸出格式，默認json格式。

3.1.1 對照界面，實現複雜查詢

--修改ProductDaoTest類型，新增動態查詢方法

@Test

public void queryDynamic(){

//1、鏈接solr服務器

HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/solrCore0719");

//2、建立查詢對象，封裝查詢條件

SolrQuery query = new SolrQuery();

//設置默認搜索的域

query.set("df", "product_name");

//參考管理界面中的 "q"標籤，封裝查詢的關鍵詞

query.set("q", "音樂盒");

//添加價格過濾

query.addFilterQuery("product_price:[10 TO 50]");

//添加類別過濾

query.addFilterQuery("product_catalog_name:幽默雜貨");

//設置排序價格升序

query.set("sort","product_price asc");

//設置分頁信息第二頁每頁10條 start=(page-1)*pageSize

query.set("start", 10);

query.set("rows",10);

//設置要查詢字段

query.set("fl", "id,product_name,product_price");

//3、執行查詢

try {

QueryResponse response = server.query(query);

//獲取查詢的響應碼

int status = response.getStatus();

System.out.println("響應碼:"+status);

if(0==status){

SolrDocumentList solrDocumentList = response.getResults();

long numFound = solrDocumentList.getNumFound();

System.out.println("共查詢到"+numFound+"條知足條件的數據!");

System.out.println("--------------");

for (SolrDocument s : solrDocumentList) {

System.out.println("商品的id:"+s.get("id"));

System.out.println("商品的名稱:"+s.get("product_name"));

System.out.println("商品的價格:"+s.get("product_price"));

System.out.println("商品的圖片:"+s.get("product_picture"));

System.out.println("商品的類別名稱:"+s.get("product_catalog_name"));

System.out.println("商品的描述:"+s.get("product_decsription"));

System.out.println("-----------分隔符---------------");

}

} catch (SolrServerException e) {

e.printStackTrace();

}

--測試結果：很是成功！！！（對比管理界面查詢結果）

3.2 安裝DataImport插件

3.2.1 Dataimport插件說明

--好處：能夠在管理界面直接從數據庫導入數據到索引庫。（即：一個插件解決入門示例中，建立索引的所有操做）

3.2.2 安裝步驟

3.2.2.1 第一步：添加jar依賴

（1）將/solr-4.10.3/dist/solr-dataimporthandler-4.10.3.jar拷貝到

/depJar/contrib/dataimporthandler/lib目錄下

（2）、將jdbc驅動包拷貝到 /depJar/contrib/db/lib 目錄下

（3）、在solrconfig.xml文件中，加載這兩個jar依賴

3.2.2.2 第二步：配置數據庫表和solr域的映射關係

--在solr實例的conf目錄下，配置數據庫映射文件data-config.xml

<?xml version="1.0" encoding="UTF-8" ?>

<dataSource type="JdbcDataSource"

driver="com.mysql.jdbc.Driver"

url="jdbc:mysql://localhost:3306/solr"

user="root"

password="gzsxt"/>

</entity>

</document>

</dataConfig>

3.2.2.3 第三步：建立dataimport處理器

--說明：Solr是在solrconfig.xml文件中，經過<requestHandler>標籤訂義各種請求處理器

--修改solrconfig.xml，添加以下配置。（加載data-config.xml映射文件）

<requestHandler name="/dataimport"

class="org.apache.solr.handler.dataimport.DataImportHandler">

<str name="config">data-config.xml</str>

</lst>

</requestHandler>

3.2.2.4 第四步：重啓tomcat，在管理界面測試

--測試清空索引庫，成功！！！

--測試從新導入數據，成功！！！

3.3 Analyzer分析器，配置中文分詞器

3.3.1 Solr自帶分詞器的缺陷

--solr跟Lucene同樣，提供了不少分析器。能夠在Analyzer選型下測試分詞效果。

--測試發現：因此的分詞器，對中文支持都不友好。

解決辦法：配置中文分詞器。

3.3.2 Solr配置中文分析器

3.3.2.1 中文分析器選擇

選擇IK中文分詞器。

3.3.2.2 配置步驟

3.3.2.2.1 第一步：添加IkAnalyze的jar依賴

--把IKAnalyzer2012FF_u1.jar添加到solr/WEB-INF/lib目錄下。

3.3.2.2.2 第二步：加載IkAnalyzer的核心配置文件

--拷貝IkAnalyzer的配置文件到solr/WEB-INF/classes目錄

3.3.2.2.3 第三步：建立中文分詞器

--在schema.xml中自定義一個FieldType，指定中文分詞器IKAnalyzer。

</fieldType>

3.3.2.3 測試中文分詞器

3.3.2.3.1 第一步：重啓tomcat

3.3.2.3.2 第二步：在analysis選項卡下，測試分詞效果。成功！！！

3.3.3 改造業務域，使用IK作分詞器

--修改schem.xml文件，修改須要分詞的域的fieldType類型

咱們只須要修改product_name、product_description兩個業務域便可。

--重啓tomcat便可。

4 Solr案例實戰

4.1 需求

使用Solr實現電商網站中商品信息搜索功能，能夠根據關鍵字、分類、價格搜索商品信息，也能夠根據價格進行排序，而且實現分頁功能。

界面以下：

4.2 分析

開發人員須要的文檔：靜態頁面（根據UI設計由美工給出）、數據庫設計、原型設計

4.2.1 UI分析

4.2.2 架構分析

架構分爲：

（1）、solr服務器。（已經作完，同入門示例）

（2）、本身開發的應用（重點）

（3）、數據庫mysql

本身開發的應用

Controller 負責和前端頁面進行請求和響應的交互

Service 封裝查詢條件，調用dao。

Dao 搜索索引庫，返回搜索結果。

4.3 環境準備

Solr：4.10.3

Jdk環境：1.7.0_72（solr4.10 不能使用jdk1.7如下）

Ide環境：Eclipse

Web服務器（servlet容器）：Tomcat 7X

4.4 功能開發

4.4.1 第一步：建立web工程，導入jar包

--導入的jar包說明：

Solrj的包

Solr服務的日誌包

Spring的包（包含springmvc）

核心包 4個 core 、bean、context、expresstion

註解包 aop

Web包 web、webmvc

Commons日誌包 common-logging

Jstl包

--導入靜態資源和jsp頁面說明：

靜態資源放在webapp目錄下，jsp頁面放到/WEB-INF/目錄下

4.4.2 第二步：Spring整合Solr、Springmvc

4.4.2.1 建立springmvc.xml

在config包下，建立springmvc.xml文件

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.1.xsd

http://www.springframework.org/schema/mvc

http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.1.xsd

http://www.springframework.org/schema/aop

http://www.springframework.org/schema/aop/spring-aop-3.1.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-3.1.xsd ">

<context:component-scan base-package="cn.gzsxt" />

<mvc:annotation-driven />

<bean

class="org.springframework.web.servlet.view.InternalResourceViewResolver">

</bean>

<constructor-arg value="http://localhost:8080/solr/solrCore0719"></constructor-arg>

</bean>

</beans>

4.4.2.2 建立Web.xml

<?xml version="1.0" encoding="UTF-8"?>

<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://xmlns.jcp.org/xml/ns/javaee" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" id="WebApp_ID" version="3.1">

<display-name>JD0719</display-name>

<servlet-name>springmvc</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<init-param>

<param-name>contextConfigLocation</param-name>

<param-value>classpath:springmvc.xml</param-value>

</init-param>

</servlet>

<servlet-mapping>

<servlet-name>springmvc</servlet-name>

<url-pattern>/</url-pattern>

</servlet-mapping>

<filter-name>Character Encoding</filter-name>

<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>

<init-param>

<param-name>encoding</param-name>

<param-value>UTF-8</param-value>

</init-param>

</filter>

<filter-mapping>

<filter-name>Character Encoding</filter-name>

<url-pattern>*.action</url-pattern>

</filter-mapping>

</web-app>

4.4.3 第三步：整合測試

4.4.3.1 需求：

訪問搜索頁面。

4.4.3.2 建立PageController類

package cn.gzsxt.solr.controller;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

@Controller

public class PageController {

@RequestMapping(value="/{page}")

public String showPage(@PathVariable("page")String page){

return page;

}

4.4.3.3 注意事項

（1）Solr服務器要先開啓。

（2）Solr服務器部署的Tomcat和本web應用的部署的Tomcat不是同一個。

（3）要同時啓動兩個Tomcat，要注意端口衝突問題。

4.4.3.4 修改Solr服務器的Tomcat的端口

--在server.xml文件中，修改端口

--tomcat端口說明：

8005：關機端口

8080：默認服務端口

8009：請求轉向端口。

--注意：這三個端口都須要修改。否則啓動會衝突

本次課程中，將solr的tomcat端口，修改成8888.

4.4.3.5 修改Springmvc.xml

--修改Solr服務的端口

<constructor-arg value="http://localhost:8888/solr/solrCore0719"></constructor-arg>

</bean>

4.4.3.6 訪問搜索頁面

地址：http://localhost:8080/solr-demo-02-jd/product_list.action

整合成功！！！

4.4.4 第四步：搜索功能實現

分析代碼結構：

請求路徑	list.action
請求方式	POST
請求參數	queryString、catalog_name、price、curPage、sort（共5個）
返回結果	定義Product 以及ProductModel

4.4.4.1 Pojo

4.4.4.1.1 分析

結合查詢界面，分析得出：

--須要一個商品的pojo（Product），存放商品信息

--須要一個包裝pojo（ResultModel），它包括商品列表信息、商品分頁信息

4.4.4.1.2 建立Product類

public class Product {

// 商品編號

private String pid;

// 商品名稱

private String name;

// 商品分類名稱

private String catalog_name;

// 價格

private double price;

// 商品描述

private String description;

// 圖片名稱

private String picture;

}

4.4.4.1.3 建立ResultModel類

public class ResultModel {

private List<Product> productList;

// 商品總數

private Long recordCount;

// 總頁數

private int pageCount;

// 當前頁

private int currentPage;

}

4.4.4.2 Dao

4.4.4.2.1 功能

接收service層傳遞過來的參數，根據參數查詢索引庫，返回查詢結果。

4.4.4.2.2 建立ProductDao接口，定義一個查詢方法

public interface ProductDao {

//查詢商品信息，包括分頁信息

public ResultModel queryProduct(SolrQuery query) throws Exception;

}

4.4.4.2.3 建立ProductDaoImpl，從新改查詢方法

package cn.gzsxt.dao.impl;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import org.apache.solr.client.solrj.SolrQuery;

import org.apache.solr.client.solrj.impl.HttpSolrServer;

import org.apache.solr.client.solrj.response.QueryResponse;

import org.apache.solr.common.SolrDocument;

import org.apache.solr.common.SolrDocumentList;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Repository;

import cn.gzsxt.bean.Product;

import cn.gzsxt.bean.ResultModel;

import cn.gzsxt.dao.ProductDao;

@Repository

public class ProductDaoImpl implements ProductDao {

@Autowired

private HttpSolrServer server;

@Override

public ResultModel queryProduct(SolrQuery query) throws Exception {

ResultModel result = new ResultModel();

// 經過server查詢索引庫

QueryResponse response = server.query(query);

// 得到查詢結果

SolrDocumentList documentList = response.getResults();

// 把查詢結果總數設置到ResultModel

result.setRecordCount(documentList.getNumFound());

List<Product> productList = new ArrayList<>();

Product product = null;

// 高亮信息

Map<String, Map<String, List<String>>> highlighting = response

.getHighlighting();

for (SolrDocument solrDocument : documentList) {

product = new Product();

product.setPid((String) solrDocument.get("id"));

String prodName = (String) solrDocument.get("product_name");

List<String> list = highlighting.get(solrDocument.get("id")).get(

"product_name");

if (list != null)

prodName = list.get(0);

product.setName(prodName);

product.setCatalog_name((String) solrDocument

.get("product_catalog_name"));

product.setPrice((float) solrDocument.get("product_price"));

product.setPicture((String) solrDocument.get("product_picture"));

productList.add(product);

}

// 把商品列表放到ResultMap中

result.setProductList(productList);

return result;

}

4.4.4.3 Service

4.4.4.3.1 功能分析

接收action傳遞過來的參數，根據參數拼裝一個查詢條件，調用dao層方法，查詢商品列表。

接收返回的商品列表和商品的總數量，根據每頁顯示的商品數量計算總頁數。

4.4.4.3.2 建立ProductService接口，定義一個查詢方法

public interface ProductService {

public ResultModel queryProduct(String queryString, String cataName,

String price, String sort, Integer curPage) throws Exception;

}

4.4.4.3.3 建立ProductServiceImpl類，重寫改查詢方法

package cn.gzsxt.service.impl;

import org.apache.solr.client.solrj.SolrQuery;

import org.apache.solr.client.solrj.SolrQuery.ORDER;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import cn.gzsxt.dao.ProductDao;

import cn.gzsxt.service.ProductService;

import cn.gzsxt.vo.ResultModel;

@Service

public class ProductServiceImpl implements ProductService {

@Autowired

private ProductDao productDao;

@Override

public ResultModel queryProduct(String queryString, String cataName,

String price, String sort, Integer curPage) throws Exception {

//封裝查詢條件

SolrQuery query = new SolrQuery();

//判斷查詢條件是否爲空

if(!"".equals(queryString)&& null != queryString){

query.setQuery(queryString);

}else{

query.setQuery("*:*");

}

//判斷過濾條件是否爲空

if(!"".equals(cataName)&& null !=cataName){

query.addFilterQuery("product_catalog_name:"+cataName);

}

//判斷商品價格是否爲空

if(!"".equals(price) && null != price){

String[] prices = price.split("-");

if(prices.length == 2){

query.addFilterQuery("product_price:["+prices[0]+" TO "+prices[1]+"]");

}

//設置排序

if("1".equals(sort)){

query.setSort("product_price", ORDER.desc);

}else {

query.setSort("product_price", ORDER.asc);

}

//設置分頁信息

if(null == curPage){

curPage = 1;

}

query.setStart((curPage-1)*20);

query.setRows(20); //每頁20條數據

//設置默認搜索域

query.set("df","product_name");

query.setHighlight(true);

query.addHighlightField("product_name");

query.setHighlightSimplePre("<font style=\"color:red\">");

query.setHighlightSimplePost("</font>");

ResultModel result = productDao.queryProduct(query);

result.setCurrentPage(curPage);

// 總頁數 = 總數量 / 每頁數據條數結果向上取整

double ceil = Math.ceil(result.getRecordCount().doubleValue()/20);

result.setPageCount((int)ceil);

return result;

}

4.4.4.4 Controller

4.4.4.4.1 建立ProductController類，定義查詢接口

package cn.gzsxt.controller;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.ui.ModelMap;

import org.springframework.web.bind.annotation.RequestMapping;

import cn.gzsxt.service.ProductService;

import cn.gzsxt.vo.ResultModel;

@Controller

public class ProductController {

@Autowired

private ProductService productService;

@RequestMapping("/list.action")

public String queryProduct(String queryString, String catalog_name,

String price, String sort, Integer curPage, ModelMap model)

throws Exception {

ResultModel resultModel = productService.queryProduct(queryString, catalog_name,

price, sort, curPage);

model.addAttribute("result", resultModel);

model.addAttribute("queryString", queryString);

model.addAttribute("catalog_name", catalog_name);

model.addAttribute("price", price);

model.addAttribute("sort", sort);

model.addAttribute("page", curPage);

return "product_list";

}

4.4.4.5 測試搜索功能

地址：http://localhost:8080/solr-demo-02-jd/list.action

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。