登录  /  注册
首页 > Java > java教程 > 正文

springboot中如何集成elasticsearch

WBOY
发布: 2023-06-01 08:22:36
转载
1024人浏览过

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> {
	Page<index> findByContent(String content, Pageable page);
}</index></index>
登录后复制

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 -&gt; {
			System.out.println("repositoryQuery =&gt; "+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 -&gt; {
				System.out.println("templateQuery =&gt; "+e.getContent());
			});
		}
	}
}</index></index>
登录后复制
init data
templateQuery =&gt; Index(id=3, content=中韩渔警冲突调查:韩警平均每天扣1艘中国渔船)
templateQuery =&gt; Index(id=4, content=中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首)
templateQuery =&gt; Index(id=5, content=中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索)
init data
repositoryQuery =&gt; Index(id=3, content=中韩渔警冲突调查:韩警平均每天扣1艘中国渔船)
repositoryQuery =&gt; Index(id=4, content=中国驻洛杉矶领事馆遭亚裔男子枪击 嫌犯已自首)
repositoryQuery =&gt; Index(id=5, content=中国天眼向全球正式开放下月世界大赛将比拼FAST脉冲星搜索)
登录后复制

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

    @Scheduled(fixedRate = 15000)
	public void ping() {
		esTemplate.execute(client -&gt; client.ping(RequestOptions.DEFAULT));
	}
登录后复制

以上就是springboot中如何集成elasticsearch的详细内容,更多请关注php中文网其它相关文章!

智能AI问答
PHP中文网智能助手能迅速回答你的编程问题,提供实时的代码和解决方案,帮助你解决各种难题。不仅如此,它还能提供编程资源和学习指导,帮助你快速提升编程技能。无论你是初学者还是专业人士,AI智能助手都能成为你的可靠助手,助力你在编程领域取得更大的成就。
相关标签:
来源:亿速云网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号