一,es簡介

Elasticsearch is a distributed, RESTful search and analytics engine capable of solving a growing number of use cases. (簡單說:es是用來解決增量資料的一個分散式,使用Restful搜尋和分析的引擎.)

二,es資料

三,使用Rest API簡單CRUD例項

import com.google.common.collect.Maps;
import com.lcj.okhttp.OkHttpUtil;
import okhttp3.OkHttpClient;
import
 
 okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.lang3.time.DateFormatUtils;

import java.util.Date;
import java.util.Map;

/**
 * @author lcj
 * @version 1.0
 * @description 簡單的使用rest api操作es
 * @Create 2017-06-21
 */
public class EsRestApi {

    /**
     * 建立索引文件
     */
    private static
 
 void createDocument(){
        //http://192.168.0.128:9200/index/type/id
        //method : put

        String url = "http://192.168.0.128:9200/book/book/14";

        Map<String,Object> book = Maps.newHashMap();
        book.put("name","使用okhttp的put方式增加index");
        book.put("author","lcj3");
        book.put("price"
 
,50.23);
        book.put("publishTime", DateFormatUtils.format(new Date(),"yyyy-MM-dd HH:mm:ss"));

        String result = OkHttpUtil.postOrPutOrDelete(url,book,null,OkHttpUtil.OkHttpMethod.PUT);

        System.out.println(result);

    }

    /**
     * 查詢文件
     */
    private static void getDocument(){
        String url = "http://192.168.0.128:9200/book/book/14";
        String result = OkHttpUtil.get(url,null,null);
        System.out.println(result);
    }

    /**
     * 更新文件
     */
    private static void updateDocument(){
        String url = "http://192.168.0.128:9200/book/book/14";

        Map<String,Object> book = Maps.newHashMap();
        book.put("author","lcj3");
        book.put("price",5340.23);

        String result = OkHttpUtil.postOrPutOrDelete(url,book,null,OkHttpUtil.OkHttpMethod.PUT);

        System.out.println(result);

    }

    /**
     * 刪除文件
     */
    private static void daleteDocument(){
        String url = "http://192.168.0.128:9200/book/book/14";

        String result = OkHttpUtil.postOrPutOrDelete(url,null,null,OkHttpUtil.OkHttpMethod.DELETE);

        System.out.println(result);

    }

    public static void main(String[] args) {
        //建立索引文件
        //createDocument();

        //查詢文件
        //getDocument();

        //更新文件
        //updateDocument();

        //刪除文件
        daleteDocument();
    }
}

四,接下來還有java api篇…