yaml配置文件
x
1
spring
2
elasticsearch
3
rest
4
urislocalhost9200
5
server
6
port9000
x
1
2
3
4
// 若ES中没有指定的索引，会自动创建。
5
// shards 分片数 replicas 副本数 refreshInterval 刷新间隔
6
(indexName = "item", type = "keyword",shards = 2, replicas = 3)
7
public class Person implements Serializable {
8
9
private String id;
10
11
private String userName;
12
(type = FieldType.Keyword)
13
private String passWord;
14
(type = FieldType.Integer)
15
private Integer age;
16
// text 类型的会分词
17
(type = FieldType.Text, analyzer = "")
18
private String comment;
19
}
service
xxxxxxxxxx
14
1
2
private ElasticsearchOperations elasticsearchOperations;
3
4
Person person=new Person();
5
person.setAge(11);
6
person.setUserName("张三");
7
person.setComment("onb");
8
person.setPassWord("onn");
9
person.setId("1");
10
IndexQuery indexQuery = new IndexQueryBuilder()
11
.withId(person.getId())
12
.withObject(person)
13
.build();
14
elasticsearchOperations.index(indexQuery);
kibana查询
x
1
{
2
"took" : 10,
3
"timed_out" : false,
4
"_shards" : {
5
"total" : 2,
6
"successful" : 2,
7
"skipped" : 0,
8
"failed" : 0
9
},
10
"hits" : {
11
"total" : {
12
"value" : 1,
13
"relation" : "eq"
14
},
15
"max_score" : 0.2876821,
16
"hits" : [
17
{
18
"_index" : "item",
19
"_type" : "keyword",
20
"_id" : "1",
21
"_score" : 0.2876821,
22
"_source" : {
23
"id" : "1",
24
"userName" : "张三",
25
"passWord" : "onn",
26
"age" : 11,
27
"comment" : "onb"
28
}
29
}
30
]
31
}
32
}
参考: