NETTY的特性总结
| 分类 | 特性 |
|---|---|
| 设计 | 统一的API，支持多种传输类型，阻塞和非阻塞的 简单而强大的线程模型 真正的无连接数据报套接字支持 链接逻辑组件以支持复用 |
| 易于使用 | 详实的Javadoc和大量实例集 不需要超过JDK1.6+的支持 |
| 性能 | 拥有比Java核心API更高的吞吐量以及更低的延迟 得益于池化和复用，拥有更低的资源消耗 最小的内存复用 |
| 健壮性 | 不会因为慢速、快速或者超载的连接而导致OutOfMemoryError 消除在高速网络中NIO应用程序常见的不公平读/写比率 |
| 安全性 | 完整的SSL/TLS以及StartTLS的支持 可用于受限环境下，如Applet和OSGI |
| 社区驱动 | 发布快速而频繁 |
NETTY的核心组件
1、Channel
2、回调
3、Future
4、事件和ChannelHandler
回调
回调可以用一个简单的例子来解释
1、Class A实现了接口CallBack callback
2、 Class A中包含了一个Class B的引用b
3、Class B中有一个参数为CallBack类型的方法f(CallBack callback)
4、A的对象a调用B的对象b中的方法f(CallBack callback)
5、然后b就可以在f(CallBack callback)方法中调用A的方法
详细的例程见下面
#######回调接口
public interface Callback {
/**
* 回调接口
*/
public void solve(String result);
}
#######接口实现类
public class HandlerA implements Callback {
private HandlerB b;
public HandlerA(HandlerB b){
this.b = b;
}
/**
* 实现的方法
*/
@Override
public void solve(String result) {
System.out.println("最终得到的结果为--->" + result);
}
/**
* 向HandleB的对象提出问题,这是一个新线程
* @param question
*/
public void askQuestion(final String question){
new Thread(new Runnable() {
@Override
public void run() {
try {
b.executeMessage(HandlerA.this, question);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
play();
}
public void play(){
System.out.println("在B处理问题的同时做其它事");
}
}
#######接口方法的处理类
public class HandlerB {
public String name;
public HandlerB(String name){
this.name = name;
}
/**
* 被处理回调函数的方法
* @param callback
* @param question
* @return
* @throws InterruptedException
*/
public void executeMessage(Callback callback,String question) throws InterruptedException{
System.out.println("小王的问题--->" + question);
//处理问题花费的时间
Thread.sleep(10000);
String result = "答案是2";
callback.solve(result);
}
}
#######测试类
public class TestMethod {
/**
* @param args
*/
public static void main(String[] args) {
HandlerB b = new HandlerB("Jack");
HandlerA a = new HandlerA(b);
a.askQuestion("1 + 1 = ?");
}
}
运行这个程序，就可以得到我们想要的结果，即A向B提出了一个问题，等待B给出解答，但是与此同时A去做其它事情，当B完成这个问题的时候，给出A答案，这样的一个过程就是回调的过程
