大橙子网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

springboot中如何集成elasticsearch-创新互联

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

成都创新互联公司主要从事网站制作、成都网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务合江,十年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:18982081108

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
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() {
		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 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”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注创新互联行业资讯频道,小编每天都会为大家更新不同的知识点。


分享标题:springboot中如何集成elasticsearch-创新互联
转载注明:http://dzwzjz.com/article/dhhpgi.html
在线咨询
服务热线
服务热线:028-86922220
TOP