elasticsearch的restful API和Java API-低调大师

elasticsearch的restful API和Java API

2018-08-29 632

本人现在使用的是elasticsearch 5.2.1的,服务器IP为192.168.5.182.所以在Java API和jar包中会有所不同.

常用的restful API如下:

http://192.168.5.182:9200/_cat/health?v 健康检查
http://192.168.5.182:9200/_cat/indices?v 查看索引
PUT http://192.168.5.182:9200/test_index?pretty 添加索引
DELETE http://192.168.5.182:9200/test_index 删除索引
PUT http://192.168.5.182:9200/ecommerce/product/1
BODY {

"name":"zhonghua yagao",
"desc":"caoben zhiwu",
"price":40,
"producer":"zhonghua producer",
"tags":["qingxin"]

} 为索引添加数据,ecommerce索引,product type,1 ID
GET http://192.168.5.182:9200/ecommerce/product/1 查询数据
PUT http://192.168.5.182:9200/ecommerce/product/1
BODY {

"name":"jiaqiangban zhonghua yagao",
"desc":"caoben zhiwu",
"price":40,
"producer":"zhonghua producer",
"tags":["qingxin"]

} 更新索引数据,方式一,必须带上所有数据
POST http://192.168.5.182:9200/ecommerce/product/1/_update
BODY {

"doc": {
    "name":"gaolujie yagao"
}

} 更新索引数据,方式二
DELETE http://192.168.5.182:9200/ecommerce/product/1 删除索引数据
GET http://192.168.5.182:9200/ecommerce/product/_search 搜索所有
GET http://192.168.5.182:9200/ecommerce/product/_search?q=name:yagao&sort=price:desc
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{
"query":{
 "match_all":{}
}
}'
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{
"query":{
    "match":{
         "name":"yagao"
    }
},
"sort":[
    {"price":"desc"}
]
}' 排序查询

curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{
"query":{
    "match_all":{}
},
"from":1,
"size":1
}' 分页查询

curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{
"query":{

    "match_all":{}

},
"_source":["name","price"]
}' 只查询指定的字段
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{

"query":{
 "bool":{
    "must":{
       "match":{
          "name":"yagao"
       }
    },
    "filter":{
       "range":{
          "price":{
             "gt":25
          }
       }
    }
 }
}
}' 查询yagao的price范围,大于25
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{
"query":{
  "match":{
     "producer":"yagao producer"
  }
}
}' 全文检索

curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{
"query":{

  "match_phrase":{
     "producer":"yagao producer"
  }

}
}' 短语搜索
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{
"query":{
   "match":{
      "producer":"producer"
   }
},
"highlight":{
   "fields":{
      "producer":{}
   }
}
}' 高亮显示
PUT http://192.168.5.182:9200/ecommerce/_mapping/product

BODY {

"properties":{
    "tags":{
        "type":"text",
        "fielddata":true
    }
}

} 将文本field的fielddata属性设置为true
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{
"aggs":{
    "group_by_tags":{
          "terms":{
               "field":"tags"
          }
    }
}
}' 对tags聚合,会显示明细
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{ "size":0,

"aggs":{
    "group_by_tags":{
          "terms":{
               "field":"tags"
          }
    }
}

}' 对tags聚合,不显示明细,只显示聚合
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{
"size":0,
"query":{

   "match":{
       "name":"yagao"
   }

},
"aggs":{

   "group_by_tags":{
       "terms":{
            "field":"tags"
       }
   }

}
}' 搜索包含条件的聚合
curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{

"size":0,
"aggs":{
     "group_by_tags":{
          "terms":{
               "field":"tags"
          },
          "aggs":{
               "avg_price":{
                     "avg":{
                           "field":"price"
                     }
               }
          }
     }
}

}' 聚合计算平均值

curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'

{

"size":0,
"aggs":{
   "group_by_tags":{
       "terms":{
           "field":"tags",
           "order":{
                "avg_price":"desc"
           }
       },
       "aggs":{
           "avg_price":{
                "avg":{
                      "field":"price"
                }
           }
       }
   }
}

}' 聚合后降序排序

curl -XGET 'http://192.168.5.182:9200/ecommerce/product/_search' -d'
{
"size":0,
"aggs":{

  "group_by_price":{
      "range":{
          "field":"price",
          "ranges":[
            {      
               "from":0,
               "to":20
            },        
            {      
               "from":20,
               "to":40
            },        
            {      
               "from":40,
               "to":60
            }
          ]
       },
       "aggs":{
          "group_by_tags":{
             "terms":{
                 "field":"tags"
             },
             "aggs":{
                 "average_price":{
                     "avg":{
                         "field":"price"
                     }
                 }
             }
          }
       }
  }

}
}' 按照价格区间分组后再聚合tags平均价格
PUT http://192.168.5.182:9200/company
BODY {

"mappings": {
        "employee": {
            "properties": {
                "age": {
                    "type": "long"
                },
                "country": {
                    "type": "text",
                    "fields": {
                        "keyword": {
                            "type": "keyword",
                            "ignore_above": 256
                        }
                    },
                    "fielddata":true
                },
                "join_date": {
                    "type": "date"
                },
                "name": {
                    "type": "text",
                    "fields": {
                        "keyword": {
                            "type": "keyword",
                            "ignore_above": 256
                        }
                    }
                },
                "position": {
                    "type": "text",
                    "fields": {
                        "keyword": {
                            "type": "keyword",
                            "ignore_above": 256
                        }
                    }
                },
                "salary": {
                    "type": "long"
                }
            }
        }
    }

} 给country建立正排索引

在Java API中,我们需要先找到相应的jar包,maven中的配置如下(开始之前请先执行上面的给country建立正排索引的restful API)

org.elasticsearch.client
transport
5.2.1

5.2.1中只需要配这一个就可以了,当然不同的版本配置的都不同,高版本的需要配

org.elasticsearch
elasticsearch

我们依然在resources文件中做如下配置(注意restful API中使用的是9200端口,而Java API使用的是9300端口)

elasticsearch:
clusterName: aubin-cluster
clusterNodes: 192.168.5.182:9300
配置类如下

@Getter
@Setter
@Configuration
@ConfigurationProperties(prefix = "elasticsearch")
public class ElasticSearchConfig {

private String clusterName;

private String clusterNodes;

/**
 * 使用elasticsearch实现类时才触发
 *
 * @return
 */

@Bean
public TransportClient transportClient() {

  // 设置集群名字
  Settings settings = Settings.builder().put("cluster.name", this.clusterName).build();
  TransportClient client = new PreBuiltTransportClient(settings);
  try {
     // 读取的ip列表是以逗号分隔的
     for (String clusterNode : this.clusterNodes.split(",")) {
        String ip = clusterNode.split(":")[0];
        String port = clusterNode.split(":")[1];
        client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(ip), Integer.parseInt(port)));
     }
  } catch (UnknownHostException e) {
     e.printStackTrace();
  }

  return client;

}
}
在5.2.1中使用的是InetSocketTransportAddress,这是一个具体的类,而在高版本中此处为TransportAddress,这是一个接口.

我们做一个数据类

@Component
public class DataEs {

@Autowired
private TransportClient transportClient;

/**
 * 添加原始数据
 * @throws IOException
 */
@PostConstruct
private void init() throws IOException {
    transportClient.prepareIndex("company","employee","1").setSource(XContentFactory.jsonBuilder().startObject()
            .field("name","jack")
            .field("age",27)
            .field("position","technique software")
            .field("country","China")
            .field("join_date","2018-01-01")
            .field("salary",10000)
            .endObject()).get();
    transportClient.prepareIndex("company","employee","2").setSource(XContentFactory.jsonBuilder().startObject()
            .field("name","marry")
            .field("age",35)
            .field("position","technique manager")
            .field("country","China")
            .field("join_date","2018-01-01")
            .field("salary",12000)
            .endObject()).get();
    transportClient.prepareIndex("company","employee","3").setSource(XContentFactory.jsonBuilder().startObject()
            .field("name","tom")
            .field("age",32)
            .field("position","senior technique software")
            .field("country","China")
            .field("join_date","2017-01-01")
            .field("salary",11000)
            .endObject()).get();
    transportClient.prepareIndex("company","employee","4").setSource(XContentFactory.jsonBuilder().startObject()
            .field("name","jen")
            .field("age",25)
            .field("position","junior finance")
            .field("country","USA")
            .field("join_date","2017-01-01")
            .field("salary",7000)
            .endObject()).get();
    transportClient.prepareIndex("company","employee","5").setSource(XContentFactory.jsonBuilder().startObject()
            .field("name","mike")
            .field("age",37)
            .field("position","finance manager")
            .field("country","USA")
            .field("join_date","2016-01-01")
            .field("salary",15000)
            .endObject()).get();
}

/**
 * 员工搜索应用程序
 * 搜索职位中包含technique的员工
 * 同时要求age在30到40岁之间
 * 分页查询,查找第一页
 */
public void executeSearch() {
    SearchResponse searchResponse = transportClient.prepareSearch("company")
            .setTypes("employee")
            .setQuery(QueryBuilders.matchQuery("position", "technique"))
            .setPostFilter(QueryBuilders.rangeQuery("age").from(30).to(40))
            .setFrom(0).setSize(1)
            .get();
    SearchHit[] hits = searchResponse.getHits().getHits();
    for (int i = 0;i < hits.length;i++) {
        System.out.println(hits[i].getSourceAsString());
    }
}

/**
 * 员工聚合分析应用程序
 * 首先按照country国家来进行分组
 * 然后在每个country分组内,再按照入职年限进行分组
 * 最后计算每个分组内的平均薪资
 */
public void executeAggregation() {
    SearchResponse searchResponse = transportClient.prepareSearch("company")
            .addAggregation(AggregationBuilders.terms("group_by_country").field("country")
            .subAggregation(AggregationBuilders.dateHistogram("group_by_join_date")
            .field("join_date").dateHistogramInterval(DateHistogramInterval.YEAR)
            .subAggregation(AggregationBuilders.avg("avg_salary").field("salary"))))
            .execute().actionGet();
    Map<String,Aggregation> aggrMap = searchResponse.getAggregations().asMap();
    StringTerms groupByCountry = (StringTerms) aggrMap.get("group_by_country");
    Iterator<StringTerms.Bucket> groupByCountryBucketIterator = groupByCountry.getBuckets().iterator();
    while (groupByCountryBucketIterator.hasNext()) {
        StringTerms.Bucket groupByCountryBucket = groupByCountryBucketIterator.next();
        System.out.println(groupByCountryBucket.getKey() + ":" + groupByCountryBucket.getDocCount());
        Histogram groupByJoinDate = (Histogram) groupByCountryBucket.getAggregations().asMap().get("group_by_join_date");
        Iterator<? extends Histogram.Bucket> groupByJoinDateIterator = groupByJoinDate.getBuckets().iterator();
        while (groupByJoinDateIterator.hasNext()) {
            Histogram.Bucket groupByJoinDateBucket = groupByJoinDateIterator.next();
            System.out.println(groupByJoinDateBucket.getKey() + ":" + groupByJoinDateBucket.getDocCount());
            Avg avg = (Avg) groupByJoinDateBucket.getAggregations().asMap().get("avg_salary");
            System.out.println(avg.getValue());
        }
    }
}
public void close() {
    transportClient.close();
}

}
在主程序中调用如下(一般我们可以先不执行搜索操作,先注入数据,因为elasticsearch本身有一个秒级写读的问题,如果数据写入,得需要1秒的时间才能读取出来)

@SpringBootApplication
public class EsApplication {
public static void main(String[] args) {

  ApplicationContext applicationContext = SpringApplication.run(EsApplication.class, args);
  DataEs dataEs = (DataEs) applicationContext.getBean(DataEs.class);
  dataEs.executeSearch();
  dataEs.executeAggregation();
  dataEs.close();

}
}

微信关注我们

原文链接：https://yq.aliyun.com/articles/631090

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

iOS objc_msgSend尾调用优化详解

这篇文章将认真彻底地分析 OC对objc_msgSend的尾调用优化。 Q1：什么是尾调用？尾调用（Tail Call）：某个函数的最后一步仅仅只是调用了一个函数（可以是自身，可以是另一个函数）。提醒：注意 “仅仅” 两个字。尾调用例子： // 尾调用： - (NSInteger)funcA:(NSInteger)num { /* Some codes... */ if (num == 0) { return [self funcA:num];// 尾调用->自身 } if (num > 0) { return [self funcB:num];// 尾调用->函数funcB } return [self funcC:num];// 尾调用->函数funcC } 正例解释：funcA的最后一步仅仅调用了另一个函数。不论是调用funcA、funcB还是funcC都属于尾调用。~（不论调用函数的位置在哪，只要最后一步仅仅调用一个函数就行）~ 反例：不是尾调用的例子 // 不是尾调用1： - (NSInteger)funcA:(NSInteger)num { NS...

2018-08-30

899

阿里云总监系列课重磅上线！聚焦人工智能、弹性计算、数据库等热门领域，首次集齐12位阿里云技术高管，耗时半年精心打磨，从理论到实践倾囊相授，从零开始绘制技术大牛成长路径。第二期《如何打造智能语音交互爆款产品？》特邀阿里云资深算法专家鄢志杰，与志杰老师带领的机器智能技术实验室团队共同为大家带来干货分享。热点热议阿里云总监课第二期：如何打造智能语音交互爆款产品？作者：燕儿199606 谈谈“野生”Java程序员学习的道路！作者：技术小能手发表于：Java后端技术 DataOps 助力容量管理 - Project 迁移优化应用实践作者：技术小能手发表于：高效运维知识整理 (十六) 整合spring cloud云架构 -使用spring cloud Bus刷新配置作者：it芒果推荐Android两种屏幕适配方案作者：技术小能手发表于：终端研发部间隔调用方法（setInterval与setTimeout）作者：景凌凯建站程序--wordpress 作者：景凌凯嗨！这是一篇值得深入学习的控件-RecyclerView（源码解析篇）作者：技术小能手发表于：终端研发...

2018-08-30

698

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。