在本文中，我將為您提供有關如何在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"}]}}]} }

• 您可以在github中查看整個項目。

翻譯自: https://www.javacodegeeks.com/2015/03/head-first-elastic-search-on-java-with-spring-boot-and-data-features.html

總結

以上是生活随笔為你收集整理的具有Spring Boot和数据功能的Java头优先弹性搜索的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。