SpringBoot 整合 elasticsearch 实例

avatar 2018年01月22日21:02:21 10 6869 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
上一篇文章介绍了安装 mac 上安装 elasticsearch

本文介绍 SpringBoot 集成 elasticsearch


一、下载 并启动 elasticsearch


下载地址：https://www.elastic.co/downloads/past-releases

选择一个版本，下载

博主这里测试使用的是 2.4.4

下载方式可以选择 ZIP 包



启动的话，windows 和 mac 有些细微区别

windows ：进入文件目录下的 bin，然后点击 elasticsearch.bat 即可

mac：在终端执行命令 bin/elasticsearch




二、配置 Maven

  1. <!-- Spring Boot Elasticsearch 依赖 -->
  2. <dependency>
  3.    <groupId>org.springframework.boot</groupId>
  4.    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  5. </dependency>

  1. <properties>
  2.    <elasticsearch.version>2.4.4</elasticsearch.version>
  3. </properties>





添加 spring-boot-starter-data-elasticsearch 依赖，并设置 elasticsearch 版本为 2.4.4



ES 和 SpirngBoot 版本参考：

https://github.com/spring-projects/spring-data-elasticsearch/wiki/Spring-Data-Elasticsearch---Spring-Boot---version-matrix


三、修改 application.properties

  1. #Project
  2. server.port=8080
  3. debug=true
  4. server.context-path=/chuyun
  7. # DataSource
  8. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
  9. spring.datasource.username=root
  10. spring.datasource.password=123456
  11. spring.datasource.url=jdbc:mysql://localhost:3306/chuyun?characterEncodeing=utf-8&useSSL=false
  13. # JPA
  14. spring.jpa.show-sql=true
  15. spring.jpa.hibernate.ddl-auto=update
  17. #Thymeleaf
  18. spring.thymeleaf.encoding=UTF-8
  19. spring.thymeleaf.cache=false
  20. spring.thymeleaf.cache-period=0
  21. spring.template.cache=false
  22. spring.thymeleaf.mode=HTML5
  23. spring.thymeleaf.prefix=classpath:templates/
  24. spring.thymeleaf.suffix=.html
  27. #Elasticsearch
  28. spring.data.elasticsearch.cluster-nodes=localhost:9300
  29. spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s

主要是添加最后面两条


四、创建 ES Bean 和 Repository


Article.java
  1. package com.liuyanzhao.chuyun.domain.es;
  3. import org.springframework.data.elasticsearch.annotations.Document;
  5. import javax.persistence.Id;
  6. import java.util.Date;
  8. /**
  9.  * @author 言曌
  10.  * @date 2018/1/22 下午4:45
  11.  */
  13. @Document(indexName="chuyun",type="article",indexStoreType="fs",shards=5,replicas=1,refreshInterval="-1")
  14. public class Article {
  16.     //文章ID，这里必须为 id
  17.     @Id
  18.     private Long id;
  20.     //标题
  21.     private String title;
  23.     //内容
  24.     private String content;
  26.     //浏览量
  27.     private Integer viewCount;
  29.     //发布时间
  30.     private Date createTime;
  32.     //更新时间
  33.     private Date updateTime;
  36.     public Article() {
  38.     }
  40.     public Long getId() {
  41.         return id;
  42.     }
  44.     public void setId(Long id) {
  45.         this.id = id;
  46.     }
  48.     public String getTitle() {
  49.         return title;
  50.     }
  52.     public void setTitle(String title) {
  53.         this.title = title;
  54.     }
  56.     public String getContent() {
  57.         return content;
  58.     }
  60.     public void setContent(String content) {
  61.         this.content = content;
  62.     }
  64.     public Integer getViewCount() {
  65.         return viewCount;
  66.     }
  68.     public void setViewCount(Integer viewCount) {
  69.         this.viewCount = viewCount;
  70.     }
  72.     public Date getCreateTime() {
  73.         return createTime;
  74.     }
  76.     public void setCreateTime(Date createTime) {
  77.         this.createTime = createTime;
  78.     }
  80.     public Date getUpdateTime() {
  81.         return updateTime;
  82.     }
  84.     public void setUpdateTime(Date updateTime) {
  85.         this.updateTime = updateTime;
  86.     }
  89.     @Override
  90.     public String toString() {
  91.         return "Article{" +
  92.                 "id=" + id +
  93.                 ", title='" + title + '\'' +
  94.                 ", content='" + content + '\'' +
  95.                 ", viewCount=" + viewCount +
  96.                 ", createTime=" + createTime +
  97.                 ", updateTime=" + updateTime +
  98.                 '}';
  99.     }
  100. }



ArticleRepository.java
  1. package com.liuyanzhao.chuyun.repository.es;
  3. import com.liuyanzhao.chuyun.domain.es.Article;
  4. import org.springframework.data.domain.Page;
  5. import org.springframework.data.domain.Pageable;
  6. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
  8. /**
  9.  * @author 言曌
  10.  * @date 2018/1/22 下午5:05
  11.  */
  13. public interface ArticleRepository extends ElasticsearchRepository<Article, Long> {
  15.     Page<Article> findDistinctByTitleContainingOrContentContaining(String title, String content, Pageable pageable);
  16. }




五、创建测试类


ArticleRepositoryTest.java
  1. package com.liuyanzhao.chuyun.repository.es;
  3. import com.liuyanzhao.chuyun.domain.es.Article;
  4. import com.liuyanzhao.chuyun.entity.User;
  5. import org.junit.Before;
  6. import org.junit.Test;
  7. import org.junit.runner.RunWith;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import org.springframework.data.domain.Page;
  11. import org.springframework.data.domain.PageRequest;
  12. import org.springframework.data.domain.Pageable;
  13. import org.springframework.test.context.junit4.SpringRunner;
  15. import java.util.Date;
  17. /**
  18.  * @author 言曌
  19.  * @date 2018/1/21 下午5:03
  20.  */
  23. @RunWith(SpringRunner.class)
  24. @SpringBootTest
  25. public class ArticleRepositoryTest {
  27.     @Autowired
  28.     private ArticleRepository articleRepository;
  30.     @Before
  31.     public void initRepositoryData() {
  32.         //清除所有数据
  33.         articleRepository.deleteAll();
  34.         Article article = new Article();
  35.         article.setId((long) 1);
  36.         article.setTitle("《蝶恋花》");
  37.         article.setContent("槛菊愁烟兰泣露，罗幕轻寒，燕子双飞去。明月不谙离恨苦，斜光到晓穿朱户。昨夜西风凋碧树，独上高楼，望尽天涯路。欲寄彩笺兼尺素，山长水阔知何处？");
  38.         article.setCreateTime(new Date());
  39.         article.setUpdateTime(new Date());
  40.         article.setViewCount(678);
  41.         articleRepository.save(article);
  43.         Article article2 = new Article();
  44.         article2.setId((long) 2);
  45.         article2.setTitle("《蝶恋花》");
  46.         article2.setContent("伫倚危楼风细细，望极春愁，黯黯生天际。草色烟光残照里，无言谁会凭阑意。拟把疏狂图一醉，对酒当歌，强乐还无味。衣带渐宽终不悔，为伊消得人憔悴。");
  47.         article2.setCreateTime(new Date());
  48.         article2.setUpdateTime(new Date());
  49.         article.setViewCount(367);
  50.         articleRepository.save(article2);
  52.         Article article3 = new Article();
  53.         article3.setId((long) 3);
  54.         article3.setTitle("《青玉案·元夕》");
  55.         article3.setContent("东风夜放花千树，更吹落，星如雨。宝马雕车香满路。凤箫声动，玉壶光转，一夜鱼龙舞。蛾儿雪柳黄金缕，笑语盈盈暗香去。众里寻他千百度，蓦然回首，那人却在，灯火阑珊处。");
  56.         article3.setCreateTime(new Date());
  57.         article3.setUpdateTime(new Date());
  58.         article3.setViewCount(786);
  59.         articleRepository.save(article3);
  60.     }
  62.     @Test
  63.     public void findDistinctByTitleContainingOrContentContainingTest() throws Exception {
  64.         Pageable pageable = new PageRequest(0,20);
  65.         String title = "我爱罗琪";
  66.         String content = "花千树";
  67.         Page<Article> page = articleRepository.findDistinctByTitleContainingOrContentContaining(title, content, pageable);
  68.         System.out.println(page);
  69.         System.out.println("---start---");
  70.         for(Article article : page.getContent()) {
  71.             System.out.println(article.toString());
  72.         }
  73.         System.out.println("---end---");
  75.     }
  77. }



运行 @Test 注解的方法

根据 title 和 content 内容查到一条数据





修改 title 和 content 
String title = "蝶恋";

String content = "东风";

查到三条数据




六、访问 http://localhost:9200/_plugin/head/


因为上一篇文章中，我们讲了装一个 head 插件，现在我们就能看到里面的数据了（多余的数据是之前测试的）



七、新建 Controller 类


ArticleController.java
  1. package com.liuyanzhao.chuyun.controller;
  3. import com.liuyanzhao.chuyun.domain.es.Article;
  4. import com.liuyanzhao.chuyun.repository.es.ArticleRepository;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.data.domain.Page;
  7. import org.springframework.data.domain.PageRequest;
  8. import org.springframework.data.domain.Pageable;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RequestParam;
  11. import org.springframework.web.bind.annotation.RestController;
  13. import java.util.List;
  15. /**
  16.  * @author 言曌
  17.  * @date 2018/1/22 下午9:07
  18.  */
  21. @RestController
  22. @RequestMapping("/article")
  23. public class ArticleController {
  25.     @Autowired
  26.     private ArticleRepository articleRepository;
  28.     @RequestMapping("")
  29.     public List<Article> list(@RequestParam(value = "title", required = false) String title,
  30.                                 @RequestParam(value = "content", required = false) String content,
  31.                                 @RequestParam(value = "pageIndex", defaultValue = "0") int pageIndex,
  32.                                 @RequestParam(value = "pageSize", defaultValue = "10") int pageSize) {
  33.         Pageable pageable = new PageRequest(pageIndex, pageSize);
  34.         Page<Article> page = articleRepository.findDistinctByTitleContainingOrContentContaining(title, content, pageable);
  35.         return page.getContent();
  36.     }
  37. }



因为之前在 测试类 里已经给 elasticsearch 添加了数据

所有现在可以在浏览器上访问：

http://localhost:8080/chuyun/article?title=浪淘沙&content=伊人









本文地址：https://liuyanzhao.com/7170.html





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

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

发表评论

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

  

已通过评论：4   待审核评论数：0
  1. avatar soul
    回复 2018年08月07日 11:04:29

    的撒旦

  2. avatar 永远的小信长
    回复 2018年07月31日 15:03:48

    it's ok 可以

  3. avatar sk2
    回复 2018年01月29日 13:29:11

    :cool: 厉害

  4. avatar 哦引力
    回复 2018年01月24日 16:56:26

    发现现在找个破解版的软解越来越难了