在ES中，涉及元信息主要有三种，分别为分片元信息、索引元信息、集群元信息（节点元信息），并且这些元信息会保留在磁盘上，这样在节点重启时即可从磁盘上读取对应元信息并恢复。
集群中每个分片都有属于自己的元信息，该元信息包括：
(资料图)
public final String indexUUID;public final boolean primary; public final AllocationId allocationId;对应的类图如下：
分片元信息在shard恢复时会被用到：
首先是GateWayAllocator在恢复主备分片时，会从集群各个节点获取对应分片元信息（节点读取分片元信息时会判断本地分片的indexUUID和索引的UUID相同），用于判断是否可以本地恢复，如果满足条件（如分片的allocatId在in_sync_allocations中）则会从本地恢复分片；其次是在创建IndexShard时，会判断本地分片的indexUUID是否和索引的UUID相同，如果不同则报错（避免分片或索引出现异常）。分片元信息会保存在磁盘上，作用：，对应文件路径路径：${data.path}/nodes/${node.id}/indices/${index.UUID}/${shard.id}/_state/state-xxx.st
实现元信息序列化的代码:
public void toXContent(XContentBuilder builder, ShardStateMetaData shardStateMetaData) throws IOException { builder.field(PRIMARY_KEY, shardStateMetaData.primary); builder.field(INDEX_UUID_KEY, shardStateMetaData.indexUUID); if (shardStateMetaData.allocationId != null) { builder.field(ALLOCATION_ID_KEY, shardStateMetaData.allocationId); }}分片被持久化的时机有两种方式，其一是分片被创建的时候，此时会分片的元信息持久化，其二是集群状态变化的时候（集群状态变化的时候，会判断分片状态是否变化，只有在当前分片的状态发生变化才更新本地文件，避免大量无效的IO）。
分片持久化的作用前面也提到了，主要是用于分片的恢复。
集群中每个索引都有属于自己的元信息，该元信息包括：
private final int routingNumShards; private final int routingPartitionSize;private final int numberOfShards;private final int numberOfReplicas; private final Index index; private final long version;private final long[] primaryTerms;private final State state;private final ImmutableOpenMap aliases;private final Settings settings;private final ImmutableOpenMap mappings;private final ImmutableOpenMap customs;private final ImmutableOpenIntMap> inSyncAllocationIds; 对应类图如下：
evernotecid://9B7AC1A3-2163-4103-A68D-1127DA246949/appyinxiangcom/8902081/ENResource/p3135
索引元信息主要是用于提供索引的配置信息以及mapping信息，以便对索引执行相应操作。
索引元信息会保存在磁盘上，作用：，对应文件路径路径：${data.path}/nodes/${node.id}/indices/${index.UUID}/_state/state-xxx.st
实现元信息序列化的代码:
public static void toXContent(IndexMetaData indexMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException { builder.startObject(indexMetaData.getIndex().getName()); builder.field(KEY_VERSION, indexMetaData.getVersion()); builder.field(KEY_ROUTING_NUM_SHARDS, indexMetaData.getRoutingNumShards()); builder.field(KEY_STATE, indexMetaData.getState().toString().toLowerCase(Locale.ENGLISH)); boolean binary = params.paramAsBoolean("binary", false); builder.startObject(KEY_SETTINGS); indexMetaData.getSettings().toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true"))); builder.endObject(); builder.startArray(KEY_MAPPINGS); for (ObjectObjectCursor cursor : indexMetaData.getMappings()) { if (binary) { builder.value(cursor.value.source().compressed()); } else { builder.map(XContentHelper.convertToMap(new BytesArray(cursor.value.source().uncompressed()), true).v2()); } } builder.endArray(); for (ObjectObjectCursor cursor : indexMetaData.getCustoms()) { builder.startObject(cursor.key); cursor.value.toXContent(builder, params); builder.endObject(); } builder.startObject(KEY_ALIASES); for (ObjectCursor cursor : indexMetaData.getAliases().values()) { AliasMetaData.Builder.toXContent(cursor.value, builder, params); } builder.endObject(); builder.startArray(KEY_PRIMARY_TERMS); for (int i = 0; i < indexMetaData.getNumberOfShards(); i++) { builder.value(indexMetaData.primaryTerm(i)); } builder.endArray(); builder.startObject(KEY_IN_SYNC_ALLOCATIONS); for (IntObjectCursor> cursor : indexMetaData.inSyncAllocationIds) { builder.startArray(String.valueOf(cursor.key)); for (String allocationId : cursor.value) { builder.value(allocationId); } builder.endArray(); } builder.endObject(); builder.endObject();} 索引原型被持久化的时机有两种方式，其一是节点启动时，此时如果如果索引元信息有发生变化，则会更新索引原型；其二是集群中索引的元信息变化时（如索引的mapping信息变化），此时会更新对应索引元信息；
索引元信息读取时机：
节点启动时用于恢复索引元信息：索引配置信息变更时判断索引元信息是否需要再次持久化：如果原来索引元信息不存在或发生变化则再次持久化分片删除时判断本节点索引元信息是否存在GateWayAllocator在恢复主备分片时，会从集群各个节点获取对应分片元信息（节点读取分片元信息时会判断本地分片的indexUUID和索引的UUID相同）集群的元信息包括：
private final String clusterUUID;private final long version;private final Settings transientSettings; private final Settings persistentSettings; private final Settings settings;private final ImmutableOpenMap indices; private final ImmutableOpenMap templates;private final ImmutableOpenMap customs;private final int numberOfShards; 对应类图如下：
evernotecid://9B7AC1A3-2163-4103-A68D-1127DA246949/appyinxiangcom/8902081/ENResource/p3147
集群元信息主要是用于提供集群以及索引相关的配置信息信息，以便对集群或索引上执行相应操作提供信息。
集群元信息会保存在磁盘上，作用：，对应文件路径路径：${data.path}/nodes/${node.id}/_state/global-xxx.st
实现元信息序列化的代码:
public static void toXContent(MetaData metaData, XContentBuilder builder, ToXContent.Params params) throws IOException { XContentContext context = XContentContext.valueOf(params.param(CONTEXT_MODE_PARAM, "API")); builder.startObject("meta-data"); builder.field("version", metaData.version()); builder.field("cluster_uuid", metaData.clusterUUID); if (!metaData.persistentSettings().isEmpty()) { builder.startObject("settings"); metaData.persistentSettings().toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true"))); builder.endObject(); } if (context == XContentContext.API && !metaData.transientSettings().isEmpty()) { builder.startObject("transient_settings"); metaData.transientSettings().toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true"))); builder.endObject(); } builder.startObject("templates"); for (ObjectCursor cursor : metaData.templates().values()) { IndexTemplateMetaData.Builder.toXContent(cursor.value, builder, params); } builder.endObject(); if (context == XContentContext.API && !metaData.indices().isEmpty()) { builder.startObject("indices"); for (IndexMetaData indexMetaData : metaData) { IndexMetaData.Builder.toXContent(indexMetaData, builder, params); } builder.endObject(); } for (ObjectObjectCursor cursor : metaData.customs()) { if (cursor.value.context().contains(context)) { builder.startObject(cursor.key); cursor.value.toXContent(builder, params); builder.endObject(); } } builder.endObject();} 集群元信息持久化时机有两个：其一是节点启动时验证集群的元信息有变化则会重新持久化，其二是集群的元信息发生变化（集群的配置发生变化）则会重新初始化。
索引元信息读取时机：节点启动时用于恢复索引集群元信息用于数据恢复。
节点的元信息包括：
private final String nodeId;对应类图如下：
evernotecid://9B7AC1A3-2163-4103-A68D-1127DA246949/appyinxiangcom/8902081/ENResource/p3148
节点元信息主要是用于在集群中唯一标记节点，以便ES在进行各项操作时能唯一区分节点。
节点元信息会保存在磁盘上，作用：，对应文件路径路径：${data.path}/nodes/${node.id}/_state/node-xxx.st
实现元信息序列化的代码:
public void toXContent(XContentBuilder builder, NodeMetaData nodeMetaData) throws IOException { builder.field(NODE_ID_KEY, nodeMetaData.nodeId);}节点元信息持久化时机：节点启动时会持久化，并且及时已经持久化了会再次写入目的是保证所有的路径上有最新的节点元信息。
索引元信息读取时机：节点启动时读取，如果节点元信息不存在则会为节点生成新的节点元信息。
关键词： ElasticsearchService Java
最新资讯
