流量防护demo

Author: karl

mse-simple-demo/B/src/main/java/com/alibabacloud/mse/demo/BController.java

@@ -69,13 +69,15 @@ private void init() {
     public String flow(HttpServletRequest request) throws ExecutionException, InterruptedException {
         long sleepTime = 5 + RANDOM.nextInt(5);
         silentSleep(sleepTime);
+
         return "B" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " + sleepTime;
     }
 
     @GetMapping("/params/{hot}")
     public String params(HttpServletRequest request,@PathVariable("hot") String hot) throws ExecutionException, InterruptedException {
         long sleepTime = 5 + RANDOM.nextInt(5);
         silentSleep(sleepTime);
+        helloServiceC.hello(hot);
         return "B" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " + sleepTime+":"+hot;
     }
 

mse-simple-demo/gateway/src/main/java/com/alibabacloud/mse/demo/DemoController.java

@@ -197,48 +197,48 @@ public void run() {
                     } catch (Exception ignore) {
                     }
 
-
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/flow-c");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/flow-c");
-                        httpGet.addHeader("x-mse-tag", "gray");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
-
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/isolate-c");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/isolate-c");
-                        httpGet.addHeader("x-mse-tag", "gray");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
-
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/params-c/hot");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
-                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
-                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/params-c/hot");
-                        httpGet.addHeader("x-mse-tag", "gray");
-                        httpClient.execute(httpGet);
-
-                    } catch (Exception ignore) {
-                    }
+//
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/flow-c");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/flow-c");
+//                        httpGet.addHeader("x-mse-tag", "gray");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
+//
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/isolate-c");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/isolate-c");
+//                        httpGet.addHeader("x-mse-tag", "gray");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
+//
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/params-c/hot");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
+//                    try (CloseableHttpClient httpClient = HttpClientBuilder.create().build()) {
+//                        HttpGet httpGet = new HttpGet("http://localhost:20000/B/params-c/hot");
+//                        httpGet.addHeader("x-mse-tag", "gray");
+//                        httpClient.execute(httpGet);
+//
+//                    } catch (Exception ignore) {
+//                    }
 
 
                 }