我是靠谱客的博主 苹果荔枝,最近开发中收集的这篇文章主要介绍spring cloud 集成elasticsearch 实现findByIds查询,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

我们使用elasticsearch常使用它的分词查询,但是因为业务需要也需要使用多id查询,elasticsearch提供了MultiGetRequest实现多ids,多索引查询:

/**
     * 根据多个索引查询
     */
    public <T> List<T> findByIds(List<String> keys, Class<T> clazz) {
        RestHighLevelClient client=this.restHighLevelClient();
        try {
            if(null == keys || keys.size() == 0){
                return  null;
            }
            // 通过MultiGetRequest.Item对象设置查询参数
            MultiGetRequest request = new MultiGetRequest();
            String[] ids = new String[keys.size()];
            for(int i = 0;i< keys.size();i++){
                ids[i] = keys.get(i);
                request.add( "索引名", keys.get(i));
            }
            List<T>  productList = Lists.newArrayList();
            MultiGetResponse response = client.mget(request, RequestOptions.DEFAULT);
            log.info("ES-findById:id[{}],result:{}", JSON.toJSONString(keys),response.getResponses());
            if(!response.isFragment()){
                for(MultiGetItemResponse multiGetItemResponse :response.getResponses()){
                    GetResponse firstGet = multiGetItemResponse.getResponse();
                    if (firstGet.isExists()) {
                        String value =firstGet.getSourceAsString();
                        productList.add(JSONObject.parseObject(value,clazz)) ;
                    }
                }
            }
            return productList;
        } catch (Exception e) {
            throw new BizException(" findByIndexIds 搜索引擎异常:"+e.getMessage());
        }finally {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

最后

以上就是苹果荔枝为你收集整理的spring cloud 集成elasticsearch 实现findByIds查询的全部内容,希望文章能够帮你解决spring cloud 集成elasticsearch 实现findByIds查询所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(63)

评论列表共有 0 条评论

立即
投稿
返回
顶部