具有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 {@Idprivate 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;}@Overridepublic 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;}@Overridepublic 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 {@Autowiredprivate 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 {@Autowiredprivate MovieService movieService;private static final Logger logger = LoggerFactory.getLogger(BootElastic.class);// add star wars and
// princess bride as a movie
// to elastic searchprivate 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 nameList < 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 nameList < 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 9List < 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"}]}}]}
}