ES写数据的基本程序

package com.znv.elasticsearch;

import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Random;

import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;


public class esTestData {
    private static TransportClient client = null;
    private static Random rnd = new Random();
    private static SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    private static final String startDate = "2017-01-01 00:00:00";


    private static long randomNum(long begin, long end)
    {
        long rtn = begin + (long)(Math.random() * (end - begin));
        if (rtn == begin || rtn == end)
        {
            return randomNum(begin,end);
        }
        return rtn;
    } 
   public  static Date randomDate(String beginDate, String endDate)
    {
        try
        {
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            Date start = format.parse(beginDate);
            Date end = format.parse(endDate);
            if (start.getTime() >= end.getTime())
            {
                return null;
            }
            long date = randomNum(start.getTime(),end.getTime());
            return new Date(date);
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        return null;
    }
 
  public static void initClient() {
        try {
            // on startup
            Settings settings = Settings.builder()
                    .put("cluster.name", "lv08-elasticsearch").build();
            client = new PreBuiltTransportClient(settings)
                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("10.45.157.130"), 9300));
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

    public static void closeClient() {
        client.close();
    }

 public static void bulkPutEs() {
        try {

            long t1 = System.currentTimeMillis();
            int n = 0;
            //写入10*1000条数据
            while (n++ < 10) {
                BulkRequestBuilder bulkRequest = client.prepareBulk();
                for (int i = 0; i < 1000; i++) {
                    int id = rnd.nextInt(1000);
                    String name = "名字" + id;
                    int gender = rnd.nextInt(2);
                    int age = rnd.nextInt(100);
                    Date enter_time = randomDate(startDate,df.format(new Date()));
                    bulkRequest.add(client.prepareIndex("test-total", "type1", String.valueOf(id)+String.valueOf(enter_time.getTime()))
                            .setSource(jsonBuilder()
                                            .startObject()
                                            .field("id", id)
                                            .field("name",name)
                                            .field("gender",gender)
                                            .field("age", age)
                                            .field("enter_time", enter_time)
                                            .endObject()
                            )
                    );
                }
               BulkResponse bulkResponse = bulkRequest.get();
                if (bulkResponse.hasFailures()) {
                    // process failures by iterating through each bulk response item
                    System.out.println(bulkRequest.toString());
                }
            }

            long ts = System.currentTimeMillis() - t1;
            System.out.println("cost "+ts +" ms.");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }


 public static void main(String []args) {
        initClient();
        bulkPutEs();
        closeClient();
    }

}