【黑马程序员】面试题-利用solr实现商品的搜索功能
【黑马程序员】面试题-利用solr实现商品的搜索功
能
问题提出：当我们访问购物网站的时候，我们可以根据我们随意所想的内容输入关键字就可以查询出相关的内容，这是怎么做到呢？这些随意的数据不可能是根据数据库的字段查询的，那是怎么查询出来的呢，为什么千奇百怪的关键字都可以查询出来呢？
答案就是全文检索工具的实现，luncence采用了词元匹配和切分词。举个例子：北京天安门------luncence切分词：北京京天天安安门等等这些分词。所以我们搜索的时候都可以检索到。
有一种分词器就是ik中文分词器，它有细粒度切分和智能切分，即根据某种智能算法。
这就使用solr的最大的好处：检索功能的实现。
使用步骤；
（１）solr服务器搭建，因为solr是用java5开发的，所以需要jdk和tomcat。搭建部署
（２）搭建完成后，我们需要将要展示的字段引入solr的库中。配置sring与solr结合，工程启动的时候启动solr
（３）将数据库中的查询内容导入到solr索引库，这里使用的是solrj的客户端实现的。具体使用可以参考api
（４）建立搜索服务，供客户端调用。调用solr，查询内容，这中间有分页功能的实现。solr高亮显示的实现。
（５）客户端接收页面的请求参数，调用搜索服务，进行搜索。
业务字段判断标准：
1、在搜索时是否需要在此字段上进行搜索。例如：商品名称、商品的卖点、商品的描述
（这些相当于将标签给了solr，导入商品数据后，solr对这些字段的对应的商品的具体内容进行分词切分，然后，我们就可以搜索到相关内容了）
2、后续的业务是否需要用到此字段。例如：商品id。
需要用到的字段：
1、商品id
2、商品title
3、卖点
4、价格
5、商品图片
6、商品分类名称
7、商品描述
Solr中的业务字段：
1、id——》商品id
其他的对应字段创建solr的字段。
[AppleScript] 纯文本查看复制代码
?
01 02 03 04 05 06 07
08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23stored="true"/> stored="false" multiValued="true"/> 重新启动tomcat Solr 是Apache下的一个顶级开源项目，采用Java开发，它是基于Lucene的全文搜索服务器。Solr提供了比Lucene更为丰富的查询语言，同时实现了可配置、可扩展，并对索引、搜索性能进行了优化。 Solr是一个全文检索服务器，只需要进行配置就可以实现全文检索服务。有效降低频繁访问数据库对数据库造成的压力。 第一步：将solr部署在linux系统下。 第二步：solrJ是solr的客户端，使用它需要依赖solrJ的jar包。 第三步：将数据库的内容添加到solr的索引库，这样查询就在索引库查询，而 不是数据库了。controller层：[AppleScript] 纯文本查看复制代码? 01 02 03 04 05 06 07 08 09 10 11 12@Controller @RequestMapping("/manager") public class ItemController { @Autowired private ItemService itemService; @RequestMapping("/importall") @ResponseBody public TaotaoResult importAllItem(){ TaotaoResult result= itemService.importAllItem(); return result; } } [AppleScript] 纯文本查看复制代码? 01 02 03 04 05 06 07 08 09 10 11package com.taotao.search.mapper; import java.util.List; import com.taotao.search.pojo.Item; public interface ItemMapper { List } mapper.xml [AppleScript] 纯文本查看复制代码? 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 a.id, a.title, a.sell_point, a.price, a.image, b. NAME category_name FROM tb_item a LEFT JOIN tb_item_cat b ON a.cid = b.id 四步：从索引库查询的逻辑编写：[AppleScript] 纯文本查看复制代码 ? 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24//从索引库里面获取商品信息，现在这个dao层是从索引库获取信息，因为之前的写的逻辑是将db里面的数据导入到索引库。后面的查询都是从索引库中进行，而不从数据库了 @Repository public class SearchDaoImpl implements SearchDao { @Autowired private SolrServer solrServer; @Override public SearchResult search(SolrQuery query) throws Exception { //这是从索引库里面，直接执行查询 QueryResponse response = solrServer.query(query); //获取查询的结果 SolrDocumentList documentList= response.getResults(); SearchResult result=new SearchResult(); //这是获取总记录数 result.setRecordCount(documentList.getNumFound()); List //商品的高亮显示，即当鼠标移到字上时，该字体变色，这是从QueryResponse中获取的 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 Map for (SolrDocument solrDocument : documentList) { //每个SolrDocument都是一个商品pojo的内容，所以这里要创建一个商品的pojo对象，来获取详细的字段 Item item=new Item(); item.setId((String) solrDocument.get("id")); //高亮显示是title的高亮显示 List highlighting.get(solrDocument.get("id")).get("item_title"); String title=""; if (list!=null && list.size()>0) { title=list.get(0); } else{ title=(String) solrDocument.get("item_title"); } item.setTitle(title); item.setPrice((Long) solrDocument.get("item_price")); item.setImage((String) solrDocument.get("item_image")); item.setCategory_name((String) solrDocument.get(" item_category_name")); item.setSell_point((String) solrDocument.get("item_sell_point")); itemList.add(item); } result.setItemList(itemList); return result; } } 第五步：索引库内容建立好后，开始编写对外的服务接口，即通过条件搜索具体的商品，比如手机，会显示出总共的手机列表信息，第几页，总共多少页，总共多少个搜索结果 请求的url： file:///C:/Users/ADMINI~1.WIN/AppData/Local/Temp/V7(XMW RN]%7BG8~CI%7DBCCR3QC.gif arch/query?q={查询条 件}&page={page}&rows={rows} 返回的结果：TaotaoResult包装商品列表。 创建一个sql语句对应的pojo，单独建立一个pojo 用来装显示的内容列表： [AppleScript] 纯文本查看复制代码 ? 01 02 03 04 05 06 07 08 09 10public class Item { private String id; private String title; private String sell_point; private long price; private String image; private String category_name; private String item_des; } controller层：[AppleScript] 纯文本查看复制代码? 01 02@Controller public class SearchController { 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 @Autowired private SearchService searchService; @RequestMapping(value="/query", method=RequestMethod.GET) @ResponseBody public TaotaoResult search(@RequestParam("q")String queryString, @RequestParam(defaultValue="1")Integer page, @RequestParam(defaultValue="60")Integer rows) { //查询条件不能为空 if (StringUtils.isBlank(queryString)) { return TaotaoResult.build(400, "查询条件不能为空"); } SearchResult searchResult = null; try { queryString = new String(queryString.getBytes("iso8859-1"), "utf-8"); searchResult = searchService.search(queryString, page, rows); } catch (Exception e) { e.printStackTrace(); return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e)); } return TaotaoResult.ok(searchResult); } } [AppleScript] 纯文本查看复制代码? 1service层：利用solrJ的solrQurery来查询： 前提是要写好如何从索引库读取数据：下面是服务的接口层编写：controller： [AppleScript] 纯文本查看复制代码? 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 @Controller public class SearchController { @Autowired private SearchService searchService; @RequestMapping(value="/query", method=RequestMethod.GET) @ResponseBody public TaotaoResult search(@RequestParam("q")String queryString, @RequestParam(defaultValue="1")Integer page, @RequestParam(defaultValue="60")Integer rows) { //查询条件不能为空 if (StringUtils.isBlank(queryString)) { return TaotaoResult.build(400, "查询条件不能为空"); } SearchResult searchResult = null; try { queryString = new String(queryString.getBytes("iso8859-1"), "utf-8"); searchResult = searchService.search(queryString, page, rows); } catch (Exception e) { e.printStackTrace(); return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e)); } return TaotaoResult.ok(searchResult); } } [AppleScript] 纯文本查看复制代码 ? 01 02 03 04@Service public class SearchServiceImpl implements SearchService { @Autowired private SearchDao searchDao; 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 @Override public SearchResult search(String queryString, int page, int rows) throws Exception { SolrQuery query=new SolrQuery(); query.setQuery(queryString); query.setStart((page-1)*rows); query.setRows(rows); //设置默认的查询搜索域，即默认的查询 query.set("df","item_keywords"); //设置高亮显示 query.setHighlight(true); query.addHighlightField("item_title"); query.setHighlightSimplePre(""); query.setHighlightSimplePost(""); //执行查询 SearchResult searchResult = searchDao.search(query); //根据结果来计算商品总共多少页 long recordCount=searchResult.getRecordCount(); long pageCount=recordCount/rows; if (recordCount % rows > 0) { pageCount++; } searchResult.setPageCount(pageCount); searchResult.setCurPage((long) page); return searchResult; } } 客户端通过输入商品来实现搜索功能：controller层： @Controller [AppleScript] 纯文本查看复制代码 ? 01p ublic class SearchController { 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 @Autowired private SearchService searchService; @RequestMapping("/search") public String search(@RequestParam("q")String queryString, @RequestParam(defaultValue="1")Integer page, Model model) { if (queryString != null) { try { queryString = new String(queryString.getBytes("iso8859-1"), "utf-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } } SearchResult searchResult = searchService.search(queryString, page); //向页面传递参数 model.addAttribute("query", queryString); //model.addAttribute("totalPages", searchResult.getPageCount()); model.addAttribute("itemList", searchResult.getItemList()); model.addAttribute("page", page); return "search"; } } service层：[AppleScript] 纯文本查看复制代码? 01 02 03 04 05 06 07 08 09@Service public class SearchServiceImpl implements SearchService { @Value("${SEARCH_BASE_URL}") private String SEARCH_BASE_URL; @Override public SearchResult search(String queryString, int page) { //这里需要的是连接+参数.这里每页显示的记录条数，可以 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33传递也可以不用传递 // 调用taotao-search的服务 //查询参数 Map param.put("q", queryString); param.put("page", page + ""); try { //调用服务 String json = HttpClientUtil.doGet(SEARCH_BASE_URL, param); //把字符串转换成java对象 TaotaoResult taotaoResult = TaotaoResult.formatToPojo(json, SearchResult.class); SearchResult result = (SearchResult) taotaoResult.getData(); return result; /* if (taotaoResult.getStatus() == 200) { }*/ } catch (Exception e) { e.printStackTrace(); return null; } } }
service层编写：
多表查询商品，显示在页面的逻辑编写：
mapper.java