Java NIO框架Netty教程(一) – Hello Netty
先啰嗦兩句,假設你還不知道Netty是做什么的能做什么。那能夠先簡單的搜索了解一下。我僅僅能說Netty是一個NIO的框架,能夠用于開發(fā)分布式的Java程序。詳細能做什么,各位能夠盡量發(fā)揮想象。技術,是服務于人而不是局限住人的。
假設你已經(jīng)萬事具備,那么我們先從一段代碼開始。程序猿們習慣的上手第一步,自然是"Hello world",只是Netty官網(wǎng)的樣例卻偏偏拋棄了"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() {@Overridepublic ChannelPipeline getPipeline()throws Exception {return Channels.pipeline(new HelloServerHandler());}});// 開放8000port供client訪問。bootstrap.bind(new InetSocketAddress(8000));}private static class HelloServerHandler extendsSimpleChannelHandler {/*** 當有client綁定到服務端的時候觸發(fā),打印"Hello world, I'm server."* * @alia OneCoder* @author lihzh*/@Overridepublic 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() {@Overridepublic 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 {/*** 當綁定到服務端的時候觸發(fā),打印"Hello world, I'm client."* * @alia OneCoder* @author lihzh*/@Overridepublic void channelConnected(ChannelHandlerContext ctx,ChannelStateEvent e) {System.out.println("Hello world, I'm client.");}} }既然是分布式的,自然要分多個服務。Netty中,須要區(qū)分Server和Client服務。全部的Client都是綁定在Server上的,他們之間是不能通過Netty直接通信的。(自己採用的其它手段,不包含在內(nèi)。)。白話一下這個通信過程,Server端開放port,供Client連接,Client發(fā)起請求,連接到Server指定的port,完畢綁定。隨后便可自由通信。事實上就是普通Socket連接通信的過程。
Netty框架是基于事件機制的,簡單說,就是發(fā)生什么事,就找相關處理方法。就跟著火了找119,搶劫了找110一個道理。所以,這里,我們處理的是當client和服務端完畢連接以后的這個事件。什么時候完畢的連接,Netty知道,他告訴我了,我就負責處理。這就是框架的作用。Netty,提供的事件還有非常多,以后會慢慢的接觸和介紹。
你應該已經(jīng)能夠上手了:)
總結
以上是生活随笔為你收集整理的Java NIO框架Netty教程(一) – Hello Netty的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 科技守卫城市安全,智慧消防解决方案
- 下一篇: Java8基础之反射