免费网站软件下载,专业网站建设组织,建站系统是什么,网站建网站建设网站文章目录 Elaticsearch 学习笔记一、什么是 Elaticsearch #xff1f;二、Elaticsearch 安装1 es 安装2 问题解决3 数据格式 三、索引操作1 PUT 请求#xff1a;在postman中#xff0c;向 ES 服务器发 PUT 请求#xff08;PUT请求相当于创建的意思#xff09;2 GET 请求二、Elaticsearch 安装1 es 安装2 问题解决3 数据格式 三、索引操作1 PUT 请求在postman中向 ES 服务器发 PUT 请求PUT请求相当于创建的意思2 GET 请求GET 请求是获取的意思获取指定的索引3 GET 请求获取全部索引4 DELETE删除索引 四、文档操作1 POST请求创建文档2 GET请求查询文档3 GET请求条件查询4 GET请求分页查询5 GET请求查询后排序6 GET多条件查询7 GET范围查询8 PUT请求修改文档-全部覆盖在请求体内贴入需修改的数据9 DELETE请求删除文档10 全文检索与部分检索match_phrase match11 检索结果高亮显示12 聚合查询-平均值 五、Java API 操作1 创建maven项目添加依赖2 索引创建3 索引查看4 索引删除5 向索引新增元素6 在索引中修改元素7 在索引中查看元素8 在索引中删除元素9 在索引中批量新增元素10 在索引中批量删除元素11 高级查询-全量查询QueryBuilders.matchAllQuery()12 高级查询-条件查询QueryBuilders.termQuery()13 高级查询-分页查询:builder.from(x)builder.size(y)14 高级查询-查询排序builder.sort()15 高级查询-排除/包含字段builder.sort()16 高级查询-组合查询 Elaticsearch 学习笔记
一、什么是 Elaticsearch Elasticsearch 是一个分布式、RESTful 风格的搜索和数据分析引擎能够解决不断涌现出的各种用例。作为 ElasticStack 的核心它集中存储您的数据帮助您发现意料之中以及意料之外的情况。 The Elastic Stack包括 Elasticsearch、Kibana、Beats 和 Logstash (也称为 ELK Stack)能够安全可靠地获取任何来源、任何格式的数据然后实时地对数据进行搜索、分析和可视化。Elaticsearch简称为ESES 是一个开源的高扩展的分布式全文搜索引擎是整个 ElasticStack 技术栈的核心。它可以近乎实时的存储、检索数据本身扩展性很好可以扩展到上百台服务器处理 PB 级别的数据。 二、Elaticsearch 安装
1 es 安装 Elaticsearch 官网地址https://www.elastic.co/cn/ 由于我的环境是 windows 环境因此下载 windows 安装包即可。
下载完windows 安装包后直接解压即可 注意9300端口为 es 集群间通信的端口9200为浏览器访问的 http 协议 的restful 端口。
启动后浏览器访问
http://localhost:9200/出现以下页面则成功启动 2 问题解决 es 是使用 java 开发的且 7.8 版本的 es 需要jdk 1.8以上默认安装包带有 jdk 环境如果系统配置 JAVA HOME那么使用系统默认的 jdk如果没有配置使用自带的 jdk一般建议使用系统配置的 jdk。 双击启动窗口闪退通过路径访问追踪错误如果是“空间不足”请修改 config/jvm.options 配置文件 # 设置 JVM 初始内存为1G。此值可以设置与-Xmx 相同以避免每次垃圾回收完成后 JVM 重新分配内存
# Xms represents the initial size of total heap space
# 设置 JVM 最大可用内存为 1G
# Xmx represents the maximum size of total heap space
-Xms1g
-Xmx1g 3 数据格式
Elasticsearch 是面向文档型数据库一条数据在这里就是一个文档。为了方便理解我们将 Elasticsearch 里存储文档数据和关系型数据库 MySQL 存储数据的概念进行一个类比 ES 里的 Index 可以看作一个库而 Types 相当于表Documents 则相当于表的行。
三、索引操作 对比关系型数据库创建索引就等同于创建数据库。 1 PUT 请求在postman中向 ES 服务器发 PUT 请求PUT请求相当于创建的意思
http://127.0.0.1:9200/shopping2 GET 请求GET 请求是获取的意思获取指定的索引
http://127.0.0.1:9200/shopping3 GET 请求获取全部索引
http://127.0.0.1:9200/_cat/indices?v4 DELETE删除索引
http://127.0.0.1:9200/shopping四、文档操作
1 POST请求创建文档
http://127.0.0.1:9200/shopping/_doc{title: 小米手机,category: 小米,images: https://ts1.cn.mm.bing.net/th?idOIP-C.NelZaFZYimRWyjjIrjd-QQHaGMw273h228c8rs1qlt90o6pid3.1rm2,price: 3999.00
}这里的id是随机生成的也可以采用put请求直接传入id
http://127.0.0.1:9200/shopping/_doc/10012 GET请求查询文档
如果只查询某个指定的id则在路径中直接指定即可
// 在路径中指定id
http://127.0.0.1:9200/shopping/_doc/1001如果要查询全部
// 指定index并且使用_search
http://127.0.0.1:9200/shopping/_search3 GET请求条件查询
http://127.0.0.1:9200/shopping/_search?qcategory:小米上述条件会查询出所有 category 字段为小米的元素。
直接在请求路径中拼接中文很有可能会乱码因此我们采用请求体查询
http://127.0.0.1:9200/shopping/_search{query : {match: {category : 小米}}
}4 GET请求分页查询
在请求体中加入from和size即可。
http://127.0.0.1:9200/shopping/_search{query : {match: {category : 小米}},from: 0,size: 2
}5 GET请求查询后排序
http://127.0.0.1:9200/shopping/_search{query : {match: {category : 小米}},from: 0,size: 2,sort: {price: {order: desc // asc}}
}6 GET多条件查询
http://127.0.0.1:9200/shopping/_search{query : {bool: {must: [{match: {category: 小米}}, // 多条件{match: {price: 4999.00}} // 多条件]}},from: 0,size: 2,sort: {price: {order: desc // asc}}
}一个条件符合多值
{query : {bool: {should: [ // 一个条件符合多值{match: {category: 小米}}, // 多值{match: {category: 华为}} // 多值]}},from: 0,size: 2,sort: {price: {order: desc // asc}}
}7 GET范围查询
http://127.0.0.1:9200/shopping/_search{query : {bool: {must: [{match: {category: 小米}}],filter :{range: {price: {gt: 3000, // 大于3000 小于8000lt: 8000}}}}},from: 0,size: 2,sort: {price: {order: desc // asc}}
}8 PUT请求修改文档-全部覆盖在请求体内贴入需修改的数据
http://127.0.0.1:9200/shopping/_doc/1001{title: 小米手机,category: 小米,images: https://ts1.cn.mm.bing.net/th?idOIP-C.NelZaFZYimRWyjjIrjd-QQHaGMw273h228c8rs1qlt90o6pid3.1rm2,price: 4999.00
}如果只修改指定的属性则使用post请求
http://127.0.0.1:9200/shopping/_update/10019 DELETE请求删除文档
http://127.0.0.1:9200/shopping/_doc/100110 全文检索与部分检索match_phrase match
http://127.0.0.1:9200/shopping/_search此处使用match是全文检索es会把小华拆分成小、华两个字符单独匹配因此查询结果会把字段category 包含小字、华字的元素都查询出来。
如果要实现完全匹配则使用match_phrase 。
{query : {bool: {must: [{match_phrase: {category: 小华}}]}}
}这时查询出来的结果集就是category 为小华的元素如果没有则是null。 11 检索结果高亮显示
http://127.0.0.1:9200/shopping/_search{query : {bool: {must: [{match_phrase: {category: 小米}}]}},highlight: {fields : {category: {} // 对category这个字段进行高亮显示}}
}12 聚合查询-平均值
http://127.0.0.1:9200/shopping/_search聚合查询
{ aggs : {price_group【价格分组】: {terms: {field: price}}}
}求平均值
{ aggs : {price_avg【价格平均值】: {avg: {field: price}}}
}五、Java API 操作 Elasticsearch 软件是由Java 语言开发的所以也可以通过 Java API 的方式对 Elasticsearch 服务进行访问。 1 创建maven项目添加依赖
!-- es 依赖 --
dependencygroupIdorg.elasticsearch/groupIdartifactIdelasticsearch/artifactIdversion7.8.0/version
/dependency!-- es的客户端 --
dependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion7.8.0/version
/dependency创建客户端连接
public class ESTestClient {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
}2 索引创建
public class ESTestCreatIndex {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 创建索引CreateIndexRequest user new CreateIndexRequest(user); // user: 索引名try {CreateIndexResponse createIndexResponse esClient.indices().create(user, RequestOptions.DEFAULT);// 响应状态boolean acknowledged createIndexResponse.isAcknowledged();System.out.println(索引操作 acknowledged);} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}}3 索引查看
public class ESTestCreatIndex {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询索引GetIndexRequest request new GetIndexRequest(user); // 获取user索引try {GetIndexResponse getIndexResponse esClient.indices().get(request, RequestOptions.DEFAULT);System.out.println(getIndexResponse.getAliases());System.out.println(getIndexResponse.getMappings());System.out.println(getIndexResponse.getSettings());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}}4 索引删除
public class ESTestDeleteIndex {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 删除索引DeleteIndexRequest request new DeleteIndexRequest(user); // 删除user索引try {AcknowledgedResponse deleteResponse esClient.indices().delete(request, RequestOptions.DEFAULT);System.out.println(deleteResponse.isAcknowledged());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}}5 向索引新增元素
public class ESTestDocInsert {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 插入数据IndexRequest request new IndexRequest();request.index(user).id(1004);User user new User();user.setName(张三);user.setAge(20);user.setSex(男);try {// 向es插入数据必须将数据转换为json格式ObjectMapper objectMapper new ObjectMapper();String userJson objectMapper.writeValueAsString(user);request.source(userJson, XContentType.JSON);IndexResponse response esClient.index(request, RequestOptions.DEFAULT);System.out.println(response.getResult());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
}6 在索引中修改元素
public class ESTestDocUpdate {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 更新数据UpdateRequest request new UpdateRequest();request.index(user).id(1004); // 传入索引和idrequest.doc(XContentType.JSON, sex, 女); // 把性别改为女try {UpdateResponse response esClient.update(request, RequestOptions.DEFAULT);System.out.println(response.getResult());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
}7 在索引中查看元素
public class ESTestDocGet {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据GetRequest request new GetRequest();request.index(user).id(1004); // 传入索引和idtry {GetResponse response esClient.get(request, RequestOptions.DEFAULT);System.out.println(response.getSourceAsString());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
}8 在索引中删除元素
public class ESTestDocDelete {public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 删除数据DeleteRequest request new DeleteRequest();request.index(user).id(1004); // 传入索引和idtry {DeleteResponse response esClient.delete(request, RequestOptions.DEFAULT);System.out.println(response.getResult());} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
}9 在索引中批量新增元素
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 批量插入数据BulkRequest request new BulkRequest();for (int i 0; i 3; i) {IndexRequest indexRequest new IndexRequest(user).id(1001 i).source(XContentType.JSON, name, 张三 i);request.add(indexRequest);}try {BulkResponse response esClient.bulk(request, RequestOptions.DEFAULT);System.out.println(response.getTook()); // 花费的时间System.out.println(response.getItems()); // 多个响应} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}10 在索引中批量删除元素
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 批量删除数据BulkRequest request new BulkRequest();for (int i 0; i 3; i) {DeleteRequest indexRequest new DeleteRequest(user).id(1001 i);request.add(indexRequest);}try {BulkResponse response esClient.bulk(request, RequestOptions.DEFAULT);System.out.println(response.getTook()); // 花费的时间System.out.println(response.getItems()); // 多个响应} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}11 高级查询-全量查询QueryBuilders.matchAllQuery()
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 高级查询-全量查询SearchRequest request new SearchRequest();request.indices(user);request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 按字符串打印元素的全部属性System.out.println(hit); // 一个元素的全部数据 json 格式System.out.println(hit.getId()); // 打印id}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}12 高级查询-条件查询QueryBuilders.termQuery()
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 高级查询-全量查询SearchRequest request new SearchRequest();request.indices(user);request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery(age, 22))); // 把年龄为22岁的查询出来try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 按字符串打印元素的全部属性System.out.println(hit); // 一个元素的全部数据 json 格式System.out.println(hit.getId()); // 打印id}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}13 高级查询-分页查询:builder.from(x)builder.size(y)
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据SearchRequest request new SearchRequest();request.indices(user);SearchSourceBuilder builder new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());builder.from(0); // 从第几条数据开始builder.size(3); // 每页查询3条数据request.source(builder);try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 只打印name}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}14 高级查询-查询排序builder.sort()
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据SearchRequest request new SearchRequest();request.indices(user);SearchSourceBuilder builder new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());builder.sort(age, SortOrder.DESC); // SortOrder.ASCrequest.source(builder);try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 只打印name}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}15 高级查询-排除/包含字段builder.sort()
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据SearchRequest request new SearchRequest();request.indices(user);SearchSourceBuilder builder new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());String[] excludes {name}; // 排除某个字段String[] includes {}; // 包含某个字段builder.fetchSource(includes, excludes); // SortOrder.ASCrequest.source(builder);try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 只打印name}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}16 高级查询-组合查询
public static void main(String[] args) {// 创建es客户端RestHighLevelClient esClient new RestHighLevelClient(RestClient.builder(new HttpHost(localhost, 9200, http)));// 查询数据SearchRequest request new SearchRequest();request.indices(user);SearchSourceBuilder builder new SearchSourceBuilder();BoolQueryBuilder boolQueryBuilder QueryBuilders.boolQuery();boolQueryBuilder.must(QueryBuilders.matchQuery(age, 24)); // age必须是25boolQueryBuilder.mustNot(QueryBuilders.matchQuery(sex, 男)); // sex必须不能是男builder.query(boolQueryBuilder);request.source();try {SearchResponse response esClient.search(request, RequestOptions.DEFAULT);System.out.println(response.getHits().getTotalHits()); // 获取user索引中元素的个数System.out.println(response.getTook()); // 获取时间for (SearchHit hit : response.getHits()) {System.out.println(hit.getSourceAsString()); // 只打印name}} catch (IOException e) {e.printStackTrace();}// 关闭es客户端try {esClient.close();} catch (IOException e) {e.printStackTrace();}}
