日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Netty系列之一开始使用

發布時間:2025/3/20 编程问答 48 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Netty系列之一开始使用 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

Netty是用來做什么的呢,我的理解是它是一個網絡開發框架,利用它能很快速方便的開發出高性能的服務端和客戶端。剛開始學習java的時候你一定接觸過怎么利用socket去實現服務端和客戶端,后來java出了NIO這一大利器極大提供了網絡程序的性能,但是NIO是基于事件驅動的模型,理解起來比常用的套接字編程要難一點,但是無論是利用NIO還是原始的socket編程從0開始編寫一個服務端或是客戶端實在是太困難了。Netty就是幫助你去解決這樣的問題的,廢話不多說先簡單介紹一個例子,我們要寫一個服務端綁定端口號后,等待客戶端的連接,客戶端連接后打印一句歡迎語句,然后客戶端輸入什么,服務端打印出來,并且返回給客戶端輸出,利用netty實現如下

1 public class Server { 2 3 private ServerBootstrap serverBootstrap; 4 5 private int port; 6 7 public Server(int port) { 8 this.port = port; 9 serverBootstrap = new ServerBootstrap( 10 new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), 11 Executors.newCachedThreadPool())); 12 serverBootstrap.setPipelineFactory(new ChannelPipelineFactory() { 13 public ChannelPipeline getPipeline() throws Exception { 14 ChannelPipeline channelPipeline = Channels.pipeline(); 15 channelPipeline.addLast("decoder", new StringDecoder()); 16 channelPipeline.addLast("encoder", new StringEncoder()); 17 channelPipeline.addLast("serverHandler", new ServerHandler()); 18 return channelPipeline; 19 } 20 }); 21 serverBootstrap.bind(new InetSocketAddress(this.port)); 22 } 23 24 25 private class ServerHandler extends SimpleChannelUpstreamHandler { 26 @Override 27 public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { 28 if(e.getMessage() instanceof String) { 29 String message = (String) e.getMessage(); 30 System.out.println("Client Send:" + message); 31 e.getChannel().write("Server receive:" + message); 32 } 33 } 34 35 @Override 36 public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception { 37 System.out.println("A client connected to this server"); 38 System.out.println("Client:" + e.getChannel().getRemoteAddress()); 39 e.getChannel().write("******************************\r\n"); 40 e.getChannel().write("Welcome to connect this server\r\n"); 41 e.getChannel().write("******************************\r\n"); 42 } 43 } 44 45 public static void main(String args[]) { 46 new Server(9999); 47 } 48 }

?

轉載于:https://www.cnblogs.com/kakaleee/p/5487784.html

與50位技術專家面對面20年技術見證,附贈技術全景圖

總結

以上是生活随笔為你收集整理的Netty系列之一开始使用的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。