Elasticsearch 学习笔记

安装  Elasticsearch
1:解压下载的安装包 elasticsearch-1.7.2.zip
修改  cluster.name: es(集群状态名字一致)
2:在https://github.com/elasticsearch/elasticsearch-servicewrapper下载该插件后，解压缩。将service目录拷贝到elasticsearch目录的bin目录下。
3: 安装es-head插件
进入elasticsearch/bin目录，输入命令./plugin --install mobz/elasticsearch-head 安装head插件
4:将 Elasticsearch scp 到其他机器
5:启动 Elasticsearch
在linux环境，进入ES目录的bin/service目录，如下图，运行命令sh elasticsearch start  访问地址 http://hadoop1:9200/_plugin/head/



Elasticsearch JavaAPI

添加   Elasticsearch maven 依赖

 <dependency>
	<groupId>org.elasticsearch</groupId>
	<artifactId>elasticsearch</artifactId>
	<version>1.7.2</version>
</dependency>

package test;

import java.io.IOException;

import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;

import entity.User;
/*
 * 返回json 数据
 */
public class JsonUtil {
	public static String obj2JsonData(User user){
        String jsonData = null;
        try {
            //使用XContentBuilder创建json数据
            XContentBuilder jsonBuild = XContentFactory.jsonBuilder();
            jsonBuild.startObject()
            .field("id",user.getId())
            .field("name", user.getName())
            .field("pwd",user.getPwd())
            .endObject();
            jsonData = jsonBuild.string();
            System.out.println(jsonData);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return jsonData;
    }
}

package test;

import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.List;

import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;

import entity.User;

public class ElasticsearchTest {
	Client client;
  /*
   * 初始化client
   */
	public ElasticsearchTest() {
		client = new TransportClient()
				.addTransportAddress(new InetSocketTransportAddress("hadoop1",9300));
	}
    /*
     * 添加
     */
	public IndexResponse createIndexResponse(String indexname, String type,
			String jsondata) {
		IndexResponse response = client.prepareIndex(indexname, type)
				.setSource(jsondata).execute().actionGet();
		return response;
	}

	/**
	 * 执行搜索
	 * 
	 * @param queryBuilder
	 * @param indexname
	 * @param type
	 * @return
	 */
	public List<User> searcher(QueryBuilder queryBuilder, String indexname,
			String type) {
		List<User> list = new ArrayList<User>();
		SearchResponse searchResponse = client.prepareSearch(indexname)
				.setTypes(type).setQuery(queryBuilder).execute().actionGet();
		SearchHits hits = searchResponse.getHits();
		System.out.println("查询到记录数=" + hits.getTotalHits());
		SearchHit[] searchHists = hits.getHits();
		if (searchHists.length > 0) {
			for (SearchHit hit : searchHists) {
				Integer id = (Integer) hit.getSource().get("id");
				String name = (String) hit.getSource().get("name");
				String function = (String) hit.getSource().get("pwd");
				list.add(new User(id, name, function));
			}
		}
		return list;
	}

	public static void main(String[] args) {

		ElasticsearchTest es = new ElasticsearchTest();
//		User user = new User();
//		user.setId(1);
//		user.setName("张三");
//		user.setPwd("123");
//		String jsondata = JsonUtil.obj2JsonData(user);
		String indexname = "indexdemo";
		String type = "typedemo";
		// es.createIndexResponse(indexname, type, jsondata);
		// 查询条件
		QueryBuilder queryBuilder = QueryBuilders.termQuery("name", "张");
		/*
		 * QueryBuilder queryBuilder = QueryBuilders.boolQuery()
		 * .must(QueryBuilders.termQuery("id", 1));
		 */
		List<User> result = es.searcher(queryBuilder, indexname, type);
        for (User us : result) {
			System.out.println(us.getName());
		}
	}

}