佛山移动网站建设公司,专业公司网站建设,贵阳小程序开发定制,房地产销售流程详细下面是一个使用Spring Boot 2.5连接Elasticsearch 7的示例程序#xff0c;包括基本的功能#xff0c;使用模板方法#xff1a;
首先#xff0c;确保你的项目中添加了以下依赖#xff1a; dependency groupIdorg.springframework.boot/groupId 包括基本的功能使用模板方法
首先确保你的项目中添加了以下依赖 dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-data-elasticsearch/artifactId /dependency
然后创建一个Elasticsearch配置类配置Elasticsearch连接信息 Configuration public class ElasticsearchConfig { Value(${elasticsearch.host}) private String host; Value(${elasticsearch.port}) private int port; Bean public RestHighLevelClient elasticsearchClient() { RestClientBuilder builder RestClient.builder(new HttpHost(host, port, http)); RestHighLevelClient client new RestHighLevelClient(builder); return client; } Bean public ElasticsearchOperations elasticsearchTemplate() { return new ElasticsearchRestTemplate(elasticsearchClient()); } }
接下来创建一个数据实体类用于映射Elasticsearch中的文档 Document(indexName my_index, type my_type) public class MyEntity { Id private String id; private String name; // getters and setters }
然后创建一个数据访问接口继承自ElasticsearchRepository用于操作Elasticsearch中的文档 public interface MyEntityRepository extends ElasticsearchRepositoryMyEntity, String { ListMyEntity findByName(String name); }
最后创建一个Spring Boot应用程序类编写一些简单的示例代码 SpringBootApplication public class DemoApplication implements CommandLineRunner { Autowired private MyEntityRepository myEntityRepository; public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } Override public void run(String... args) throws Exception { // 创建一个文档 MyEntity entity new MyEntity(); entity.setId(1); entity.setName(John); myEntityRepository.save(entity); // 根据名称查询文档 ListMyEntity entities myEntityRepository.findByName(John); for (MyEntity e : entities) { System.out.println(e.getId() : e.getName()); } } }
在application.properties文件中配置Elasticsearch连接信息 elasticsearch.hostlocalhost elasticsearch.port9200
这样就完成了一个使用Spring Boot连接Elasticsearch的简单示例程序。你可以根据自己的需求进一步扩展和定制。
