Merge pull request apache#261 from songxiaosheng/doc_offical_master

⬆️ quic support dubbo3.2
songxiaosheng · Dec 21, 2023 · b021c18 · b021c18
2 parents a2ccd42 + ea87c33
commit b021c18
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 3 deletions.
diff --git a/dubbo-remoting-extensions/dubbo-remoting-quic/README.md b/dubbo-remoting-extensions/dubbo-remoting-quic/README.md
diff --git a/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml b/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml
@@ -29,7 +29,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>dubbo-remoting-quic</artifactId>
-    <version>1.0.2-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
 
 
     <dependencies>
@@ -38,15 +38,20 @@
             <groupId>io.netty.incubator</groupId>
             <artifactId>netty-incubator-codec-quic</artifactId>
             <version>0.0.14.Final</version>
-            <classifier>${os.detected.classifier}</classifier>
         </dependency>
 
         <dependency>
             <groupId>org.apache.dubbo</groupId>
             <artifactId>dubbo-remoting-api</artifactId>
             <optional>true</optional>
+            <version>3.2.7</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo</artifactId>
+            <version>3.2.7</version>
+            <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-all</artifactId>

diff --git a/...remoting-quic/src/main/java/org/apache/dubbo/remoting/transport/quic/QuicNettyServer.java b/...remoting-quic/src/main/java/org/apache/dubbo/remoting/transport/quic/QuicNettyServer.java
@@ -56,6 +56,7 @@
 public class QuicNettyServer extends AbstractServer implements RemotingServer {
 
     private static final Logger logger = LoggerFactory.getLogger(QuicNettyServer.class);
+    private static final String SERVER_THREAD_POOL_NAME = "DubboServerHandler";
     /**
      * the cache for alive worker channel.
      * <ip:port, dubbo channel>
@@ -172,6 +173,11 @@ protected void doClose() throws Throwable {
         }
     }
 
+    @Override
+    protected int getChannelsSize() {
+        return channels == null ? 0 : channels.size();
+    }
+
     @Override
     public Collection<Channel> getChannels() {
         Collection<Channel> chs = new ArrayList<>(this.channels.size());