springboot中如何集成elasticsearch

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

1，引入依赖

                                       org.springframework.boot                        spring-boot-starter-data-elasticsearch                

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 {        Page findByContent(String content, Pageable page);}

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

@SpringBootTestpublic class EsTest {        @Autowired        ElasticsearchRestTemplate esTemplate;        @Autowired        IndexRepository indexRepository;                @BeforeEach        public 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脉冲星搜索")                ));        }                @Test        void testRepositoryQuery() {                Page pageList = indexRepository.findByContent("中国", PageRequest.of(0, 10));                pageList.getContent().forEach(e -> {                        System.out.println("repositoryQuery => "+e);                });        }                @Test        void testTemplateQuery() {                BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery()                                .must(QueryBuilders.simpleQueryStringQuery("中国").field("content"));                NativeSearchQuery query = new NativeSearchQueryBuilder()                                .withQuery(queryBuilder)                                .withPageable(PageRequest.of(0, 10))                                .build();                SearchHits 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"的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注行业资讯频道，小编每天都会为大家更新不同的知识点。