GET /_analyze
{
  "analyzer": "standard",
  "text": "中華人民共和國"
}

GET /_analyze
{
  "analyzer": "ik_max_word",
  "text": "中華人民共和國"
}

GET /_analyze
{
  "analyzer": "ik_smart",
  "text": "中華人民共和國"
}

PUT index_name
{
  "mappings": {         # 設(shè)置 mappings
    "properties": {     # 屬性，固定寫法
      "city": {         # 字段名
        "type": "text", # city 字段的類型為 text
        "fields": {     # 多字段域，固定寫法
          "raw": {      # 子字段名稱
            "type":  "keyword"  # 子字段類型
            "ignore_above": 256  #在ElasticSearch中keyword，text類型字段ignore_above屬性(動(dòng)態(tài)映射默認(rèn)是256) ，表示最大的字段值長(zhǎng)度，超出這個(gè)長(zhǎng)度的字段將不會(huì)被索引，查詢不到，但是會(huì)存儲(chǔ)。
          }
        }
      }
    }
  }
}

<!--json文件轉(zhuǎn)json對(duì)象-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.54</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-io</artifactId>
            <version>1.3.2</version>
        </dependency>

package org.project.es.common.util;

import java.io.InputStream;
import org.apache.commons.io.IOUtils;
import com.alibaba.fastjson.JSONObject;
/**
 * 將json文件裝換為json對(duì)象
 * @author Administrator
 */
public class JsonUtil {
    public static JSONObject fileToJson(String fileName) {
        JSONObject json = null;
        try (
                InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream(fileName);
        ) {
            json = JSONObject.parseObject(IOUtils.toString(is, "utf-8"));
        } catch (Exception e) {
            System.out.println(fileName + "文件讀取異常" + e);
        }
        return json;
    }
    public static void main(String[] args) {
        String fileName = "doc/policy.json";
        JSONObject json = JsonUtil.fileToJson(fileName);
        System.out.println(json);
    }
}

public static void createIndex(RestHighLevelClient client,String index) throws IOException {
        // 1.創(chuàng)建索引 - 請(qǐng)求對(duì)象
        CreateIndexRequest request = new CreateIndexRequest(index);
        // 2.設(shè)置setting，也就是索引的基本配置信息，將setting添加到請(qǐng)求對(duì)象中
        Settings setting = Settings.builder()
                //設(shè)置分片數(shù),主分片數(shù)量一旦設(shè)置后就不能修改了
                .put("index.number_of_shards", 1)
                //索引的刷新時(shí)間間隔,索引更新多久才對(duì)搜索可見(即數(shù)據(jù)寫入es到可以搜索到的時(shí)間間隔，設(shè)置越小越靠近實(shí)時(shí)，但是索引的速度會(huì)明顯下降，),
                // 默認(rèn)為1秒，如果我們對(duì)實(shí)時(shí)搜索沒有太大的要求，反而更注重索引的速度，那么我們就應(yīng)該設(shè)置的稍微大一些，這里設(shè)置30s
                .put("index.refresh_interval", "30s")
                //每個(gè)節(jié)點(diǎn)上允許最多分片數(shù)
                .put("index.routing.allocation.total_shards_per_node", 3)
                //將數(shù)據(jù)同步到磁盤的頻率,為了保證性能，插入ES的數(shù)據(jù)并不會(huì)立刻落盤，而是首先存放在內(nèi)存當(dāng)中，
                // 等到條件成熟后觸發(fā)flush操作，內(nèi)存中的數(shù)據(jù)才會(huì)被寫入到磁盤當(dāng)中
                .put("index.translog.sync_interval", "30s")
                //每個(gè)主分片擁有的副本數(shù),副本數(shù)量可以修改
                .put("index.number_of_replicas", 1)
                //一次最多獲取多少條記錄
                .put("index.max_result_window", "10000000")
                .build();
        request.settings(setting);

        // 3.使用工具類將json文件轉(zhuǎn)換為json對(duì)象，添加到請(qǐng)求對(duì)象中
        JSONObject mapping = JsonUtil.fileToJson("doc/policy.json");
        request.mapping(mapping);

        // 4.發(fā)送請(qǐng)求，獲取響應(yīng)
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        boolean acknowledged = response.isAcknowledged();
        // 5.輸出響應(yīng)狀態(tài)
        System.out.println("操作狀態(tài) = " + acknowledged);
    }