1、使用Jackson生成Index

public static IndexResponse getIndexResponseWithJackson(TransportClientclient) {
    IndexResponse response = null;
    try{
        //instance a json mapper
        ObjectMappermapper = new ObjectMapper();
        UserModel um = new UserModel();
        um.setId(111);
        um.setMessage("huangjinjin");
        um.setSendTime(new Date());
        //generate json
        byte[] json = mapper.writeValueAsBytes(um);
         response= client.prepareIndex
                ("twitter2", "tweet2", "2")
                .setSource(json, XContentType.JSON)
                .get();
    }catch (Exception e){
        e.printStackTrace();
    }
    returnresponse;

}

2、 使用XContentBuilder生成Index

public static IndexResponse getIndexResponseWithXContentBuilder(TransportClient client) {

    IndexResponse response = null;

    try{

        XContentBuilder builder = XContentFactory.jsonBuilder()

                .startObject() // 数组的话是 startArray(String

                .field("user", "kimchy")

                .field("postDate", new Date())

                .field("message", "trying out Elasticsearch")

                .endObject(); // 数组的话是 endArray()



        // String json = builder.string();// 甚至可以通过 builder 来代替 Jackson 转换

        response = client.prepareIndex("fendo", "fendodata")

                .setSource(builder).get();

    }catch (Exception e){

        e.printStackTrace();

    }

    return response;

}

使用Jackson需要时需要在pom.xml文件中引入

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.9.9</version>
</dependency>

掌握了如何使用Index API创建Document后，下面讲解如何使用Get Index获取Document。

public static GetResponse getGetResponse(TransportClient client,
                                         String index,
                                         String type,
                                         String id) {

    GetResponse response = client.prepareGet(index, type, id).get();
    return response;
}

测试获取Index

GetResponse getResponse = IndexGet.getGetResponse(client,"twitter2", "tweet2", "2");
String str = getResponse.getSourceAsString();
System.out.println(str);

使用GetResponse的getSourceAsString() 可以返回 JSON 字符串，这样反序列化就非常简单。

☆

往期精彩

☆

01 漫谈发版哪些事，好课程推荐

02 Linux的常用最危险的命令

03 精讲Spring Boot—入门+进阶+实例

04 优秀的Java程序员必须了解的GC哪些

05 互联网支付系统整体架构详解