架构实战篇（十一）：Spring Boot 集成企业级搜索引擎 SolrCloud

mulan 2018-05-04 13:30:46 ⋅ 593 阅读


SolrCloud 简介

Lucene是一个Java语言编写的利用倒排原理实现的文本检索类库；

Solr是以Lucene为基础实现的文本检索应用服务。Solr部署方式有单机方式、多机Master-Slaver方式、Cloud方式。

SolrCloud是基于Solr和Zookeeper的分布式搜索方案。当索引越来越大，一个单一的系统无法满足磁盘需求，查询速度缓慢，此时就需要分布式索引。在分布式索引中，原来的大索引，将会分成多个小索引，solr可以将这些小索引返回的结果合并，然后返回给客户端。

准备

环境安装

CentOs7.3 搭建 SolrCloud 集群服务

https://segmentfault.com/a/1190000010836061

测试用例

Github 代码

代码我已放到 Github ，导入 spring-boot-solr-cloud 项目

github https://github.com/souyunku/spring-boot-examples/tree/master/spring-boot-solr-cloud

添加依赖

 
    
  
  1. <dependency>
    2. 
  
  2.     <groupId>org.springframework.boot</groupId>
    3. 
  
  3.     <artifactId>spring-boot-starter-data-solr</artifactId>
    4. 
  
  4. </dependency>
    5. 
  
  5. <dependency>
    6. 
  
  6.     <groupId>org.springframework.data</groupId>
    7. 
  
  7.     <artifactId>spring-data-jpa</artifactId>
    8. 
  
  8. </dependency>
    9.

启用 Solr

 
    
  
  1. @Configuration
    2. 
  
  2. @EnableSolrRepositories(basePackages = {"io.ymq.solr"}, multicoreSupport = true)
    3. 
  
  3. public class SolrConfig {
    4. 
  
    5. 
  
  5.     @Value("${spring.data.solr.zk-host}")
    6. 
  
  6.     private String zkHost;
    7. 
  
    8. 
  
  8.     @Bean
    9. 
  
  9.     public CloudSolrClient solrClient() {
    10. 
  
  10.         return new CloudSolrClient(zkHost);
    11. 
  
  11.     }
    12. 
  
    13. 
  
  13. }
    14.

映射的实体类

 
    
  
  1. @SolrDocument(solrCoreName = "test_collection")
    2. 
  
  2. public class Ymq implements Serializable {
    3. 
  
    4. 
  
  4.     @Id
    5. 
  
  5.     @Field
    6. 
  
  6.     private String id;
    7. 
  
    8. 
  
  8.     @Field
    9. 
  
  9.     private String ymqTitle;
    10. 
  
    11. 
  
  11.     @Field
    12. 
  
  12.     private String ymqUrl;
    13. 
  
    14. 
  
  14.     @Field
    15. 
  
  15.     private String ymqContent;
    16. 
  
    17. 
  
    18. 
  
  18.   get 。。。
    19. 
  
    20. 
  
  20.   set 。。。
    21. 
  
  21. }
    22.

继承 SolrCrudRepository

 
    
  
  1. public interface YmqRepository extends SolrCrudRepository<Ymq, String> {
    2. 
  
    3. 
  
  3.     /**
    4. 
  
  4.      * 通过标题查询
    5. 
  
  5.      *
    6. 
  
  6.      * @param ymqTitle
    7. 
  
  7.      * @return
    8. 
  
  8.      */
    9. 
  
  9.     @Query(" ymqTitle:*?0* ")
    10. 
  
  10.     public List<Ymq> findByQueryAnnotation(String ymqTitle);
    11. 
  
  11. }
    12.

CloudSolrClient 工具类

 
    
  
  1. package io.ymq.solr.utils;
    2. 
  
    3. 
  
  3. import io.ymq.solr.pagehelper.PageInfo;
    4. 
  
  4. import io.ymq.solr.pagehelper.PageInfoFacet;
    5. 
  
  5. import io.ymq.solr.pagehelper.RowBounds;
    6. 
  
  6. import org.apache.solr.client.solrj.SolrQuery;
    7. 
  
  7. import org.apache.solr.client.solrj.SolrServerException;
    8. 
  
    9. 
  
  9. import org.apache.solr.client.solrj.response.QueryResponse;
    10. 
  
    11. 
  
  11. import java.io.IOException;
    12. 
  
  12. import java.util.Collection;
    13. 
  
  13. import java.util.List;
    14. 
  
    15. 
  
  15. /**
    16. 
  
  16.  * 描述: CloudSolrClient 工具类
    17. 
  
  17.  *
    18. 
  
  18.  * @author yanpenglei
    19. 
  
  19.  * @create 2017-10-19 10:56
    20. 
  
  20.  **/
    21. 
  
  21. public interface BaseSolr {
    22. 
  
    23. 
  
  23.     /**
    24. 
  
  24.      * 添加数据
    25. 
  
  25.      *
    26. 
  
  26.      * @param defaultCollection solr 库
    27. 
  
  27.      * @param bean              对象
    28. 
  
  28.      * @throws IOException
    29. 
  
  29.      * @throws SolrServerException
    30. 
  
  30.      */
    31. 
  
  31.     public void add(String defaultCollection, Object bean) throws IOException, SolrServerException;
    32. 
  
    33. 
  
  33.     /**
    34. 
  
  34.      * 添加一组数据
    35. 
  
  35.      *
    36. 
  
  36.      * @param defaultCollection solr 库
    37. 
  
  37.      * @param beans             list集合数据添加
    38. 
  
  38.      * @throws IOException
    39. 
  
  39.      * @throws SolrServerException
    40. 
  
  40.      */
    41. 
  
  41.     public void adds(String defaultCollection, Collection<?> beans) throws IOException, SolrServerException;
    42. 
  
    43. 
  
  43.     /**
    44. 
  
  44.      * 根据多个id删除数据
    45. 
  
  45.      *
    46. 
  
  46.      * @param defaultCollection
    47. 
  
  47.      * @param ids
    48. 
  
  48.      * @throws IOException
    49. 
  
  49.      * @throws SolrServerException
    50. 
  
  50.      */
    51. 
  
  51.     public void deleteByIds(String defaultCollection, List<String> ids) throws IOException, SolrServerException;
    52. 
  
    53. 
  
  53.     /**
    54. 
  
  54.      * 根据ID删除数据
    55. 
  
  55.      *
    56. 
  
  56.      * @param defaultCollection solr 库
    57. 
  
  57.      * @param id                要删除的文档的id
    58. 
  
  58.      * @throws IOException
    59. 
  
  59.      * @throws SolrServerException
    60. 
  
  60.      */
    61. 
  
  61.     public void deleteById(String defaultCollection, String id) throws IOException, SolrServerException;
    62. 
  
    63. 
  
  63.     /**
    64. 
  
  64.      * 根据指定索引(字段)模糊删除数据
    65. 
  
  65.      *
    66. 
  
  66.      * @param defaultCollection solr 库
    67. 
  
  67.      * @param field
    68. 
  
  68.      * @param fieldValue
    69. 
  
  69.      * @throws IOException
    70. 
  
  70.      * @throws SolrServerException
    71. 
  
  71.      */
    72. 
  
  72.     public void deleteByField(String defaultCollection, String field, String fieldValue) throws IOException, SolrServerException;
    73. 
  
    74. 
  
  74.     /**
    75. 
  
  75.      * 查询数据
    76. 
  
  76.      *
    77. 
  
  77.      * @param defaultCollection solr 库
    78. 
  
  78.      * @param clazz             对象Po
    79. 
  
  79.      * @param query             查询条件
    80. 
  
  80.      * @param <T>               返回查询集合
    81. 
  
  81.      * @return
    82. 
  
  82.      * @throws IOException
    83. 
  
  83.      * @throws SolrServerException
    84. 
  
  84.      */
    85. 
  
  85.     public <T> List<T> query(String defaultCollection, Class<T> clazz, SolrQuery query) throws IOException, SolrServerException;
    86. 
  
    87. 
  
  87.     /**
    88. 
  
  88.      * 查询
    89. 
  
  89.      *
    90. 
  
  90.      * @param defaultCollection solr 库
    91. 
  
  91.      * @param query             查询条件
    92. 
  
  92.      * @return 返回response对象
    93. 
  
  93.      * @throws IOException
    94. 
  
  94.      * @throws SolrServerException
    95. 
  
  95.      */
    96. 
  
  96.     public QueryResponse query(String defaultCollection, SolrQuery query) throws IOException, SolrServerException;
    97. 
  
    98. 
  
  98.     /**
    99. 
  
  99.      * @param defaultCollection solr 库
    100. 
  
  100.      * @param clazz             查询的数据对应的对象
    101. 
  
  101.      * @param query             查询条件
    102. 
  
  102.      * @param rowBounds         分页参数
    103. 
  
  103.      * @param <T>
    104. 
  
  104.      * @return
    105. 
  
  105.      * @throws IOException
    106. 
  
  106.      * @throws SolrServerException
    107. 
  
  107.      */
    108. 
  
  108.     public <T> PageInfo query(String defaultCollection, Class<T> clazz, SolrQuery query, RowBounds rowBounds) throws IOException, SolrServerException;
    109. 
  
    110. 
  
  110.     /**
    111. 
  
  111.      * 查询数据
    112. 
  
  112.      *
    113. 
  
  113.      * @param defaultCollection solr 库
    114. 
  
  114.      * @param query             查询条件
    115. 
  
  115.      * @param rowBounds         分页
    116. 
  
  116.      * @return
    117. 
  
  117.      * @throws IOException
    118. 
  
  118.      * @throws SolrServerException
    119. 
  
  119.      */
    120. 
  
  120.     public PageInfo query(String defaultCollection, SolrQuery query, RowBounds rowBounds) throws IOException, SolrServerException;
    121. 
  
    122. 
  
  122.     /**
    123. 
  
  123.      * solrj的facet结果集查询
    124. 
  
  124.      *
    125. 
  
  125.      * @param defaultCollection solr 库
    126. 
  
  126.      * @param query             查询条件
    127. 
  
  127.      * @param rowBounds         分页数
    128. 
  
  128.      * @return
    129. 
  
  129.      * @throws IOException
    130. 
  
  130.      * @throws SolrServerException
    131. 
  
  131.      */
    132. 
  
  132.     public PageInfoFacet queryFacet(String defaultCollection, SolrQuery query, RowBounds rowBounds) throws IOException, SolrServerException;
    133. 
  
  133. }
    134.

参数配置

application.properties

 
    
  
  1. #SolrCloud zookeeper
    2. 
  
  2. spring.data.solr.zk-host=node1:2181,node2:2181,node3:2181
    3.

单元测试

 
    
  
  1. package io.ymq.solr.test;
    2. 
  
    3. 
  
  3. import com.alibaba.fastjson.JSONObject;
    4. 
  
  4. import io.ymq.solr.YmqRepository;
    5. 
  
  5. import io.ymq.solr.pagehelper.PageInfo;
    6. 
  
  6. import io.ymq.solr.pagehelper.RowBounds;
    7. 
  
  7. import io.ymq.solr.po.Ymq;
    8. 
  
  8. import io.ymq.solr.run.Startup;
    9. 
  
  9. import io.ymq.solr.utils.BaseSolr;
    10. 
  
  10. import org.apache.solr.client.solrj.SolrQuery;
    11. 
  
  11. import org.apache.solr.client.solrj.SolrServerException;
    12. 
  
  12. import org.apache.solr.client.solrj.impl.CloudSolrClient;
    13. 
  
    14. 
  
  14. import org.apache.solr.client.solrj.response.QueryResponse;
    15. 
  
  15. import org.junit.Test;
    16. 
  
  16. import org.junit.runner.RunWith;
    17. 
  
  17. import org.springframework.beans.factory.annotation.Autowired;
    18. 
  
  18. import org.springframework.boot.test.context.SpringBootTest;
    19. 
  
  19. import org.springframework.test.context.junit4.SpringRunner;
    20. 
  
    21. 
  
  21. import java.io.IOException;
    22. 
  
  22. import java.util.List;
    23. 
  
    24. 
  
    25. 
  
  25. /**
    26. 
  
  26.  * 描述: 测试 solr cloud
    27. 
  
  27.  *
    28. 
  
  28.  * @author yanpenglei
    29. 
  
  29.  * @create 2017-10-17 19:00
    30. 
  
  30.  **/
    31. 
  
  31. @RunWith(SpringRunner.class)
    32. 
  
  32. @SpringBootTest(classes = Startup.class)
    33. 
  
  33. public class BaseTest {
    34. 
  
    35. 
  
  35.     @Autowired
    36. 
  
  36.     private YmqRepository ymqRepository;
    37. 
  
    38. 
  
  38.     @Autowired
    39. 
  
  39.     private CloudSolrClient cloudSolrClient;
    40. 
  
    41. 
  
  41.     @Autowired
    42. 
  
  42.     private BaseSolr baseSolr;
    43. 
  
    44. 
  
  44.     /**
    45. 
  
  45.      * 使用 ymqRepository 方式新增
    46. 
  
  46.      *
    47. 
  
  47.      * @throws Exception
    48. 
  
  48.      */
    49. 
  
  49.     @Test
    50. 
  
  50.     public void testAddYmqRepository() {
    51. 
  
    52. 
  
  52.         Ymq ymq1 = new Ymq();
    53. 
  
  53.         ymq1.setId("1");
    54. 
  
  54.         ymq1.setYmqTitle("penglei");
    55. 
  
  55.         ymq1.setYmqUrl("www_ymq_io");
    56. 
  
  56.         ymq1.setYmqContent("ymqContent");
    57. 
  
    58. 
  
  58.         Ymq ymq2 = new Ymq();
    59. 
  
  59.         ymq2.setId("2");//
    60. 
  
  60.         ymq2.setYmqTitle("penglei");
    61. 
  
  61.         ymq2.setYmqUrl("www_ymq_io");
    62. 
  
  62.         ymq2.setYmqContent("ymqContent");
    63. 
  
    64. 
  
  64.         ymqRepository.save(ymq1);
    65. 
  
  65.         ymqRepository.save(ymq2);
    66. 
  
  66.     }
    67. 
  
    68. 
  
    69. 
  
  69.     /**
    70. 
  
  70.      * 使用 cloudSolrClient 方式新增
    71. 
  
  71.      *
    72. 
  
  72.      * @throws Exception
    73. 
  
  73.      */
    74. 
  
  74.     @Test
    75. 
  
  75.     public void testAddCloudSolrClient() throws IOException, SolrServerException {
    76. 
  
    77. 
  
  77.         Ymq ymq = new Ymq();
    78. 
  
  78.         ymq.setId("3");
    79. 
  
  79.         ymq.setYmqTitle("penglei");
    80. 
  
  80.         ymq.setYmqUrl("www_ymq_io");
    81. 
  
  81.         ymq.setYmqContent("ymqContent");
    82. 
  
    83. 
  
  83.         cloudSolrClient.setDefaultCollection("test_collection");
    84. 
  
  84.         cloudSolrClient.connect();
    85. 
  
    86. 
  
  86.         cloudSolrClient.addBean(ymq);
    87. 
  
  87.         cloudSolrClient.commit();
    88. 
  
  88.     }
    89. 
  
    90. 
  
  90.     /**
    91. 
  
  91.      * 删除数据
    92. 
  
  92.      */
    93. 
  
  93.     @Test
    94. 
  
  94.     public void testDelete() {
    95. 
  
    96. 
  
  96.         Ymq ymq = new Ymq();
    97. 
  
  97.         ymq.setId("4");
    98. 
  
  98.         ymq.setYmqTitle("delete_penglei");
    99. 
  
  99.         ymq.setYmqUrl("www_ymq_io");
    100. 
  
  100.         ymq.setYmqContent("ymqContent");
    101. 
  
    102. 
  
  102.         // 添加一条测试数据，用于删除的测试数据
    103. 
  
  103.         ymqRepository.save(ymq);
    104. 
  
    105. 
  
  105.         // 通过标题查询数据ID
    106. 
  
  106.         List<Ymq> list = ymqRepository.findByQueryAnnotation("delete_penglei");
    107. 
  
    108. 
  
  108.         for (Ymq item : list) {
    109. 
  
    110. 
  
  110.             System.out.println("查询响应 :" + JSONObject.toJSONString(item));
    111. 
  
    112. 
  
  112.             //通过主键 ID 删除
    113. 
  
  113.             ymqRepository.delete(item.getId());
    114. 
  
  114.         }
    115. 
  
    116. 
  
  116.     }
    117. 
  
    118. 
  
  118.     /**
    119. 
  
  119.      * data JPA 方式查询
    120. 
  
  120.      *
    121. 
  
  121.      * @throws Exception
    122. 
  
  122.      */
    123. 
  
  123.     @Test
    124. 
  
  124.     public void testYmqRepositorySearch() throws Exception {
    125. 
  
    126. 
  
  126.         List<Ymq> list = ymqRepository.findByQueryAnnotation("penglei");
    127. 
  
    128. 
  
  128.         for (Ymq item : list) {
    129. 
  
  129.             System.out.println(" data JPA 方式查询响应 :" + JSONObject.toJSONString(item));
    130. 
  
  130.         }
    131. 
  
  131.     }
    132. 
  
    133. 
  
  133.     /**
    134. 
  
  134.      * SolrQuery 语法查询
    135. 
  
  135.      *
    136. 
  
  136.      * @throws Exception
    137. 
  
  137.      */
    138. 
  
  138.     @Test
    139. 
  
  139.     public void testYmqSolrQuery() throws Exception {
    140. 
  
    141. 
  
  141.         SolrQuery query = new SolrQuery();
    142. 
  
    143. 
  
  143.         String ymqTitle = "penglei";
    144. 
  
    145. 
  
  145.         query.setQuery(" ymqTitle:*" + ymqTitle + "* ");
    146. 
  
    147. 
  
  147.         cloudSolrClient.setDefaultCollection("test_collection");
    148. 
  
  148.         cloudSolrClient.connect();
    149. 
  
  149.         QueryResponse response = cloudSolrClient.query(query);
    150. 
  
    151. 
  
  151.         List<Ymq> list = response.getBeans(Ymq.class);
    152. 
  
    153. 
  
  153.         for (Ymq item : list) {
    154. 
  
  154.             System.out.println("SolrQuery 语法查询响应 :" + JSONObject.toJSONString(item));
    155. 
  
  155.         }
    156. 
  
  156.     }
    157. 
  
    158. 
  
  158.     /**
    159. 
  
  159.      * 使用 baseSolr 工具类 查询
    160. 
  
  160.      *
    161. 
  
  161.      * @throws Exception
    162. 
  
  162.      */
    163. 
  
  163.     @Test
    164. 
  
  164.     public void testBaseSolrQuery() throws Exception {
    165. 
  
    166. 
  
  166.         SolrQuery query = new SolrQuery();
    167. 
  
    168. 
  
  168.         String ymqTitle = "penglei";
    169. 
  
  169.         String defaultCollection = "test_collection";
    170. 
  
    171. 
  
  171.         query.setQuery(" ymqTitle:*" + ymqTitle + "* ");
    172. 
  
    173. 
  
  173.         List<Ymq> list = baseSolr.query(defaultCollection, Ymq.class, query);
    174. 
  
    175. 
  
  175.         for (Ymq item : list) {
    176. 
  
  176.             System.out.println("baseSolr 工具类  查询响应 :" + JSONObject.toJSONString(item));
    177. 
  
  177.         }
    178. 
  
  178.     }
    179. 
  
    180. 
  
  180.     /**
    181. 
  
  181.      * 使用 baseSolr 工具类 分页 查询
    182. 
  
  182.      *
    183. 
  
  183.      * @throws Exception
    184. 
  
  184.      */
    185. 
  
  185.     @Test
    186. 
  
  186.     public void testBaseSolrPageInfoQuery() throws Exception {
    187. 
  
    188. 
  
  188.         SolrQuery query = new SolrQuery();
    189. 
  
    190. 
  
  190.         String ymqTitle = "penglei";
    191. 
  
  191.         String defaultCollection = "test_collection";
    192. 
  
    193. 
  
  193.         query.setQuery(" ymqTitle:*" + ymqTitle + "* ");
    194. 
  
    195. 
  
  195.         PageInfo pageInfo = baseSolr.query(defaultCollection, Ymq.class, query,new RowBounds(0,2));
    196. 
  
    197. 
  
  197.         System.out.println("使用 baseSolr 工具类 分页 查询响应 :" + JSONObject.toJSONString(pageInfo));
    198. 
  
  198.     }
    199. 
  
  199. }
    200.

一些查询,响应

 
    
  
  1.  data JPA 方式查询响应 :{"id":"1","ymqContent":"ymqContent","ymqTitle":"penglei","ymqUrl":"www_ymq_io"}
    2. 
  
  2.  data JPA 方式查询响应 :{"id":"2","ymqContent":"ymqContent","ymqTitle":"penglei","ymqUrl":"www_ymq_io"}
    3. 
  
  3.  data JPA 方式查询响应 :{"id":"3","ymqContent":"ymqContent","ymqTitle":"penglei","ymqUrl":"www_ymq_io"}
    4.

代码我已放到 Github ，导入 spring-boot-solr-cloud 项目

github https://github.com/souyunku/spring-boot-examples/tree/master/spring-boot-solr-cloud

关注我们

如果需要源码可以关注“IT实战联盟”公众号并留言也可以加入交流群和作者互撩哦~~~

Contact

  • 作者：鹏磊

  • 出处：http://www.ymq.io/2017/10/18/solr-cloud-spring-boot-example

  • Email：admin@souyunku.com

  • 版权归作者所有，转载请注明出处

  • Wechat：关注公众号，搜云库，专注于开发技术的研究与知识分享



注意：本文归作者所有，未经作者允许，不得转载

#架构 #Spring Boot
阅读全部

全部评论: 0 条

    我有话说:

    架构实战篇（十七）：Spring Boot Assembly 整合 thymeleaf

    如何让服务器上的 sprig boot 项目升级变的方便快捷

    架构实战篇（九）：Spring Boot 集成 RocketMQ

    快速集成阿里开源消息队列 RocketMQ

    架构实战篇（十三）：Spring Boot Logback 邮件通知

    日志对于应用程序来说是非常重要的，当你的程序报错了，而你又不知道是多么可怕的一件事情，本文使用logback把程序报错信息邮件到开发者

    架构实战篇（十八）：Spring Boot Redis实现分布式锁

    轻松使用Redis 实现分布式锁

    微服务架构实战篇（六）：Spring boot2.x 集成阿里大鱼短信接口详解与Demo

    Spring boot2.x 集成阿里大鱼短信接口，发送短信验证码及短信接口详解。

    架构实战篇（十）：Spring Boot 集成 Dubbo

    Dubbo是阿里巴巴SOA服务化治理方案的核心框架，一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案。

    架构实战篇（十五）：Spring Boot 解耦之事件驱动

    通过使用spring 事件来解决业务代码的耦合

    架构实战篇（十二）：Spring Boot 分布式Session共享Redis

    分布式Web网站一般都会碰到集群session共享问题，小编整理了一套解决方案，内附GitHub 源码地址哦~~~

    架构实战篇（一）-Spring Boot+MyBatis基础架构搭建

    Spring的追求一定是简单点简单点，让java的开发变得更加简单、容易。瞧瞧的告诉你们直接copy就能用哦~~~

    架构实战篇（三）-Spring Boot架构搭建RESTful API案例

    之前分享了Spring Boot 整合Swagger 让API可视化和前后端分离架构 受到了大家一致好评 ，本节就接着上节的代码做了详细的查询代码的补充和完善并搭建RESTful API架构案例。

    架构实战篇（七）：Spring Boot Data JPA 快速入门

    Spring Data JPA 是Spring Data 的一个子项目，它通过提供基于JPA的Repository极大了减少了操作JPA的代码。

    架构实战篇（六）：Spring Boot RestTemplate的使用

    RestTemplate是Spring提供的用于访问Rest服务的客户端，RestTemplate提供了多种便捷访问远程Http服务的方法，能够大大提高客户端的编写效率。

    架构实战篇（四）：Spring Boot整合 Thymeleaf

    Thymeleaf 是一种模板语言。那模板语言或模板引擎是什么？

    微服务架构实战篇（五）：Spring boot2.x + Guava 并使用RateLimiter实现秒杀限流demo

    码云：https://gitee.com/itunion/spring-boot-starter-guava

    架构实战篇（十四）：Spring Boot 多缓存实战

    多场景下的不同缓存策略解决方案

    架构实战篇（十六）：Spring Boot Assembly服务化打包

    使用assembly来打包springboot微服务项目，让发布更简单

    码云推荐：一个优秀的分布式spring boot/Spring Cloud API限流框架，特别适合微服务架构

    一个优秀的分布式spring boot/Spring Cloud API限流框架，特别适合微服务架构.

    SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper

    不啰嗦，本篇完成两件事：1、搭建SpringBoot 框架；2、基于spring boot框架访问zookeeper。

    架构实战篇（八）：Spring Boot 集成 Druid 数据源监控

    Druid是目前最好的数据库连接池，在功能、性能、扩展性方面，都超过其他数据库连接池，包括DBCP、C3P0、BoneCP、Proxool、JBoss DataSource。