1、Netty的重要Handle类
- SimpleChannelInboundHandler 是一个输入流
- ChannelOutboundHandlerAdapter是一个输出流
- Netty提供了很多组件进行解码器和加码器，对二进制的内容进行解析转换成真实的内容
- ChannelHandlerContext，获取上下文的内容信息：如远程的地址
protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
//获取地址
System.out.println(ctx.channel().remoteAddress());
}
SimpleChannelInboundHandler
ChannelOutboundHandlerAdapter
ChannelHandlerContext
2、 GlobalEventExcecutor类
- GlobalEventExcecutor类是一个单线程的类
-
GlobalEventExecutor是具备任务队列的单线程事件执行器,其适合用来实行时间短，碎片化的任务
GlobalEventExcecutor
public final class GlobalEventExecutor extends AbstractScheduledEventExecutor {
//单例对象
public static final GlobalEventExecutor INSTANCE = new GlobalEventExecutor();
//维护的任务队列
final BlockingQueue<Runnable> taskQueue = new LinkedBlockingQueue<Runnable>();
ScheduledFutureTask.deadlineNanos(SCHEDULE_QUIET_PERIOD_INTERVAL), -SCHEDULE_QUIET_PERIOD_INTERVAL);
//线程工厂
final ThreadFactory threadFactory =
new DefaultThreadFactory(DefaultThreadFactory.toPoolName(getClass()), false, Thread.NORM_PRIORITY, null);
//一个循环运行的执行器
private final TaskRunner taskRunner = new TaskRunner();
//标记当前线程是否启动
private final AtomicBoolean started = new AtomicBoolean();
//运行中的线程
volatile Thread thread;
@Override
public boolean inEventLoop(Thread thread) {
return thread == this.thread;
}
}
-
inEventLoop方法
判断当前执行代码是否在同一个线程，有两种情况
第一次没有异步线程,则创建新线程
若在非当前运行线程中添加任务,判断异步线程是否在执行，如果没有则创建新的线程(原线程已经执行完毕)
3、DefaultPromise的实现
- 本质是使用EventExecutor的execute方法，将通知方法放到异步线程队列中,所以其回调也是在EventExecutor的线程中执行
4、如何检测分布式节点与节点的存活状态
- 节点与节点的存活（分布式）其实是用心跳检测机制通知对方（A -> B -> C）如：C调用B，如果当C尝试调用了三次以上或更多次以上，就认为对方都没有响应(超时或断开连接等事件)，从而失去连接就从集群里面移除掉（重点）
5、什么是解码和加码
- 解码Decoder：解码是将字符数组转换成字符串
- 加码Encoder：加码是将字符串转换成字符数组
