Spring 4+ElasticSearch如何集成

小編給大家分享一下Spring 4+ElasticSearch如何集成，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

一: ElasticSearch 基本概念

INDEX：這是ES存儲數據的地方，類似于關系數據庫的DATABASE。


Document TYPE：嗯，類似關系數據庫的表，主要功能是將完全不同SCHEMA（這個概念以后會講到，不急）的數據分開，一個INDEX里面可以有若干個Document TYPE。


Document：好吧，這個類似關系數據庫的一行，在同一個Document TYPE下面，每一Document都有一個唯一的ID作為區分；


Filed：類似關系數據庫的某一列，這是ES數據存儲的最小單位。


Cluster和Node：ES可以以單點或者集群方式運行，以一個整體對外提供search服務的所有節點組成cluster，組成這個cluster的各個節點叫做node。


shard：通常叫分片，這是ES提供分布式搜索的基礎，其含義為將一個完整的INDEX分成若干部分存儲在相同或不同的節點上，這些組成INDEX的部分就叫做shard。


Replica：和REPLICATION通常指的都是一回事，即INDEX的冗余備份，可以用于防止數據丟失，或者用來做負載分擔。


二： ElasticSearch TransportClient和NodeClient

如果你使用Java，ElasticSearch 提供Transport CLIENT和Node CLIENT兩種連接方式。transport CLIENT充當ES集群和你的應用直接的通信層，它知道API，并且能夠在節點間自動輪循。


Node CLIENT，事實上是集群中的一個節點（但是不存儲數據，并且不能作為主節點），由于它是一個節點，它知道整個集群的狀態（全部節點都在哪，哪些分片在哪些節點上等等），這意味著它執行API時可以少用一個網絡跳躍。


但需要完整的Node節點參數配置。


兩種CLIENT的使用場景：


1.如果你想讓你的應用和集群解耦，transport CLIENT是一個理想的選擇。例如，如果你的集群快速創建和銷毀連接，那么transport CLIENT比node CLIENT輕很多，因為它不是集群的一部分。


同樣，如果你需要創建上千個連接，但是你不希望有上千個node CLIENT加入你的集群，transport CLIENT將是一個更好的選擇。


2.在另一方面，如果你只需要幾個長連接的，能持久的連接到集群，node CLIENT會更高效一點，因為它知道集群的結構，但是要注意防火墻影響相關通信的問題。


三：與Spring 集成

1. @Configuration
   

2. @PropertySource("classpath:context-datasource.properties")
   

3. public class ElasticSearchElConfig {
   

4.     @Value("${el.cluster.name}")
   

5.     private String elClusterName;
   

6.     @Value("${el.cluster.node1.url}")
   

7.     private String elClusterNode1Url;
   

8.     @Value("${el.cluster.node1.port}")
   

9.     private Integer elClusterNode2Port;
   

10. 
    

11.     @Bean(name = "elasticSearchClient")
    

12.     public Client elasticSearchClient() {
    

13.         Map<String, Object> settimgMap = new HashMap<String, Object>();
    

14.         settimgMap.put("cluster.name", elClusterName);
    

15. 
    

16.         Settings settings = Settings.settingsBuilder().put(settimgMap).build();
    

17. 
    

18.         TransportClient client = TransportClient.builder().settings(settings).build()
    

19.                 .addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress(elClusterNode1Url, elClusterNode2Port)));
    

20.         return client;
    

21. 
    

22.     }
    

23. 
    

24.     @Bean(name = "elasticTemplate")
    

25.     public ElasticsearchTemplate elasticTemplate(Client elasticSearchClient) {
    

26.         return new ElasticsearchTemplate(elasticSearchClient);
    

27.     }
    

28. 
    

29.     @Autowired
    

30.     private Environment environment;
    

31. 
    

32.     @Bean
    

33.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {
    

34.         return new PropertySourcesPlaceholderConfigurer();
    

35.     }
    

36. }

四：Demo

文檔類

點擊(此處)折疊或打開

1. @Document(indexName="gmap_system_log_index",type="gmap_system_log")
   

2. public class Logs extends ValueObject{
   

3. 
   

4.     /**
   

5.      *
   

6.      */
   

7.     private static final long serialVersionUID = 1L;
   

8.     
   

9.     @Field(type=FieldType.Integer,index=FieldIndex.not_analyzed,store=true)
   

10.     private Integer userId;
    

11.     @Field(type=FieldType.String,index=FieldIndex.not_analyzed,store=true)
    

12.     private String system;
    

13.     @Field(type=FieldType.String,index=FieldIndex.not_analyzed,store=true)
    

14.     private String url;
    

15.     @Field(type=FieldType.String,index=FieldIndex.analyzed,store=true)
    

16.     private String content;
    

17.     /**
    

18.      * @return the userId
    

19.      */
    

20.     public Integer getUserId() {
    

21.         return userId;
    

22.     }
    

23.     /**
    

24.      * @param userId the userId to set
    

25.      */
    

26.     public void setUserId(Integer userId) {
    

27.         this.userId = userId;
    

28.     }
    

29.     /**
    

30.      * @return the system
    

31.      */
    

32.     public String getSystem() {
    

33.         return system;
    

34.     }
    

35.     /**
    

36.      * @param system the system to set
    

37.      */
    

38.     public void setSystem(String system) {
    

39.         this.system = system;
    

40.     }
    

41.     /**
    

42.      * @return the url
    

43.      */
    

44.     public String getUrl() {
    

45.         return url;
    

46.     }
    

47.     /**
    

48.      * @param url the url to set
    

49.      */
    

50.     public void setUrl(String url) {
    

51.         this.url = url;
    

52.     }
    

53.     /**
    

54.      * @return the content
    

55.      */
    

56.     public String getContent() {
    

57.         return content;
    

58.     }
    

59.     /**
    

60.      * @param content the content to set
    

61.      */
    

62.     public void setContent(String content) {
    

63.         this.content = content;
    

64.     }
    

65.     
    

66.     
    

67. }

服務類

點擊(此處)折疊或打開

1. import java.util.ArrayList;
   

2. import java.util.List;
   

3. 
   

4. import org.springframework.beans.factory.annotation.Autowired;
   

5. import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
   

6. import org.springframework.data.elasticsearch.core.query.IndexQuery;
   

7. import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;
   

8. import org.springframework.stereotype.Component;
   

9. 
   

10. /**
    

11.  * TODO:
    

12.  *
    

13.  * @author gengchong
    

14.  * @date 2017年4月28日 下午4:24:01
    

15.  */
    

16. @Component("elasticSearchDemo")
    

17. public class ElasticSearchDemo {
    

18. 
    

19.     @Autowired
    

20.     private ElasticsearchTemplate elasticTemplate;
    

21. 
    

22.     /**
    

23.      * 創建索引
    

24.      */
    

25.     public void createGmapLogsIndex() {
    

26.         System.out.println(elasticTemplate.createIndex(Logs.class));
    

27.     }
    

28. 
    

29.     /**
    

30.      * 批量添加文檔
    

31.      *
    

32.      * @param logs
    

33.      */
    

34.     public void createGmapLogs(List<Logs> logs) {
    

35.         List<IndexQuery> queries = new ArrayList<>();
    

36.         for (Logs log : logs) {
    

37.             IndexQuery indexQuery = new IndexQueryBuilder().withObject(log).build();
    

38.             queries.add(indexQuery);
    

39.         }
    

40. 
    

41.         elasticTemplate.bulkIndex(queries);
    

42.     }
    

43. 
    

44.     /**
    

45.      * 添加文檔
    

46.      *
    

47.      * @param log
    

48.      */
    

49.     public void createGmapLog(Logs log) {
    

50.         List<Logs> logs = new ArrayList<>();
    

51.         logs.add(log);
    

52.         createGmapLogs(logs);
    

53.     }
    

54. 
    

55. }

以上是“Spring 4+ElasticSearch如何集成”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！