Netty

#服务端

#客户端
EventLoop
EventLoopServer
EventLoopClient

Java

@Slf4j

publicclassEventLoopClient{

publicstaticvoidmain(String[]args)throwsInterruptedException{

// 1.启动类

Channelchannel=newBootstrap()

// 2.添加EventLoop

.group(newNioEventLoopGroup())

// 3.选择客户端channel实现

.channel(NioSocketChannel.class)

// 4.添加处理器

.handler(newChannelInitializer<NioSocketChannel>(){

                   @Override//连接初始化调用

protectedvoidinitChannel(NioSocketChannelch)throwsException{

ch.pipeline().addLast(newStringEncoder());

}

//5.链接到服务器

})

.connect(newInetSocketAddress("localhost",8080))

.sync()

.channel();

System.out.println(channel);

System.out.println("");

}

}

SO_BACKLOG

ByteBuf 源码

Java

// 池化技术

static{

StringallocType=SystemPropertyUtil.get(

"io.netty.allocator.type",PlatformDependent.isAndroid()?"unpooled" : "pooled");

allocType=allocType.toLowerCase(Locale.US).trim();

ByteBufAllocatoralloc;

if("unpooled".equals(allocType)){

alloc=UnpooledByteBufAllocator.DEFAULT;

logger.debug("-Dio.netty.allocator.type: {}",allocType);

}elseif("pooled".equals(allocType)){

alloc=PooledByteBufAllocator.DEFAULT;

logger.debug("-Dio.netty.allocator.type: {}",allocType);

}else{

alloc=PooledByteBufAllocator.DEFAULT;

logger.debug("-Dio.netty.allocator.type: pooled (unknown: {})",allocType);

}

DEFAULT_ALLOCATOR=alloc;

//是否使用堆内存  默认采用直接内存

// We should always prefer direct buffers by default if we can use a Cleaner to release direct buffers.

DIRECT_BUFFER_PREFERRED=CLEANER!=NOOP

&&!SystemPropertyUtil.getBoolean("io.netty.noPreferDirect",false);

if(logger.isDebugEnabled()){

logger.debug("-Dio.netty.noPreferDirect: {}",!DIRECT_BUFFER_PREFERRED);

}