🐛 修复路由解析结果中存在非GRPC协议实例 (#52)

polarismesh · Mar 27, 2024 · 0e27a4a · 0e27a4a
1 parent 84637ca
commit 0e27a4a
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java
@@ -149,10 +149,12 @@ private void doWatch(Listener2 listener) {
 
     private void notifyListener(Listener2 listener, InstancesResponse response) {
         ServiceInstances serviceInstances = response.toServiceInstances();
-	List<EquivalentAddressGroup> equivalentAddressGroups = serviceInstances.getInstances()
-                .stream()
-                .map(this::buildEquivalentAddressGroup)
-                .collect(Collectors.toList());
+        List<EquivalentAddressGroup> equivalentAddressGroups = new ArrayList<>();
+        for (Instance instance : serviceInstances.getInstances()) {
+            if (Objects.equals("grpc", instance.getProtocol())) {
+                equivalentAddressGroups.add(buildEquivalentAddressGroup(instance));
+            }
+        }
 
         Attributes.Builder builder = Attributes.newBuilder();