重构类结构

discovery-plugin-strategy-extension-service/src/main/java/com/nepxion/discovery/plugin/strategy/extension/service/aop/ServiceStrategyInterceptor.java

@@ -51,14 +51,14 @@ public class ServiceStrategyInterceptor extends AbstractInterceptor {
         context.add(ServiceStrategyConstant.METHOD, methodName);
         context.add(ServiceStrategyConstant.PARAMETER_MAP, parameterMap);
 
-        LOG.debug("Service strategy context is set with class={}, methodName={}, parameterMap={}", proxiedClass, methodName, parameterMap);
+        LOG.debug("Service strategy context is set with {}", context);
         
         try {
             return invocation.proceed();
-        } catch (Exception e) {
-            throw e;
         } finally {
-            context.clear();
+            ServiceStrategyContext.clearCurrentContext();
+
+            LOG.debug("Service strategy context is cleared");
         }
     }
 }
\ No newline at end of file

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

@@ -11,6 +11,7 @@ package com.nepxion.discovery.plugin.example.service.extension;
 
 import java.util.Map;
 
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -41,7 +42,7 @@ public class MyDiscoveryEnabledAdapter implements DiscoveryEnabledAdapter {
         if (attributes.containsKey(ServiceStrategyConstant.PARAMETER_MAP)) {
             Map<String, Object> parameterMap = (Map<String, Object>) attributes.get(ServiceStrategyConstant.PARAMETER_MAP);
             String value = parameterMap.get("value").toString();
-            if (value.contains("abc")) {
+            if (StringUtils.isNotEmpty(value) && value.contains("abc")) {
                 LOG.info("过滤条件：当前端输入值包含'abc'的时候，不能被Ribbon负载均衡到");
 
                 return false;

discovery-springcloud-example-zuul/src/main/java/com/nepxion/discovery/plugin/example/zuul/extension/MyDiscoveryEnabledAdapter.java

@@ -11,8 +11,6 @@ package com.nepxion.discovery.plugin.example.zuul.extension;
 
 import java.util.Map;
 
-import javax.servlet.http.HttpServletRequest;
-
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -32,15 +30,17 @@ public class MyDiscoveryEnabledAdapter implements DiscoveryEnabledAdapter {
     @Override
     public boolean apply(Server server) {
         RequestContext context = RequestContext.getCurrentContext();
-        HttpServletRequest request = context.getRequest();
-        String token = request.getHeader("token");
+        String token = context.getRequest().getHeader("token");
+        // String value = context.getRequest().getParameter("value");
 
         String serviceId = server.getMetaInfo().getAppName().toLowerCase();
         Map<String, String> metadata = pluginAdapter.getServerMetadata(server);
 
         LOG.info("Zuul端负载均衡用户定制触发：serviceId={}, host={}, metadata={}, context={}", serviceId, server.toString(), metadata, context);
 
-        if (StringUtils.equals(token, "abc")) {
+        if (StringUtils.isNotEmpty(token) && token.contains("abc")) {
+            LOG.info("过滤条件：当前端输入值包含'abc'的时候，不能被Ribbon负载均衡到");
+
             return false;
         }