solr配置與整合

本文轉載自查看原文 2019-07-19 18:22 523

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 架構分析

spring容器

表現層

springmvc

Service層

Dao層

Solr索引庫

mysql數據庫

商品信息

Tomcat

Solr服務

索引、搜索請求

架構分為：

（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";

}

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 solr(四) : springboot 整合 solr solr從服務器配置整合到項目實戰 springboot整合solr solr與java整合使用 solr(一) : 整合 tomcat Maven整合Spring與Solr solr8.0 springboot整合solr（四） Solr記錄-solr介紹及配置 solr(二) : 整合ik-analyzer Solr5.3.1整合IKAnalyzer