Service:

/**

* 添加文档

* @param obj

*/

public String createDoc(Object obj){

/**

* 设置索引，必须是小写，所以使用toLowerCase()方法进行转换

*/

IndexRequest request = new IndexRequest(obj.getClass().getSimpleName().toLowerCase());

/**

* 设置文档id。如果不设置，系统会自动生成

*/

//request.id("xxxx");

request.source(JSONObject.toJSONString(obj), XContentType.JSON);

try {

IndexResponse response = client.index(request, RequestOptions.DEFAULT);

log.info(JSONObject.toJSONString(response));

if(DocWriteResponse.Result.CREATED == response.getResult()){

return response.getId();

}

} catch (IOException e) {

e.printStackTrace();

}

return "";

}

/**

* 批量处理文档

* @param list 需要处理的文档列表

*/

public void createMultiDoc(List list){

BulkRequest request = new BulkRequest();

/**

* 遍历

* IndexRequest不设置id，让系统自己添加

* DeleteRequest 批量删除

* UpdateRequest 批量更新

*/

list.forEach((obj)->{

request.add(new IndexRequest(obj.getClass().getSimpleName().toLowerCase())

.source(JSONObject.toJSONString(obj), XContentType.JSON));

});

try {

BulkResponse bulkResponse = client.bulk(request,RequestOptions.DEFAULT);

log.info(JSONObject.toJSONString(bulkResponse));

bulkResponse.forEach((BulkItemResponse bulkItemResponse)->{

DocWriteResponse itemResponse = bulkItemResponse.getResponse();

switch (bulkItemResponse.getOpType()) {

case INDEX:

case CREATE:

IndexResponse indexResponse = (IndexResponse) itemResponse;

log.info(JSONObject.toJSONString(indexResponse));

if(DocWriteResponse.Result.CREATED == indexResponse.getResult()){

log.info("添加成功");

}

break;

case UPDATE:

UpdateResponse updateResponse = (UpdateResponse) itemResponse;

break;

case DELETE:

DeleteResponse deleteResponse = (DeleteResponse) itemResponse;

break;

default:break;

}

});

} catch (IOException e) {

e.printStackTrace();

}

}

测试类：

/**

* 测试添加文档

*/

@Test

public void createDoc(){

Article article = new Article();

article.setTitle("水调歌头·明月几时有");

article.setContent("丙辰中秋，欢饮达旦，大醉，作此篇，兼怀子由。\n" +

"\n" +

"明月几时有？把酒问青天。不知天上宫阙，今夕是何年。我欲乘风归去，又恐琼楼玉宇，高处不胜寒。起舞弄清影，何似在人间？(何似 一作：何时；又恐 一作：惟 / 唯恐)\n" +

"转朱阁，低绮户，照无眠。不应有恨，何事长向别时圆？人有悲欢离合，月有阴晴圆缺，此事古难全。但愿人长久，千里共婵娟。(长向 一作：偏向)");

article.setCreate_time(new Date());

String result = commodityServiceImpl.createDoc(article);

log.info("添加文档返回的id：{}",result);

}

/**

* 测试批量添加文档

*/

@Test

public void createMultiDoc(){

Article article1 = new Article();

article1.setTitle("声声慢·寻寻觅觅");

article1.setContent("寻寻觅觅，冷冷清清，凄凄惨惨戚戚。乍暖还寒时候，最难将息。三杯两盏淡酒，怎敌他、晚来风急？雁过也，正伤心，却是旧时相识。\n" +

"满地黄花堆积，憔悴损，如今有谁堪摘？守着窗儿，独自怎生得黑？梧桐更兼细雨，到黄昏、点点滴滴。这次第，怎一个愁字了得！(守着窗儿 一作：守著窗儿)测试春晚");

article1.setCreate_time(new Date());

Article article2 = new Article();

article2.setTitle("卜算子·咏梅");

article2.setContent("驿外断桥边，寂寞开无主。已是黄昏独自愁，更著风和雨。(著 同：着) \n" +

"无意苦争春，一任群芳妒。零落成泥碾作尘，只有香如故。");

article2.setCreate_time(new Date());

Article article3 = new Article();

article3.setTitle("武陵春·春晚");

article3.setContent("风住尘香花已尽，日晚倦梳头。物是人非事事休，欲语泪先流。\n" +

"闻说双溪春尚好，也拟泛轻舟。只恐双溪舴艋舟，载不动许多愁。测试寻寻觅觅咏梅.测试咏梅");

article3.setCreate_time(new Date());

List list = new ArrayList<>();

list.add(article1);

list.add(article2);

list.add(article3);

commodityServiceImpl.createMultiDoc(list);

}

运行测试类的批量添加之后控制台输出：

2019-09-21 00:31:08.468 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : {"fragment":false,"id":"LTODT20Bk6nS0BLhTTX_","index":"article","primaryTerm":1,"result":"CREATED","seqNo":0,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":1}

2019-09-21 00:31:08.468 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : 添加成功

2019-09-21 00:31:08.469 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : {"fragment":false,"id":"LjODT20Bk6nS0BLhTTX_","index":"article","primaryTerm":1,"result":"CREATED","seqNo":1,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":1}

2019-09-21 00:31:08.469 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : 添加成功

2019-09-21 00:31:08.469 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : {"fragment":false,"id":"LzODT20Bk6nS0BLhTTX_","index":"article","primaryTerm":1,"result":"CREATED","seqNo":2,"shardId":{"fragment":true,"id":-1,"index":{"fragment":false,"name":"article","uUID":"_na_"},"indexName":"article"},"shardInfo":{"failed":0,"failures":[],"fragment":false,"successful":1,"total":1},"type":"_doc","version":1}

2019-09-21 00:31:08.469 INFO 230324 --- [ main] c.z.e.service.impl.ServiceImpl : 添加成功

在kibana中查看mapping，发现实体类Article的create_time也出现了

{

"mapping": {

"properties": {

"content": {

"type": "text",

"analyzer": "ik_max_word"

},

"create_time": {

"type": "long"

},

"title": {

"type": "text",

"analyzer": "ik_max_word"

}

}

}

}

也可以在后台看到新创建的文档数量

在Dev Tools 页面执行GET /article/_search 查看：上面使用批量添加接口添加的文档已经出现了