67556ba8ea
Rework `org.springframework.boot.context.embedded` to relocate classes to `org.springframework.boot.web`. Packages are now organized around the following areas: Packages for shared concerns, for example the `WebServer` interface to start/stop a server and the common configuration elements: - org.springframework.boot.web.context - org.springframework.boot.web.server Servlet specific packages: - org.springframework.boot.web.servlet.server - org.springframework.boot.web.servlet.context - org.springframework.boot.web.servlet.filter Reactive specific packages: - org.springframework.boot.web.reactive.context - org.springframework.boot.web.reactive.server Embedded server implementations (both reactive and servlet): - org.springframework.boot.web.embedded In addition: - Rename `EmbeddedServletContainerFactory` to `ServletWebServerFactory` to align with the `ReactiveWebServerFactory`. - Rename `EmbeddedWebApplicationContext` to `ServletWebServerApplicationContext` and - Rename `EmbeddedReactiveWebApplicationContext` to `ReactiveWebServerApplicationContext`. - Add checkstyle rules to restrict imports. - Fixup all affected code to use the correct imports and local names. Fixes gh-8532
90 lines
2.8 KiB
Java
90 lines
2.8 KiB
Java
/*
|
|
* Copyright 2012-2017 the original author or authors.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
package sample.session.redis;
|
|
|
|
import java.net.URI;
|
|
|
|
import org.junit.Test;
|
|
|
|
import org.springframework.boot.builder.SpringApplicationBuilder;
|
|
import org.springframework.boot.web.context.ServerPortInfoApplicationContextInitializer;
|
|
import org.springframework.context.ConfigurableApplicationContext;
|
|
import org.springframework.data.redis.RedisConnectionFailureException;
|
|
import org.springframework.http.HttpHeaders;
|
|
import org.springframework.http.HttpMethod;
|
|
import org.springframework.http.RequestEntity;
|
|
import org.springframework.http.ResponseEntity;
|
|
import org.springframework.web.client.RestTemplate;
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat;
|
|
|
|
/**
|
|
* Tests for {@link SampleSessionRedisApplication}.
|
|
*
|
|
* @author Andy Wilkinson
|
|
*/
|
|
public class SampleSessionRedisApplicationTests {
|
|
|
|
@Test
|
|
public void sessionExpiry() throws Exception {
|
|
|
|
String port = null;
|
|
|
|
try {
|
|
ConfigurableApplicationContext context = new SpringApplicationBuilder()
|
|
.sources(SampleSessionRedisApplication.class)
|
|
.properties("server.port:0")
|
|
.initializers(new ServerPortInfoApplicationContextInitializer())
|
|
.run();
|
|
port = context.getEnvironment().getProperty("local.server.port");
|
|
}
|
|
catch (RuntimeException ex) {
|
|
if (!redisServerRunning(ex)) {
|
|
return;
|
|
}
|
|
throw ex;
|
|
}
|
|
|
|
URI uri = URI.create("http://localhost:" + port + "/");
|
|
RestTemplate restTemplate = new RestTemplate();
|
|
|
|
ResponseEntity<String> response = restTemplate.getForEntity(uri, String.class);
|
|
String uuid1 = response.getBody();
|
|
HttpHeaders requestHeaders = new HttpHeaders();
|
|
requestHeaders.set("Cookie", response.getHeaders().getFirst("Set-Cookie"));
|
|
|
|
RequestEntity<Void> request = new RequestEntity<>(requestHeaders, HttpMethod.GET,
|
|
uri);
|
|
|
|
String uuid2 = restTemplate.exchange(request, String.class).getBody();
|
|
assertThat(uuid1).isEqualTo(uuid2);
|
|
|
|
Thread.sleep(5000);
|
|
|
|
String uuid3 = restTemplate.exchange(request, String.class).getBody();
|
|
assertThat(uuid2).isNotEqualTo(uuid3);
|
|
}
|
|
|
|
private boolean redisServerRunning(Throwable ex) {
|
|
if (ex instanceof RedisConnectionFailureException) {
|
|
return false;
|
|
}
|
|
return (ex.getCause() == null || redisServerRunning(ex.getCause()));
|
|
}
|
|
|
|
}
|