Netty－简介
Netty－简介
Netty是一个NIO client-server框架，可以快速和简单的开发网络应用程序，比如协议服务器服务器和客户端。Netty向你提供了一种新的方式开发你的网络应用程序，使得它简单和可扩展。它通过这样的方式实现：抽象出所涉及的复杂性和通过提供一种简单易用的API，这个将业务逻辑从网络处理代码中解耦出来。因为它是为NIO构建,所有的Netty API都是异步的.
不选择Java原生NIO编程的原因
为什么不建议开发者直接使用 JDK 的 NIO 类库进行开发, 具体原因如下。
- NIO的类库和API繁杂,使用麻烦,你需要熟练掌握Selector、 ServerSocketChannel、SocketChannel、ByteBuffer等。
- 需要具备其他的额外技能做铺垫,例如熟悉Java多线程编程。这是因为 NIO编程涉及到Reactor模式,你必须对多线程和网路编程非常熟悉,才能 编写出高质量的NIO程序。
- 可靠性靠能力补齐,工作量和难度都非常大。例如客户端面临断连重连、网 络闪断、半包读写、失败缓存、网络拥塞和异常码流的处理等问题,NIO 编程的特点是功能开发相对容易,但是可靠性能力补齐的工作量和难度都 非常大。
- JDK NIO的BUG,例如臭名昭著的epoll bug,它会导致Selector空轮询, 最终导致CPU 100%。官方声称在JDK1.6版本的update18修复了该问题,但 是直到JDK1.7版本该问题仍旧存在,只不过该BUG发生概率降低了一些而 已,它并没有被根本解决。该BUG以及与该BUG相关的问题单可以参见以下 链接内容。
选择Netty的理由
Netty 是业界最流行的 NIO 框架之一,它的健壮性、功能、性能、可定制性 和可扩展性在同类框架中都是首屈一指的,它已经得到成百上千的商用项目验证, 例如 Hadoop 的 RPC 框架 avro 使用 Netty 作为底层通信框架;很多其他业界主流 的 RPC 框架,也使用 Netty 来构建高性能的异步通信能力。
通过对 Netty 的分析,我们将它的优点总结如下 :
- API使用简单,开发门槛低;
- 功能强大,预置了多种编解码功能,支持多种主流协议;
- 定制能力强,可以通过ChannelHandler对通信框架进行灵活地扩展;
- 性能高,通过与其他业界主流的NIO框架对比,Netty的综合性能最优;
- 成熟、稳定,Netty修复了已经发现的所有JDK NIO BUG,业务开发人员不需要再为NIO的BUG而烦恼;
- 社区活跃,版本迭代周期短,发现的BUG可以被及时修复,同时,更多的新功能会加入;
- 经历了大规模的商业应用考验,质量得到验证。在互联网、大数据、网络游戏、企业应用、电信软件等众多行业得到成功商用,证明了它已经完全能够满足不同行业的商业应用了。
正是因为这些优点,Netty 逐渐成为 Java NIO 编程的首选框架。
Netty架构
异步设计
异步设计并不是什么新鲜玩意，异步的思想已经很广泛。现今I/O处理往往会成为系统的瓶颈所在，异步处理显得尤为重要。但是不同的异步模式之间是有很多区别的，我们需要弄清楚这些模式背后的规则。
异步是指在应用处理当前任务的同时，可以新建一个任务处理一些其他的事情，然后在事情处理完成时再获取通知，而不是等待。这种方式使资源利用更加有效。
Callback 回调模式
Example
public interface Fetcher {
void fetchData(FetchCallback callback);
}
public interface FetchCallback {
void onData(Data data);
void onError(Throwable cause);
}
public class Worker {
public void doWork() {
Fetcher fetcher = ...
fetcher.fetchData(new FetchCallback() {
@Override
public void onData(Data data) { #1
System.out.println("Data received: " + data);
}
@Override
public void onError(Throwable cause) { #2
System.err.println("An error accour: " + cause.getMessage());
}
});
... }
}
- 回调接口
FetchCallback -
Fetcher.fetchData(FetchCallback)接收一个回调对象，这样我们可以将执行逻辑从回调者所在线程转移到其他线程。
Future
java.util.concurrent.Future对象在任务正常时可以持有执行结果，在任务异常时可以持有执行的异常。
Example
ExecutorService executor = Executors.newCachedThreadPool();
Runnable task1 = new Runnable() {
@Override
public void run() {
doSomeHeavyWork();
}
...
}
Callable<Interger> task2 = new Callable() {
@Override
public Integer call() {
return doSomeHeavyWorkWithResul();
}
...
}
Future<?> future1 = executor.submit(task1);
Future<Integer> future2 = executor.submit(task2);
while (!future1.isDone() || !future2.isDone()) {
...
// do something else
...
}
两种方式各有利弊：Callback的方式好处在于，当任务完成后会自动回调定义的回调接口，Future方式需要额外的检测；但是这样的编码风格可读性比较差。
