zoukankan      html  css  js  c++  java
  • ElasticSearch学习

    ElasticSearch这里用的是windows的7.6.1版本测试。

    kibana和ik分词器也是用的对应版本。

    跑起来遇到的问题

    1.ElasticSearch、kibana、ik版本要一致,不然跑不起来。

    2.ElasticSearch会提示用jdk11,jdk8跑起来也没问题。

    理论东西,不想看可以不看

    # ElasticSearch相关概念(术语)
    
    ## 3.1 概述
    
    Elasticsearch是面向文档(document oriented)的,这意味着它可以存储整个对象或文档(document)。然而它不仅仅是存储,还会索引(index)每个文档的内容使之可以被搜索。在Elasticsearch中,你可以对文档(而非成行成列的数据)进行索引、搜索、排序、过滤。Elasticsearch比传统关系型数据库如下:
    
    ```
    Relational DB -> Databases -> Tables -> Rows -> Columns
    Elasticsearch -> Indices   -> Types  -> Documents -> Fields
    ```
    
    ## 3.2 **Elasticsearch核心概念** 
    
    ### 3.2.1 索引 index
    
    一个索引就是一个拥有几分相似特征的文档的集合。比如说,你可以有一个客户数据的索引,另一个产品目录的索引,还有一个订单数据的索引。一个索引由一个名字来标识(必须全部是小写字母的),并且当我们要对对应于这个索引中的文档进行索引、搜索、更新和删除的时候,都要使用到这个名字。在一个集群中,可以定义任意多的索引。
    
    ### 3.2.2 类型 type
    
    在一个索引中,你可以定义一种或多种类型。一个类型是你的索引的一个逻辑上的分类/分区,其语义完全由你来定。通常,会为具有一组共同字段的文档定义一个类型。比如说,我们假设你运营一个博客平台并且将你所有的数据存储到一个索引中。在这个索引中,你可以为用户数据定义一个类型,为博客数据定义另一个类型,当然,也可以为评论数据定义另一个类型。
    
    ### 3.2.3 字段Field
    
    相当于是数据表的字段,对文档数据根据不同属性进行的分类标识
    
    ### 3.2.4 映射 mapping
    
    mapping是处理数据的方式和规则方面做一些限制,如某个字段的数据类型、默认值、分析器、是否被索引等等,这些都是映射里面可以设置的,其它就是处理es里面数据的一些使用规则设置也叫做映射,按着最优规则处理数据对性能提高很大,因此才需要建立映射,并且需要思考如何建立映射才能对性能更好。
    
    ### 3.2.5 文档 document
    
    一个文档是一个可被索引的基础信息单元。比如,你可以拥有某一个客户的文档,某一个产品的一个文档,当然,也可以拥有某个订单的一个文档。文档以JSON(Javascript Object Notation)格式来表示,而JSON是一个到处存在的互联网数据交互格式。
    
    在一个index/type里面,你可以存储任意多的文档。注意,尽管一个文档,物理上存在于一个索引之中,文档必须被索引/赋予一个索引的type。
    
    ### 3.2.6 接近实时 NRT
    
    Elasticsearch是一个接近实时的搜索平台。这意味着,从索引一个文档直到这个文档能够被搜索到有一个轻微的延迟(通常是1秒以内)
    
    ### 3.2.7 集群 cluster
    
    一个集群就是由一个或多个节点组织在一起,它们共同持有整个的数据,并一起提供索引和搜索功能。一个集群由一个唯一的名字标识,这个名字默认就是“elasticsearch”。这个名字是重要的,因为一个节点只能通过指定某个集群的名字,来加入这个集群
    
    ### 3.2.8 节点 node
    
    一个节点是集群中的一个服务器,作为集群的一部分,它存储数据,参与集群的索引和搜索功能。和集群类似,一个节点也是由一个名字来标识的,默认情况下,这个名字是一个随机的漫威漫画角色的名字,这个名字会在启动的时候赋予节点。这个名字对于管理工作来说挺重要的,因为在这个管理过程中,你会去确定网络中的哪些服务器对应于Elasticsearch集群中的哪些节点。
    
    一个节点可以通过配置集群名称的方式来加入一个指定的集群。默认情况下,每个节点都会被安排加入到一个叫做“elasticsearch”的集群中,这意味着,如果你在你的网络中启动了若干个节点,并假定它们能够相互发现彼此,它们将会自动地形成并加入到一个叫做“elasticsearch”的集群中。
    
    在一个集群里,只要你想,可以拥有任意多个节点。而且,如果当前你的网络中没有运行任何Elasticsearch节点,这时启动一个节点,会默认创建并加入一个叫做“elasticsearch”的集群。
    
    ### 3.2.9 分片和复制 shards&replicas
    
    一个索引可以存储超出单个结点硬件限制的大量数据。比如,一个具有10亿文档的索引占据1TB的磁盘空间,而任一节点都没有这样大的磁盘空间;或者单个节点处理搜索请求,响应太慢。为了解决这个问题,Elasticsearch提供了将索引划分成多份的能力,这些份就叫做分片。当你创建一个索引的时候,你可以指定你想要的分片的数量。每个分片本身也是一个功能完善并且独立的“索引”,这个“索引”可以被放置到集群中的任何节点上。分片很重要,主要有两方面的原因: 
    1)允许你水平分割/扩展你的内容容量。 
    2)允许你在分片(潜在地,位于多个节点上)之上进行分布式的、并行的操作,进而提高性能/吞吐量。
    
    至于一个分片怎样分布,它的文档怎样聚合回搜索请求,是完全由Elasticsearch管理的,对于作为用户的你来说,这些都是透明的。
    
    在一个网络/云的环境里,失败随时都可能发生,在某个分片/节点不知怎么的就处于离线状态,或者由于任何原因消失了,这种情况下,有一个故障转移机制是非常有用并且是强烈推荐的。为此目的,Elasticsearch允许你创建分片的一份或多份拷贝,这些拷贝叫做复制分片,或者直接叫复制。
    
    复制之所以重要,有两个主要原因: 在分片/节点失败的情况下,提供了高可用性。因为这个原因,注意到复制分片从不与原/主要(original/primary)分片置于同一节点上是非常重要的。扩展你的搜索量/吞吐量,因为搜索可以在所有的复制上并行运行。总之,每个索引可以被分成多个分片。一个索引也可以被复制0次(意思是没有复制)或多次。一旦复制了,每个索引就有了主分片(作为复制源的原来的分片)和复制分片(主分片的拷贝)之别。分片和复制的数量可以在索引创建的时候指定。在索引创建之后,你可以在任何时候动态地改变复制的数量,但是你事后不能改变分片的数量。
    
    默认情况下,Elasticsearch中的每个索引被分片5个主分片和1个复制,这意味着,如果你的集群中至少有两个节点,你的索引将会有5个主分片和另外5个复制分片(1个完全拷贝),这样的话每个索引总共就有10个分片。
    View Code

    下面执行都是在kibana(直接bat启动就可以)的控制台执行的,在postman、elasticsearch-head-master(包下载不下来放弃了)都可以执行

    一.新建索引

         在7.0以前版本mappings下面还会有Type这一层,类型表。7.0默认为_doc,8.0以后这一层直接没有了

    PUT index4
    {
      //映射 
      "mappings": {
        //属性 也叫字段
        "properties":{
          "id":{"type":"long"},
          "name":{
            // 字段类型
            "type":"text", 
            "store": true,
            "index": true,
            //用的分词器 ik的ik_smart模式
            "analyzer": "ik_smart"
          },
          "text":{
            "type":"text", 
            "store": true,
            "index": true,
            "analyzer": "ik_smart"}
        }
      }
    }

    查询索引结构

    GET index4

    结果:

    {
      "index4" : {
        "aliases" : { },
        "mappings" : {
          "properties" : {
            "id" : {
              "type" : "long"
            },
            "name" : {
              "type" : "text",
              "store" : true,
              "analyzer" : "ik_smart"
            },
            "text" : {
              "type" : "text",
              "store" : true,
              "analyzer" : "ik_smart"
            }
          }
        },
        "settings" : {
          "index" : {
            "creation_date" : "1611411497126",
            "number_of_shards" : "1",
            "number_of_replicas" : "1",
            "uuid" : "VOYwc8swQMaifgoWMLN00w",
            "version" : {
              "created" : "7060199"
            },
            "provided_name" : "index4"
          }
        }
      }
    }

    二.添加数据

    下面_doc必须带,感觉有点多余

    POST index4/_doc
    {
      "id":1,
      "name":"张三34国家",
      "text":"好好学习,天天向上34国家"
    }

    查询所有数据

    GET index4/_search
    GET index4/_doc/_search

    结果

    {
      "took" : 0,
      "timed_out" : false,
      "_shards" : {
        "total" : 1,
        "successful" : 1,
        "skipped" : 0,
        "failed" : 0
      },
      "hits" : {
        "total" : {
          "value" : 1,
          "relation" : "eq"
        },
        "max_score" : 1.0,
        "hits" : [
          {
            "_index" : "index4",
            "_type" : "_doc",
            "_id" : "vu-cL3cB0aX2dlMHwQ87",
            "_score" : 1.0,
            "_source" : {
              "id" : 1,
              "name" : "张三34国家",
              "text" : "好好学习,天天向上34国家"
            }
          }
        ]
      }
    }

    三.查询

    3.1查询的字符不分词

    POST index4/_search
    {
      "query": {
        "term": {
          "name": "国家"
        }
      }
    }

    结果

    {
      "took" : 0,
      "timed_out" : false,
      "_shards" : {
        "total" : 1,
        "successful" : 1,
        "skipped" : 0,
        "failed" : 0
      },
      "hits" : {
        "total" : {
          "value" : 1,
          "relation" : "eq"
        },
        "max_score" : 0.2876821,
        "hits" : [
          {
            "_index" : "index4",
            "_type" : "_doc",
            "_id" : "vu-cL3cB0aX2dlMHwQ87",
            "_score" : 0.2876821,
            "_source" : {
              "id" : 1,
              "name" : "张三34国家",
              "text" : "好好学习,天天向上34国家"
            }
          }
        ]
      }
    }

    3.2查询文字分词

    先将查询的文本分词,再将每个分词的文本都去匹配

    POST index4/_search
    {
      "query": {
        "query_string": {
          "default_field": "name",
          "query": "国家人民",
          "analyzer": "ik_smart"
        }
      }
    }

    结果:

    {
      "took" : 1,
      "timed_out" : false,
      "_shards" : {
        "total" : 1,
        "successful" : 1,
        "skipped" : 0,
        "failed" : 0
      },
      "hits" : {
        "total" : {
          "value" : 1,
          "relation" : "eq"
        },
        "max_score" : 0.2876821,
        "hits" : [
          {
            "_index" : "index4",
            "_type" : "_doc",
            "_id" : "vu-cL3cB0aX2dlMHwQ87",
            "_score" : 0.2876821,
            "_source" : {
              "id" : 1,
              "name" : "张三34国家",
              "text" : "好好学习,天天向上34国家"
            }
          }
        ]
      }
    }

    四.分词器

    这里用到的是ik分词器,先说下分词器的概率。

    如:中文“我是中国人” :分词器会将该此分词为 “我”、“是”、“中国”、“人”来分词存储

    IK提供了两个分词算法ik_smart 和 ik_max_word

    其中 ik_smart 为最少切分,ik_max_word为最细粒度划分 我们分别来试一下

    测试分词结果:

    GET _analyze
    {
      "analyzer": "ik_smart",
      "text" : "我是中国人"
    }

    结果:

    {
      "tokens" : [
        {
          "token" : "我",
          "start_offset" : 0,
          "end_offset" : 1,
          "type" : "CN_CHAR",
          "position" : 0
        },
        {
          "token" : "是",
          "start_offset" : 1,
          "end_offset" : 2,
          "type" : "CN_CHAR",
          "position" : 1
        },
        {
          "token" : "中国人",
          "start_offset" : 2,
          "end_offset" : 5,
          "type" : "CN_WORD",
          "position" : 2
        }
      ]
    }

    广度分词:

    GET _analyze
    {
      "analyzer": "ik_max_word",
      "text" : "我是中国人"
    }
    {
      "tokens" : [
        {
          "token" : "我",
          "start_offset" : 0,
          "end_offset" : 1,
          "type" : "CN_CHAR",
          "position" : 0
        },
        {
          "token" : "是",
          "start_offset" : 1,
          "end_offset" : 2,
          "type" : "CN_CHAR",
          "position" : 1
        },
        {
          "token" : "中国人",
          "start_offset" : 2,
          "end_offset" : 5,
          "type" : "CN_WORD",
          "position" : 2
        },
        {
          "token" : "中国",
          "start_offset" : 2,
          "end_offset" : 4,
          "type" : "CN_WORD",
          "position" : 3
        },
        {
          "token" : "国人",
          "start_offset" : 3,
          "end_offset" : 5,
          "type" : "CN_WORD",
          "position" : 4
        }
      ]
    }
  • 相关阅读:
    键盘事件
    冒泡事件-捕获事件-阻止事件
    Date()常用属性
    dom树节点的增删改插
    boost/c++11 变量类型打印、相等判断以及成员函数指针相关
    c++ std:call_once 与 单例模式实现
    c++11 异步编程 std::async
    c++ STL中一些常用函数/模板
    c++11 std::atomic 原子操作
    C++ std::atomic_flag 实现spinLock
  • 原文地址:https://www.cnblogs.com/zhuyapeng/p/14319485.html
Copyright © 2011-2022 走看看