增加RestTemplateStrategyInterceptor机制

discovery-springcloud-example-service/src/main/java/com/nepxion/discovery/plugin/example/service/DiscoveryApplicationA1.java

@@ -9,17 +9,22 @@ package com.nepxion.discovery.plugin.example.service;
  * @version 1.0
  */
 
+import java.util.Collections;
+
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.context.annotation.Bean;
+import org.springframework.web.client.RestTemplate;
 
 import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryEnabledStrategy;
 import com.nepxion.discovery.plugin.example.service.impl.MyDiscoveryListener;
 import com.nepxion.discovery.plugin.example.service.impl.MyLoadBalanceListener;
 import com.nepxion.discovery.plugin.example.service.impl.MyRegisterListener;
 import com.nepxion.discovery.plugin.example.service.impl.MySubscriber;
+import com.nepxion.discovery.plugin.strategy.service.aop.RestTemplateStrategyInterceptor;
 
 @SpringBootApplication
 @EnableDiscoveryClient
@@ -32,6 +37,15 @@ public class DiscoveryApplicationA1 {
     }
 
     @Bean
+    @LoadBalanced
+    public RestTemplate restTemplate(RestTemplateStrategyInterceptor restTemplateStrategyInterceptor) {
+        RestTemplate restTemplate = new RestTemplate();
+        restTemplate.setInterceptors(Collections.singletonList(restTemplateStrategyInterceptor));
+
+        return restTemplate;
+    }
+
+    @Bean
     public MyRegisterListener myRegisterListener() {
         return new MyRegisterListener();
     }

discovery-springcloud-example-service/src/main/java/com/nepxion/discovery/plugin/example/service/rest/ARestImpl.java

+package com.nepxion.discovery.plugin.example.service.rest;
+
+/**
+ * <p>Title: Nepxion Discovery</p>
+ * <p>Description: Nepxion Discovery</p>
+ * <p>Copyright: Copyright (c) 2017-2050</p>
+ * <p>Company: Nepxion</p>
+ * @author Haojun Ren
+ * @version 1.0
+ */
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestTemplate;
+
+import com.nepxion.discovery.common.constant.DiscoveryConstant;
+
+@RestController
+@ConditionalOnProperty(name = DiscoveryConstant.SPRING_APPLICATION_NAME, havingValue = "discovery-springcloud-example-a")
+public class ARestImpl extends AbstractRestImpl {
+    private static final Logger LOG = LoggerFactory.getLogger(ARestImpl.class);
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @RequestMapping(path = "/rest", method = RequestMethod.POST)
+    public String rest(@RequestBody String value) {
+        value = doRest(value);
+        value = restTemplate.postForEntity("http://discovery-springcloud-example-b/rest", value, String.class).getBody();  
+
+        LOG.info("调用路径：{}", value);
+
+        return value;
+    }
+}
\ No newline at end of file

discovery-springcloud-example-service/src/main/java/com/nepxion/discovery/plugin/example/service/rest/AbstractRestImpl.java

+package com.nepxion.discovery.plugin.example.service.rest;
+
+/**
+ * <p>Title: Nepxion Discovery</p>
+ * <p>Description: Nepxion Discovery</p>
+ * <p>Copyright: Copyright (c) 2017-2050</p>
+ * <p>Company: Nepxion</p>
+ * @author Haojun Ren
+ * @version 1.0
+ */
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.nepxion.discovery.plugin.framework.adapter.PluginAdapter;
+
+public class AbstractRestImpl {
+    @Autowired
+    private PluginAdapter pluginAdapter;
+
+    public String doRest(String value) {
+        String serviceId = pluginAdapter.getServiceId();
+        String version = pluginAdapter.getVersion();
+        // String host = pluginAdapter.getHost();
+        // int port = pluginAdapter.getPort();
+
+        return value + " -> " + serviceId + "[" + version + "]";
+    }
+}
\ No newline at end of file

discovery-springcloud-example-service/src/main/java/com/nepxion/discovery/plugin/example/service/rest/BRestImpl.java

+package com.nepxion.discovery.plugin.example.service.rest;
+
+/**
+ * <p>Title: Nepxion Discovery</p>
+ * <p>Description: Nepxion Discovery</p>
+ * <p>Copyright: Copyright (c) 2017-2050</p>
+ * <p>Company: Nepxion</p>
+ * @author Haojun Ren
+ * @version 1.0
+ */
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestTemplate;
+
+import com.nepxion.discovery.common.constant.DiscoveryConstant;
+
+@RestController
+@ConditionalOnProperty(name = DiscoveryConstant.SPRING_APPLICATION_NAME, havingValue = "discovery-springcloud-example-b")
+public class BRestImpl extends AbstractRestImpl {
+    private static final Logger LOG = LoggerFactory.getLogger(BRestImpl.class);
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @RequestMapping(path = "/rest", method = RequestMethod.POST)
+    public String rest(@RequestBody String value) {
+        value = doRest(value);
+        value = restTemplate.postForEntity("http://discovery-springcloud-example-c/rest", value, String.class).getBody();  
+
+        LOG.info("调用路径：{}", value);
+
+        return value;
+    }
+}
\ No newline at end of file

discovery-springcloud-example-service/src/main/java/com/nepxion/discovery/plugin/example/service/rest/CRestImpl.java

+package com.nepxion.discovery.plugin.example.service.rest;
+
+/**
+ * <p>Title: Nepxion Discovery</p>
+ * <p>Description: Nepxion Discovery</p>
+ * <p>Copyright: Copyright (c) 2017-2050</p>
+ * <p>Company: Nepxion</p>
+ * @author Haojun Ren
+ * @version 1.0
+ */
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nepxion.discovery.common.constant.DiscoveryConstant;
+
+@RestController
+@ConditionalOnProperty(name = DiscoveryConstant.SPRING_APPLICATION_NAME, havingValue = "discovery-springcloud-example-c")
+public class CRestImpl extends AbstractRestImpl {
+    private static final Logger LOG = LoggerFactory.getLogger(CRestImpl.class);
+
+    @RequestMapping(path = "/rest", method = RequestMethod.POST)
+    public String rest(@RequestBody String value) {
+        value = doRest(value);
+
+        LOG.info("调用路径：{}", value);
+
+        return value;
+    }
+}
\ No newline at end of file