From b28ab962c6787351f0d95d217fe17a3f5e209bbb Mon Sep 17 00:00:00 2001 From: songxiaosheng Date: Wed, 20 Dec 2023 22:25:06 +0800 Subject: [PATCH] :arrow_up: quic support dubbo3.2 --- .../dubbo-remoting-quic/README.md | 0 dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml | 11 ++++++++--- .../remoting/transport/quic/QuicNettyServer.java | 6 ++++++ 3 files changed, 14 insertions(+), 3 deletions(-) create mode 100644 dubbo-remoting-extensions/dubbo-remoting-quic/README.md diff --git a/dubbo-remoting-extensions/dubbo-remoting-quic/README.md b/dubbo-remoting-extensions/dubbo-remoting-quic/README.md new file mode 100644 index 00000000..e69de29b diff --git a/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml b/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml index 627e3d19..ca73f068 100644 --- a/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml +++ b/dubbo-remoting-extensions/dubbo-remoting-quic/pom.xml @@ -29,7 +29,7 @@ 4.0.0 dubbo-remoting-quic - 1.0.2-SNAPSHOT + 3.2.0-SNAPSHOT @@ -38,15 +38,20 @@ io.netty.incubator netty-incubator-codec-quic 0.0.14.Final - ${os.detected.classifier} org.apache.dubbo dubbo-remoting-api true + 3.2.7 + + + org.apache.dubbo + dubbo + 3.2.7 + test - io.netty netty-all diff --git a/dubbo-remoting-extensions/dubbo-remoting-quic/src/main/java/org/apache/dubbo/remoting/transport/quic/QuicNettyServer.java b/dubbo-remoting-extensions/dubbo-remoting-quic/src/main/java/org/apache/dubbo/remoting/transport/quic/QuicNettyServer.java index d162046f..ce3d1872 100644 --- a/dubbo-remoting-extensions/dubbo-remoting-quic/src/main/java/org/apache/dubbo/remoting/transport/quic/QuicNettyServer.java +++ b/dubbo-remoting-extensions/dubbo-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. * @@ -172,6 +173,11 @@ protected void doClose() throws Throwable { } } + @Override + protected int getChannelsSize() { + return channels == null ? 0 : channels.size(); + } + @Override public Collection getChannels() { Collection chs = new ArrayList<>(this.channels.size());