- spring-cloud-kubernetes-coordinator支持native

Author: ccwxl

spring-cloud-kubernetes-coordinator/README.md

@@ -26,5 +26,5 @@
       "parameterTypes": []
     }
   ]
-},
+}
 ```

spring-cloud-kubernetes-coordinator/src/main/java/spring/cloud/kubernetes/coordinator/gateway/apisix/KubernetesServiceChooseFilter.java

@@ -63,12 +63,15 @@ public void filter(HttpRequest request, HttpResponse response, PluginFilterChain
     }
 
     private void doServiceChoose(PluginConfig pluginConfig, BlockingLoadBalancerClient blockingLoadBalancerClient, HttpRequest request) {
-        String sourceIp;
+        String sourceIp = null;
         if (StringUtils.hasText(pluginConfig.getRealIp())) {
             sourceIp = request.getHeader(pluginConfig.getRealIp().toLowerCase());
-        } else {
+        }
+
+        if (!StringUtils.hasLength(sourceIp)) {
             sourceIp = request.getSourceIP();
         }
+
         LoadbalancerContextHolder.setLoadbalancerIp(sourceIp);
         Set<LoadBalancerLifecycle> supportedLifecycleProcessors = getSupportedLifecycleProcessors(pluginConfig.getService());
         supportedLifecycleProcessors.forEach(lifecycle -> lifecycle.onStart(ReactiveLoadBalancer.REQUEST));

spring-cloud-kubernetes-coordinator/src/main/resources/META-INF/native-image/reflect-config.json

@@ -628,6 +628,15 @@
       }
     ]
   },
+  {
+    "name": "io.netty.channel.epoll.EpollServerDomainSocketChannel",
+    "methods": [
+      {
+        "name": "<init>",
+        "parameterTypes": []
+      }
+    ]
+  },
   {
     "name": "io.netty.channel.unix.DatagramSocketAddress"
   },