Rumah > Java > javaTutorial > Bagaimana untuk mengintegrasikan elasticsearch dalam springboot

Bagaimana untuk mengintegrasikan elasticsearch dalam springboot

WBOY
Lepaskan: 2023-06-01 08:22:36
ke hadapan
1246 orang telah melayarinya

1. Memperkenalkan pergantungan

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
		</dependency>
Salin selepas log masuk

2 Tulis kelas pemetaan entiti

@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;
}
Salin selepas log masuk

3. Antara muka akses tulis (jika anda perlu membuat indeks secara automatik, antara muka ini mesti ditulis, jika tidak tidak akan berfungsi apabila projek dimulakan Secara automatik mengesan dan mencipta indeks)

@Repository
public interface IndexRepository extends ElasticsearchRepository<Index, String> {
	Page<Index> findByContent(String content, Pageable page);
}
Salin selepas log masuk

4 Uji, gunakan templat dan repositori untuk menguji

@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());
			});
		}
	}
}
Salin selepas log masuk
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脉冲星搜索)
Salin selepas log masuk

5 Anda boleh memulakan tugasan yang dijadualkan dan ping dengan kerap menghalang tamat masa Sambungan

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

Atas ialah kandungan terperinci Bagaimana untuk mengintegrasikan elasticsearch dalam springboot. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:yisu.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan