springboot中如何集成elasticsearch

这篇文章主要介绍“SpringBoot中如何集成elasticsearch”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“springboot中如何集成elasticsearch”文章能帮助大家解决问题。

1，引入依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId></dependency>

2，编写实体映射类

@Data@Document(indexName = "index", createIndex = true)public class Index {@Id    private String id;    @Field(type = FieldType.Text, analyzer = "ik_max_Word", searchAnalyzer = "ik_smart")private String content;}

3，编写访问接口（如果需要自动创建索引，该接口必须写，否则项目启动时不会自动检测并创建索引）

@Repositorypublic interface IndexRepository extends ElasticsearchRepository<Index, String> {Page<Index> findByContent(String content, Pageable page);}

4，测试，用了template，和repository两种方式测试

@SpringBootTestpublic class EsTest {@AutowiredElasticsearchRestTemplate esTemplate;@AutowiredIndexRepository indexRepository;@BeforeEachpublic void init() {System.out.println("init");indexRepository.deleteAll();indexRepository.saveAll(ListUtil.of(new Index("1","美国留给伊拉克的是个烂摊子吗"),new Index("2","公安部：各地校车将享最高路权"),new Index("3","中韩渔警冲突调查：韩警平均每天扣1艘中国渔船"),new Index("4","中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首"),new Index("5","中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索")));}@Testvoid testRepositoryQuery() {Page<Index> pageList = indexRepository.findByContent("中国", PageRequest.of(0, 10));pageList.getContent().forEach(e -> {System.out.println("repositoryQuery => "+e);});}@Testvoid testTemplateQuery() {BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery().must(QueryBuilders.simpleQueryStringQuery("中国").field("content"));NativeSearchQuery query = new NativeSearchQueryBuilder().withQuery(queryBuilder).withPageable(PageRequest.of(0, 10)).build();SearchHits<Index> search = esTemplate.search(query, Index.class);if(search.hasSearchHits()) {search.getSearchHits().forEach(e -> {System.out.println("templateQuery => "+e.getContent());});}}}

init datatemplateQuery => Index(id=3, content=中韩渔警冲突调查：韩警平均每天扣1艘中国渔船)templateQuery => Index(id=4, content=中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首)templateQuery => Index(id=5, content=中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索)init datarepositoryQuery => Index(id=3, content=中韩渔警冲突调查：韩警平均每天扣1艘中国渔船)repositoryQuery => Index(id=4, content=中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首)repositoryQuery => Index(id=5, content=中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索)

5，可启动一个定时任务，定时ping，防止Connection time out

    @Scheduled(fixedRate = 15000)public void ping() {esTemplate.execute(client -> client.ping(RequestOptions.DEFAULT));}

关于“springboot中如何集成elasticsearch”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注编程网精选频道，小编每天都会为大家更新不同的知识点。