Fix

pom.xml

@@ -14,15 +14,15 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.0.2.RELEASE</version>
+		<version>2.3.1.RELEASE</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 		<java.version>1.8</java.version>
-		<spring-cloud.version>Finchley.RC2</spring-cloud.version>
+		<spring-cloud.version>Hoxton.SR5</spring-cloud.version>
 	</properties>
 
 	<dependencies>
@@ -33,6 +33,12 @@
 		<dependency>
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-starter</artifactId>
+			<exclusions>
+				<exclusion>
+					<groupId>org.springframework.boot</groupId>
+					<artifactId>spring-boot-starter-validation</artifactId>
+				</exclusion>
+			</exclusions>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
@@ -87,44 +93,4 @@
 			</plugin>
 		</plugins>
 	</build>
-
-	<repositories>
-		<repository>
-			<id>spring-snapshots</id>
-			<name>Spring Snapshots</name>
-			<url>https://repo.spring.io/snapshot</url>
-			<snapshots>
-				<enabled>true</enabled>
-			</snapshots>
-		</repository>
-		<repository>
-			<id>spring-milestones</id>
-			<name>Spring Milestones</name>
-			<url>https://repo.spring.io/milestone</url>
-			<snapshots>
-				<enabled>false</enabled>
-			</snapshots>
-		</repository>
-	</repositories>
-
-	<pluginRepositories>
-		<pluginRepository>
-			<id>spring-snapshots</id>
-			<name>Spring Snapshots</name>
-			<url>https://repo.spring.io/snapshot</url>
-			<snapshots>
-				<enabled>true</enabled>
-			</snapshots>
-		</pluginRepository>
-		<pluginRepository>
-			<id>spring-milestones</id>
-			<name>Spring Milestones</name>
-			<url>https://repo.spring.io/milestone</url>
-			<snapshots>
-				<enabled>false</enabled>
-			</snapshots>
-		</pluginRepository>
-	</pluginRepositories>
-
-
 </project>

src/main/java/com/example/demogateway/CustomFilter.java

@@ -0,0 +1,5 @@
+//package com.example.demogateway;
+//
+//public class CustomFilter implements Filter {
+//}
+//a

src/main/java/com/example/demogateway/DemogatewayApplication.java

@@ -14,65 +14,8 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-@RestController
 @SpringBootApplication
 public class DemogatewayApplication {
-
-	@RequestMapping("/hystrixfallback")
-	public String hystrixfallback() {
-		return "This is a fallback";
-	}
-
-	@Bean
-	public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
-		//@formatter:off
-		return builder.routes()
-				.route("path_route", r -> r.path("/get")
-						.uri("http://httpbin.org"))
-				.route("host_route", r -> r.host("*.myhost.org")
-						.uri("http://httpbin.org"))
-				.route("rewrite_route", r -> r.host("*.rewrite.org")
-						.filters(f -> f.rewritePath("/foo/(?<segment>.*)",
-								"/${segment}"))
-						.uri("http://httpbin.org"))
-				.route("hystrix_route", r -> r.host("*.hystrix.org")
-						.filters(f -> f.hystrix(c -> c.setName("slowcmd")))
-								.uri("http://httpbin.org"))
-				.route("hystrix_fallback_route", r -> r.host("*.hystrixfallback.org")
-						.filters(f -> f.hystrix(c -> c.setName("slowcmd").setFallbackUri("forward:/hystrixfallback")))
-								.uri("http://httpbin.org"))
-				.route("limit_route", r -> r
-					.host("*.limited.org").and().path("/anything/**")
-						.filters(f -> f.requestRateLimiter(c -> c.setRateLimiter(redisRateLimiter())))
-					.uri("http://httpbin.org"))
-				.route("websocket_route", r -> r.path("/echo")
-					.uri("ws://localhost:9000"))
-				.build();
-		//@formatter:on
-	}
-
-	@Bean
-	RedisRateLimiter redisRateLimiter() {
-		return new RedisRateLimiter(1, 2);
-	}
-
-	@Bean
-	SecurityWebFilterChain springWebFilterChain(ServerHttpSecurity http) throws Exception {
-		return http.httpBasic().and()
-				.csrf().disable()
-				.authorizeExchange()
-				.pathMatchers("/anything/**").authenticated()
-				.anyExchange().permitAll()
-				.and()
-				.build();
-	}
-
-	@Bean
-	public MapReactiveUserDetailsService reactiveUserDetailsService() {
-		UserDetails user = User.withDefaultPasswordEncoder().username("user").password("password").roles("USER").build();
-		return new MapReactiveUserDetailsService(user);
-	}
-
 	public static void main(String[] args) {
 		SpringApplication.run(DemogatewayApplication.class, args);
 	}

src/main/java/com/example/demogateway/RestAPI.java

@@ -0,0 +1,22 @@
+package com.example.demogateway;
+
+import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class RestAPI {
+
+    @RequestMapping("/hystrixfallback")
+    public String hystrixfallback() {
+        return "This is a fallback";
+    }
+
+    @GetMapping("/hello")
+    public String hello(ServerHttpRequest request){
+        request.getHeaders().forEach((key, value) -> System.out.println(key + " " + value));
+        return "Hello, from spring boot application";
+    }
+
+}

src/main/java/com/example/demogateway/Routing.java

@@ -0,0 +1,32 @@
+package com.example.demogateway;
+
+import org.springframework.cloud.gateway.filter.ratelimit.RedisRateLimiter;
+import org.springframework.cloud.gateway.route.RouteLocator;
+import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class Routing {
+
+    @Bean
+    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
+        //@formatter:off
+        return builder.routes()
+                .route(p -> p.path("/hello").filters(f -> f.addRequestHeader("Hello", "World")).uri("http://httpbin.org:80"))
+                .route("path_route", r -> r.path("/get").uri("http://httpbin.org"))
+                .route("host_route", r -> r.host("*.myhost.org").uri("http://httpbin.org"))
+                .route("rewrite_route", r -> r.host("*.rewrite.org").filters(f -> f.rewritePath("/foo/(?<segment>.*)","/${segment}")).uri("http://httpbin.org"))
+                .route("hystrix_route", r -> r.host("*.hystrix.org").filters(f -> f.hystrix(c -> c.setName("slowcmd"))).uri("http://httpbin.org"))
+                .route("hystrix_fallback_route", r -> r.host("*.hystrixfallback.org").filters(f -> f.hystrix(c -> c.setName("slowcmd").setFallbackUri("forward:/hystrixfallback"))).uri("http://httpbin.org"))
+                .route("limit_route", r -> r.host("*.limited.org").and().path("/anything/**").filters(f -> f.requestRateLimiter(c -> c.setRateLimiter(redisRateLimiter()))).uri("http://httpbin.org"))
+                .route("websocket_route", r -> r.path("/echo").uri("ws://localhost:9000"))
+                .build();
+        //@formatter:on
+    }
+
+    @Bean
+    RedisRateLimiter redisRateLimiter() {
+        return new RedisRateLimiter(1, 2);
+    }
+}

src/main/java/com/example/demogateway/SecurityConfiguration.java

@@ -0,0 +1,30 @@
+package com.example.demogateway;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.config.web.server.ServerHttpSecurity;
+import org.springframework.security.core.userdetails.MapReactiveUserDetailsService;
+import org.springframework.security.core.userdetails.User;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.web.server.SecurityWebFilterChain;
+
+@Configuration
+public class SecurityConfiguration {
+
+    @Bean
+    SecurityWebFilterChain springWebFilterChain(ServerHttpSecurity http) throws Exception {
+        return http.httpBasic().and()
+                .csrf().disable()
+                .authorizeExchange()
+                .pathMatchers("/anything/**").authenticated()
+                .anyExchange().permitAll()
+                .and()
+                .build();
+    }
+
+    @Bean
+    public MapReactiveUserDetailsService reactiveUserDetailsService() {
+        UserDetails user = User.withDefaultPasswordEncoder().username("user").password("password").roles("USER").build();
+        return new MapReactiveUserDetailsService(user);
+    }
+}

src/test/java/com/example/demogateway/DemogatewayApplicationTests.java

@@ -23,9 +23,13 @@ public class DemogatewayApplicationTests {
 	int port;
 	private WebTestClient client;
 
+	int staticPort = 8080;
+	private WebTestClient staticClient;
+
 	@Before
 	public void setup() {
 		client = WebTestClient.bindToServer().baseUrl("http://localhost:" + port).build();
+		staticClient = WebTestClient.bindToServer().baseUrl("http://localhost:" + staticPort).build();
 	}
 
 	@Test
@@ -40,6 +44,18 @@ public void pathRouteWorks() {
 				});
 	}
 
+	@Test
+	@SuppressWarnings("unchecked")
+	public void helloPathRouteWorks() {
+		staticClient.get().uri("/hello")
+				.exchange()
+				.expectStatus().isOk()
+				.expectBody(Map.class)
+				.consumeWith(result -> {
+					assertThat(result.getResponseBody()).isNotEmpty();
+				});
+	}
+
 	@Test
 	@SuppressWarnings("unchecked")
 	public void hostRouteWorks() {