Merge branch '2.1.x'

Closes gh-17486
This commit is contained in:
Madhura Bhave 2019-07-10 15:32:22 -07:00
commit d590c3ed10
8 changed files with 60 additions and 39 deletions

View File

@ -16,6 +16,7 @@
package org.springframework.boot.actuate.autoconfigure.logging; package org.springframework.boot.actuate.autoconfigure.logging;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnAvailableEndpoint; import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnAvailableEndpoint;
import org.springframework.boot.actuate.logging.LogFileWebEndpoint; import org.springframework.boot.actuate.logging.LogFileWebEndpoint;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
@ -48,8 +49,9 @@ public class LogFileWebEndpointAutoConfiguration {
@Bean @Bean
@ConditionalOnMissingBean @ConditionalOnMissingBean
@Conditional(LogFileCondition.class) @Conditional(LogFileCondition.class)
public LogFileWebEndpoint logFileWebEndpoint(Environment environment, LogFileWebEndpointProperties properties) { public LogFileWebEndpoint logFileWebEndpoint(ObjectProvider<LogFile> logFile,
return new LogFileWebEndpoint(environment, properties.getExternalFile()); LogFileWebEndpointProperties properties) {
return new LogFileWebEndpoint(logFile.getIfAvailable(), properties.getExternalFile());
} }
private static class LogFileCondition extends SpringBootCondition { private static class LogFileCondition extends SpringBootCondition {

View File

@ -19,6 +19,7 @@ package org.springframework.boot.actuate.autoconfigure.endpoint.web.documentatio
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.boot.actuate.logging.LogFileWebEndpoint; import org.springframework.boot.actuate.logging.LogFileWebEndpoint;
import org.springframework.boot.logging.LogFile;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import; import org.springframework.context.annotation.Import;
@ -56,7 +57,7 @@ class LogFileWebEndpointDocumentationTests extends MockMvcEndpointDocumentationT
@Bean @Bean
LogFileWebEndpoint endpoint(Environment environment) { LogFileWebEndpoint endpoint(Environment environment) {
return new LogFileWebEndpoint(environment); return new LogFileWebEndpoint(LogFile.get(environment), null);
} }
} }

View File

@ -25,7 +25,6 @@ import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
import org.springframework.boot.actuate.endpoint.annotation.ReadOperation; import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
import org.springframework.boot.actuate.endpoint.web.annotation.WebEndpoint; import org.springframework.boot.actuate.endpoint.web.annotation.WebEndpoint;
import org.springframework.boot.logging.LogFile; import org.springframework.boot.logging.LogFile;
import org.springframework.core.env.Environment;
import org.springframework.core.io.FileSystemResource; import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.Resource; import org.springframework.core.io.Resource;
@ -42,17 +41,13 @@ public class LogFileWebEndpoint {
private static final Log logger = LogFactory.getLog(LogFileWebEndpoint.class); private static final Log logger = LogFactory.getLog(LogFileWebEndpoint.class);
private final Environment environment;
private File externalFile; private File externalFile;
public LogFileWebEndpoint(Environment environment, File externalFile) { private final LogFile logFile;
this.environment = environment;
this.externalFile = externalFile;
}
public LogFileWebEndpoint(Environment environment) { public LogFileWebEndpoint(LogFile logFile, File externalFile) {
this(environment, null); this.externalFile = externalFile;
this.logFile = logFile;
} }
@ReadOperation(produces = "text/plain; charset=UTF-8") @ReadOperation(produces = "text/plain; charset=UTF-8")
@ -68,12 +63,11 @@ public class LogFileWebEndpoint {
if (this.externalFile != null) { if (this.externalFile != null) {
return new FileSystemResource(this.externalFile); return new FileSystemResource(this.externalFile);
} }
LogFile logFile = LogFile.get(this.environment); if (this.logFile == null) {
if (logFile == null) {
logger.debug("Missing 'logging.file.name' or 'logging.file.path' properties"); logger.debug("Missing 'logging.file.name' or 'logging.file.path' properties");
return null; return null;
} }
return new FileSystemResource(logFile.toString()); return new FileSystemResource(this.logFile.toString());
} }
} }

View File

@ -25,6 +25,7 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir; import org.junit.jupiter.api.io.TempDir;
import org.springframework.boot.logging.LogFile;
import org.springframework.core.io.Resource; import org.springframework.core.io.Resource;
import org.springframework.mock.env.MockEnvironment; import org.springframework.mock.env.MockEnvironment;
import org.springframework.util.FileCopyUtils; import org.springframework.util.FileCopyUtils;
@ -43,8 +44,6 @@ class LogFileWebEndpointTests {
private final MockEnvironment environment = new MockEnvironment(); private final MockEnvironment environment = new MockEnvironment();
private final LogFileWebEndpoint endpoint = new LogFileWebEndpoint(this.environment);
private File logFile; private File logFile;
@BeforeEach @BeforeEach
@ -55,19 +54,22 @@ class LogFileWebEndpointTests {
@Test @Test
void nullResponseWithoutLogFile() { void nullResponseWithoutLogFile() {
assertThat(this.endpoint.logFile()).isNull(); LogFileWebEndpoint endpoint = new LogFileWebEndpoint(null, null);
assertThat(endpoint.logFile()).isNull();
} }
@Test @Test
void nullResponseWithMissingLogFile() { void nullResponseWithMissingLogFile() {
this.environment.setProperty("logging.file.name", "no_test.log"); this.environment.setProperty("logging.file.name", "no_test.log");
assertThat(this.endpoint.logFile()).isNull(); LogFileWebEndpoint endpoint = new LogFileWebEndpoint(LogFile.get(this.environment), null);
assertThat(endpoint.logFile()).isNull();
} }
@Test @Test
void resourceResponseWithLogFile() throws Exception { void resourceResponseWithLogFile() throws Exception {
this.environment.setProperty("logging.file.name", this.logFile.getAbsolutePath()); this.environment.setProperty("logging.file.name", this.logFile.getAbsolutePath());
Resource resource = this.endpoint.logFile(); LogFileWebEndpoint endpoint = new LogFileWebEndpoint(LogFile.get(this.environment), null);
Resource resource = endpoint.logFile();
assertThat(resource).isNotNull(); assertThat(resource).isNotNull();
assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--"); assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--");
} }
@ -76,14 +78,15 @@ class LogFileWebEndpointTests {
@Deprecated @Deprecated
void resourceResponseWithLogFileAndDeprecatedProperty() throws Exception { void resourceResponseWithLogFileAndDeprecatedProperty() throws Exception {
this.environment.setProperty("logging.file", this.logFile.getAbsolutePath()); this.environment.setProperty("logging.file", this.logFile.getAbsolutePath());
Resource resource = this.endpoint.logFile(); LogFileWebEndpoint endpoint = new LogFileWebEndpoint(LogFile.get(this.environment), null);
Resource resource = endpoint.logFile();
assertThat(resource).isNotNull(); assertThat(resource).isNotNull();
assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--"); assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--");
} }
@Test @Test
void resourceResponseWithExternalLogFile() throws Exception { void resourceResponseWithExternalLogFile() throws Exception {
LogFileWebEndpoint endpoint = new LogFileWebEndpoint(this.environment, this.logFile); LogFileWebEndpoint endpoint = new LogFileWebEndpoint(null, this.logFile);
Resource resource = endpoint.logFile(); Resource resource = endpoint.logFile();
assertThat(resource).isNotNull(); assertThat(resource).isNotNull();
assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--"); assertThat(contentOf(resource.getFile())).isEqualTo("--TEST--");

View File

@ -19,16 +19,17 @@ package org.springframework.boot.actuate.logging;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.io.TempDir; import org.junit.jupiter.api.io.TempDir;
import org.springframework.boot.actuate.endpoint.web.test.WebEndpointTest; import org.springframework.boot.actuate.endpoint.web.test.WebEndpointTest;
import org.springframework.boot.test.util.TestPropertyValues; import org.springframework.boot.logging.LogFile;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.http.MediaType; import org.springframework.http.MediaType;
import org.springframework.mock.env.MockEnvironment;
import org.springframework.test.web.reactive.server.WebTestClient; import org.springframework.test.web.reactive.server.WebTestClient;
import org.springframework.util.FileCopyUtils; import org.springframework.util.FileCopyUtils;
@ -44,31 +45,28 @@ class LogFileWebEndpointWebIntegrationTests {
private WebTestClient client; private WebTestClient client;
private File logFile; private static File tempFile;
@BeforeEach @BeforeEach
void setUp(@TempDir File temp, WebTestClient client, ConfigurableApplicationContext context) throws IOException { void setUp(WebTestClient client, ConfigurableApplicationContext context) {
this.logFile = new File(temp, "test.log");
this.client = client; this.client = client;
this.context = context; this.context = context;
FileCopyUtils.copy("--TEST--".getBytes(), this.logFile);
} }
@WebEndpointTest @BeforeAll
void getRequestProduces404ResponseWhenLogFileNotFound() { static void setup(@TempDir File temp) throws IOException {
this.client.get().uri("/actuator/logfile").exchange().expectStatus().isNotFound(); tempFile = temp;
} }
@WebEndpointTest @WebEndpointTest
void getRequestProducesResponseWithLogFile() { void getRequestProducesResponseWithLogFile() {
TestPropertyValues.of("logging.file.name:" + this.logFile.getAbsolutePath()).applyTo(this.context);
this.client.get().uri("/actuator/logfile").exchange().expectStatus().isOk().expectHeader() this.client.get().uri("/actuator/logfile").exchange().expectStatus().isOk().expectHeader()
.contentType("text/plain; charset=UTF-8").expectBody(String.class).isEqualTo("--TEST--"); .contentType("text/plain; charset=UTF-8").expectBody(String.class).isEqualTo("--TEST--");
} }
@WebEndpointTest @WebEndpointTest
void getRequestThatAcceptsTextPlainProducesResponseWithLogFile() { void getRequestThatAcceptsTextPlainProducesResponseWithLogFile() {
TestPropertyValues.of("logging.file:" + this.logFile.getAbsolutePath()).applyTo(this.context);
this.client.get().uri("/actuator/logfile").accept(MediaType.TEXT_PLAIN).exchange().expectStatus().isOk() this.client.get().uri("/actuator/logfile").accept(MediaType.TEXT_PLAIN).exchange().expectStatus().isOk()
.expectHeader().contentType("text/plain; charset=UTF-8").expectBody(String.class).isEqualTo("--TEST--"); .expectHeader().contentType("text/plain; charset=UTF-8").expectBody(String.class).isEqualTo("--TEST--");
} }
@ -77,8 +75,12 @@ class LogFileWebEndpointWebIntegrationTests {
static class TestConfiguration { static class TestConfiguration {
@Bean @Bean
LogFileWebEndpoint logFileEndpoint(Environment environment) { LogFileWebEndpoint logFileEndpoint() throws IOException {
return new LogFileWebEndpoint(environment); File logFile = new File(tempFile, "test.log");
FileCopyUtils.copy("--TEST--".getBytes(), logFile);
MockEnvironment environment = new MockEnvironment();
environment.setProperty("logging.file", logFile.getAbsolutePath());
return new LogFileWebEndpoint(LogFile.get(environment), null);
} }
} }

View File

@ -121,6 +121,11 @@ public class LoggingApplicationListener implements GenericApplicationListener {
*/ */
public static final String LOGGING_SYSTEM_BEAN_NAME = "springBootLoggingSystem"; public static final String LOGGING_SYSTEM_BEAN_NAME = "springBootLoggingSystem";
/**
* The name of the {@link LogFile} bean.
*/
public static final String LOGFILE_BEAN_NAME = "springBootLogFile";
private static final Map<String, List<String>> DEFAULT_GROUP_LOGGERS; private static final Map<String, List<String>> DEFAULT_GROUP_LOGGERS;
static { static {
MultiValueMap<String, String> loggers = new LinkedMultiValueMap<>(); MultiValueMap<String, String> loggers = new LinkedMultiValueMap<>();
@ -161,6 +166,8 @@ public class LoggingApplicationListener implements GenericApplicationListener {
private LoggingSystem loggingSystem; private LoggingSystem loggingSystem;
private LogFile logFile;
private int order = DEFAULT_ORDER; private int order = DEFAULT_ORDER;
private boolean parseArgs = true; private boolean parseArgs = true;
@ -225,6 +232,9 @@ public class LoggingApplicationListener implements GenericApplicationListener {
if (!beanFactory.containsBean(LOGGING_SYSTEM_BEAN_NAME)) { if (!beanFactory.containsBean(LOGGING_SYSTEM_BEAN_NAME)) {
beanFactory.registerSingleton(LOGGING_SYSTEM_BEAN_NAME, this.loggingSystem); beanFactory.registerSingleton(LOGGING_SYSTEM_BEAN_NAME, this.loggingSystem);
} }
if (this.logFile != null && !beanFactory.containsBean(LOGFILE_BEAN_NAME)) {
beanFactory.registerSingleton(LOGFILE_BEAN_NAME, this.logFile);
}
} }
private void onContextClosedEvent() { private void onContextClosedEvent() {
@ -247,12 +257,12 @@ public class LoggingApplicationListener implements GenericApplicationListener {
*/ */
protected void initialize(ConfigurableEnvironment environment, ClassLoader classLoader) { protected void initialize(ConfigurableEnvironment environment, ClassLoader classLoader) {
new LoggingSystemProperties(environment).apply(); new LoggingSystemProperties(environment).apply();
LogFile logFile = LogFile.get(environment); this.logFile = LogFile.get(environment);
if (logFile != null) { if (this.logFile != null) {
logFile.applyToSystemProperties(); this.logFile.applyToSystemProperties();
} }
initializeEarlyLoggingLevel(environment); initializeEarlyLoggingLevel(environment);
initializeSystem(environment, this.loggingSystem, logFile); initializeSystem(environment, this.loggingSystem, this.logFile);
initializeFinalLoggingLevels(environment, this.loggingSystem); initializeFinalLoggingLevels(environment, this.loggingSystem);
registerShutdownHookIfNecessary(environment, this.loggingSystem); registerShutdownHookIfNecessary(environment, this.loggingSystem);
} }

View File

@ -63,6 +63,13 @@ class EndpointsPropertiesSampleActuatorApplicationTests {
assertThat(entity.getBody()).contains("\"hello\":\"world\""); assertThat(entity.getBody()).contains("\"hello\":\"world\"");
} }
@Test
void logfileWithRandomName() {
ResponseEntity<String> entity = this.restTemplate.withBasicAuth("user", getPassword())
.getForEntity("/admin/logfile", String.class);
assertThat(entity.getStatusCode()).isEqualTo(HttpStatus.OK);
}
private String getPassword() { private String getPassword() {
return "password"; return "password";
} }

View File

@ -1,3 +1,5 @@
server.error.path: /oops server.error.path: /oops
management.endpoint.health.show-details: always management.endpoint.health.show-details: always
management.endpoints.web.base-path: /admin management.endpoints.web.base-path: /admin
logging.file=./target/${spring.application.instance_id}.log
spring.application.instance_id=${random.value}