索引庫(kù)搭建solr搜索功能實(shí)現(xiàn)圖片顯示問(wèn)題解決課堂06.淘淘商城-day06v2

1、1. 課程計(jì)劃1、搜索工程的搭建2、linux 下 solr 服務(wù)的搭建3、Solrj 使用測(cè)試4、把數(shù)據(jù)庫(kù)中的數(shù)據(jù)導(dǎo)入索引庫(kù)5、搜索功能的實(shí)現(xiàn)2. 搜索工程搭建要實(shí)現(xiàn)搜索功能，需要搭建 solr 服務(wù)、搜索服務(wù)工程、搜索系統(tǒng)(表現(xiàn)層的工程)2.1. Solr 服務(wù)搭建Solr 的環(huán)境Solr 是 java 開(kāi)發(fā)。 solr 的安裝文件 需要安裝 jdk。安裝環(huán)境 Linux。需要安裝 Tomcat。搭建步驟第一步：把 solr 的壓縮包上傳到 Linux 系統(tǒng)第二步：解壓 solr。第三步：安裝 Tomcat，解壓縮即可。第四步：把 solr 部署到 Tomcat 下。第五步：解壓縮 war

2、 包?？梢詥?dòng) Tomcat 解壓。第六步：把/root/solr-4.10.3/exrootlocalhost ext# pwdle/lib/ext 目錄下的所有的 jar 包，添加到 solr 工。/root/solr-4.10.3/exle/lib/extrootlocalhost ext# cp * /usr/local/solr/tomcat/webapps/solr/WEB-INF/lib/第七步：創(chuàng)建一個(gè) solrhome 。/ex/usr/local/solr/solrhomele/solr 目錄就是一個(gè) solrhome 。此目錄到rootlocalhost ex/root/

3、solr-4.10.3/ex rootlocalhost ex rootlocalhost exle# pwd lele# cp -r solr /usr/local/solr/solrhomele#第八步：關(guān)聯(lián) solr 及 solrhome。需要修改 solr 工程的 web.xml 文件。第九步：?jiǎn)?dòng) Tomcat和 windows 下的配置完全一樣。2.1.3. Solr 的使用添加文檔必須有 id 域，其他域 必須在 solr 的 schema.xml 中定義。2.2. 配置業(yè)務(wù)域schema.xml 中定義1、商品 Id使用 schema.xml 中的 id 域2、商品標(biāo)題3、商品

4、賣(mài)點(diǎn)4、商品價(jià)格5、商品6、分類(lèi)名稱7、商品描述創(chuàng)建對(duì)應(yīng)的業(yè)務(wù)域。需要制定中文分析器。創(chuàng)建步驟：第一步：把中文分析器添加到 solr 工。1、把 IKyzer2012FF_u1.jar 添加到 solr 工程的 lib 目錄下2、把擴(kuò)展詞典、配置文件放到 solr 工程的 WEB-INF/classes 目錄下。第二步：配置一個(gè) FieldType，制定使用 IK修改 schema.xml 文件yzer修改 Solr 的 schema.xml 文件，添加 FieldType：第三步：配置業(yè)務(wù)域，type 制定使用自定義的 FieldType。設(shè)置業(yè)務(wù)系統(tǒng) Field第四步：重啟 tomcat2

5、.3. 搜索服務(wù)工程搭建可以參考 taotao-manager 創(chuàng)建。Taotao-search（聚合工程 pom）|-taotao-search-erface（jar）|-taotao-search-Service（war）目錄結(jié)構(gòu)如下：2.3.1. taotao-search打包方式為 pom.pom.xml4.0.0com.taotaotaotao-parent0.0.1-SNAPSHOTcom.taotaotaotao-search0.0.1-SNAPSHOTpomtaotao-search-erfacetaotao-search-service2.3.2. taotao-search

6、-打包方式為 jarerface.apache.tomcat.maventomcat7-maven-plugin8084/pom.xml2.3.3. taotao-search-service4.0.0com.taotaotaotao-search0.0.1-SNAPSHOTtaotao-search-erfacecom.taotaotaotao-managojo0.0.1-SNAPSHOTcom.taotaomon0.0.1-SNAPSHOTpom.xml4.0.0com.taotaotaotao-search0.0.1-SNAPSHOTtaotao-search-servicewarcom

7、.alibabadubbo.springframeworkspring.jtynetty.apache.zookeeperzookeepercom.sgroschupfzkcntcom.taotaotaotao-search-erface0.0.1-SNAPSHOT.springframeworkspring-context.springframeworkspring-beans.springframeworkspring-webmvc.springframeworkspring-jdbc.springframeworkspring-aspects配置文件：.springframeworksp

8、ring-jms.springframeworkspring-context-support.apache.solrsolr-solrj.apache.maven.pluginsmaven-surefire-plugin2.12.4trueapplicationContext-.xml:由于搜索的數(shù)據(jù)涉及到 3，所以 mapper 接口及，需要自己定義 mapper,而 mapper 的使用，只在搜索服務(wù)工文件需要放在 taotao-search-service 工。第三步：創(chuàng)建一個(gè)文檔對(duì)象 SolrInput對(duì)象。第四步：向文檔中添加域。必須有 id 域，域的名稱必須在 schema.xml

9、 中定義。第五步：把文檔添加到索引庫(kù)中。第六步：提交。3.2. 刪除文檔3.2.1. 根據(jù) id 刪除第一步：創(chuàng)建一個(gè) SolrServer 對(duì)象。第二步：調(diào)用 SolrServer 對(duì)象的根據(jù) id 刪除的方法。第三步：提交。3.2.2. 根據(jù)查詢刪除Testpublic void deleteByQuery() throws Exception SolrServer solrServer = new HttpSolrServer(); solrServer.deleteByQuery(title:change.me);Testpublic void deleteById() throws

10、Exception / 第一步：創(chuàng)建一個(gè)SolrServer 對(duì)象。SolrServer solrServer = new HttpSolrServer();/ 第二步：調(diào)用SolrServer 對(duì)象的根據(jù) id 刪除的方法。solrServer.deleteById(1);/ 第三步：提交。mit();Testpublic void add() throws Exception / 第一步：把solrJ 的jar 包添加到工。/ 第二步：創(chuàng)建一個(gè)SolrServer，使用HttpSolrServer 創(chuàng)建對(duì)象。SolrServer solrServer = new HttpSolrServe

11、r();/ 第三步：創(chuàng)建一個(gè)文檔對(duì)象SolrInput對(duì)象。SolrInput= new SolrInput();/ 第四步：向文檔中添加域。必須有 id 域，域的名稱必須在schema.xml 中定義。.addField(id, test001);.addField(item_title, 測(cè)試商品);.addField(item_price, 199);/ 第五步：把文檔添加到索引庫(kù)中。solrServer.add();/ 第六步：提交。mit();3.3. 查詢索引庫(kù)查詢步驟：第一步：創(chuàng)建一個(gè) SolrServer 對(duì)象第二步：創(chuàng)建一個(gè) SolrQuery 對(duì)象。第三步：向 SolrQu

12、ery 中添加查詢條件、過(guò)濾條件。第四步：執(zhí)行查詢。得到一個(gè) Response 對(duì)象。第五步：取查詢結(jié)果。第六步：遍歷結(jié)果并打印。3.3.1.簡(jiǎn)單查詢3.3.2.帶顯示Testpublic void queryWithHighLighting() throws Exception / 第一步：創(chuàng)建一個(gè)SolrServer 對(duì)象SolrServer solrServer = new HttpSolrServer();/ 第二步：創(chuàng)建一個(gè)SolrQuery 對(duì)象。SolrQuery query = new SolrQuery();Testpublic void query() throws Exc

13、eption / 第一步：創(chuàng)建一個(gè)SolrServer 對(duì)象SolrServer solrServer = new HttpSolrServer();/ 第二步：創(chuàng)建一個(gè)SolrQuery 對(duì)象。SolrQuery query = new SolrQuery();/ 第三步：向SolrQuery 中添加查詢條件、過(guò)濾條件。query.setQuery(*:*);/ 第四步：執(zhí)行查詢。得到一個(gè) Response 對(duì)象。QueryResponse response = solrServer.query(query);/ 第五步：取查詢結(jié)果。SolrList solrList = response.

14、getResults();System.out.prln(查詢結(jié)果的錄數(shù)： + solrList.getNumFound();/ 第六步：遍歷結(jié)果并打印。for (Solrsolr: solrList) System.out.prln(solr.get(id); System.out.prln(solr.get(item_title); System.out.prln(solr.get(item_price);mit();4. 把商品數(shù)據(jù)導(dǎo)入到索引庫(kù)中4.1. 功能分析在 schema.xml 中定義以下業(yè)務(wù)域（已經(jīng)定義好）：商品 Id商品標(biāo)題商品賣(mài)點(diǎn)商品價(jià)格商品/ 第三步：向SolrQuer

15、y 中添加查詢條件、過(guò)濾條件。query.setQuery(測(cè)試);/指定默認(rèn)搜索域query.set(df, item_keywords);/開(kāi)啟顯示query.setHighlight(true);/顯示的域 query.addHighlightField(item_title); query.setHighlightSimplePre();query.setHighlightSimplet();/ 第四步：執(zhí)行查詢。得到一個(gè) Response 對(duì)象。QueryResponse response = solrServer.query(query);/ 第五步：取查詢結(jié)果。SolrList

16、solrList = response.getResults();System.out.prln(查詢結(jié)果的錄數(shù)： + solrList.getNumFound();/ 第六步：遍歷結(jié)果并打印。for (Solrsolr: solrList) System.out.prln(solr.get(id);System.out.prln(itemTitle);System.out.prln(solr.get(item_price);/取顯示MapString, MapString, List highlighting = response.getHighlighting();List list =

17、highlighting.get(solrString itemTitle = null;if (list != null & list.size() 0) itemTitle = list.get(0); else .get(id).get(item_title);itemTitle = (String) solr.get(item_title);分類(lèi)名稱商品描述需要從 tb_item, tb_item_cat, tb_item_desc 表中查詢數(shù)據(jù)。Sql 語(yǔ)句：SELECTid, a.title,a.sell_po, a.price, a.image,NAME category_nam

18、e, c.item_descFROMtb_item a, tb_item_cat b, tb_item_desc cWHEREa.cid = b.id AND a.id = c.item_id AND a.sus = 1;應(yīng)該在 taotao-manager-web 工調(diào)用導(dǎo)入索引庫(kù)的服務(wù)。即可將數(shù)據(jù)從數(shù)據(jù)庫(kù)中導(dǎo)入到索引庫(kù)）。業(yè)務(wù)邏輯：點(diǎn)擊按鈕，表現(xiàn)層調(diào)用服務(wù)層的工程的導(dǎo)入索引庫(kù)的方法服務(wù)層實(shí)現(xiàn) 調(diào)用 mapper 接口的方法查詢所有的商品的數(shù)據(jù)3.將數(shù)據(jù)一條條添加到 solrinput 4.將文檔添加到索引庫(kù)中5.提交，并返回導(dǎo)入成功即可文檔中4.2.層4.2.1. 創(chuàng)建POJO創(chuàng)建以下 P

19、OJO 用于存放查詢到的用于搜索的商品的數(shù)據(jù) 并放入mon 中packagemon.pojo;import java.io.Serializable;/*在 taotao-manager-web系統(tǒng)中 做一個(gè)導(dǎo)入索引庫(kù)的功能界面（例個(gè)按鈕，點(diǎn)擊搜索的商品數(shù)據(jù)POJOtitle SearchItem.javadescriptioncompany:author ljh* ver1.0*/public class SearchItem implements Serializable privaong id;/商品的idprivate String title;/商品標(biāo)題 private String

20、 sell_po;/商品賣(mài)點(diǎn) privaong price;/價(jià)格private String image;/商品的路徑 private String category_name;/商品分類(lèi)名稱 private String item_desc;/商品的描述public Long getId() return id;public void setId(Long id) this.id = id;public String getTitle() return title;public void setTitle(String title) this.title = title;public St

21、ring getSell_po() return sell_po;public void setSell_po(String sell_po) thil_po= sell_po;public Long getPrice() return price;public void setPrice(Long price) this.price = price;public String getImage() return image;public void setImage(String image) 4.2.2. 定義mapper 接口接口定義：放入 taotao-search-service 工。

22、4.2.3. Mapper文件 SELECTa.id, a.title, a.sell_po, a.price, a.image,b. NAME category_name, c.item_descFROMtb_item a,publicerfaearchItemMapper public List getSearchItemList();this.image = image;public String getCategory_name() return category_name;public void setCategory_name(String category_name) this.

23、category_name = category_name;public String getItem_desc() return item_desc;public void setItem_desc(String item_desc) this.item_desc = item_desc;4.3. Service 層參數(shù)：無(wú)業(yè)務(wù)邏輯：taotao-search 中實(shí)現(xiàn)1、查詢所有商品數(shù)據(jù)。2、創(chuàng)建一個(gè)SolrServer 對(duì)象。3、為每個(gè)商品創(chuàng)建一個(gè) SolrInput 4、為文檔添加域5、向索引庫(kù)中添加文檔。6、返回 TaotaoResult。對(duì)象。4.3.1. 創(chuàng)建application

24、Context-solr.xml在applicationContext-solr.xml 中配置 SolrServer 對(duì)象。tb_item_cat b, tb_item_desc cWHEREa.cid = b.id AND a.id = c.item_id AND a.sus = 1注意：以上黃色部分地址改成自己的 solr 所在的 IP 和端口4.3.2. 定義 service 接口接口放在 taotao-search-erface 中4.3.3. service 實(shí)現(xiàn)類(lèi)Servicepublic class SearchItemServiceImpl implements Search

25、ItemService Autowiredprivate SearchItemMapper searchItemMapper; Autowiredprivate SolrServer solrServer;Overridepublic TaotaoResult importAllItems() throws Exception/ 1、查詢所有商品數(shù)據(jù)。List itemList = searchItemMapper.getSearchItemList();/ 2、創(chuàng)建一個(gè)SolrServer 對(duì)象。/ 3、為每個(gè)商品創(chuàng)建一個(gè)SolrInput對(duì)象。for (SearchItem searchI

26、tem : itemList) SolrInput= new SolrInput();/ 4、為文檔添加域.addField(id, searchItem.getId();.addField(item_title, searchItem.getTitle();.addField(item_sell_po, searchItem.getSell_po();package com.taotao.search.service;importmon.pojo.TaotaoResult;publicerfaearchItemService /*導(dǎo)入所有的商品數(shù)據(jù)到索引庫(kù)中returnthrows Exce

27、ption*/public TaotaoResult importAllItems() throws Exception;4.3.4. 在 taotao-search-service 中發(fā)布服務(wù)4.4. 表現(xiàn)層4.4.1.服務(wù)在 taotao-manager-web 中服務(wù)。4.4.2. 添加 taotao-search-erface 的依賴在 taotao-manager-web 工的 pom.xml 中添加如下：.addField(item_price, searchItem.getPrice();.addField(item_image, searchItem.getImage();.a

28、ddField(item_category_name, searchItem.getCategory_name();.addField(item_desc, searchItem.getItem_desc();/ 5、向索引庫(kù)中添加文檔。 solrServer.add();/提交修改mit();/ 6、返回TaotaoResult。return TaotaoResult.ok();4.4.3. Controller請(qǐng)求的 url：/index/importall參數(shù)：無(wú)返回值：json 數(shù)據(jù)。TaotaoResult。4.4.4. 創(chuàng)建 JSP在 taotao-manager-web 中創(chuàng)建一

29、個(gè) jsp:Controllerpublic class SearchItemController Autowiredprivate SearchItemServiearchItemService;RequestMap(/index/importall) ResponseBodypublic TaotaoResult importAllItems() try TaotaoResult result = searchItemService.importAllItems();return result; catch (Exception e) e.prStackTrace();return Tao

30、taoResult.build(500, 導(dǎo)入數(shù)據(jù)失敗);4.4.5. 修改：index.jsp添加如下代碼到 index.jsp 中:索引管理導(dǎo)入索引庫(kù)一鍵導(dǎo)入商品數(shù)據(jù)到索引庫(kù)function importAll() $.t(/index/importall,null,function(data)if (data.sus=200) $.messager.alert(提示,商品數(shù)據(jù)導(dǎo)入成功！); else $.messager.alert(提示,商品數(shù)據(jù)導(dǎo)入失?。?;);4.4.6. 測(cè)試測(cè)試出錯(cuò)，原因是未將工的文件發(fā)布到 classpath 中。在 taotao-search-service

31、 工程的 pom 文件中添加如下配置：還需要在 taotao-manager-service 中加入依賴：junitjunittestsrc/main/java*/*.properties*/*.xmlfalsesrc/main/resour*/*.properties*/*.xmlfalse5. 商品搜索功能實(shí)現(xiàn)5.1. 搜索表現(xiàn)層工程搭建搜索結(jié)果頁(yè)面的展示?？梢詤⒖?taotao-manager-web 創(chuàng)建。打包方式 war。Taotao-search-web.mybatismybatis.mybatismybatis-springcom.pagehelperpagehelper-con

32、nector-javacom.alibabadruid5.1.1. Pom 文件4.0.0com.taotaotaotao-parent0.0.1-SNAPSHOTcom.taotaotaotao-search-web0.0.1-SNAPSHOTwarcom.taotaomon0.0.1-SNAPSHOTcom.taotaotaotao-search-erface0.0.1-SNAPSHOTcom.alibabadubbo.springframeworkspring.jtynetty.apache.zookeeperzookeepercom.sgroschupfzkcnt.springfram

33、eworkspring-context.springframeworkspring-beans.springframeworkspring-webmvc.springframeworkspring-jdbc.springframeworkspring-aspects.springframeworkspring-jms.springframeworkspring-context-supportjstljstljavax.servletservlet-apiprovidedjavax.servletjsp-apiprovidedjunitjunittest5.1.2.配置文件5.1.3. spri

34、ngmvc.xmlbeans xmlns=xmlns:xsi=xmlns:p=xmlns:context=xmlns:dubbo=/schema/dubboxmlns:mvc=.apache.tomcat.maventomcat7-maven-plugin8085/黃色部分注意改成自己的 IP 地址和端口5.1.4. web.xmltaotao-search-webindex.jspCharacterEncodingFilterxsi:schemaLocation=/schema/dubbo/schema/dubbo/dubbo.xsd!- -5.1.5. 靜態(tài)頁(yè)面將靜態(tài)頁(yè)面放入到 taota

35、o-search-web 工.springframework.web.filter.CharacterEncodingFilterencodingutf-8CharacterEncodingFilter/*taotao-search-web.springframework.web.servlet.DispatcherServletcontextConfigLocationclasspath:spring/springmvc.xml1taotao-search-web*.html5.2. 搜索功能分析在首頁(yè)的搜索框中輸入搜索條件， 然后跳轉(zhuǎn)到搜索結(jié)果頁(yè)面。搜索結(jié)果頁(yè)面在taotao-search

36、-web 工。首頁(yè)搜索框的點(diǎn)擊按鈕處理函數(shù)在:首頁(yè)的 JS 中，應(yīng)當(dāng)改成 8085,如圖：請(qǐng)求的 url：/search參數(shù)：1、q 查詢條件。2、page 頁(yè)碼。默認(rèn)為 1每頁(yè)顯示多少行 在 controller 中寫(xiě)死即可。比如：60返回值： String。(商品的列表信息，總頁(yè)數(shù) ，錄數(shù)，數(shù)據(jù)回顯)業(yè)務(wù)邏輯：1、接收查詢條件。2、創(chuàng)建一個(gè) SolrServer 對(duì)象，需要注入。3、創(chuàng)建一個(gè) SolrQuery 對(duì)象。4、需要設(shè)置查詢條件、分頁(yè)條件、設(shè)置默認(rèn)搜索域、設(shè)置。5、執(zhí)行查詢，返回 QueryResponse 對(duì)象。6、取返回結(jié)果，封裝到 List中。7、返回查詢結(jié)果的錄數(shù)，計(jì)算查

37、詢結(jié)果的總頁(yè)數(shù)。8、得到查詢結(jié)果，渲染 jsp.5.3.層5.3.1. 功能分析索引庫(kù)的類(lèi)。定義一些通用的數(shù)據(jù)業(yè)務(wù)邏輯就是查詢索引庫(kù)。參數(shù)：SolrQuery 對(duì)象業(yè)務(wù)邏輯：1、根據(jù) Query 對(duì)象進(jìn)行查詢。方法。2、返回查詢結(jié)果。包括 List、查詢結(jié)果的錄數(shù)。需要把返回結(jié)果封裝到 pojo 中，至少包含兩個(gè)屬性：List、Long recordCount再包含一個(gè)總頁(yè)數(shù)。創(chuàng)建如下 SearchResult 對(duì)象，放入mon 中5.3.2. 創(chuàng)建Search由于搜索功能只在搜索工用到，可以不寫(xiě)接口，只寫(xiě)類(lèi)。返回值：SearchResultReitorypublic class Search

38、Autowiredprivate SolrServer solrServer;public SearchResult search(SolrQuery query) throws Exception /根據(jù)query 對(duì)象查詢索引庫(kù)QueryResponse response = solrServer.query(query);/取商品列表SolrList solrList = response.getResults();/商品列表List itemList = new ArrayList();public class SearchResult implements Serializable

39、privaist itemList;/搜索結(jié)果列表privaong recordCount;/錄數(shù)privaong pageCount;/總頁(yè)數(shù)5.4. Service 層5.4.1. 功能分析參數(shù)：queryString：查詢條件 Page：頁(yè)碼 Rows：每頁(yè)顯示的業(yè)務(wù)邏輯：1、創(chuàng)建一個(gè) SolrQuery 對(duì)象。2、設(shè)置查詢條件3、設(shè)置分頁(yè)條件4、需要指定默認(rèn)搜索域。5、設(shè)置數(shù)。for (Solrsolr: solrList) SearchItem item = new SearchItem(); item.setId(String) solr.get(id);item.setCateg

40、ory_name(String) solr.get(item_category_name); item.setImage(String) solr.get(item_image); item.setPrice(long) solr.get(item_price);item.setSell_po(String) solr.get(item_sell_po);/取顯示MapString, MapString, List highlighting = response.getHighlighting(); List list = highlighting.get(solr.get(id).get(i

41、tem_title); String itemTitle = ;/有顯示的內(nèi)容時(shí)。if (list != null & list.size() 0) itemTitle = list.get(0); else itemTitle = (String) solr.get(item_title);item.setTitle(itemTitle);/添加到商品列表 itemList.add(item);SearchResult result = new SearchResult();/商品列表 result.setItemList(itemList);/錄數(shù)result.setRecordCount

42、(solrList.getNumFound();return result;6、執(zhí)行查詢，調(diào)用 Search 7、需要計(jì)算總頁(yè)數(shù)。8、返回 SearchResult。得到 SearchResult5.4.2. 定義 service 接口接口已存在，只需要添加方法即可。5.4.3. 定義 service 接口實(shí)現(xiàn)類(lèi)Servicepublic class SearchServiceImpl implements SearchService Autowiredprivate Searchsearch;Overridepublic SearchResult search(String queryStr

43、ing,page,rows) throws Exception / 1、創(chuàng)建一個(gè)SolrQuery 對(duì)象。SolrQuery query = new SolrQuery();/ 2、設(shè)置查詢條件 query.setQuery(queryString);/ 3、設(shè)置分頁(yè)條件 query.setStart( 1) * rows); query.setRows(rows);/ 4、需要指定默認(rèn)搜索域。 query.set(df, item_title);/ 5、設(shè)置 query.setHighlight(true);query.addHighlightField(item_title);query.setHighlightSimplePre();publicerfaearchService /*導(dǎo)入數(shù)據(jù)到索引庫(kù)return*/public void importAllItems() th