今天就跟大家聊聊有关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具体方法命名规则参考官网：https://docs.spring.io/spring-data/elasticsearch/docs/4.1.7/reference/html/#elasticsearch.query-methods
@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有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注亿速云行业资讯频道，感谢大家的支持。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/233090/blog/5013520
