具有Spring Boot和数据功能的Java头优先弹性搜索
在本文中,我將為您提供有關(guān)如何在Java項(xiàng)目中使用Elastic Search的簡(jiǎn)單介紹。 由于Spring Boot是開始我們項(xiàng)目的最簡(jiǎn)單,最快的方法,因此我選擇使用它。 此外,我們將大量使用心愛的Spring Data的Repository Goods。
首先,在我們的機(jī)器上安裝Elastic Search并首次運(yùn)行我們的Elastic Server。
我轉(zhuǎn)到elastic-folder \ bin并運(yùn)行elasticsearch.bat(是的,我正在使用Windows),但是沒有運(yùn)氣。 我得到這個(gè):
“ VM初始化期間發(fā)生錯(cuò)誤
無(wú)法為對(duì)象堆保留足夠的空間
錯(cuò)誤:無(wú)法創(chuàng)建Java虛擬機(jī)。
錯(cuò)誤:發(fā)生致命異常。 程序?qū)?huì)退出。”
多么美好的開始!
在我的bin文件夾中,有一個(gè)“ elasticsearch.in.bat”文件。 我將ES_MAX_MEM = 1g設(shè)置為ES_MAX_MEM = 512mb ,瞧,它是固定的。
之后,我可以毫無(wú)問題地啟動(dòng)新服務(wù)器。
現(xiàn)在該定義我們將在彈性搜索中建立索引的文檔了。 假設(shè)我們有要索引的電影信息。 我們的模型非常簡(jiǎn)單。 電影中有名稱,等級(jí)和流派。 如果我們考慮關(guān)系數(shù)據(jù)庫(kù)的術(shù)語(yǔ),我選擇“ elastic_sample”作為索引名稱,這聽起來(lái)像數(shù)據(jù)庫(kù)名稱,而選擇“ movie”作為類型,對(duì)于表名稱則是良好的。 如您所見,模型中沒有任何花哨的東西。
@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 +'}';} }對(duì)于那些想知道流派是什么的人。 只是一個(gè)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;} }不是時(shí)候創(chuàng)建DAO層了,所以我們可以將我們的文檔保存到彈性搜索服務(wù)器并從中加載文件。 我們的存儲(chǔ)庫(kù)擴(kuò)展了經(jīng)典的ElasticserchRepository(不知道為什么它是搜索而不是Search)。 您可能知道,Spring Data可以使用我們使用字段名稱的這些預(yù)定義方法查詢一個(gè)或多個(gè)字段。 findByName將在名稱字段中搜索,findByRating將在評(píng)級(jí)字段中搜索,依此類推。 此外,由于使用了Spring Data,我們不需要為其編寫實(shí)現(xiàn),我們只需在接口中放入方法名稱即可。
public interface MovieRepository extends ElasticsearchRepository < Movie, Long > {public List < Movie > findByName(String name);public List < Movie> findByRatingBetween(Double beginning, Double end); }我們的DAO層將由Service層調(diào)用:
@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);} }這是我們將用于運(yùn)行應(yīng)用程序的主要類。 EnableAutoConfiguration將自動(dòng)配置在類路徑下可以識(shí)別的所有內(nèi)容。 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);} }如果我們運(yùn)行它,結(jié)果是:
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查詢彈性服務(wù)器時(shí),通常會(huì)使用端口9200。 但是,當(dāng)我們以編程方式到達(dá)它時(shí),我們正在使用9300。如果您有多個(gè)節(jié)點(diǎn),則可以用逗號(hào)分隔它們,并使用9301、9302等作為端口號(hào)。 我們的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,使用彈性搜索非常容易。 讓我們檢查一下我們從服務(wù)器api索引的內(nèi)容。 我將使用Sense-用于彈性命令的chrome插件-。
這是結(jié)果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中查看整個(gè)項(xiàng)目。
翻譯自: https://www.javacodegeeks.com/2015/03/head-first-elastic-search-on-java-with-spring-boot-and-data-features.html
總結(jié)
以上是生活随笔為你收集整理的具有Spring Boot和数据功能的Java头优先弹性搜索的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 电脑怎么添加光驱(电脑增加光驱)
- 下一篇: Openshift:使用Java 8在W