先啰嗦兩句，假設你還不知道Netty是做什么的能做什么。那能夠先簡單的搜索了解一下。我僅僅能說Netty是一個NIO的框架，能夠用於開發分布式的Java程序。詳細能做什么，各位能夠盡量發揮想象。技術，是服務於人而不是局限住人的。
假設你已經萬事具備，那么我們先從一段代碼開始。程序猿們習慣的上手第一步，自然是"Hello world"，只是Netty官網的樣例卻偏偏拋棄了"Hello world"。那我們就自己寫一個最簡單的"Hello world"的樣例，作為上手。
/**
* Netty 服務端代碼
*
* @author lihzh
* @alia OneCoder
* @blog http://www.coderli.com
*/
public class HelloServer {
public static void main(String args[]) {
// Server服務啟動器
ServerBootstrap bootstrap = new ServerBootstrap(
new NioServerSocketChannelFactory(
Executors.newCachedThreadPool(),
Executors.newCachedThreadPool()));
// 設置一個處理client消息和各種消息事件的類(Handler)
bootstrap
.setPipelineFactory(new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline()
throws Exception {
return Channels
.pipeline(new HelloServerHandler());
}
});
// 開放8000port供client訪問。
bootstrap.bind(new InetSocketAddress(8000));
}
private static class HelloServerHandler extends
SimpleChannelHandler {
/**
* 當有client綁定到服務端的時候觸發，打印"Hello world, I'm server."
*
* @alia OneCoder
* @author lihzh
*/
@Override
public void channelConnected(
ChannelHandlerContext ctx,
ChannelStateEvent e) {
System.out.println("Hello world, I'm server.");
}
}
}
/**
* Netty client代碼
*
* @author lihzh
* @alia OneCoder
* @blog http://www.coderli.com
*/
public class HelloClient {
public static void main(String args[]) {
// Client服務啟動器
ClientBootstrap bootstrap = new ClientBootstrap(
new NioClientSocketChannelFactory(
Executors.newCachedThreadPool(),
Executors.newCachedThreadPool()));
// 設置一個處理服務端消息和各種消息事件的類(Handler)
bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
@Override
public ChannelPipeline getPipeline() throws Exception {
return Channels.pipeline(new HelloClientHandler());
}
});
// 連接到本地的8000port的服務端
bootstrap.connect(new InetSocketAddress(
"127.0.0.1", 8000));
}
private static class HelloClientHandler extends SimpleChannelHandler {
/**
* 當綁定到服務端的時候觸發，打印"Hello world, I'm client."
*
* @alia OneCoder
* @author lihzh
*/
@Override
public void channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) {
System.out.println("Hello world, I'm client.");
}
}
}
既然是分布式的，自然要分多個服務。Netty中，須要區分Server和Client服務。全部的Client都是綁定在Server上的，他們之間是不能通過Netty直接通信的。（自己採用的其它手段，不包含在內。）。白話一下這個通信過程，Server端開放port，供Client連接，Client發起請求，連接到Server指定的port，完畢綁定。隨后便可自由通信。事實上就是普通Socket連接通信的過程。
Netty框架是基於事件機制的，簡單說，就是發生什么事，就找相關處理方法。就跟着火了找119，搶劫了找110一個道理。所以，這里，我們處理的是當client和服務端完畢連接以后的這個事件。什么時候完畢的連接，Netty知道，他告訴我了，我就負責處理。這就是框架的作用。Netty，提供的事件還有非常多，以后會慢慢的接觸和介紹。
你應該已經能夠上手了：）