1.maven pom 引入包
1
2
3
4
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
2.实体类TestLog.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
@Component
@Document(indexName = "apidemo",indexStoreType = "testLog", shards = 1,replicas = 0, refreshInterval = "-1")
public class TestLog implements Serializable {
// 必须指定一个id，
@Id
private String id;
private String message;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getMmessage() {
return message;
}
public void setMessage(String loginfo) {
this.message = loginfo;
}
}
*注意添加@Document注解参数
2.properties配置
1
2
3
spring.data.elasticsearch.client.reactive.endpoints=XXX.XXX.XXX.XXX:9300
spring.data.elasticsearch.client.reactive.connection-timeout=10s
spring.data.elasticsearch.client.reactive.socket-timeout=10s
*elasticsearch基本信息配置
3.接口继承调用
1
2
3
@Repository
public interface TestlogRepository extends ElasticsearchRepository<TestLog, String> {
}
*ElasticsearchRepository已经包含常用的查询等crud操作, 直接可使用
##4.方法中调用查询
1
2
3
4
5
6
7
@Autowired
private TestlogRepository testlogRepository;
@Test
void contextLoads() {
System.out.println(testlogRepository.findById("TJcu6XgBm56pu8b2mi35").get().getMessage());
}
*查询id为TJcu6XgBm56pu8b2mi35的es日志信息
