ElasticSearch入门- 设置分片副本数量及putMapping

在之前的一篇文章中，写到如何创建mapping。里面只是简单的创建了一个mapping。其实，这种比较重要并且一旦建立无法修改的操作还是需要仔细规划的。

今天我介绍设置index的分片数量及副本数量，即创建索引的如何指定分片的个数及副本的个数。分片的个数在创建之后是无法再增加和减少的，除非你另外建一个索引库，而副本是可以在运行的时候，动态增加和减少。因此，在创建索引库时，规划好分片（Shard)是非常重要的。

1、如何在创建index时，指定分片的个数？

其实代码也很简单。

Settings settings = ImmutableSettings.settingsBuilder()
				//5个主分片
                .put("number_of_shards", 5)
                //测试环境，减少副本提高速度
                .put("number_of_replicas", 0).build();

 在非生产环境，这个副本最好设置成0，即不保留副本，因为每增加一个副本，写数据的成本就增加一倍。本来elasticsearch写的速度就比较慢。

2、如果在创建Index时，顺便把type的mapping也创建？

//首先创建索引库
		CreateIndexResponse  indexresponse = client.admin().indices()
		//这个索引库的名称还必须不包含大写字母
		.prepareCreate("testindex").setSettings(settings)
		//这里直接添加type的mapping
		.addMapping("testType", getMapping())

 有几个type就addMapping几个。

综合起来的代码：

import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;

import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;

import com.donlianli.es.ESUtils;
/**
 * 创建索引时，指定分片及副本
 * 并且创建type一起执行
 * @author donlianli@126.com
 */
public class PutMappingTest {
	public static void  main(String[] argv) throws Exception{
		Client client = ESUtils.getClient();
		Settings settings = ImmutableSettings.settingsBuilder()
				//5个主分片
                .put("number_of_shards", 5)
                //测试环境，减少副本提高速度
                .put("number_of_replicas", 0).build();
		//首先创建索引库
		CreateIndexResponse  indexresponse = client.admin().indices()
		//这个索引库的名称还必须不包含大写字母
		.prepareCreate("testindex").setSettings(settings)
		//这里直接添加type的mapping
		.addMapping("testType", getMapping())
		.execute().actionGet();
		System.out.println(indexresponse.acknowledged());
	}
	/**
	 * mapping 一旦定义，之后就不能修改。
	 * @return
	 * @throws Exception
	 */
	private static XContentBuilder getMapping() throws Exception{
		XContentBuilder mapping = jsonBuilder()  
			       .startObject()  
			         .startObject("test")  
			         .startObject("properties")         
			           .startObject("id")
			           		.field("type", "long")
			           		.field("store", "yes")
			           	.endObject()    
			           	
			           .startObject("type")
			           		.field("type", "string")
			           		.field("index", "not_analyzed")
			           	.endObject()  
			           	
			           .startObject("catIds")
			           		.field("type", "integer")
			           .endObject()  
			         .endObject()  
			        .endObject()  
			      .endObject();  
		return mapping;
	}
}

 3、如果修改副本的数量？

import org.elasticsearch.action.admin.indices.settings.UpdateSettingsResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings;
import com.donlianli.es.ESUtils;
/**
 * 更新副本个数
 * @author donlianli@126.com
 */
public class UpdateReplicaTest {
	public static void  main(String[] argv) throws Exception{
		Client client = ESUtils.getClient();
		Settings settings =  ImmutableSettings.settingsBuilder()
                //可以更新的配置还有很多，见elasticsearch官网
                .put("number_of_replicas", 2).build();
		//首先创建索引库
		UpdateSettingsResponse  updateSettingsResponse = client.admin().indices()
		.prepareUpdateSettings("testindex").setSettings(settings).execute().actionGet();
		System.out.println(updateSettingsResponse);
	}

}