使用了ElasticSearch之后，公司系统查询速度快了50倍，工资直接翻一倍_elasticsearch速度能有多快

公司的OA系统在查询我发起的流程的功能的时候需要从Activiti的表中去查询数据的

这就会导致一个问题，当数据量越来越大的时候，我们的接口的响应速度就会越来越慢

所以我打算重写一下公司的查询流程功能，并且给它来一次系统大升级：可以全文搜索关键字。所以我选择使用了ElasticSearch这个搜索引擎，之前也写过几篇相关于ES的文章，大家可以去看一下：

新年第一天，老板让升级ElasticSearch版本，我说得加钱

同事说关键字查询用Mysql，我上去就是一个高压锅，用ElasticSearch不香吗？

ElasticSearch对标Mysql，谁能拔得头筹？

其实调用es的方法有很多，其中es就提供了java相关的api去使用，但是我这里选择的是使用http的原始方式去操作es。
这里又可以分为几种方式，自己使用原生的http去封装成一个工具类去使用，还有一种如果你们公司用的是SpringCloud的话，就可以使用他的组件Feign去调用es，这样也会更优雅，更高级一点（其实也没有）

@FeignClient(name = "EIP-MAPP-SEARCH-SERVER", url = "${elsearch.url}", fallbackFactory = ElasticHystrix.class)
public interface ElasticSearchApi {

    @PostMapping("/{index}/_doc/{id}")
    Object insertData(@PathVariable(name = "index") String index, @PathVariable(name = "id") String id, @RequestBody JSONObject jsonObject);

    @GetMapping("/{index}/_search")
    Object indexSearch(@PathVariable(name = "index") String index, @RequestBody JSONObject jsonObject);

    @GetMapping("/{aliases}/_search")
    Object aliasesSearch(@PathVariable(name = "aliases") String aliases, @RequestBody JSONObject jsonObject);

    @PutMapping("/{index}")
    Object insertAliases(@PathVariable(name = "index") String index, @RequestBody JSONObject jsonObject);

    @RequestMapping(value = "/{index}",method = RequestMethod.HEAD)
    Object checkIndex(@PathVariable(name = "index") String index);

    @PostMapping("/{index}/_doc/{id}/_update")
    Object updateData(@PathVariable(name = "index") String index, @PathVariable(name = "id") String id, @RequestBody JSONObject jsonObject);


}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

然后在yml的配置文件里面配置好es服务器的地址(这个是可以自定义的)

elsearch:
  process:
    enable: true
  url:
    http://10.123.236.106:9200
1
2
3
4
5

如果你不知道安装es，请参考我的安装教程：（保姆式教学）

Linux安装ElasticSearch以及Ik分词器（图文解说详细版）

这里好了之后我们就可以在业务中进行数据的插入了，有了数据之后我们自然可以进行查询，但是由于我这里使用的是JsonObject的方式去作为传参，所以我们在查询的时候就需要把他封装成最原始的参数去传参，就像我下面的两个例子一样

封装方法

 private ResultUtils getResultUtils(PageRequestDTO<OAElasticSearchParamDto> pageRequestDTO, String type, String queryParam) {
        JSONObject jsonObject = getPage(pageRequestDTO);
        //查询参数
        OAElasticSearchParamDto params = pageRequestDTO.getParams();
        String keyWord = params.getKeyWord();
        //提交审批、完成审批时间
        List<ColumnOption> optionList = pageRequestDTO.getOptionList();
        JSONArray timeList = new JSONArray();
        if (!optionList.isEmpty()) {
            timeList = getTimeList(optionList);
        }
        //根据关键字查询
        JSONObject elasticMatch = null;
        if (!StringUtils.isEmpty(keyWord)) {
            elasticMatch = getJsonObject(keyWord, "elasticData", "match");
        }
        //查询我发起的
        UserInfoDTO user = UserUtils.getActiveUser().getUser();
        String userId = user.getPsnCode();
        if ("handledUser".equals(type)) {
            userId = "*" + userId + "*";
        }
        JSONObject myStartMatch = getJsonObject(userId, type, queryParam);
        //任务状态
        return getResultUtils(pageRequestDTO, jsonObject, params, elasticMatch, myStartMatch, timeList);
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

封装方法

private ResultUtils getResultUtils(PageRequestDTO<OAElasticSearchParamDto> pageRequestDTO, JSONObject jsonObject,
                                       OAElasticSearchParamDto params, JSONObject elasticMatch, JSONObject myHandleJson, JSONArray timeList) {
        String taskStatus = pageRequestDTO.getParams().getTaskStatus();
        //组合查询
        JSONArray mustJsonArray = new JSONArray();
        mustJsonArray.add(elasticMatch);
        mustJsonArray.add(myHandleJson);
        mustJsonArray.addAll(timeList);
        if (!StringUtils.isEmpty(taskStatus)) {
            JSONObject taskStatusMatch = getJsonObject(taskStatus, "taskStatus", "match");
            mustJsonArray.add(taskStatusMatch);
        }
        JSONObject mustJson = new JSONObject();
        mustJson.put("must", mustJsonArray);
        // "bool"封装
        JSONObject boolJson = new JSONObject();
        boolJson.put("bool", mustJson);

        jsonObject.put("query", boolJson);
        //排除返回字段
        JSONObject excludes = new JSONObject();
        excludes.put("excludes", "elasticData");
        jsonObject.put("_source", excludes);
        //微服务名称
        String serveName = params.getServeName();
        Object search = elasticSearchApi.aliasesSearch(serveName, jsonObject);
        return ResultUtils.success(search);
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

调用方法

@Override
    public ResultUtils myStart(PageRequestDTO<OAElasticSearchParamDto> pageRequestDTO) {
        return getResultUtils(pageRequestDTO, "taskStartUser", "match");
    }


    /**
     * 我的待办
     *
     * @Param: [pageRequestDTO]
     * @return: com.lydsoft.eip.mapp.common.utils.ResultUtils
     * @Author: MaSiyi
     * @Date: 2022/1/26
     */
    @Override
    public ResultUtils myHandling(PageRequestDTO<OAElasticSearchParamDto> pageRequestDTO) {
        return getResultUtils(pageRequestDTO, "assignee", "match");
    }


    /**
     * 我处理的
     *
     * @Param: [pageRequestDTO]
     * @return: com.lydsoft.eip.mapp.common.utils.ResultUtils
     * @Author: MaSiyi
     * @Date: 2022/1/26
     */
    @Override
    public ResultUtils myHandled(PageRequestDTO<OAElasticSearchParamDto> pageRequestDTO) {
        return getResultUtils(pageRequestDTO, "handledUser", "wildcard");
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

这里再教大家一个小技巧：idea可以抽取重复的代码片段出来组成一个新的方法，所以我们在写代码的时候可以偷一下懒，把抽取方法交给idea去做。

具体的快捷键是Ctrl+Atl+M

使用了es之后，这几个接口就会直接从es里面去查询数据，我们只需要在新建流程的时候将数据同时存到es中就行了。这样速度就会快很多！！

今天就是这篇文章的总结了，如果你从中学到了一些皮毛，也希望鼓励一下博主，给博主一个点赞收藏加关注，就是博主继续创作的最大动力！！！