File tree Expand file tree Collapse file tree 3 files changed +26
-1
lines changed
SpringCloudA/src/main/java/com/alibabacloud/mse/demo/a
SpringCloudD/src/main/java/com/alibabacloud/mse/demo/d Expand file tree Collapse file tree 3 files changed +26
-1
lines changed Original file line number Diff line number Diff line change @@ -28,6 +28,12 @@ RestTemplate restTemplate() {
28
28
return new RestTemplate ();
29
29
}
30
30
31
+ @ Bean
32
+ @ LoadBalanced
33
+ RestTemplate loadBalancedRestTemplate () {
34
+ return new RestTemplate ();
35
+ }
36
+
31
37
@ Bean (name = "serviceTag" )
32
38
String serviceTag () {
33
39
String tag = parseServiceTag ("/etc/podinfo/labels" );
Original file line number Diff line number Diff line change @@ -22,12 +22,31 @@ public class AController {
22
22
@ Autowired
23
23
private RestTemplate restTemplate ;
24
24
25
+ @ Autowired
26
+ private RestTemplate loadBalancedRestTemplate ;
27
+
25
28
@ Autowired
26
29
InetUtils inetUtils ;
27
30
28
31
@ Autowired
29
32
String serviceTag ;
30
33
34
+ @ RequestMapping (value = "/d" )
35
+ public String d (HttpServletRequest request ) throws UnknownHostException {
36
+
37
+ StringBuilder sb = new StringBuilder ();
38
+ Enumeration <String > headers = request .getHeaderNames ();
39
+ if (headers .hasMoreElements ()) {
40
+ String headerKey = headers .nextElement ();
41
+ String value = request .getHeader (headerKey );
42
+ sb .append (headerKey ).append (":" ).append (value ).append (", " );
43
+ }
44
+
45
+ log .info ("/A/d request headers info: " + sb .toString ());
46
+ String resp = loadBalancedRestTemplate .getForObject ("http://spring-cloud-d/D/d" , String .class );
47
+ return "A:" + InetAddress .getLocalHost ().getHostAddress () + ":" + serviceTag + " - " + resp ;
48
+ }
49
+
31
50
@ RequestMapping (value = "/a" )
32
51
public String a (@ RequestParam (name = "call_type" , required = false ) String callType ,
33
52
HttpServletRequest request ) throws UnknownHostException {
Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ public String d(HttpServletRequest request) throws UnknownHostException {
27
27
String value = request .getHeader (headerKey );
28
28
sb .append (headerKey ).append (":" ).append (value ).append (", " );
29
29
}
30
- log .info ("/A/a request headers info: " + sb .toString ());
30
+ log .info ("/D/d request headers info: " + sb .toString ());
31
31
32
32
return "D:" + InetAddress .getLocalHost ().getHostAddress () + ":" + serviceTag ;
33
33
}
You can’t perform that action at this time.
0 commit comments