From 4c2280e5434132f3e67c58e7d249db7b16b99794 Mon Sep 17 00:00:00 2001 From: huangsimin Date: Tue, 23 Jul 2019 11:34:52 +0800 Subject: [PATCH] =?UTF-8?q?=E9=99=90=E6=B5=81=E7=9A=84dubbo=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E9=80=9A=E8=BF=87.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/resources/test-gateway4.yaml | 4 ++-- .../service/usergw/TestHttp2DubboConfig4.java | 16 ++++++++++------ 2 files changed, 12 insertions(+), 8 deletions(-) diff --git a/usergw-service/src/main/resources/test-gateway4.yaml b/usergw-service/src/main/resources/test-gateway4.yaml index 05cebb7..01c7412 100644 --- a/usergw-service/src/main/resources/test-gateway4.yaml +++ b/usergw-service/src/main/resources/test-gateway4.yaml @@ -46,8 +46,8 @@ dubbo: - name: RequestRateLimiter args: key-resolver: '#{@ipResolver}' #SPEL表达式去的对应的bean - redis-rate-limiter.replenishRate: 81 # 令牌桶的容积 - redis-rate-limiter.burstCapacity: 40 # 流速 每秒 + redis-rate-limiter.replenishRate: 40 # 令牌桶的容积 + redis-rate-limiter.burstCapacity: 80 # 流速 每秒 # - name: RequestRateLimiter1 # args: diff --git a/usergw-service/src/test/java/cn/ecpark/service/usergw/TestHttp2DubboConfig4.java b/usergw-service/src/test/java/cn/ecpark/service/usergw/TestHttp2DubboConfig4.java index 4644ada..8828e33 100644 --- a/usergw-service/src/test/java/cn/ecpark/service/usergw/TestHttp2DubboConfig4.java +++ b/usergw-service/src/test/java/cn/ecpark/service/usergw/TestHttp2DubboConfig4.java @@ -12,6 +12,7 @@ import org.springframework.boot.test.context.SpringBootTest.WebEnvironment; import org.springframework.boot.web.server.LocalServerPort; import org.springframework.cloud.gateway.filter.factory.RequestRateLimiterGatewayFilterFactory; import org.springframework.cloud.gateway.filter.factory.SetRequestHeaderGatewayFilterFactory; +import org.springframework.data.redis.core.ReactiveRedisTemplate; import org.springframework.test.context.TestPropertySource; import org.springframework.test.context.junit4.SpringRunner; @@ -30,9 +31,8 @@ public class TestHttp2DubboConfig4 { @Test public void Test1RequestHttp2DubboSetHeader() { - // Test Base Url - for(int i = 0; i < 2;i++) { + for(int i = 0; i < 50;i++) { HttpClient client = HttpClient.create(); ResponseReceiver receiver; String content; @@ -42,10 +42,14 @@ public class TestHttp2DubboConfig4 { HttpClientResponse response = receiver.response().block(); Assert.assertNotNull(response); - Assert.assertEquals(response.status().code(), 200); - content = receiver.responseContent().asString().blockLast(); - Assert.assertNotNull(content); - Assert.assertEquals(content, "Hello Dubbo"); + + if(response.status().code() == 200) { + content = receiver.responseContent().asString().blockLast(); + Assert.assertNotNull(content); + Assert.assertEquals(content, "Hello Dubbo"); + } else { + Assert.assertEquals(response.status().code(), 429); + } } }