elasticsearch

private TransportClient client;
public void initClient() throws Exception{
		//提供一些连接es的信息 ip:port
		//准备一个配置对象,可以设置当前客户端连接的'
		//集群名称elasticsearch
		Settings set=Settings.builder().put("cluster.name","elasticsearch").build();
		client=new PreBuiltTransportClient(set);
		//为client赋值,底层使用的prepare预包装 提供ip端口
		InetSocketTransportAddress ista1=new InetSocketTransportAddress(InetAddress.getByName("10.42.141.101"), 9300);//代码插件,客户端连接es使用的9300
		InetSocketTransportAddress ista2=new InetSocketTransportAddress(InetAddress.getByName("10.42.145.240"), 9300);
		InetSocketTransportAddress ista3=new InetSocketTransportAddress(InetAddress.getByName("10.42.66.53"), 9300);
		
		//交给client三个地址对象,只要能联通一个节点就可以操作es
		client.addTransportAddress(ista1);
	}

public void indexManage(){
		//transportClient视同pre**实现方式,将所有访问的功能,都封装成了单独的request和response对象
		//首先需要在代码中封装对应功能的request对象,利用client接受响应
		//创建索引,需要先获取索引的管理对象
		AdminClient admin=client.admin();
		IndicesAdminClient indices=admin.indices();
		//新建索引,看不到代码的请求方式,看不到url
		//prepare前缀的方法都是获取一个request对象
		CreateIndexRequestBuilder request=indices.prepareCreate("index03");
		CreateIndexResponse response=request.get();
		response.isAcknowledged();
		response.isShardsAcked();
		response.remoteAddress();//看到当前的请求是哪个远程es节点返回的消息
		//对索引其他的操作
		indices.prepareDelete("");
		indices.prepareExists("");
	}

public void documentManage() throws JsonProcessingException{
		/*//获取文档,索引名称,类型名,索引id
		GetRequestBuilder request=client.prepareGet("index01","article","2");
		//获取响应结果
		GetResponse response=request.get();
		//将获取的document所有的数据封装了json字符串
		response.getSource();
		Map<String,Object> map=response.getSourceAsMap();
		String json=response.getSourceAsString();
		System.out.println(json);
		//删除document
		//client.prepareDelete(index,type,id)
		//新增document
		//测试 如何从数据库获取product 利用客户端将数据写进索引*/
		Product p=new Product();
		p.setProductCategory("1");
		p.setProductDescription("1");
		p.setProductId("1");
		p.setProductImgurl("1");
		p.setProductName("手机");
		p.setProductPrice(100.0);
		p.setProductNum(1);
		IndexRequestBuilder irRequest=client.prepareIndex("index02","product",p.getProductId());
		ObjectMapper mapper=new ObjectMapper();
		String pJson=mapper.writeValueAsString(p);
		irRequest.setSource(pJson);
		IndexResponse iResponse=irRequest.get();
		iResponse.getResult();
	}

	public void queryManage(){
		//client调用创建的搜索条件query,设置分页进行搜索
		//QueryBuilders.fuzzyQuery(name, value) 模糊查询
		MatchQueryBuilder query=QueryBuilders.matchQuery("productName", "手机");
		//client调用搜索实现数据获取
		SearchRequestBuilder request=client.prepareSearch("index02");
		//将参数配置交给请求对象
		//from相当于sql分页查询的start起始位置
		//size相当于rows
		SearchResponse response=request.setQuery(query).setFrom(0).setSize(5).get();
		SearchHits hits=response.getHits();
		System.out.println(hits.totalHits);
		System.out.println(hits.maxScore());
		SearchHit[] hits2=hits.getHits();
		for(SearchHit hit:hits2){
			String json=hit.getSourceAsString();
			System.out.println(json);
		}
	}