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 settimgMap = new HashMap();
    

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) {
    

35. List 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 = new ArrayList<>();
    

51. logs.add(log);
    

52. createGmapLogs(logs);
    

53. }
    

54. 
    

55. }

以上是"Spring 4+ElasticSearch如何集成"这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注行业资讯频道！