elasticsearch学习

1.是什么

  • 分布式的实时文件存储，每个字段都被索引并可被搜索
  • 分布式的实时分析搜索引擎
  • 可以扩展到上百台服务器，处理PB级结构化或非结构化数据

2.名词解释

  • index
    类似于MySQL的数据库

  • type
    类似于MySQL的表

  • document
    类似于MySQL的行

3.简单入门

  1. 依赖 ```xml cn.hutool hutool-all 4.0.12 org.elasticsearch elasticsearch 6.2.4 org.elasticsearch.client transport 6.2.4 org.elasticsearch elasticsearch com.alibaba fastjson 1.2.47

org.springframework.boot spring-boot-starter-logging

org.springframework.boot spring-boot-starter-web 

  3. 2. 
  4. 配置文件
  6.    1. 
  7. application.properties
  8. ```pr
  9. # Elasticsearch
  10. # 9200端口是用来让HTTP REST API来访问ElasticSearch，而9300端口是传输层监听的默认端口
  11. elasticsearch.ip=127.0.0.1
  12. elasticsearch.port=9300
  13. # 默认值是核心线程数*4
  14. elasticsearch.pool=5
  15. elasticsearch.cluster.name=qiudx_es_study
  1. es配置文件ElasticsearchConfig ```java

/**

  • 用于定义配置类，可替换xml配置文件 *
  • @author qiudx

  • @version $Id ElasticsearchConfig.java, v 0.1 2018-06-13 13:26 qiudx Exp $$ */ @Configuration public class ElasticsearchConfig {

    private static final Logger LOGGER = LoggerFactory.getLogger(ElasticsearchConfig.class);

    /**

    • elk集群地址 */ @Value(“${elasticsearch.ip}”) private String hostName;

      /**

    • 端口 */ @Value(“${elasticsearch.port}”) private String port;

      /**

    • 集群名称 */ @Value(“${elasticsearch.cluster.name}”) private String clusterName;

      /**

    • 连接池 */ @Value(“${elasticsearch.pool}”) private String poolSize;

      /**

    • Bean name default 函数名字 */ @Bean(name = “transportClient”) public TransportClient transportClient() { LOGGER.info(“Elasticsearch初始化开始。。。。。”); TransportClient transportClient = null; try {
      1.  // 配置信息
      2.  Settings esSetting = Settings.builder()
      3.          //集群名字
      4.          .put("cluster.name", clusterName)
      5.          //增加嗅探机制，找到ES集群
      6.          .put("client.transport.sniff", true)
      7.          //增加线程池个数，暂时设为5
      8.          .put("thread_pool.search.size", Integer.parseInt(poolSize))
      9.          .build();
      10.  //配置信息Settings自定义
      11.  transportClient = new PreBuiltTransportClient(esSetting);
      12.  TransportAddress transportAddress = new TransportAddress(InetAddress.getByName(hostName), Integer.valueOf(port));
      13.  transportClient.addTransportAddresses(transportAddress);
      } catch (Exception e) {
      1.  LOGGER.error("elasticsearch TransportClient create error!!", e);
      } return transportClient; }

}

  3. 3. 
  4. 工具类
  6.    1. 
  7. 对es操作进行封装
  8. ```java
  10. /**
  11.  * @author qiudx
  12.  * @version $Id ElasticsearchUtil.java, v 0.1 2018-06-13 13:29 qiudx Exp $$
  13.  */
  14. @Component
  15. public class ElasticsearchUtil {
  17.     private static final Logger LOGGER = LoggerFactory.getLogger(ElasticsearchUtil.class);
  19.     private final TransportClient transportClient;
  21.     private static TransportClient client;
  23.     @Autowired
  24.     public ElasticsearchUtil(TransportClient transportClient) {
  25.         this.transportClient = transportClient;
  26.     }
  28.     /**
  29.      * spring容器初始化的时候执行该方法
  30.      */
  31.     @PostConstruct
  32.     public void init() {
  33.         client = this.transportClient;
  34.     }
  36.     /**
  37.      * 创建索引
  38.      */
  39.     public static boolean createIndex(String index) {
  40.         if (!isIndexExist(index)) {
  41.             LOGGER.info("Index is not exits!");
  42.         }
  43.         CreateIndexResponse indexresponse = client.admin().indices().prepareCreate(index).execute().actionGet();
  44.         LOGGER.info("执行建立成功？" + indexresponse.isAcknowledged());
  45.         return indexresponse.isAcknowledged();
  46.     }
  48.     /**
  49.      * 删除索引
  50.      */
  51.     public static boolean deleteIndex(String index) {
  52.         if (!isIndexExist(index)) {
  53.             LOGGER.info("Index is not exits!");
  54.         }
  55.         DeleteIndexResponse dResponse = client.admin().indices().prepareDelete(index).execute().actionGet();
  56.         if (dResponse.isAcknowledged()) {
  57.             LOGGER.info("delete index " + index + "  successfully!");
  58.         } else {
  59.             LOGGER.info("Fail to delete index " + index);
  60.         }
  61.         return dResponse.isAcknowledged();
  62.     }
  64.     /**
  65.      * 判断索引是否存在
  66.      */
  67.     public static boolean isIndexExist(String index) {
  68.         IndicesExistsResponse inExistsResponse = client.admin().indices().exists(new IndicesExistsRequest(index)).actionGet();
  69.         if (inExistsResponse.isExists()) {
  70.             LOGGER.info("Index [" + index + "] is exist!");
  71.         } else {
  72.             LOGGER.info("Index [" + index + "] is not exist!");
  73.         }
  74.         return inExistsResponse.isExists();
  75.     }
  77.     /**
  78.      * 数据添加，正定ID
  79.      *
  80.      * @param jsonObject 要增加的数据
  81.      * @param index      索引，类似数据库
  82.      * @param type       类型，类似表
  83.      * @param id         数据ID
  84.      */
  85.     public static String addData(JSONObject jsonObject, String index, String type, String id) {
  87.         IndexResponse response = client.prepareIndex(index, type, id).setSource(jsonObject).get();
  89.         LOGGER.info("addData response status:{},id:{}", response.status().getStatus(), response.getId());
  91.         return response.getId();
  92.     }
  94.     /**
  95.      * 数据添加
  96.      *
  97.      * @param jsonObject 要增加的数据
  98.      * @param index      索引，类似数据库
  99.      * @param type       类型，类似表
  100.      */
  101.     public static String addData(JSONObject jsonObject, String index, String type) {
  102.         return addData(jsonObject, index, type, UUID.randomUUID().toString().replaceAll("-", "").toUpperCase());
  103.     }
  105.     /**
  106.      * 通过ID删除数据
  107.      *
  108.      * @param index 索引，类似数据库
  109.      * @param type  类型，类似表
  110.      * @param id    数据ID
  111.      */
  112.     public static void deleteDataById(String index, String type, String id) {
  114.         DeleteResponse response = client.prepareDelete(index, type, id).execute().actionGet();
  116.         LOGGER.info("deleteDataById response status:{},id:{}", response.status().getStatus(), response.getId());
  117.     }
  119.     /**
  120.      * 通过ID 更新数据
  121.      *
  122.      * @param jsonObject 要增加的数据
  123.      * @param index      索引，类似数据库
  124.      * @param type       类型，类似表
  125.      * @param id         数据ID
  126.      */
  127.     public static void updateDataById(JSONObject jsonObject, String index, String type, String id) {
  129.         UpdateRequest updateRequest = new UpdateRequest();
  131.         updateRequest.index(index).type(type).id(id).doc(jsonObject);
  133.         client.update(updateRequest);
  135.     }
  137.     /**
  138.      * 通过ID获取数据
  139.      *
  140.      * @param index  索引，类似数据库
  141.      * @param type   类型，类似表
  142.      * @param id     数据ID
  143.      * @param fields 需要显示的字段，逗号分隔（缺省为全部字段）
  144.      */
  145.     public static Map<String, Object> searchDataById(String index, String type, String id, String fields) {
  147.         GetRequestBuilder getRequestBuilder = client.prepareGet(index, type, id);
  149.         if (StrUtil.isNotEmpty(fields)) {
  150.             getRequestBuilder.setFetchSource(fields.split(","), null);
  151.         }
  153.         GetResponse getResponse = getRequestBuilder.execute().actionGet();
  155.         return getResponse.getSource();
  156.     }
  158.     /**
  159.      * 使用分词查询,并分页
  160.      *
  161.      * @param index          索引名称
  162.      * @param type           类型名称,可传入多个type逗号分隔
  163.      * @param startPage      当前页
  164.      * @param pageSize       每页显示条数
  165.      * @param query          查询条件
  166.      * @param fields         需要显示的字段，逗号分隔（缺省为全部字段）
  167.      * @param sortField      排序字段
  168.      * @param highlightField 高亮字段
  169.      */
  170.     public static EsPage searchDataPage(String index, String type, int startPage, int pageSize, QueryBuilder query, String fields, String sortField, String highlightField) {
  171.         SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index);
  172.         if (StrUtil.isNotEmpty(type)) {
  173.             searchRequestBuilder.setTypes(type.split(","));
  174.         }
  175.         searchRequestBuilder.setSearchType(SearchType.QUERY_THEN_FETCH);
  177.         // 需要显示的字段，逗号分隔（缺省为全部字段）
  178.         if (StrUtil.isNotEmpty(fields)) {
  179.             searchRequestBuilder.setFetchSource(fields.split(","), null);
  180.         }
  182.         //排序字段
  183.         if (StrUtil.isNotEmpty(sortField)) {
  184.             searchRequestBuilder.addSort(sortField, SortOrder.DESC);
  185.         }
  187.         // 高亮（xxx=111,aaa=222）
  188.         if (StrUtil.isNotEmpty(highlightField)) {
  189.             HighlightBuilder highlightBuilder = new HighlightBuilder();
  191.             //highlightBuilder.preTags("<span style='color:red' >");//设置前缀
  192.             //highlightBuilder.postTags("</span>");//设置后缀
  194.             // 设置高亮字段
  195.             highlightBuilder.field(highlightField);
  196.             searchRequestBuilder.highlighter(highlightBuilder);
  197.         }
  199.         //searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
  200.         searchRequestBuilder.setQuery(query);
  202.         // 分页应用
  203.         searchRequestBuilder.setFrom(startPage).setSize(pageSize);
  205.         // 设置是否按查询匹配度排序
  206.         searchRequestBuilder.setExplain(true);
  208.         //打印的内容 可以在 Elasticsearch head 和 Kibana  上执行查询
  209.         LOGGER.info("\n{}", searchRequestBuilder);
  211.         // 执行搜索,返回搜索响应信息
  212.         SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
  214.         long totalHits = searchResponse.getHits().totalHits;
  215.         long length = searchResponse.getHits().getHits().length;
  217.         LOGGER.debug("共查询到[{}]条数据,处理数据条数[{}]", totalHits, length);
  219.         if (searchResponse.status().getStatus() == 200) {
  220.             // 解析对象
  221.             List<Map<String, Object>> sourceList = setSearchResponse(searchResponse, highlightField);
  223.             return new EsPage(startPage, pageSize, (int) totalHits, sourceList);
  224.         }
  226.         return null;
  228.     }
  230.     /**
  231.      * 使用分词查询
  232.      *
  233.      * @param index          索引名称
  234.      * @param type           类型名称,可传入多个type逗号分隔
  235.      * @param query          查询条件
  236.      * @param size           文档大小限制
  237.      * @param fields         需要显示的字段，逗号分隔（缺省为全部字段）
  238.      * @param sortField      排序字段
  239.      * @param highlightField 高亮字段
  240.      */
  241.     public static List<Map<String, Object>> searchListData(String index, String type, QueryBuilder query, Integer size, String fields, String sortField, String highlightField) {
  243.         SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index);
  244.         if (StrUtil.isNotEmpty(type)) {
  245.             searchRequestBuilder.setTypes(type.split(","));
  246.         }
  248.         if (StrUtil.isNotEmpty(highlightField)) {
  249.             HighlightBuilder highlightBuilder = new HighlightBuilder();
  250.             // 设置高亮字段
  251.             highlightBuilder.field(highlightField);
  252.             searchRequestBuilder.highlighter(highlightBuilder);
  253.         }
  255.         searchRequestBuilder.setQuery(query);
  257.         if (StrUtil.isNotEmpty(fields)) {
  258.             searchRequestBuilder.setFetchSource(fields.split(","), null);
  259.         }
  260.         searchRequestBuilder.setFetchSource(true);
  262.         if (StrUtil.isNotEmpty(sortField)) {
  263.             searchRequestBuilder.addSort(sortField, SortOrder.DESC);
  264.         }
  266.         if (size != null && size > 0) {
  267.             searchRequestBuilder.setSize(size);
  268.         }
  270.         //打印的内容 可以在 Elasticsearch head 和 Kibana  上执行查询
  271.         LOGGER.info("\n{}", searchRequestBuilder);
  273.         SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
  275.         long totalHits = searchResponse.getHits().totalHits;
  276.         long length = searchResponse.getHits().getHits().length;
  278.         LOGGER.info("共查询到[{}]条数据,处理数据条数[{}]", totalHits, length);
  280.         if (searchResponse.status().getStatus() == 200) {
  281.             // 解析对象
  282.             return setSearchResponse(searchResponse, highlightField);
  283.         }
  285.         return null;
  287.     }
  289.     /**
  290.      * 高亮结果集 特殊处理
  291.      */
  292.     private static List<Map<String, Object>> setSearchResponse(SearchResponse searchResponse, String highlightField) {
  293.         List<Map<String, Object>> sourceList = new ArrayList<>();
  294.         StringBuilder stringBuffer = new StringBuilder();
  295.         for (SearchHit searchHit : searchResponse.getHits().getHits()) {
  296.             searchHit.getSourceAsMap().put("id", searchHit.getId());
  298.             if (StrUtil.isNotEmpty(highlightField)) {
  300.                 System.out.println("遍历 高亮结果集，覆盖 正常结果集" + searchHit.getSourceAsMap());
  301.                 Text[] text = searchHit.getHighlightFields().get(highlightField).getFragments();
  303.                 if (text != null) {
  304.                     for (Text str : text) {
  305.                         stringBuffer.append(str.string());
  306.                     }
  307.                     //遍历 高亮结果集，覆盖 正常结果集
  308.                     searchHit.getSourceAsMap().put(highlightField, stringBuffer.toString());
  309.                 }
  310.             }
  311.             sourceList.add(searchHit.getSourceAsMap());
  312.         }
  314.         return sourceList;
  315.     }
  317. }

  1. 分页工具类 ```java /**

    • @author qiudx
    • @version $Id EsPage.java, v 0.1 2018-06-13 13:32 qiudx Exp $$ */ public class EsPage {

    /**

    • 当前页 / private int currentPage; /*
    • 每页显示多少条 */ private int pageSize;

    /**

    • 总记录数 / private int recordCount; /*
    • 本页的数据列表 */ private List> recordList;

    /**

    • 总页数 / private int pageCount; /*
    • 页码列表的开始索引（包含） / private int beginPageIndex; /*
    • 页码列表的结束索引（包含） */ private int endPageIndex;

    /**

    • 只接受前4个必要的属性，会自动的计算出其他3个属性的值 */ public EsPage(int currentPage, int pageSize, int recordCount, List> recordList) { this.currentPage = currentPage; this.pageSize = pageSize; this.recordCount = recordCount; this.recordList = recordList;

      // 计算总页码 pageCount = (recordCount + pageSize - 1) / pageSize;

      // 计算 beginPageIndex 和 endPageIndex // >> 总页数不多于10页，则全部显示 if (pageCount <= 10) {

      1. beginPageIndex = 1;
      2. endPageIndex = pageCount;

      } // >> 总页数多于10页，则显示当前页附近的共10个页码 else { // 当前页附近的共10个页码（前4个 + 当前页 + 后5个）

      1. beginPageIndex = currentPage - 4;
      2. endPageIndex = currentPage + 5;
      3. // 当前面的页码不足4个时，则显示前10个页码
      4. if (beginPageIndex < 1) {
      5.     beginPageIndex = 1;
      6.     endPageIndex = 10;
      7. }

      // 当后面的页码不足5个时，则显示后10个页码

      1. if (endPageIndex > pageCount) {
      2.     endPageIndex = pageCount;
      3.     beginPageIndex = pageCount - 10 + 1;
      4. }

      } }

    public int getCurrentPage() { return currentPage; }

    public void setCurrentPage(int currentPage) { this.currentPage = currentPage; }

    public int getPageSize() { return pageSize; }

    public void setPageSize(int pageSize) { this.pageSize = pageSize; }

    public int getRecordCount() { return recordCount; }

    public void setRecordCount(int recordCount) { this.recordCount = recordCount; }

    public List> getRecordList() { return recordList; }

    public void setRecordList(List> recordList) { this.recordList = recordList; }

    public int getPageCount() { return pageCount; }

    public void setPageCount(int pageCount) { this.pageCount = pageCount; }

    public int getBeginPageIndex() { return beginPageIndex; }

    public void setBeginPageIndex(int beginPageIndex) { this.beginPageIndex = beginPageIndex; }

    public int getEndPageIndex() { return endPageIndex; }

    public void setEndPageIndex(int endPageIndex) { this.endPageIndex = endPageIndex; }

}

  3. 4. 
  4. 实体
  5. ```java
  7. /**
  8.  * @author qiudx
  9.  * @version $Id EsModel.java, v 0.1 2018-06-13 13:40 qiudx Exp $$
  10.  */
  11. public class EsModel {
  12.     private String id;
  13.     private String name;
  14.     private int age;
  15.     private Date date;
  17.     /**
  18.      * Getter method for property <tt>id</tt>.
  19.      *
  20.      * @return property value of id
  21.      */
  22.     public String getId() {
  23.         return id;
  24.     }
  26.     /**
  27.      * Setter method for property <tt>id</tt>.
  28.      *
  29.      * @param id value to be assigned to property id
  30.      */
  31.     public void setId(String id) {
  32.         this.id = id;
  33.     }
  35.     /**
  36.      * Getter method for property <tt>name</tt>.
  37.      *
  38.      * @return property value of name
  39.      */
  40.     public String getName() {
  41.         return name;
  42.     }
  44.     /**
  45.      * Setter method for property <tt>name</tt>.
  46.      *
  47.      * @param name value to be assigned to property name
  48.      */
  49.     public void setName(String name) {
  50.         this.name = name;
  51.     }
  53.     /**
  54.      * Getter method for property <tt>age</tt>.
  55.      *
  56.      * @return property value of age
  57.      */
  58.     public int getAge() {
  59.         return age;
  60.     }
  62.     /**
  63.      * Setter method for property <tt>age</tt>.
  64.      *
  65.      * @param age value to be assigned to property age
  66.      */
  67.     public void setAge(int age) {
  68.         this.age = age;
  69.     }
  71.     /**
  72.      * Getter method for property <tt>date</tt>.
  73.      *
  74.      * @return property value of date
  75.      */
  76.     public Date getDate() {
  77.         return date;
  78.     }
  80.     /**
  81.      * Setter method for property <tt>date</tt>.
  82.      *
  83.      * @param date value to be assigned to property date
  84.      */
  85.     public void setDate(Date date) {
  86.         this.date = date;
  87.     }
  88. }

  1. 测试

    1. /**
    2. * @author qiudx
    3. * @version $Id EsController.java, v 0.1 2018-06-13 13:36 qiudx Exp $$
    4. */
    5. @RestController
    6. @EnableAutoConfiguration
    7. @RequestMapping("/es")
    8. public class EsController {
    10.  /**
    11.   * 测试索引
    12.   */
    13.  private String indexName = "test_index";
    15.  /**
    16.   * 类型
    17.   */
    18.  private String esType = "external";
    20.  /**
    21.   * http://127.0.0.1:8080/es/createIndex
    22.   * 创建索引
    23.   */
    24.  @RequestMapping("/createIndex")
    25.  public String createIndex() {
    26.      if (!ElasticsearchUtil.isIndexExist(indexName)) {
    27.          ElasticsearchUtil.createIndex(indexName);
    28.      } else {
    29.          return "索引已经存在";
    30.      }
    31.      return "索引创建成功";
    32.  }
    34.  /**
    35.   * 插入记录
    36.   */
    37.  @RequestMapping("/insertJson")
    38.  public String insertJson() {
    39.      JSONObject jsonObject = new JSONObject();
    40.      jsonObject.put("id", DateUtil.formatDate(new Date()));
    41.      jsonObject.put("age", 25);
    42.      jsonObject.put("name", "j-" + new Random(100).nextInt());
    43.      jsonObject.put("date", new Date());
    44.      return ElasticsearchUtil.addData(jsonObject, indexName, esType, jsonObject.getString("id"));
    45.  }
    47.  /**
    48.   * 插入记录
    49.   */
    50.  @RequestMapping("/insertModel")
    51.  public String insertModel() {
    52.      EsModel esModel = new EsModel();
    53.      esModel.setId(DateUtil.formatDate(new Date()));
    54.      esModel.setName("m-" + new Random(100).nextInt());
    55.      esModel.setAge(30);
    56.      esModel.setDate(new Date());
    57.      JSONObject jsonObject = (JSONObject) JSONObject.toJSON(esModel);
    58.      return ElasticsearchUtil.addData(jsonObject, indexName, esType, jsonObject.getString("id"));
    59.  }
    61.  /**
    62.   * 删除记录
    63.   */
    64.  @RequestMapping("/delete")
    65.  public String delete(String id) {
    66.      if (StrUtil.isNotBlank(id)) {
    67.          ElasticsearchUtil.deleteDataById(indexName, esType, id);
    68.          return "删除id=" + id;
    69.      } else {
    70.          return "id为空";
    71.      }
    72.  }
    74.  /**
    75.   * 更新数据
    76.   */
    77.  @RequestMapping("/update")
    78.  public String update(String id) {
    79.      if (StrUtil.isNotBlank(id)) {
    80.          JSONObject jsonObject = new JSONObject();
    81.          jsonObject.put("id", id);
    82.          jsonObject.put("age", 31);
    83.          jsonObject.put("name", "修改");
    84.          jsonObject.put("date", new Date());
    85.          ElasticsearchUtil.updateDataById(jsonObject, indexName, esType, id);
    86.          return "id=" + id;
    87.      } else {
    88.          return "id为空";
    89.      }
    90.  }
    92.  /**
    93.   * 获取数据
    94.   * http://127.0.0.1:8080/es/getData?id=2018-04-25%2016:33:44
    95.   */
    96.  @RequestMapping("/getData")
    97.  public String getData(String id) {
    98.      if (StrUtil.isNotBlank(id)) {
    99.          Map<String, Object> map = ElasticsearchUtil.searchDataById(indexName, esType, id, null);
    100.          return JSONObject.toJSONString(map);
    101.      } else {
    102.          return "id为空";
    103.      }
    104.  }
    106.  /**
    107.   * 查询数据
    108.   * 模糊查询
    109.   */
    110.  @RequestMapping("/queryMatchData")
    111.  @ResponseBody
    112.  public String queryMatchData() {
    113.      BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    114.      boolQuery.must(QueryBuilders.matchQuery("name", "修"));
    115.      List<Map<String, Object>> list = ElasticsearchUtil.searchListData(indexName, esType, boolQuery, 10, null, null, null);
    116.      return JSONObject.toJSONString(list);
    117.  }
    119.  /**
    120.   * 通配符查询数据
    121.   * 通配符查询 ?用来匹配1个任意字符，*用来匹配零个或者多个字符
    122.   */
    123.  @RequestMapping("/queryWildcardData")
    124.  public String queryWildcardData() {
    125.      QueryBuilder queryBuilder = QueryBuilders.wildcardQuery("name.keyword", "修*");
    126.      List<Map<String, Object>> list = ElasticsearchUtil.searchListData(indexName, esType, queryBuilder, 10, null, null, null);
    127.      return JSONObject.toJSONString(list);
    128.  }
    130.  /**
    131.   * 正则查询
    132.   */
    133.  @RequestMapping("/queryRegexpData")
    134.  public String queryRegexpData() {
    135.      QueryBuilder queryBuilder = QueryBuilders.regexpQuery("name.keyword", "j--[0-9]{1,11}");
    136.      List<Map<String, Object>> list = ElasticsearchUtil.searchListData(indexName, esType, queryBuilder, 10, null, null, null);
    137.      return JSONObject.toJSONString(list);
    138.  }
    140.  /**
    141.   * 查询数字范围数据
    142.   */
    143.  @RequestMapping("/queryIntRangeData")
    144.  public String queryIntRangeData() {
    145.      BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    146.      boolQuery.must(QueryBuilders.rangeQuery("age").from(31)
    147.              .to(32));
    148.      List<Map<String, Object>> list = ElasticsearchUtil.searchListData(indexName, esType, boolQuery, 10, null, null, null);
    149.      return JSONObject.toJSONString(list);
    150.  }
    152.  /**
    153.   * 查询日期范围数据
    154.   */
    155.  @RequestMapping("/queryDateRangeData")
    156.  public String queryDateRangeData() {
    157.      BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    158.      boolQuery.must(QueryBuilders.rangeQuery("date").from("2018-04-25T08:33:44.840Z")
    159.              .to("2018-04-25T10:03:08.081Z"));
    160.      List<Map<String, Object>> list = ElasticsearchUtil.searchListData(indexName, esType, boolQuery, 10, null, null, null);
    161.      return JSONObject.toJSONString(list);
    162.  }
    164.  /**
    165.   * 查询分页
    166.   *
    167.   * @param startPage 第几条记录开始
    168.   *                  从0开始
    169.   *                  第1页 ：http://127.0.0.1:8080/es/queryPage?startPage=0&pageSize=2
    170.   *                  第2页 ：http://127.0.0.1:8080/es/queryPage?startPage=2&pageSize=2
    171.   * @param pageSize  每页大小
    172.   */
    173.  @RequestMapping("/queryPage")
    174.  public String queryPage(String startPage, String pageSize) {
    175.      if (StrUtil.isNotBlank(startPage) && StrUtil.isNotBlank(pageSize)) {
    176.          BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
    177.          boolQuery.must(QueryBuilders.rangeQuery("date").from("2018-04-25T08:33:44.840Z")
    178.                  .to("2018-04-25T10:03:08.081Z"));
    179.          EsPage list = ElasticsearchUtil.searchDataPage(indexName, esType, Integer.parseInt(startPage), Integer.parseInt(pageSize), boolQuery, null, null, null);
    180.          return JSONObject.toJSONString(list);
    181.      } else {
    182.          return "startPage或者pageSize缺失";
    183.      }
    184.  }
    185. }