单元测试

README.md

@@ -11,9 +11,9 @@ spring5 -> webflux ->spring gateway
 * 2.0.* -> Finchley
 
 ## 路由配置参考
-1. https://www.jianshu.com/p/86660b8b24c4
-2. https://www.jdon.com/51642
-3. 
+1. [https://www.jianshu.com/p/86660b8b24c4](https://www.jianshu.com/p/86660b8b24c4)
+2. [https://www.jdon.com/51642](https://www.jdon.com/51642)
+3.  
 
 ## gateway filter
 1. AddRequestHeader 添加header给下流接口
@@ -36,7 +36,16 @@ spring5 -> webflux ->spring gateway
 
 ## 全局过滤器
 1. ReactiveLoadBalancerClientFilter
-2. Gateway Metrics 
+2. Gateway Metrics
+3. 
+
+## 单元测试
+1. wiremock
+2. [https://www.infoq.com/articles/stubbing-mocking-service-virtualization-differences](https://www.infoq.com/articles/stubbing-mocking-service-virtualization-differences/)
+
+## 其他
+1. spring.cloud.gateway.discovery.locator.enabled=true
+2. actuator 配置
 3. 
 
 

pom.xml

@@ -79,8 +79,49 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
 		</dependency>
-
 		
+		<!-- Spring test 依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        
+        <!-- 集成wireMock来实现mock请求响应。wireMock会自动构建一个虚拟远程服务 -->
+		<dependency>
+		   <groupId>org.springframework.cloud</groupId>
+		   <artifactId>spring-cloud-contract-wiremock</artifactId>
+		   <scope>test</scope>
+		</dependency>
+		
+		<!-- 提供打包预定义数据服务 -->
+		<dependency>
+		   <groupId>org.springframework.cloud</groupId>
+		   <artifactId>spring-cloud-starter-contract-stub-runner</artifactId>
+		   <scope>test</scope>
+		</dependency>
+		
+		<!-- 自动生成单元测试代码 -->
+		<dependency>
+		   <groupId>org.springframework.cloud</groupId>
+		   <artifactId>spring-cloud-starter-contract-verifier</artifactId>
+		   <scope>test</scope>
+		</dependency>
+
+
+		<dependency>
+			<groupId>com.github.tomakehurst</groupId>
+			<artifactId>wiremock-standalone</artifactId>
+			<version>2.18.0</version>
+			<scope>test</scope>
+		</dependency>
+
 		<!-- lombok依赖包 -->
 		<dependency>
 			<groupId>org.projectlombok</groupId>

src/main/java/com/yaozhitech/spring5/App.java

@@ -2,7 +2,12 @@ package com.yaozhitech.spring5;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
 
+import com.yaozhitech.spring5.config.UriConfiguration;
+
+
+@EnableConfigurationProperties(UriConfiguration.class)
 @SpringBootApplication
 public class App {
 
@@ -10,4 +15,5 @@ public class App {
         // 程序启动入口
         SpringApplication.run(App.class,args);
     }
+	
 }

src/main/java/com/yaozhitech/spring5/config/RouterConfig.java

@@ -12,19 +12,22 @@ import reactor.core.publisher.Mono;
 @Configuration
 public class RouterConfig {
 	
+	
+	
 	@Bean
-	public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
+	public RouteLocator customRouteLocator(RouteLocatorBuilder builder, UriConfiguration uriConfiguration) {
+		String httpUri = uriConfiguration.getHttpbin();
 		//@formatter:off
 		return builder.routes()
 				.route("path_route", r -> r.path("/city_list.do")
 						.filters(f -> f.requestRateLimiter(c -> c.setRateLimiter(redisRateLimiter()).setKeyResolver(urlPathKeyResolver())))
-						.uri("https://api.bbztx.com"))
+						.uri(httpUri))
 				.route("host_route", r -> r.host("*.myhost.org")
 						.uri("http://httpbin.org"))
 				.route("rewrite_route", r -> r.path("/city_list")
 						.filters(f -> f.rewritePath("city_list",  // rewritePath方法会使用内建的过滤器重写路径
 								"city_list.do"))
-						.uri("https://api.bbztx.com"))
+						.uri(httpUri))
 //				.route("hystrix_fallback_route", r -> r.path("/slow_query.do")
 //						.filters(f -> f
 //										.rewritePath("_query.do", "")

src/main/java/com/yaozhitech/spring5/config/UriConfiguration.java

@@ -0,0 +1,17 @@
+package com.yaozhitech.spring5.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@ConfigurationProperties
+public class UriConfiguration {
+
+	private String httpbin = "https://api.bbztx.com";
+
+	public String getHttpbin() {
+		return httpbin;
+	}
+
+	public void setHttpbin(String httpbin) {
+		this.httpbin = httpbin;
+	}
+}

src/test/java/com/yaozhitech/spring5/ApplicationTest.java

@@ -0,0 +1,70 @@
+package com.yaozhitech.spring5;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
+import static com.github.tomakehurst.wiremock.client.WireMock.get;
+import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
+import static com.github.tomakehurst.wiremock.client.WireMock.urlEqualTo;
+import static org.assertj.core.api.Assertions.assertThat;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.web.server.LocalServerPort;
+import org.springframework.cloud.contract.wiremock.AutoConfigureWireMock;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.web.reactive.server.WebTestClient;
+
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
+        properties = {"httpbin=http://localhost:${wiremock.server.port}"})
+@AutoConfigureWireMock(port = 0)
+public class ApplicationTest {
+
+	@Autowired
+    private WebTestClient webClient;
+	
+	@LocalServerPort
+    private int port;
+
+    @Before
+    public void setUp() throws Exception {
+        System.out.println(String.format("port is : [%d]", port));
+    }
+
+    @Test
+    public void contextLoads() throws Exception {
+        //Stubs
+        stubFor(get(urlEqualTo("/get"))
+                .willReturn(aResponse()
+                    .withBody("{\"headers\":{\"Hello\":\"World\"}}")
+                    .withHeader("Content-Type", "application/json")));
+        stubFor(get(urlEqualTo("/delay/3"))
+            .willReturn(aResponse()
+                .withBody("no fallback")
+                .withFixedDelay(3000)));
+        
+        stubFor(get(urlEqualTo("/city_list.do"))
+                .willReturn(aResponse()
+                    .withBody("{}")
+                    .withFixedDelay(100)));
+
+//        webClient
+//            .get().uri("/get")
+//            .exchange()
+//            .expectStatus().isOk()
+//            .expectBody()
+//            .jsonPath("$.headers.Hello").isEqualTo("World");
+
+        webClient
+            .get().uri("/city_list")
+//            .header("Host", "www.hystrix.com")
+            .exchange()
+            .expectStatus().isOk()
+            .expectBody()
+            .consumeWith(
+                response -> assertThat(response.getResponseBody()).isEqualTo("{}".getBytes()));
+    }
+}