文章目錄
- 一、概念
- 1、什么是Solr
- 2、與Lucene的比較區別
- 1)Lucene
- 2)Solr
- 二、Solr的安裝與配置
- 1、Solr的下載
- 2、Solr的文件夾結構
- 3、運行環境
- 4、Solr整合tomcat
- 1)Solr Home與SolrCore
- 2)整合步驟
- 5、Solr管理后臺
- 1)Dashboard
- 2)Logging
- 3)Cloud
- 4)Core Admin
- 5) java properties
- 6)Tread Dump
- 7)Core selector
- 8)Analysis
- 9)Dataimport
- 10)Document
- 11)Query
- 6、配置中文分析器
- 1)Schema.xml
- 1. FieldType域類型定義
- 2. Field定義
- 3. uniqueKey
- 4. copyField復制域
- 5. dynamicField(動態字段)
- 2)安裝使用IKAnalyzer中文分詞器
- 三、Solr管理索引庫(不推薦)
- 1、添加/更新文檔
- 2、批量導入數據
- 3、刪除文檔
- 4、查詢文檔
- 四、使用SolrJ管理索引庫
- 1、什么是solrJ
- 2、創建Java工程,導入jar包
- 3、添加文檔
- 4、刪除文檔
- 5、修改文檔
- 6、查詢文檔
- 五、案例實現
- 1、創建一個web工程導入jar包
- 2、配置xml文件
- 3、導入jsp頁面和css
- 4、具體代碼實現
一、概念
1、什么是Solr
Solr 是Apache下的一個頂級開源項目,采用Java開發,它是基于Lucene的全文搜索服務器。Solr提供了比Lucene更為豐富的查詢語言,同時實現了可配置、可擴展,并對索引、搜索性能進行了優化。
Solr可以獨立運行,運行在Jetty、Tomcat等這些Servlet容器中,Solr 索引的實現方法很簡單,用 POST 方法向 Solr 服務器發送一個描述 Field 及其內容的 XML 文檔,Solr根據xml文檔添加、刪除、更新索引 。Solr 搜索只需要發送 HTTP GET 請求,然后對 Solr 返回Xml、json等格式的查詢結果進行解析,組織頁面布局。Solr不提供構建UI的功能,Solr提供了一個管理界面,通過管理界面可以查詢Solr的配置和運行情況。
2、與Lucene的比較區別
1)Lucene
Lucene是一個開放源代碼的全文檢索引擎工具包,它不是一個完整的全文檢索引擎,Lucene提供了完整的查詢引擎和索引引擎,目的是為軟件開發人員提供一個簡單易用的工具包,以方便的在目標系統中實現全文檢索的功能,或者以Lucene為基礎構建全文檢索引擎。
單獨使用Lucene實現站內搜索需要開發的工作量較大,主要表現在:索引維護、索引性能優化、搜索性能優化等,因此不建議采用。
2)Solr
Solr的目標是打造一款企業級的搜索引擎系統,它是一個搜索引擎服務,可以獨立運行,通過Solr可以非常快速的構建企業的搜索引擎,通過Solr也可以高效的完成站內搜索功能。
基于Solr實現站內搜索擴展性較好并且可以減少程序員的工作量,因為Solr提供了較為完備的搜索引擎解決方案,因此在門戶、論壇等系統中常用此方案。
二、Solr的安裝與配置
1、Solr的下載
從Solr官方網站(http://lucene.apache.org/solr/ )下載Solr4.10.3,根據Solr的運行環境,Linux下需要下載lucene-4.10.3.tgz,windows下需要下載lucene-4.10.3.zip。
Solr使用指南可參考:https://wiki.apache.org/solr/FrontPage。
2、Solr的文件夾結構
將solr-4.10.3.zip解壓后,目錄如下:
- bin:solr的運行腳本
- contrib:solr的一些貢獻軟件/插件,用于增強solr的功能。
- dist:該目錄包含build過程中產生的war和jar文件,以及相關的依賴文件。
- docs:solr的API文檔
- example:solr工程的例子目錄:
example/solr:該目錄是一個包含了默認配置信息的Solr的Core目錄。
example/multicore:該目錄包含了在Solr的multicore中設置的多個Core目錄。
example/webapps: 該目錄中包括一個solr.war,該war可作為solr的運行實例工程。 - licenses:solr相關的一些許可信息
3、運行環境
solr 需要運行在一個Servlet容器中,Solr4.10.3要求jdk使用1.7以上,Solr默認提供Jetty(java寫的Servlet容器),本教程使用Tocmat作為Servlet容器,環境如下:
- Solr:Solr4.10.3
- Jdk:jdk1.8.0_72
- Tomcat:apache-tomcat-7.0.53
4、Solr整合tomcat
1)Solr Home與SolrCore
創建一個Solr home目錄,SolrHome是Solr運行的主目錄,目錄中包括了運行Solr實例所有的配置文件和數據文件,Solr實例就是SolrCore,一個SolrHome可以包括多個SolrCore(Solr實例),每個SolrCore提供單獨的搜索和索引服務。
example\solr是一個solr home目錄結構,如下:
上圖中“collection1”是一個SolrCore(Solr實例)目錄 ,目錄內容如下所示:
說明:
collection1:是一個Solr運行實例SolrCore,SolrCore名稱不固定,一個solr運行實例對外單獨提供索引和搜索接口。
solrHome中可以創建多個solr運行實例SolrCore。
一個solr的運行實例對應一個索引目錄
conf是SolrCore的配置文件目錄 。
data目錄存放索引文件需要創建
2)整合步驟
- 第一步:安裝tomcat。
- 第二步:把solr的war包復制到tomcat 的webapp目錄下。
- 第三步:solr.war解壓。
- 第四步:把\solr-4.10.3\example\lib\ext目錄下的所有的jar包添加到solr工程中的WEB-INF\lib。
- 第五步:配置solrHome和solrCore。
1)創建一個solrhome(存放solr所有配置文件的一個文件夾)。
2)把\solr-4.10.3\example\solr文件夾復制到solrhome文件夾中,文件夾名字沒規定是這個,是為了便于理解。 - 第六步:告訴solr服務器配置文件也就是solrHome的位置。修改solr工程中的web.xml。
Solr/home名稱必須是固定的。
- 第七步:啟動tomcat
- 第八步:訪問http://localhost:8090/solr/
5、Solr管理后臺
1)Dashboard
儀表盤,顯示了該Solr實例開始啟動運行的時間、版本、系統資源、jvm等信息。
2)Logging
Solr運行日志信息
3)Cloud
Cloud即SolrCloud,即Solr云(集群),當使用Solr Cloud模式運行時會顯示此菜單。
4)Core Admin
Solr Core的管理界面。Solr Core 是Solr的一個獨立運行實例單位,它可以對外提供索引和搜索服務,一個Solr工程可以運行多個SolrCore(Solr實例),一個Core對應一個索引目錄。
添加solrcore:
- 第一步:復制collection1改名為collection2
- 第二步:修改core.properties。name=collection2
- 第三步:重啟tomcat
5) java properties
Solr在JVM 運行環境中的屬性信息,包括類路徑、文件編碼、jvm內存設置等信息。
6)Tread Dump
顯示Solr Server中當前活躍線程信息,同時也可以跟蹤線程運行棧信息。
7)Core selector
選擇一個SolrCore進行詳細操作,如下:
8)Analysis
通過此界面可以測試索引分析器和搜索分析器的執行情況。
9)Dataimport
可以定義數據導入處理器,從關系數據庫將數據導入 到Solr索引庫中。
10)Document
通過此菜單可以創建索引、更新索引、刪除索引等操作,界面如下:
/update表示更新索引,solr默認根據id(唯一約束)域來更新Document的內容,如果根據id值搜索不到id域則會執行添加操作,如果找到則更新。
11)Query
通過/select執行搜索索引,必須指定“q”查詢條件方可搜索。
6、配置中文分析器
1)Schema.xml
schema.xml,在SolrCore的conf目錄下,它是Solr數據表配置文件,它定義了加入索引的數據的數據類型的。主要包括FieldTypes、Fields和其他的一些缺省設置。
1. FieldType域類型定義
“text_general”是Solr默認提供的FieldType,通過它說明FieldType定義的內容:
FieldType子結點包括:name,class,positionIncrementGap等一些參數:
- name:是這個FieldType的名稱
- class:是Solr提供的包solr.TextField,solr.TextField 允許用戶通過分析器來定制索引和查詢,分析器包括一個分詞器(tokenizer)和多個過濾器(filter)
- positionIncrementGap:可選屬性,定義在同一個文檔中此類型數據的空白間隔,避免短語匹配錯誤,此值相當于Lucene的短語查詢設置slop值,根據經驗設置為100。
在FieldType定義的時候最重要的就是定義這個類型的數據在建立索引和進行查詢的時候要使用的分析器analyzer,包括分詞和過濾
- 索引分析器:使用solr.StandardTokenizerFactory標準分詞器,solr.StopFilterFactory停用詞過濾器,solr.LowerCaseFilterFactory小寫過濾器。
- 搜索分析器:使用solr.StandardTokenizerFactory標準分詞器,solr.StopFilterFactory停用詞過濾器,這里還用到了solr.SynonymFilterFactory同義詞過濾器。
2. Field定義
在fields結點內定義具體的Field,filed定義包括name,type(為之前定義過的各種FieldType),indexed(是否被索引),stored(是否被儲存),multiValued(是否存儲多個值)等屬性,如下:
<field name="name" type="text_general" indexed="true" stored="true"/>
<field name="features" type="text_general" indexed="true" stored="true" multiValued="true"/>
multiValued:該Field如果要存儲多個值時設置為true,solr允許一個Field存儲多個值,比如存儲一個用戶的好友id(多個),商品的圖片(多個,大圖和小圖),通過使用solr查詢要看出返回給客戶端是數組:
3. uniqueKey
Solr中默認定義唯一主鍵key為id域,如下:
Solr在刪除、更新索引時使用id域進行判斷,也可以自定義唯一主鍵。
注意在創建索引時必須指定唯一約束
4. copyField復制域
copyField復制域,可以將多個Field復制到一個Field中,以便進行統一的檢索,比如,輸入關鍵字搜索title標題內容content,定義title、content、text的域:
根據關鍵字只搜索text域的內容就相當于搜索title和content,將title和content復制到text中,如下:
5. dynamicField(動態字段)
動態字段就是不用指定具體的名稱,只要定義字段名稱的規則,例如定義一個 dynamicField,name 為*_i,定義它的type為text,那么在使用這個字段的時候,任何以_i結尾的字段都被認為是符合這個定義的,例如:name_i,gender_i,school_i等。
a、自定義Field名為:product_title_t,“product_title_t”和scheam.xml中的dynamicField規則匹配成功,如下:“product_title_t”是以“_t”結尾。
b、創建索引
c、搜索索引
2)安裝使用IKAnalyzer中文分詞器
- 第一步:把IKAnalyzer2012FF_u1.jar添加到solr/WEB-INF/lib目錄下。
- 第二步:復制IKAnalyzer的配置文件和自定義詞典和停用詞詞典到solr的classpath(在web-inf中自建的)下。
- 第三步:在schema.xml中添加一個自定義的fieldType,使用中文分析器。
<!-- IKAnalyzer-->
<fieldType name="text_ik" class="solr.TextField"><analyzer class="org.wltea.analyzer.lucene.IKAnalyzer"/>
</fieldType>
- 第四步:定義field,指定field的type屬性為text_ik
<!--IKAnalyzer Field-->
<field name="title_ik" type="text_ik" indexed="true" stored="true" />
<field name="content_ik" type="text_ik" indexed="true" stored="false" multiValued="true"/>
- 第五步:重啟tomcat
測試效果:
三、Solr管理索引庫(不推薦)
1、添加/更新文檔
添加或更新單個文檔
2、批量導入數據
使用dataimport插件批量導入數據。
- 第一步:把dataimport插件依賴的jar包以及mysql的數據庫驅動包
添加到solrhome\collection1\lib中
- 第二步:配置solrhome\collection1\conf路徑下的solrconfig.xml文件,添加一個requestHandler。
<requestHandler name="/dataimport"
class="org.apache.solr.handler.dataimport.DataImportHandler"><lst name="defaults"><str name="config">data-config.xml</str></lst></requestHandler>
- 第三步:創建一個data-config.xml,保存到collection1\conf\目錄下
<?xml version="1.0" encoding="UTF-8" ?>
<dataConfig>
<dataSource type="JdbcDataSource" driver="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost:3306/lucene" user="root" password="123"/>
<document> <entity name="product" query="SELECT pid,name,catalog_name,price,description,picture FROM products "><field column="pid" name="id"/> <field column="name" name="product_name"/> <field column="catalog_name" name="product_catalog_name"/> <field column="price" name="product_price"/> <field column="description" name="product_description"/> <field column="picture" name="product_picture"/> </entity>
</document>
</dataConfig>
- 第四步:這里還沒有lucene數據庫,創建一個,然后導入sql文件。
- 第五步:data-config.xml里面的字段還沒映射,配置schema.xml
<!--product--><field name="product_name" type="text_ik" indexed="true" stored="true"/><field name="product_price" type="float" indexed="true" stored="true"/><field name="product_description" type="text_ik" indexed="true" stored="false" /><field name="product_picture" type="string" indexed="false" stored="true" /><field name="product_catalog_name" type="string" indexed="true" stored="true" /><field name="product_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/><copyField source="product_name" dest="product_keywords"/><copyField source="product_description" dest="product_keywords"/>
- 第六步:重啟tomcat
- 第七步:點擊“execute”按鈕導入數據
導入數據前會先清空索引庫,然后再導入。
3、刪除文檔
1) 刪除制定ID的索引
<delete>
<id>8</id>
</delete>
<commit/>
2) 刪除查詢到的索引數據
<delete>
<query>product_catalog_name:幽默雜貨</query>
</delete>
3) 刪除所有索引數據
<delete>
<query>*:*</query>
</delete>
4、查詢文檔
通過/select搜索索引,Solr制定一些參數完成不同需求的搜索:
1.q - 查詢字符串,必須的,如果查詢所有使用,例如:
2.fq-(filter query)過慮查詢,作用:在q查詢符合結果中同時是fq查詢符合的,例如:
過濾查詢價格從1到20的記錄。
也可以在“q”查詢條件中使用product_price:[1 TO 20],例如:
也可以使用“*”表示無限,例如:
- 20以上:product_price:[20 TO *]
- 20以下:product_price:[* TO 20]
3.sort - 排序,格式:sort=+<desc|asc>[,+<desc|asc>]… 。示例:
4.start - 分頁顯示使用,開始記錄下標,從0開始
5.rows - 指定返回結果最多有多少條記錄,配合start來實現分頁
顯示前10條
6.fl - 指定返回那些字段內容,用逗號或空格分隔多個。
7.df-指定一個搜索Field
也可以在SolrCore目錄 中conf/solrconfig.xml文件中指定默認搜索Field,指定后就可以直接在“q”查詢條件中輸入關鍵字。
8.wt - (writer type)指定輸出格式,可以有 xml, json, php, phps, 后面 solr 1.3增加的,要用通知我們,因為默認沒有打開。
9.hl 是否高亮 ,設置高亮Field,設置格式前綴和后綴。
四、使用SolrJ管理索引庫
1、什么是solrJ
solrj是訪問Solr服務的java客戶端,提供索引和搜索的請求方法,SolrJ通常在嵌入在業務系統中,通過SolrJ的API接口操作Solr服務,如下圖:
2、創建Java工程,導入jar包
依賴的jar包
新建一個java文件:SolrManager,方便后續操作
import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Test;public class SolrManager {}
3、添加文檔
@Test
public void testadd() throws Exception{String baseURL="http://localhost:8090/solr";SolrServer solrServer=new HttpSolrServer(baseURL);SolrInputDocument doc = new SolrInputDocument();doc.setField("id", "123");doc.setField("name", "林格");//添加solrServer.add(doc);solrServer.commit();
}
4、刪除文檔
根據id刪除
//刪除文檔,根據id刪除
@Test
public void deleteDocumentByid() throws Exception {//創建連接SolrServer solrServer = new HttpSolrServer("http://localhost:8090/solr");//根據id刪除文檔solrServer.deleteById("123");//提交修改solrServer.commit();
}
根據查詢刪除
//根據查詢條件刪除文檔
@Test
public void deleteDocumentByQuery() throws Exception {//創建連接SolrServer solrServer = new HttpSolrServer("http://localhost:8090/solr");//根據查詢條件刪除文檔solrServer.deleteByQuery("*:*");//提交修改solrServer.commit();
}
5、修改文檔
在solrJ中修改沒有update方法,只有add方法,我們只需要添加一條新的文檔,和被修改的文檔id一致就可以修改了。本質上就是先刪除后添加。
6、查詢文檔
//簡單查詢
@Test
public void queryIndex() throws Exception{//創建連接SolrServer solrServer = new HttpSolrServer("http://localhost:8090/solr");//創建一個query對象SolrQuery query = new SolrQuery();//設置查詢條件query.setQuery("*:*");//執行查詢QueryResponse queryResponse = solrServer.query(query);//得到查詢結果SolrDocumentList solrDocumentList= queryResponse.getResults();//查詢到的商品數量System.out.println("共查詢到商品數量:" + solrDocumentList.getNumFound());for (SolrDocument solrDocument : solrDocumentList) {System.out.println(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"));}
}
復雜查詢,其中包含查詢、過濾、分頁、排序、高亮顯示等處理。
//復雜查詢
@Test
public void queryIndex2() throws Exception{//創建連接SolrServer solrServer = new HttpSolrServer("http://localhost:8090/solr");//創建一個query對象SolrQuery query = new SolrQuery();//設置查詢條件query.setQuery("臺燈");//過濾條件query.set("fq","product_catalog_name:雅致燈飾");//排序query.addSort("product_price",ORDER.desc);//分頁query.setStart(0);query.setRows(10);//指定返回那些字段內容query.setFields("id","product_name","product_price","product_catalog_name","product_picture");//指定一個搜索Fieldquery.set("df", "product_name");//高亮顯示query.setHighlight(true);//高亮顯示的域query.addHighlightField("product_name");//高亮顯示的前綴query.setHighlightSimplePre("<em>");//高亮顯示的后綴query.setHighlightSimplePost("</em>");//執行查詢QueryResponse queryResponse = solrServer.query(query);//得到查詢結果SolrDocumentList solrDocumentList= queryResponse.getResults();//查詢到的商品數量System.out.println("共查詢到商品數量:" + solrDocumentList.getNumFound()); for (SolrDocument solrDocument : solrDocumentList) {System.out.println(solrDocument.get("id"));//取高亮顯示String productName = "";Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();List<String> list = highlighting.get(solrDocument.get("id")).get("product_name");//判斷是否有高亮內容if (null != list) {productName = list.get(0);} else {productName = (String) solrDocument.get("product_name");}System.out.println(solrDocument.get("productName"));System.out.println(solrDocument.get("product_price"));System.out.println(solrDocument.get("product_catalog_name"));System.out.println(solrDocument.get("product_picture"));}}
五、案例實現
原型分析
系統架構
具體工程搭建實現如下:
1、創建一個web工程導入jar包
springmvc的相關jar包+solrJ的jar包+Example\lib\ext下的jar包
2、配置xml文件
配置web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5"><display-name>jd</display-name><welcome-file-list><welcome-file>index.html</welcome-file><welcome-file>index.htm</welcome-file><welcome-file>index.jsp</welcome-file><welcome-file>default.html</welcome-file><welcome-file>default.htm</welcome-file><welcome-file>default.jsp</welcome-file></welcome-file-list><!-- 前端控制器 --><servlet><servlet-name>jd</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>jd</servlet-name><url-pattern>*.action</url-pattern></servlet-mapping><!-- 解決post亂碼問題 --><filter><filter-name>CharacterEncodingFilter</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>CharacterEncodingFilter</filter-name><url-pattern>/*</url-pattern></filter-mapping>
</web-app>
配置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:p="http://www.springframework.org/schema/p"xmlns:context="http://www.springframework.org/schema/context"xmlns:mvc="http://www.springframework.org/schema/mvc"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"><context:component-scan base-package="com.it.jd"/><!-- 配置注解驅動,如果配置此標簽可以不用配置處理器映射器和適配器 --><mvc:annotation-driven/><!-- 配置視圖解析器 --><bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"><property name="prefix" value="/WEB-INF/jsp/"/><property name="suffix" value=".jsp"/></bean><!-- SolrServer的配置 --><bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer"><constructor-arg index="0" value="http://localhost:8090/solr"/></bean>
</beans>
3、導入jsp頁面和css
4、具體代碼實現
pojo代碼
package com.it.jd.pojo;public class ProductModel {// 商品編號private String pid;// 商品名稱private String name;// 商品分類名稱private String catalog_name;// 價格private float price;// 商品描述private String description;
// 圖片名稱private String picture;
public String getPid() { return pid; } public void setPid(String pid) { this.pid = pid; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getCatalog_name() { return catalog_name; } public void setCatalog_name(String catalog_name) { this.catalog_name = catalog_name; } public float getPrice() { return price; } public void setPrice(float price) { this.price = price; } public String getDescription() { return description; } public void setDescription(String description) { this.description = description; } public String getPicture() { return picture; } public void setPicture(String picture) { this.picture = picture; } }
Dao代碼
package com.it.jd.dao;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.SolrServer;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.SolrQuery.ORDER;
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 com.it.jd.pojo.ProductModel;@Repository
public class jdDaoImpl implements jdDao {@Autowiredprivate SolrServer solrServer;@Overridepublic List<ProductModel> selectProductModelListByQuery(String queryString, String catalog_name, String price,String sort) throws Exception {//創建一個query對象SolrQuery query = new SolrQuery();//設置查詢條件query.setQuery(queryString);//過濾條件if(catalog_name!=null&&!"".equals(catalog_name))query.set("fq","product_catalog_name:"+catalog_name);if(null != price && !"".equals(price)){//0-9 50-*String[] p = price.split("-");query.set("fq", "product_price:[" + p[0] + " TO " + p[1] + "]");}//排序if("1".equals(sort))query.addSort("product_price",ORDER.desc);elsequery.addSort("product_price",ORDER.asc);//分頁query.setStart(0);query.setRows(10);//指定返回那些字段內容query.set("fl","id","product_name","product_price","product_picture");//指定一個搜索Fieldquery.set("df", "product_name");//高亮顯示query.setHighlight(true);//高亮顯示的域query.addHighlightField("product_name");//高亮顯示的前綴query.setHighlightSimplePre("<span style='color:red'>");//高亮顯示的后綴query.setHighlightSimplePost("</span>");//執行查詢QueryResponse queryResponse = solrServer.query(query);//得到查詢結果SolrDocumentList solrDocumentList= queryResponse.getResults();//查詢到的商品數量//System.out.println("共查詢到商品數量:" + solrDocumentList.getNumFound()); Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();List<ProductModel> productModels = new ArrayList<ProductModel>();for (SolrDocument doc : solrDocumentList) {ProductModel pm=new ProductModel();pm.setPid((String) doc.get("id"));pm.setPrice((Float) doc.get("product_price"));pm.setPicture((String) doc.get("product_picture"));Map<String, List<String>> map = highlighting.get((String) doc.get("id"));List<String> list = map.get("product_name");pm.setName(list.get(0));productModels.add(pm);}return productModels;}}
Service代碼
package com.it.jd.service;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import com.it.jd.dao.jdDao;
import com.it.jd.pojo.ProductModel;@Service
public class jdServiceImpl implements jdService {@Autowiredprivate jdDao dao;@Overridepublic List<ProductModel> selectProductModelListByQuery(String queryString, String catalog_name, String price,String sort) throws Exception {return dao.selectProductModelListByQuery(queryString, catalog_name, price, sort);}}
Controller代碼
package com.it.jd.controller;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;import com.it.jd.pojo.ProductModel;
import com.it.jd.service.jdService;@Controller
public class jdController {@Autowiredprivate jdService jdService;@RequestMapping("list.action")public String list(String queryString,String catalog_name,String price,String sort,Model model) throws Exception{List<ProductModel> productModels = jdService.selectProductModelListByQuery(queryString, catalog_name, price, sort);model.addAttribute("productModels", productModels);model.addAttribute("queryString", queryString);model.addAttribute("catalog_name", catalog_name);model.addAttribute("price", price);model.addAttribute("sort", sort);return "product_list";}
}