You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2022/02/25 08:45:29 UTC
[dubbo] branch master updated: netty4_extend (#9702)
This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 5bc4e91 netty4_extend (#9702)
5bc4e91 is described below
commit 5bc4e913381edf8fe66629af1693d8c9d7f9298c
Author: Owen.Cai <89...@qq.com>
AuthorDate: Fri Feb 25 16:44:57 2022 +0800
netty4_extend (#9702)
---
.../remoting/transport/netty4/NettyClient.java | 18 +++++++-
.../remoting/transport/netty4/NettyServer.java | 54 ++++++++++++++++++----
2 files changed, 62 insertions(+), 10 deletions(-)
diff --git a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
index 174742f..ce4825f 100644
--- a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
+++ b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
@@ -89,8 +89,16 @@ public class NettyClient extends AbstractClient {
*/
@Override
protected void doOpen() throws Throwable {
- final NettyClientHandler nettyClientHandler = new NettyClientHandler(getUrl(), this);
+ final NettyClientHandler nettyClientHandler = createNettyClientHandler();
bootstrap = new Bootstrap();
+ initBootstrap(nettyClientHandler);
+ }
+
+ protected NettyClientHandler createNettyClientHandler() {
+ return new NettyClientHandler(getUrl(), this);
+ }
+
+ protected void initBootstrap(NettyClientHandler nettyClientHandler) {
bootstrap.group(EVENT_LOOP_GROUP)
.option(ChannelOption.SO_KEEPALIVE, true)
.option(ChannelOption.TCP_NODELAY, true)
@@ -214,4 +222,12 @@ public class NettyClient extends AbstractClient {
public boolean canHandleIdle() {
return true;
}
+
+ protected EventLoopGroup getEventLoopGroup() {
+ return EVENT_LOOP_GROUP;
+ }
+
+ protected Bootstrap getBootstrap() {
+ return bootstrap;
+ }
}
diff --git a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyServer.java b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyServer.java
index 87e3cd1..19e8a3d 100644
--- a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyServer.java
+++ b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyServer.java
@@ -88,14 +88,36 @@ public class NettyServer extends AbstractServer implements RemotingServer {
protected void doOpen() throws Throwable {
bootstrap = new ServerBootstrap();
- bossGroup = NettyEventLoopFactory.eventLoopGroup(1, "NettyServerBoss");
- workerGroup = NettyEventLoopFactory.eventLoopGroup(
+ bossGroup = createBossGroup();
+ workerGroup = createWorkerGroup();
+
+ final NettyServerHandler nettyServerHandler = createNettyServerHandler();
+ channels = nettyServerHandler.getChannels();
+
+ initServerBootstrap(nettyServerHandler);
+
+ // bind
+ ChannelFuture channelFuture = bootstrap.bind(getBindAddress());
+ channelFuture.syncUninterruptibly();
+ channel = channelFuture.channel();
+
+ }
+
+ protected EventLoopGroup createBossGroup() {
+ return NettyEventLoopFactory.eventLoopGroup(1, "NettyServerBoss");
+ }
+
+ protected EventLoopGroup createWorkerGroup() {
+ return NettyEventLoopFactory.eventLoopGroup(
getUrl().getPositiveParameter(IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS),
"NettyServerWorker");
+ }
- final NettyServerHandler nettyServerHandler = new NettyServerHandler(getUrl(), this);
- channels = nettyServerHandler.getChannels();
+ protected NettyServerHandler createNettyServerHandler() {
+ return new NettyServerHandler(getUrl(), this);
+ }
+ protected void initServerBootstrap(NettyServerHandler nettyServerHandler) {
boolean keepalive = getUrl().getParameter(KEEP_ALIVE_KEY, Boolean.FALSE);
bootstrap.group(bossGroup, workerGroup)
@@ -121,11 +143,6 @@ public class NettyServer extends AbstractServer implements RemotingServer {
.addLast("handler", nettyServerHandler);
}
});
- // bind
- ChannelFuture channelFuture = bootstrap.bind(getBindAddress());
- channelFuture.syncUninterruptibly();
- channel = channelFuture.channel();
-
}
@Override
@@ -199,4 +216,23 @@ public class NettyServer extends AbstractServer implements RemotingServer {
return channel.isActive();
}
+ protected EventLoopGroup getBossGroup() {
+ return bossGroup;
+ }
+
+ protected EventLoopGroup getWorkerGroup() {
+ return workerGroup;
+ }
+
+ protected ServerBootstrap getServerBootstrap() {
+ return bootstrap;
+ }
+
+ protected io.netty.channel.Channel getBossChannel() {
+ return channel;
+ }
+
+ protected Map<String, Channel> getServerChannels() {
+ return channels;
+ }
}