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, String> { Page<Index> findByContent(String content, Pageable page); }
4、テスト、テンプレート、およびテスト用のリポジトリを使用します
@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()); }); } } }
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 を実行できます。接続タイムアウトを防ぐ
@Scheduled(fixedRate = 15000) public void ping() { esTemplate.execute(client -> client.ping(RequestOptions.DEFAULT)); }
以上がelasticsearch を springboot に統合する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。