重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
今天就跟大家聊聊有关springboot中怎么集成elasticsearch,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创新互联技术团队十多年来致力于为客户提供成都网站建设、网站设计、成都品牌网站建设、网络营销推广、搜索引擎SEO优化等服务。经过多年发展,公司拥有经验丰富的技术团队,先后服务、推广了上千家网站,包括各类中小企业、企事单位、高校等机构单位。
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,编写访问接口(如果需要自动创建索引,该接口必须写,否则项目启动时不会自动检测并创建索引)
其中repository具体方法命名规则参考官网:https://docs.spring.io/spring-data/elasticsearch/docs/4.1.7/reference/html/#elasticsearch.query-methods
@Repository public interface IndexRepository extends ElasticsearchRepository{ Page 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() { PagepageList = 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 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有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。