具有Spring Boot和数据功能的Java头优先弹性搜索
在本文中，我将为您提供有关如何在Java项目中使用Elastic Search的简单介绍。 由于Spring Boot是开始我们项目的最简单，最快的方法，因此我选择使用它。 此外，我们将大量使用心爱的Spring Data的Repository Goods。
首先，在我们的机器上安装Elastic Search并首次运行我们的Elastic Server。
我转到elastic-folder \ bin并运行elasticsearch.bat（是的，我正在使用Windows），但是没有运气。 我得到这个：
“ VM初始化期间发生错误
无法为对象堆保留足够的空间
错误：无法创建Java虚拟机。
错误：发生致命异常。 程序将会退出。”
多么美好的开始！
在我的bin文件夹中，有一个“ elasticsearch.in.bat”文件。 我将ES_MAX_MEM = 1g设置为ES_MAX_MEM = 512mb ，瞧，它是固定的。
之后，我可以毫无问题地启动新服务器。
现在该定义我们将在弹性搜索中建立索引的文档了。 假设我们有要索引的电影信息。 我们的模型非常简单。 电影中有名称，等级和流派。 如果我们考虑关系数据库的术语，我选择“ elastic_sample”作为索引名称，这听起来像数据库名称，而选择“ movie”作为类型，对于表名称则是良好的。 如您所见，模型中没有任何花哨的东西。
@Document(indexName = "elastic_sample", type = "movie")
public class Movie {
@Id
private String id;
private String name;
@Field(type = FieldType.Nested)
private List < Genre > genre;
private Double rating;
public Double getRating() {
return rating;
}
public void setRating(Double rating) {
this.rating = rating;
}
public void setId(String id) {
this.id = id;
}
public List < Genre > getGenre() {
return genre;
}
public void setGenre(List < Genre > genre) {
this.genre = genre;
}
public String getId() {
return id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Movie{" +
"id=" + id +
", name='" + name + '\'' +
", genre=" + genre +
", rating=" + rating +
'}';
}
}
对于那些想知道流派是什么的人。 只是一个POJO。
public class Genre {
private String name;
public Genre() {
}
public Genre(String name) {
this.name = name;
}
public String getName() {
return name;
}
@Override
public String toString() {
return "Genre{" +
"name='" + name + '\'' +
'}';
}
public void setName(String name) {
this.name = name;
}
}
不是时候创建DAO层了，所以我们可以将我们的文档保存到弹性搜索服务器并从中加载文件。 我们的存储库扩展了经典的ElasticserchRepository（不知道为什么它是搜索而不是Search）。 您可能知道，Spring Data可以使用我们使用字段名称的这些预定义方法查询一个或多个字段。 findByName将在名称字段中搜索，findByRating将在评级字段中搜索，依此类推。 此外，由于使用了Spring Data，我们不需要为其编写实现，我们只需在接口中放入方法名称即可。
public interface MovieRepository extends ElasticsearchRepository < Movie, Long > {
public List < Movie > findByName(String name);
public List < Movie> findByRatingBetween(Double beginning, Double end);
}
我们的DAO层将由Service层调用：
@Service
public class MovieService {
@Autowired
private MovieRepository repository;
public List < Movie > getByName(String name) {
return repository.findByName(name);
}
public List < Movie > getByRatingInterval(Double beginning, Double end) {
return repository.findByRatingBetween(beginning, end);
}
public void addMovie(Movie movie) {
repository.save(movie);
}
}
这是我们将用于运行应用程序的主要类。 EnableAutoConfiguration将自动配置在类路径下可以识别的所有内容。 ComponentScan将在主类的目录下扫描Spring注释。
@Configuration
@EnableAutoConfiguration
@ComponentScan
public class BootElastic implements CommandLineRunner {
@Autowired
private MovieService movieService;
private static final Logger logger = LoggerFactory.getLogger(BootElastic.class);
// add star wars and
// princess bride as a movie
// to elastic search
private void addSomeMovies() {
Movie starWars = getFirstMovie();
movieService.addMovie(starWars);
Movie princessBride = getSecondMovie();
movieService.addMovie(princessBride);
}
private Movie getSecondMovie() {
Movie secondMovie = new Movie();
secondMovie.setId("2");
secondMovie.setRating(8.4d);
secondMovie.setName("The Princess Bride");
List < Genre > princessPrideGenre = new ArrayList < Genre >();
princessPrideGenre.add(new Genre("ACTION"));
princessPrideGenre.add(new Genre("ROMANCE"));
secondMovie.setGenre(princessPrideGenre);
return secondMovie;
}
private Movie getFirstMovie() {
Movie firstMovie = new Movie();
firstMovie.setId("1");
firstMovie.setRating(9.6d);
firstMovie.setName("Star Wars");
List < Genre > starWarsGenre = new ArrayList < Genre >();
starWarsGenre.add(new Genre("ACTION"));
starWarsGenre.add(new Genre("SCI_FI"));
firstMovie.setGenre(starWarsGenre);
return firstMovie;
}
public void run(String... args) throws Exception {
addSomeMovies();
// We indexed star wars and pricess bride to our movie
// listing in elastic search
//Lets query if we have a movie with Star Wars as name
List < Movie > starWarsNameQuery = movieService.getByName("Star Wars");
logger.info("Content of star wars name query is {}", starWarsNameQuery);
//Lets query if we have a movie with The Princess Bride as name
List < Movie > brideQuery = movieService.getByName("The Princess Bride");
logger.info("Content of princess bride name query is {}", brideQuery);
//Lets query if we have a movie with rating between 6 and 9
List < Movie > byRatingInterval = movieService.getByRatingInterval(6d, 9d);
logger.info("Content of Rating Interval query is {}", byRatingInterval);
}
public static void main(String[] args) throws Exception {
SpringApplication.run(BootElastic.class, args);
}
}
如果我们运行它，结果是：
015-02-28 18:26:12.368 INFO 3616 --- [ main] main.BootElastic: Content of star wars name query is [Movie{id=1, name='Star Wars', genre=[Genre{name='ACTION'}, Genre{name='SCI_FI'}], rating=9.6}]
2015-02-28 18:26:12.373 INFO 3616 --- [ main] main.BootElastic: Content of princess bride name query is [Movie{id=2, name='The Princess Bride', genre=[Genre{name='ACTION'}, Genre{name='ROMANCE'}], rating=8.4}]
2015-02-28 18:26:12.384 INFO 3616 --- [ main] main.BootElastic: Content of Rating Interval query is [Movie{id=2, name='The Princess Bride', genre=[Genre{name='ACTION'}, Genre{name='ROMANCE'}], rating=8.4}]
如您所见，间隔查询仅检索到公主新娘。 我们没有做任何配置吗？ 这很不寻常。 我必须与您共享庞大的配置文件：
spring.data.elasticsearch.cluster-nodes=localhost:9300 # if spring data repository support is enabled spring.data.elasticsearch.repositories.enabled=true
查询弹性服务器时，通常会使用端口9200。 但是，当我们以编程方式到达它时，我们正在使用9300。如果您有多个节点，则可以用逗号分隔它们，并使用9301、9302等作为端口号。 我们的pom文件也不足为奇。 只是弹性的入门pom，我们就可以开始了。
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0" xsi:schemalocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelversion>4.0.0</modelversion>
<groupid>caught.co.nr</groupid>
<artifactid>boot-elastic-sample</artifactid>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<!-- Inherit defaults from Spring Boot -->
<parent>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-parent</artifactid>
<version>1.2.2.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-data-elasticsearch</artifactid>
</dependency>
</dependencies>
<!-- Needed for fat jar -->
<build>
<plugins>
<plugin>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-maven-plugin</artifactid>
</plugin>
</plugins>
</build>
</project>
如您所见，感谢Spring Boot和Data，使用弹性搜索非常容易。 让我们检查一下我们从服务器api索引的内容。 我将使用Sense-用于弹性命令的chrome插件-。
这是结果json：
{
"took": 2,
"timed_out": false,
"_shards": {
"total": 1,
"successful": 1,
"failed": 0
},
"hits": {
"total": 2,
"max_score": 1,
"hits": [
{
"_index": "elastic_sample",
"_type": "movie",
"_id": "1",
"_score": 1,
"_source": {
"id": 1,
"name": "Star Wars",
"genre": [
{
"name": "ACTION"
},
{
"name": "SCI_FI"
}
]
}
},
{
"_index": "elastic_sample",
"_type": "movie",
"_id": "2",
"_score": 1,
"_source": {
"id": 2,
"name": "The Princess Bride",
"genre": [
{
"name": "ACTION"
},
{
"name": "ROMANCE"
}
]
}
}
]
}
}
- 您可以在github中查看整个项目。