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，编写访问接口（如果需要自动创建索引，该接口必须写，否则项目启动时不会自动检测并创建索引）

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

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

@SpringBootTest public 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<Index> 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<Index> search = esTemplate.search(query, Index.class);	if(search.hasSearchHits()) {	search.getSearchHits().forEach(e -> {	System.out.println("templateQuery => "+e.getContent());	});	}	} }

init data templateQuery => Index(id=3, content=中韩渔警冲突调查：韩警平均每天扣1艘中国渔船) templateQuery => Index(id=4, content=中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首) templateQuery => Index(id=5, content=中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索) init data repositoryQuery => 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”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注亿速云行业资讯频道，小编每天都会为大家更新不同的知识点。