SpringBoot 整合ElasticSearch，实现站内搜索，高亮关键字

avatar 2019年02月06日11:02:06 7 7963 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
ElasticSearch 是目前最风靡的开源框架之一，常用于站内搜索和日志分析。上一篇文章介绍了 ES 和 MySQL 数据同步，本文就介绍 ES 如何集成到 SpringBoot 中，实现基本的查询。

本文主要用于站内搜索，可实现智能分词，高亮关键字等功能，查询速度也很快。

本文采用 ElasticSearch 6.5.0，客户端是 Rest Client

一、整合 SpringBoot


1.pom.xml
  1. <!-- ElasticSearch -->
  2.    <dependency>
  3.      <groupId>org.elasticsearch</groupId>
  4.      <artifactId>elasticsearch</artifactId>
  5.      <version>6.5.0</version>
  6.    </dependency>
  8.    <!-- Java High Level REST Client -->
  9.    <dependency>
  10.      <groupId>org.elasticsearch.client</groupId>
  11.      <artifactId>elasticsearch-rest-high-level-client</artifactId>
  12.      <version>6.5.0</version>
  13.      <exclusions>
  14.        <exclusion>
  15.          <groupId>org.elasticsearch</groupId>
  16.          <artifactId>elasticsearch</artifactId>
  17.        </exclusion>
  18.      </exclusions>
  19.    </dependency>



2.配置类

ESConfig.java
  1. package com.liuyanzhao.sens.config;
  3. import org.apache.http.HttpHost;
  4. import org.elasticsearch.client.RestClient;
  5. import org.elasticsearch.client.RestHighLevelClient;
  6. import org.springframework.context.annotation.Bean;
  7. import org.springframework.context.annotation.Configuration;
  9. /**
  10.  * ElasticSearch 配置类
  11.  * 实例化 client
  12.  *
  13.  * @author 言曌
  14.  * @date 2019/2/2 下午3:55
  15.  */
  17. @Configuration
  18. public class ESConfig {
  21.     @Bean
  22.     public RestHighLevelClient client() {
  23.         RestHighLevelClient client = new RestHighLevelClient(
  24.                 RestClient.builder(
  25.                         new HttpHost("localhost", 9200, "http")));
  26.         return client;
  27.     }
  28. }

主要用于创建 client，然后要用的地方只需要注入，而不是在方法里，每次 new 一个。



3. Controller 层
  1. @Autowired
  2.    private RestHighLevelClient client;
  3.    /**
  4.     * 搜索
  5.     *
  6.     * @param model model
  7.     * @param page  当前页码
  8.     * @return 模板路径/themes/{theme}/index
  9.     */
  10.    @GetMapping(value = "/search/page/{page}")
  11.    public String searchPage(Model model,
  12.                             @PathVariable(value = "page") Integer page,
  13.                             @RequestParam("keyword") String keyword) {
  14.        //默认显示20条
  15.        Integer size = 20;
  16.        //所有日志数据，分页
  17.        Page posts = new Page(page, size);
  18.       // Page<Post> posts = postService.searchByKeywords(HtmlUtil.escape(keyword), pageable);
  20.        page = page > 0 ? page : 0;
  22.        //search request
  23.        SearchRequest searchRequest = new SearchRequest("blog");
  25.        //search builder
  26.        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
  27.        sourceBuilder.query(QueryBuilders.matchQuery("postTitle", keyword));
  28.        sourceBuilder.from((page - 1) * size);
  29.        sourceBuilder.size(size);
  30.        sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
  32.        //sort
  33.        sourceBuilder.sort(new ScoreSortBuilder().order(SortOrder.DESC));
  35.        //highlight
  36.        HighlightBuilder highlightBuilder = new HighlightBuilder();
  37.        HighlightBuilder.Field highlightTitle = new HighlightBuilder.Field("postTitle");
  38.        highlightTitle.preTags("<span class=\"highlight\">");
  39.        highlightTitle.postTags("</span>");
  40.        highlightBuilder.field(highlightTitle);
  41.        sourceBuilder.highlighter(highlightBuilder);
  43.        // add builder into request
  44.        searchRequest.indices("blog");
  45.        searchRequest.source(sourceBuilder);
  47.        //response
  48.        SearchResponse searchResponse = null;
  49.        try {
  50.            searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  51.        } catch (IOException e) {
  52.            e.printStackTrace();
  53.        }
  54.        TimeValue took = searchResponse.getTook();
  56.        //search hits
  57.        SearchHits hits = searchResponse.getHits();
  58.        long totalHits = hits.getTotalHits();
  60.        SearchHit[] searchHits = hits.getHits();
  61.        List<EsPost> postList = new ArrayList<>();
  62.        posts.setTotal((int) totalHits);
  63.        for (SearchHit hit : searchHits) {
  64.            String str = hit.getSourceAsString();
  65.            EsPost esPost = JSONObject.parseObject(str, EsPost.class);
  67.            Map<String, HighlightField> highlightFields = hit.getHighlightFields();
  68.            HighlightField highlight = highlightFields.get("postTitle");
  69.            if (highlight != null) {
  70.                Text[] fragments = highlight.fragments();
  71.                String fragmentString = fragments[0].string();
  72.                esPost.setPostTitle(fragmentString);
  73.            }
  74.            postList.add(esPost);
  75.        }
  76.        posts.setRecords(postList);
  77.        model.addAttribute("is_index", true);
  78.        model.addAttribute("posts", posts);
  79.        model.addAttribute("prefix", "/search");
  80.        model.addAttribute("suffix", "?keyword=" + keyword);
  81.        model.addAttribute("time", took);
  82.        return this.render("search");
  83.    }

本例只是个 demo，主要关注其中23-75行。正常情况，需要把逻辑实现写在 Service 层


二、具体效果


css 样式
  1.     .highlight {
  2.         color: red;
  3.     }



比如搜 springboot入门





历史上的今天
二月
06日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：2   待审核评论数：0
  1. avatar Charrian
    回复 2019年07月17日 21:40:38

    学习到了！佩服博主 :wink: :wink:

  2. avatar 人工智能技术jxtszn.com
    回复 2019年05月15日 17:39:56

    ElasticSearch这个开源程序挺好的