以下是一个简化的Spring Boot整合Elasticsearch的例子。
- 添加依赖到
pom.xml：
<dependencies>
<!-- Spring Boot相关依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- 其他依赖... -->
</dependencies>
- 配置
application.properties：
spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=localhost:9300
- 创建一个实体类：
@Document(indexName = "sample_index", type = "sample_type")
public class SampleEntity {
@Id
private String id;
private String content;
// 省略getter和setter
}
- 创建一个Elasticsearch仓库接口：
public interface SampleRepository extends ElasticsearchRepository<SampleEntity, String> {
// 可以根据需要添加自定义查询方法
}
- 创建一个服务类：
@Service
public class SampleService {
@Autowired
private SampleRepository sampleRepository;
public SampleEntity save(SampleEntity entity) {
return sampleRepository.save(entity);
}
public List<SampleEntity> findAll() {
return sampleRepository.findAll();
}
// 可以添加更多的方法
}
- 创建一个控制器类：
@RestController
public class SampleController {
@Autowired
private SampleService sampleService;
@PostMapping("/sample")
public SampleEntity create(@RequestBody SampleEntity entity) {
return sampleService.save(entity);
}
@GetMapping("/sample")
public List<SampleEntity> list() {
return sampleService.findAll();
}
}
- 创建一个Spring Boot应用启动类：
@SpringBootApplication
public class ElasticsearchApplication {
public static void main(String[] args) {
SpringApplication.run(ElasticsearchApplication.class, args);
}
}
以上代码提供了一个简单的Spring Boot应用整合Elasticsearch的例子。这个例子包括了添加依赖、配置Elasticsearch、创建实体类、仓库接口、服务类和控制器类。通过这个例子，开发者可以学习如何在Spring Boot应用中使用Elasticsearch进行基本的数据操作。