当前位置：文江博客话题详情

您将如何扩展频道？

发布于 2024-12-27 04:31:18 字数 90 浏览 0 评论 0原文

我需要一些有关 Netty 的帮助。我想知道如何扩展 Channel 接口并向其中添加我自己的方法并使 Netty 使用它（或强制转换为它）？

马特。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

热血少△年 2025-01-03 04:31:18

答案对于 netty 4.1.25.Final 来说是实际的。

首先扩展您的通道类型，

public class ExtendedNioChannel extends NioSocketChannel implements Channel {
    private volatile boolean handshakeComplete;
    // more custom fields and methods
}

如果您想将其用于客户端引导，只需将该类传递给它即可。

 Bootstrap b = new Bootstrap();
                b.group(workerGroup);
                b.channel(ExtendedNioChannel.class);

对于服务器引导程序，您需要覆盖 NioServerSocketChannel 并将 NioServerSocketChannel.class 传递给 ServerBootstrap。

public class ExtendedNioServerChannel extends NioServerSocketChannel {
    private static final InternalLogger logger = InternalLoggerFactory.getInstance(NioServerSocketChannel.class);

    @Override
    protected int doReadMessages(List<Object> buf) throws Exception {
        SocketChannel ch = SocketUtils.accept(javaChannel());

        try {
            if (ch != null) {
                buf.add(new ExtendedNioChannel(this, ch));
                return 1;
            }
        } catch (Throwable t) {
            logger.warn("Failed to create a new channel from an accepted socket.", t);

            try {
                ch.close();
            } catch (Throwable t2) {
                logger.warn("Failed to close a socket.", t2);
            }
        }

        return 0;
    }
}

 ServerBootstrap b = new ServerBootstrap();
            b.group(acceptGroup, workerGroup)
                    .channel(BtcNioServerChannel.class)

The answer is actual for netty 4.1.25.Final.

First extend your channel type

public class ExtendedNioChannel extends NioSocketChannel implements Channel {
    private volatile boolean handshakeComplete;
    // more custom fields and methods
}

If you want to use it for client bootstap just pass that class to it.

 Bootstrap b = new Bootstrap();
                b.group(workerGroup);
                b.channel(ExtendedNioChannel.class);

For server bootstrap you need to override NioServerSocketChannel and pass NioServerSocketChannel.class to ServerBootstrap.

public class ExtendedNioServerChannel extends NioServerSocketChannel {
    private static final InternalLogger logger = InternalLoggerFactory.getInstance(NioServerSocketChannel.class);

    @Override
    protected int doReadMessages(List<Object> buf) throws Exception {
        SocketChannel ch = SocketUtils.accept(javaChannel());

        try {
            if (ch != null) {
                buf.add(new ExtendedNioChannel(this, ch));
                return 1;
            }
        } catch (Throwable t) {
            logger.warn("Failed to create a new channel from an accepted socket.", t);

            try {
                ch.close();
            } catch (Throwable t2) {
                logger.warn("Failed to close a socket.", t2);
            }
        }

        return 0;
    }
}

 ServerBootstrap b = new ServerBootstrap();
            b.group(acceptGroup, workerGroup)
                    .channel(BtcNioServerChannel.class)

回复收藏 0 原文