要將Spring Boot集成Elasticsearch日志,需要進行以下步驟:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
spring.data.elasticsearch.cluster-nodes=localhost:9200
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
@Document(indexName = "logs", type = "log")
public class Log {
@Id
private String id;
private String message;
// 其他字段和getter/setter方法
}
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
public interface LogRepository extends ElasticsearchRepository<Log, String> {
}
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class MyLogger {
@Autowired
private LogRepository logRepository;
public void log(String message) {
Log log = new Log();
log.setMessage(message);
logRepository.save(log);
}
}
這樣,當(dāng)調(diào)用log
方法時,日志會被保存到Elasticsearch中的logs
索引的log
類型中。
注意:上述步驟僅僅是一個簡單的示例,實際使用中可能還需要做一些其他的配置和處理,例如設(shè)置索引的分片和副本數(shù)量、自定義查詢等。