import org.springframework.data.elasticsearch.client.TransportClientFactoryBean; //导入依赖的package包/类
/**
 * 描述: Elasticsearch服务初始化
 * 时间: 2017年11月14日 上午10:55:02
 * @author yi.zhang
 */
public void init(String clusterName,String servers,String username,String password){
	try {
		TransportClientFactoryBean client = new TransportClientFactoryBean();
		client.setClusterName(clusterName);
		String clusterNodes = "";
		for(String server : servers.split(",")){
			String[] address = server.split(":");
			String ip = address[0];
			int port=9300;
			if(address.length>1){
				port = Integer.valueOf(address[1]);
			}
			if(StringUtil.isEmpty(clusterNodes)){
				clusterNodes = ip+":"+port;
			}else{
				clusterNodes +=","+ ip+":"+port;
			}
		}
		client.setClusterNodes(clusterNodes);
		if(!StringUtil.isEmpty(username)&&!StringUtil.isEmpty(password)){
			Properties properties = new Properties();
			properties.put("xpack.security.user",username+":"+password);
			client.setProperties(properties);
		}
		client.afterPropertiesSet();
		template = new ElasticsearchTemplate(client.getObject());
	} catch (Exception e) {
		logger.error("-----Elasticsearch Config init Error-----", e);
	}
}
 

import org.springframework.data.elasticsearch.client.TransportClientFactoryBean; //导入依赖的package包/类
private Client createTransportClient() throws Exception {
	TransportClientFactoryBean factory = new TransportClientFactoryBean();
	factory.setClusterNodes(this.properties.getClusterNodes());
	factory.setProperties(createProperties());
	factory.afterPropertiesSet();
	TransportClient client = factory.getObject();
	this.releasable = client;
	return client;
}