前言:
之前分析使用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
关注
打赏