這篇文章主要介紹“springboot中如何集成elasticsearch”的相關(guān)知識(shí)，小編通過(guò)實(shí)際案例向大家展示操作過(guò)程，操作方法簡(jiǎn)單快捷，實(shí)用性強(qiáng)，希望這篇“springboot中如何集成elasticsearch”文章能幫助大家解決問(wèn)題。

成都創(chuàng)新互聯(lián)公司主要從事網(wǎng)站制作、成都網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)合江,十年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專(zhuān)業(yè),歡迎來(lái)電咨詢(xún)建站服務(wù):18982081108

1，引入依賴(lài)

			org.springframework.boot
			spring-boot-starter-data-elasticsearch
		

2，編寫(xiě)實(shí)體映射類(lèi)

@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，編寫(xiě)訪問(wèn)接口（如果需要自動(dòng)創(chuàng)建索引，該接口必須寫(xiě)，否則項(xiàng)目啟動(dòng)時(shí)不會(huì)自動(dòng)檢測(cè)并創(chuàng)建索引）

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

4，測(cè)試，用了template，和repository兩種方式測(cè)試

@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","美國(guó)留給伊拉克的是個(gè)爛攤子嗎"),
		new Index("2","公安部：各地校車(chē)將享高路權(quán)"),
		new Index("3","中韓漁警沖突調(diào)查：韓警平均每天扣1艘中國(guó)漁船"),
		new Index("4","中國(guó)駐洛杉磯領(lǐng)事館遭亞裔男子槍擊 嫌犯已自首"),
		new Index("5","中國(guó)天眼向全球正式開(kāi)放下月世界大賽將比拼FAST脈沖星搜索")
		));
	}
	
	@Test
	void testRepositoryQuery() {
		Page pageList = indexRepository.findByContent("中國(guó)", PageRequest.of(0, 10));
		pageList.getContent().forEach(e -> {
			System.out.println("repositoryQuery => "+e);
		});
	}
	
	@Test
	void testTemplateQuery() {
		BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery()
				.must(QueryBuilders.simpleQueryStringQuery("中國(guó)").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=中韓漁警沖突調(diào)查：韓警平均每天扣1艘中國(guó)漁船)
templateQuery => Index(id=4, content=中國(guó)駐洛杉磯領(lǐng)事館遭亞裔男子槍擊 嫌犯已自首)
templateQuery => Index(id=5, content=中國(guó)天眼向全球正式開(kāi)放下月世界大賽將比拼FAST脈沖星搜索)
init data
repositoryQuery => Index(id=3, content=中韓漁警沖突調(diào)查：韓警平均每天扣1艘中國(guó)漁船)
repositoryQuery => Index(id=4, content=中國(guó)駐洛杉磯領(lǐng)事館遭亞裔男子槍擊 嫌犯已自首)
repositoryQuery => Index(id=5, content=中國(guó)天眼向全球正式開(kāi)放下月世界大賽將比拼FAST脈沖星搜索)

5，可啟動(dòng)一個(gè)定時(shí)任務(wù)，定時(shí)ping，防止Connection time out

    @Scheduled(fixedRate = 15000)
	public void ping() {
		esTemplate.execute(client -> client.ping(RequestOptions.DEFAULT));
	}

關(guān)于“springboot中如何集成elasticsearch”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，小編每天都會(huì)為大家更新不同的知識(shí)點(diǎn)。

當(dāng)前題目：springboot中如何集成elasticsearch-創(chuàng)新互聯(lián)
URL標(biāo)題：http://weahome.cn/article/dhhpgi.html