add spring boot call

Author: robberphex

mse-simple-demo/A/Dockerfile

@@ -36,4 +36,4 @@ RUN --mount=type=cache,target=/root/.m2/repository/ \
 
 EXPOSE 20001
 ENTRYPOINT ["sh", "-c"]
-CMD ["java -jar /app/target/A-1.0.0.jar"]
+CMD ["java -jar /app/target/A.jar"]

mse-simple-demo/A/pom.xml

@@ -107,8 +107,7 @@
                 <artifactId>spring-boot-maven-plugin</artifactId>
             </plugin>
         </plugins>
+        <finalName>${project.artifactId}</finalName>
     </build>
 
-
 </project>
-

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/AApplication.java

@@ -24,7 +24,13 @@ public static void main(String[] args) {
         SpringApplication.run(AApplication.class, args);
     }
 
-    @Bean
+    @Bean(name = "loadBalancedRestTemplate")
+    @LoadBalanced
+    RestTemplate loadBalancedRestTemplate() {
+        return new RestTemplate();
+    }
+
+    @Bean(name = "restTemplate")
     @LoadBalanced
     RestTemplate restTemplate() {
         return new RestTemplate();

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/AController.java

@@ -12,6 +12,7 @@
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.util.EntityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.commons.util.InetUtils;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@@ -30,7 +31,12 @@
 class AController {
 
     @Autowired
-    RestTemplate restTemplate;
+    @Qualifier("loadBalancedRestTemplate")
+    private RestTemplate loadBalancedRestTemplate;
+
+    @Autowired
+    @Qualifier("restTemplate")
+    private RestTemplate restTemplate;
 
     @Autowired
     InetUtils inetUtils;
@@ -81,13 +87,21 @@ public String a(HttpServletRequest request) throws ExecutionException, Interrupt
             }
         }
 
-        String result=restTemplate.getForObject("http://sc-B/b", String.class);
+        String result = loadBalancedRestTemplate.getForObject("http://sc-B/b", String.class);
 //        String result = taskExecutor.submit(() ->
 //                restTemplate.getForObject("http://sc-B/b", String.class)
 //        ).get();
 
-        return "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + "[config=" + configValue + "]" + " -> " +
-                result;
+        return "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" +
+                "[config=" + configValue + "]" + " -> " + result;
+    }
+
+    @GetMapping("/spring_boot")
+    public String spring_boot(HttpServletRequest request) {
+        String result = restTemplate.getForObject("http://sc-B/spring_boot", String.class);
+
+        return "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" +
+                " -> " + result;
     }
 
     @ApiOperation(value = "HTTP 全链路灰度入口", tags = {"入口应用"})
@@ -104,7 +118,7 @@ public String aZone(HttpServletRequest request) {
             }
         }
         return "A" + serviceTag + "[" + currentZone + "]" + " -> " +
-                restTemplate.getForObject("http://sc-B/b-zone", String.class);
+                loadBalancedRestTemplate.getForObject("http://sc-B/b-zone", String.class);
     }
 
     @ApiOperation(value = "Dubbo 全链路灰度入口", tags = {"入口应用"})

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

@@ -20,8 +20,13 @@ public static void main(String[] args) {
         SpringApplication.run(BApplication.class, args);
     }
 
+    @Bean(name = "loadBalancedRestTemplate")
+    @LoadBalanced
+    RestTemplate loadBalancedRestTemplate() {
+        return new RestTemplate();
+    }
 
-    @Bean
+    @Bean(name = "restTemplate")
     @LoadBalanced
     RestTemplate restTemplate() {
         return new RestTemplate();

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

@@ -7,6 +7,7 @@
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.util.EntityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.cloud.commons.util.InetUtils;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -19,7 +20,12 @@
 class BController {
 
     @Autowired
-    RestTemplate restTemplate;
+    @Qualifier("loadBalancedRestTemplate")
+    private RestTemplate loadBalancedRestTemplate;
+
+    @Autowired
+    @Qualifier("restTemplate")
+    private RestTemplate restTemplate;
 
     @Autowired
     InetUtils inetUtils;
@@ -50,12 +56,18 @@ private void init() {
     @GetMapping("/b")
     public String b(HttpServletRequest request) {
         return "B" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
-                restTemplate.getForObject("http://sc-C/c", String.class);
+                loadBalancedRestTemplate.getForObject("http://sc-C/c", String.class);
     }
 
     @GetMapping("/b-zone")
     public String bZone(HttpServletRequest request) {
         return "B" + serviceTag + "[" + currentZone + "]" + " -> " +
-                restTemplate.getForObject("http://sc-C/c-zone", String.class);
+                loadBalancedRestTemplate.getForObject("http://sc-C/c-zone", String.class);
+    }
+
+    @GetMapping("/spring-boot")
+    public String spring_boot(HttpServletRequest request) {
+        return "B" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
+                restTemplate.getForObject("http://sc-C/spring-boot", String.class);
     }
 }

mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java

@@ -19,12 +19,17 @@ public static void main(String[] args) {
         SpringApplication.run(CApplication.class, args);
     }
 
-    @Bean
+    @Bean(name = "loadBalancedRestTemplate")
     @LoadBalanced
-    RestTemplate restTemplate() {
+    RestTemplate loadBalancedRestTemplate() {
         return new RestTemplate();
     }
 
+    @Bean(name = "restTemplate")
+    @LoadBalanced
+    RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
 
     @Bean(name = "serviceTag")
     String serviceTag() {

mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CController.java

@@ -7,6 +7,7 @@
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.util.EntityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.commons.util.InetUtils;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -19,9 +20,6 @@
 @RestController
 class CController {
 
-    @Autowired
-    RestTemplate restTemplate;
-
     @Autowired
     InetUtils inetUtils;
 
@@ -56,7 +54,7 @@ public String c(HttpServletRequest request) {
         if (throwException) {
             throw new RuntimeException();
         }
-        return "C" + serviceTag+ "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]";
+        return "C" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]";
     }
 
     @GetMapping("/c-zone")
@@ -66,4 +64,9 @@ public String cZone(HttpServletRequest request) {
         }
         return "C" + serviceTag + "[" + currentZone + "]";
     }
+
+    @GetMapping("/spring-boot")
+    public String spring_boot(HttpServletRequest request) {
+        return "C" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]";
+    }
 }