您当前的位置: 首页 > 

恐龙弟旺仔

暂无认证

  • 0浏览

    0关注

    282博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

Netty源码解析-共享Channel的使用

恐龙弟旺仔 发布时间:2021-12-28 19:53:21 ,浏览量:0

前言:

之前分析使用ChannelHandler的文章中,每次我们在ChannelPipeline中添加上新new出来的ChannelHandler即可。在ChannelPipeline.addFirst()或其他相关添加方法中,我们可以看到以下代码

public class DefaultChannelPipeline implements ChannelPipeline {
    @Override
    public final ChannelPipeline addFirst(EventExecutorGroup group, String name, ChannelHandler handler) {
        final AbstractChannelHandlerContext newCtx;
        synchronized (this) {
            // 在这里会验证一下
            checkMultiplicity(handler);
            name = filterName(name, handler);

            newCtx = newContext(group, name, handler);

            addFirst0(newCtx);
            ...
        }
    }
    
    // 校验是否重复添加
    private static void checkMultiplicity(ChannelHandler handler) {
        if (handler instanceof ChannelHandlerAdapter) {
            ChannelHandlerAdapter h = (ChannelHandlerAdapter) handler;
            // 如果ChannelHandler非sharable且已经添加过,则直接抛出异常
            if (!h.isSharable() && h.added) {
                throw new ChannelPipelineException(
                        h.getClass().getName() +
                        " is not a @Sharable handler, so can't be added or removed multiple times.");
            }
            h.added = true;
        }
    }
}

在这里可以看到,如果ChannelHandler非sharable类型,且已经被添加过,则直接抛错。

在这里引出一个sharable类型,这个是做什么的呢?貌似平时根本没有用到过呢。本文就来分析下这个sharable类型。

1.ChannelHandler的sharable类型判断

我们通过代码来看下sharable是如何判断的

public abstract class ChannelHandlerAdapter implements ChannelHandler {
	public boolean isSharable() {
        Class clazz = getClass();
        Map            
关注
打赏
1655041699
查看更多评论
0.0361s