Browse Source

Revert "Moves random uuid back to constructor, but only if config is set."

This reverts commit 0997dc6f
pull/1554/head
Spencer Gibb 5 years ago
parent
commit
1e263bbc86
No known key found for this signature in database
GPG Key ID: 7788A47380690861
  1. 2
      docs/src/main/asciidoc/spring-cloud-gateway.adoc
  2. 32
      spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java
  3. 9
      spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/RouteDefinition.java
  4. 12
      spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/route/RouteDefinitionDefaultIdTests.java

2
docs/src/main/asciidoc/spring-cloud-gateway.adoc

@ -51,8 +51,6 @@ NOTE: URIs defined in routes without a port will get a default port set to 80 an @@ -51,8 +51,6 @@ NOTE: URIs defined in routes without a port will get a default port set to 80 an
Spring Cloud Gateway matches routes as part of the Spring WebFlux `HandlerMapping` infrastructure. Spring Cloud Gateway includes many built-in Route Predicate Factories. All of these predicates match on different attributes of the HTTP request. Multiple Route Predicate Factories can be combined and are combined via logical `and`.
WARNING: Previously, Spring Cloud Gateway generated a default Route ID by creating a random UUID. Generating a random UUID is a blocking operation and can lead to instability. Default id generation has been turned off by default. To re-enable this set an environment variable `SPRING_CLOUD_GATEWAY_ROUTE_GENERATE_ID` or system property `spring.cloud.gateway.route.generate-id` to `true`.
=== After Route Predicate Factory
The After Route Predicate Factory takes one parameter, a datetime. This predicate matches requests that happen after the current datetime.

32
spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java

@ -16,22 +16,52 @@ @@ -16,22 +16,52 @@
package org.springframework.cloud.gateway.route;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import org.springframework.util.AlternativeJdkIdGenerator;
import org.springframework.util.IdGenerator;
/**
* @author Spencer Gibb
*/
public class CompositeRouteDefinitionLocator implements RouteDefinitionLocator {
private static final Log log = LogFactory
.getLog(CompositeRouteDefinitionLocator.class);
private final Flux<RouteDefinitionLocator> delegates;
private final IdGenerator idGenerator;
public CompositeRouteDefinitionLocator(Flux<RouteDefinitionLocator> delegates) {
this(delegates, new AlternativeJdkIdGenerator());
}
public CompositeRouteDefinitionLocator(Flux<RouteDefinitionLocator> delegates,
IdGenerator idGenerator) {
this.delegates = delegates;
this.idGenerator = idGenerator;
}
@Override
public Flux<RouteDefinition> getRouteDefinitions() {
return this.delegates.flatMap(RouteDefinitionLocator::getRouteDefinitions);
return this.delegates.flatMap(RouteDefinitionLocator::getRouteDefinitions)
.flatMap(routeDefinition -> Mono.justOrEmpty(routeDefinition.getId())
.defaultIfEmpty(idGenerator.generateId().toString())
.publishOn(Schedulers.elastic()).map(id -> {
if (routeDefinition.getId() == null) {
routeDefinition.setId(id);
if (log.isDebugEnabled()) {
log.debug(
"Id set on route definition: " + routeDefinition);
}
}
return routeDefinition;
}));
}
}

9
spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/RouteDefinition.java

@ -20,7 +20,6 @@ import java.net.URI; @@ -20,7 +20,6 @@ import java.net.URI;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.UUID;
import javax.validation.Valid;
import javax.validation.ValidationException;
@ -39,7 +38,6 @@ import static org.springframework.util.StringUtils.tokenizeToStringArray; @@ -39,7 +38,6 @@ import static org.springframework.util.StringUtils.tokenizeToStringArray;
@Validated
public class RouteDefinition {
@NotEmpty
private String id;
@NotEmpty
@ -55,13 +53,6 @@ public class RouteDefinition { @@ -55,13 +53,6 @@ public class RouteDefinition {
private int order = 0;
public RouteDefinition() {
String envGenerateId = System.getenv("SPRING_CLOUD_GATEWAY_ROUTE_GENERATE_ID");
String propGenerateId = System
.getProperty("spring.cloud.gateway.route.generate-id", "false");
if ("true".equalsIgnoreCase(envGenerateId)
|| "true".equalsIgnoreCase(propGenerateId)) {
id = UUID.randomUUID().toString();
}
}
public RouteDefinition(String text) {

12
spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/route/RouteDefinitionDefaultIdTests.java

@ -16,8 +16,6 @@ @@ -16,8 +16,6 @@
package org.springframework.cloud.gateway.route;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
@ -45,16 +43,6 @@ public class RouteDefinitionDefaultIdTests { @@ -45,16 +43,6 @@ public class RouteDefinitionDefaultIdTests {
@Autowired
private GatewayProperties properties;
@BeforeClass
public static void before() {
System.setProperty("spring.cloud.gateway.route.generate-id", "true");
}
@AfterClass
public static void after() {
System.clearProperty("spring.cloud.gateway.route.generate-id");
}
@Test
public void testDefaultIdWorks() {
assertThat(properties.getRoutes()).hasSize(1);

Loading…
Cancel
Save