5

我正在尝试关闭与它建立连接的 Netty 服务器，但它只是挂起。这就是我所做的。

  • 在一台机器上启动服务器，在另一台机器上启动客户端。
  • 从客户端向服务器发送一条消息，我得到响应。
  • 使用 Ctrl-C 关闭服务器

我已经在服务器上注册了一个关闭钩子，它关闭 ChannelGroup 并在 ServerBootstrap 上调用 releaseExternalResources（或者实际上我正在使用 protobuf-pro-duplex 库的 DuplexTcpServerBootstrap 来执行此操作）。无论如何，关闭钩子在关闭时被正确调用，但它永远不会返回。当我对正在发生的事情进行线程转储时，我可以看到两个有趣的堆栈：

   java.lang.Thread.State: TIMED_WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00000006b0890950> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
    at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1433)
    at org.jboss.netty.util.internal.ExecutorUtil.terminate(ExecutorUtil.java:103)
    at org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool.releaseExternalResources(AbstractNioWorkerPool.java:80)
    at org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory.releaseExternalResources(NioServerSocketChannelFactory.java:162)
    at org.jboss.netty.bootstrap.Bootstrap.releaseExternalResources(Bootstrap.java:319)
    at com.googlecode.protobuf.pro.duplex.server.DuplexTcpServerBootstrap.releaseExternalResources(DuplexTcpServerBootstrap.java:132)
    at com.xxx.yyy.node.NodeServer$2.run(NodeServer.java:104)
    at java.lang.Thread.run(Thread.java:722)

所以这是永远不会返回的关闭钩子线程。下面是另一个似乎正在等待通道的线程：

   java.lang.Thread.State: RUNNABLE
    at sun.nio.ch.EPollArrayWrapper.interrupt(Native Method)
    at sun.nio.ch.EPollArrayWrapper.interrupt(EPollArrayWrapper.java:274)
    at sun.nio.ch.EPollSelectorImpl.wakeup(EPollSelectorImpl.java:193)
    - locked <0x00000006b0896660> (a java.lang.Object)
    at java.nio.channels.spi.AbstractSelector$1.interrupt(AbstractSelector.java:210)
    at java.nio.channels.spi.AbstractSelector.begin(AbstractSelector.java:216)
    at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:80)
    at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
    - locked <0x00000006b08964a8> (a sun.nio.ch.Util$2)
    - locked <0x00000006b0896498> (a java.util.Collections$UnmodifiableSet)
    - locked <0x00000006b0890d20> (a sun.nio.ch.EPollSelectorImpl)
    at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
    at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:52)
    at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:208)
    at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:38)
    at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
    at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
    at java.lang.Thread.run(Thread.java:722)

我在 Linux 上使用 Netty 3.4.6.Final 和 Java 7.04。谢谢！

兄弟，弗兰克。

4

3 回答 3

4

裸 Netty 客户端/服务器也有同样的“问题”。

问题是，关闭服务器通道不会关闭为接受的客户端连接创建的打开通道。必须明确跟踪服务器中的客户端通道。这可以通过通道组和将客户端通道添加到该组的处理程序来完成。在关闭服务器时，应该以批处理方式关闭组中的所有通道，而不是仅关闭一个服务器通道（也可以放入通道组）。

用户指南（9. 关闭您的应用程序）中有出色的文档： http : //static.netty.io/3.5/guide/ 和 ChannelGroup API 文档（使用 ChannelGroup 简化关闭过程）：http://static。 netty.io/3.5/api/org/jboss/netty/channel/group/ChannelGroup.html

于 2012-08-04T10:47:33.740 回答
3

我有同样的问题并解决了。您必须EventLoopGroup同步关闭所有端口，然后关闭端口。

完全关机可能需要 4-5 秒。

这是一个示例代码（我认为您应该使用start和stop按钮制作一个简单的 GUI 来测试它）：

public class ReusePortServer {
    private final int port;
    ChannelFuture f;
    EventLoopGroup group;
    EpollEventLoopGroup bossGroup;
    EpollEventLoopGroup workerGroup;


    public ReusePortServer(int port) {
        this.port = port;
    }

    public void start() throws Exception {

        group = new EpollEventLoopGroup();

        bossGroup = new EpollEventLoopGroup();
        workerGroup = new EpollEventLoopGroup();

        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
                .channel(EpollServerSocketChannel.class)
                .option(EpollChannelOption.SO_REUSEPORT, true)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    public void initChannel(SocketChannel ch) throws Exception {
                        ch.pipeline().addLast(new ReusePortHandler());
                    }
                });

        f = b.bind(port).sync();
        log(String.format("%s started and listen on %s", ReusePortServer.class.getName(), f.channel().localAddress()));
    }

    private final static SimpleDateFormat datefmt = new SimpleDateFormat("HH:mm:ss ");

    public static void log(final String msg) {
        System.out.print(datefmt.format(new Date()));
        System.out.println(msg);
        System.out.flush();
    }

    public void stop() {
        System.out.println("ReusePortServer.stop");
        try {
            // shutdown EventLoopGroup
            bossGroup.shutdownGracefully().sync();
            workerGroup.shutdownGracefully().sync();
            f.channel().closeFuture().sync();   // close port

        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public static void main(final String[] args) throws Exception {
        int port = 12345;
        new ReusePortServer(port).start();
    }
}

注意：您可以更改EpollEventLoopGroup为任何EventLoopGroup您想要的。

于 2016-08-13T08:55:05.723 回答
0

Netty 服务器关闭

  1. 关闭服务器通道
  2. 关闭老板和工人执行者
  3. 释放服务器引导资源

示例代码

ChannelFuture cf = serverChannel.close();
cf.awaitUninterruptibly();
bossExecutor.shutdown();
workerExecutor.shutdown();
thriftServer.releaseExternalResources();
于 2012-06-07T10:49:48.520 回答