apache#3

Author: panxiaojun233

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/InvokerResolver.java

@@ -6,7 +6,7 @@
 @SPI("triple")
 public interface InvokerResolver {
 
-    void add(String path, Invoker<?> invoker);
+    void add(String path, String service, Invoker<?> invoker);
 
     Invoker<?> resolve(String path);
 }

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2FrameListener.java

@@ -52,8 +52,6 @@ public void onPingAckRead(ChannelHandlerContext ctx, long data) throws Http2Exce
     public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
             throws Http2Exception {
         System.out.println("onDataRead:" + streamId);
-        final TripleHttp2ConnectionHandler connectionHandler = ctx.pipeline().get(TripleHttp2ConnectionHandler.class);
-        Http2Connection connection = connectionHandler.encoder().connection();
         Http2Stream stream = connection.stream(streamId);
         Http2Request request = stream == null ? null : (Http2Request) stream.getProperty(streamKey);
 

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerResolver.java

@@ -3,13 +3,22 @@
 
 import org.apache.dubbo.rpc.Invoker;
 
+import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
 public class TripleInvokerResolver implements InvokerResolver {
     private final ConcurrentHashMap<String, Invoker<?>> path2Invoker = new ConcurrentHashMap<>();
+    private final Set<String> ignoreSet = ConcurrentHashMap.newKeySet();
 
     @Override
-    public void add(String path, Invoker<?> invoker) {
+    public void add(String path, String service,Invoker<?> invoker) {
+        // todo path == service
+        Invoker<?> old = path2Invoker.putIfAbsent(service, invoker);
+        if (old != null || ignoreSet.contains(service)) {
+            path2Invoker.remove(service);
+            ignoreSet.add(service);
+        }
+
         path2Invoker.put(path, invoker);
     }
 

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleProtocol.java

@@ -70,7 +70,9 @@ public void unexport() {
         };
 
         exporterMap.put(key, exporter);
-        serviceContainer.add(invoker.getUrl().getServiceKey(), invoker);
+
+        String service = url.getServiceInterface();
+        serviceContainer.add(url.getServiceKey(), service, invoker);
         PortUnificationExchanger.bind(invoker.getUrl());
         return exporter;
     }