2. 程式人生 > >netty初認識

netty初認識

阿新 • • 發佈：2017-07-31
技術 chm 做到 rtt 監聽 erro extend apple buffered

Netty是什麽？

本質：JBoss做的一個Jar包

目的：快速開發高性能、高可靠性的網絡服務器和客戶端程序

優點：提供異步的、事件驅動的網絡應用程序框架和工具

通俗的說：一個好使的處理Socket的東東

如果沒有Netty？

遠古：java.net + java.io

近代：java.nio

其他：Mina，Grizzly

為什麽不是Mina？

1、都是Trustin Lee的作品，Netty更晚；

2、Mina將內核和一些特性的聯系過於緊密，使得用戶在不需要這些特性的時候無法脫離，相比下性能會有所下降，Netty解決了這個設計問題；

3、Netty的文檔更清晰，很多Mina的特性在Netty裏都有；

4、Netty更新周期更短，新版本的發布比較快；

5、它們的架構差別不大，Mina靠apache生存，而Netty靠jboss，和jboss的結合度非常高，Netty有對google protocal buf的支持，有更完整的ioc容器支持(spring,guice,jbossmc和osgi)；

6、Netty比Mina使用起來更簡單，Netty裏你可以自定義的處理upstream events 或/和 downstream events，可以使用decoder和encoder來解碼和編碼發送內容；

7、Netty和Mina在處理UDP時有一些不同，Netty將UDP無連接的特性暴露出來；而Mina對UDP進行了高級層次的抽象，可以把UDP當成"面向連接"的協議，而要Netty做到這一點比較困難。

Netty的特性

設計

統一的API，適用於不同的協議（阻塞和非阻塞）

基於靈活、可擴展的事件驅動模型

高度可定制的線程模型

可靠的無連接數據Socket支持（UDP）

性能

更好的吞吐量，低延遲

更省資源

盡量減少不必要的內存拷貝

安全

完整的SSL/TLS和STARTTLS的支持

能在Applet與Android的限制環境運行良好

健壯性

不再因過快、過慢或超負載連接導致OutOfMemoryError

不再有在高速網絡環境下NIO讀寫頻率不一致的問題

易用

完善的JavaDoc，用戶指南和樣例

簡潔簡單

僅信賴於JDK1.5

看例子吧！

Server端：

Java代碼 技術分享
  1. package me.hello.netty;
  3. import org.jboss.netty.bootstrap.ServerBootstrap;
  4. import org.jboss.netty.channel.*;
  5. import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
  6. import org.jboss.netty.handler.codec.string.StringDecoder;
  7. import org.jboss.netty.handler.codec.string.StringEncoder;
  9. import java.net.InetSocketAddress;
  10. import java.util.concurrent.Executors;
  12. /**
  13. * God Bless You!
  14. * Author: Fangniude
  15. * Date: 2013-07-15
  16. */
  17. public class NettyServer {
  18. public static void main(String[] args) {
  19. ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
  21. // Set up the default event pipeline.
  22. bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
  23. @Override
  24. public ChannelPipeline getPipeline() throws Exception {
  25. return Channels.pipeline(new StringDecoder(), new StringEncoder(), new ServerHandler());
  26. }
  27. });
  29. // Bind and start to accept incoming connections.
  30. Channel bind = bootstrap.bind(new InetSocketAddress(8000));
  31. System.out.println("Server已經啟動，監聽端口: " + bind.getLocalAddress() + "， 等待客戶端註冊。。。");
  32. }
  34. private static class ServerHandler extends SimpleChannelHandler {
  35. @Override
  36. public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  37. if (e.getMessage() instanceof String) {
  38. String message = (String) e.getMessage();
  39. System.out.println("Client發來:" + message);
  41. e.getChannel().write("Server已收到剛發送的:" + message);
  43. System.out.println("\n等待客戶端輸入。。。");
  44. }
  46. super.messageReceived(ctx, e);
  47. }
  49. @Override
  50. public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
  51. super.exceptionCaught(ctx, e);
  52. }
  54. @Override
  55. public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
  56. System.out.println("有一個客戶端註冊上來了。。。");
  57. System.out.println("Client:" + e.getChannel().getRemoteAddress());
  58. System.out.println("Server:" + e.getChannel().getLocalAddress());
  59. System.out.println("\n等待客戶端輸入。。。");
  60. super.channelConnected(ctx, e);
  61. }
  62. }
  63. }

客戶端：

Java代碼 技術分享
  1. package me.hello.netty;
  3. import org.jboss.netty.bootstrap.ClientBootstrap;
  4. import org.jboss.netty.channel.*;
  5. import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
  6. import org.jboss.netty.handler.codec.string.StringDecoder;
  7. import org.jboss.netty.handler.codec.string.StringEncoder;
  9. import java.io.BufferedReader;
  10. import java.io.InputStreamReader;
  11. import java.net.InetSocketAddress;
  12. import java.util.concurrent.Executors;
  14. /**
  15. * God Bless You!
  16. * Author: Fangniude
  17. * Date: 2013-07-15
  18. */
  19. public class NettyClient {
  21. public static void main(String[] args) {
  22. // Configure the client.
  23. ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
  25. // Set up the default event pipeline.
  26. bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
  27. @Override
  28. public ChannelPipeline getPipeline() throws Exception {
  29. return Channels.pipeline(new StringDecoder(), new StringEncoder(), new ClientHandler());
  30. }
  31. });
  33. // Start the connection attempt.
  34. ChannelFuture future = bootstrap.connect(new InetSocketAddress("localhost", 8000));
  36. // Wait until the connection is closed or the connection attempt fails.
  37. future.getChannel().getCloseFuture().awaitUninterruptibly();
  39. // Shut down thread pools to exit.
  40. bootstrap.releaseExternalResources();
  41. }
  43. private static class ClientHandler extends SimpleChannelHandler {
  44. private BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
  46. @Override
  47. public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
  48. if (e.getMessage() instanceof String) {
  49. String message = (String) e.getMessage();
  50. System.out.println(message);
  52. e.getChannel().write(sin.readLine());
  54. System.out.println("\n等待客戶端輸入。。。");
  55. }
  57. super.messageReceived(ctx, e);
  58. }
  60. @Override
  61. public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
  62. System.out.println("已經與Server建立連接。。。。");
  63. System.out.println("\n請輸入要發送的信息：");
  64. super.channelConnected(ctx, e);
  66. e.getChannel().write(sin.readLine());
  67. }
  68. }
  69. }

Netty整體架構


技術分享

Netty組件

ChannelFactory

Boss

Worker

Channel

ChannelEvent

Pipeline

ChannelContext

Handler

Sink

Server端核心類

NioServerSocketChannelFactory

NioServerBossPool

NioWorkerPool

NioServerBoss

NioWorker

NioServerSocketChannel

NioAcceptedSocketChannel

DefaultChannelPipeline

NioServerSocketPipelineSink

Channels

ChannelFactory

Channel工廠，很重要的類

保存啟動的相關參數

NioServerSocketChannelFactory

NioClientSocketChannelFactory

NioDatagramChannelFactory

這是Nio的，還有Oio和Local的

SelectorPool

Selector的線程池

NioServerBossPool 默認線程數：1

NioClientBossPool 1

NioWorkerPool 2 * Processor

NioDatagramWorkerPool

Selector

選擇器，很核心的組件

NioServerBoss

NioClientBoss

NioWorker

NioDatagramWorker

Channel

通道

NioServerSocketChannel

NioClientSocketChannel

NioAcceptedSocketChannel

NioDatagramChannel

Sink

負責和底層的交互

如bind，Write，Close等

NioServerSocketPipelineSink

NioClientSocketPipelineSink

NioDatagramPipelineSink

Pipeline

負責維護所有的Handler

ChannelContext

一個Channel一個，是Handler和Pipeline的中間件

Handler

對Channel事件的處理器

ChannelPipeline


技術分享

技術分享

優秀的設計----事件驅動


技術分享

優秀的設計----線程模型


技術分享

註意事項

解碼時的Position

Channel的關閉

更多Handler

Channel的關閉

用完的Channel，可以直接關閉；

1、ChannelFuture加Listener

2、writeComplete

一段時間沒用，也可以關閉

TimeoutHandler

轉自： http://lippeng.iteye.com/blog/1907279

netty初認識

相關推薦

netty初認識

技術 chm 做到 rtt 監聽 erro extend apple buffered Netty是什麽？ 本質：JBoss做的一個Jar包 目的：快速開發高性能、高可靠性的網絡服務器和客戶端程序 優點：提供異步的、事件驅動的網絡應用程序框架和工具 通俗的說

FPGA之初認識

而已 nbsp lte 內部 ron 受限 ram 我們 特定 什麽是FPGA FPGA（Field-Programmable Gate Array），即現場可編程門陣列 。看到編程兩個字碼農就笑了，不就是編程嘛，那可是我們的強項 。且慢，此編程非彼編程 。一定要把 F

Linux初認識

linux 命令 虛擬機1.虛擬機使用[[email protected]/* */ Desktop]$ rht-vmctl start desktop（開啟desktop虛擬機）[[email protected]/* */ Desktop]$ rht-vmctl view desk

zookeeper初認識

集群管理 分布式應用 目錄樹 判斷 down 並不是 通知 ast 種類型 zookeeper是什麽 zookeeper是一個分布式應用協調系統，它主要提供了命名服務、狀態同步服務、集群管理、分布式應用配置項的管理等功能。 簡單的說，zookeeper=文件系統+通知機制。

學習筆記--數論--莫比烏斯反演初認識

開頭 iostream rime prime 沒有 ace 建議 bool names 前言 本文只是用比較通俗的例子讓大家了解一下什麽是莫比烏斯反演，其中說明 （明明都是瞎猜）可能有紕漏。本人也是個蒟蒻，未能給出珂學證明，還望多多指教。 理論基礎 “|”符號表示整除

Spring Cloud 初認識

依據 分布式服務 顯示 關系 man 單個 strong 消息 追蹤 Spring Cloud是一個繼承了眾多開源的框架，其利用了Springboot開發的便利性來實現分布式服務功能，是一套開放、易部署、易維護的分布式開發工具包，而且有成熟的社區且社區活躍度很高。Sprin

python之路，Day2-python模塊初認識&數據類型

存在 logs key sort 等價 不可 bsp list 變量 一、模塊初識 首先，文件名不能和導入的模塊名稱一樣。因為系統默認先從當前文件尋找模塊名，如果文件名和導入的模塊名稱一樣的話，就相當於自己調用自己，會找不到相應的方法的。 sys模塊 sys.path 　　

netty初步認識

配置 decode name 業務邏輯 try dwr safe election sim package com.hhr.demo; import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.B

YII1 MVC初認識（二）

end public 靜態頁 意思 好的 assets 如何 sset 還要 上次說了yii1的安裝，這次說下簡單的使用,其實使用看手冊就可以了，我這裏就簡單說下快速調通一個框架，跑通一個helloworld的方法。 1.首先 你得知道 views cont

stm32架構初認識

渠道 pll 寄存器 基本 置1 得到 工作 采集 相對 剛接觸stm32f373c8t6的芯片，這到底是怎末開發的，應該說它是SOC，內部有一個核心芯片，然後在芯片的外部添加了一些有特殊功能的外設，使開發者能夠完成想要的功能，以stm32f373c 8t6為例，它與

Java初認識--基本資料型別（int 和byte之間賦值）預設值 型別強轉

主類和主方法 Test.java–是原始檔，原始檔必須與主類名(public class )保持一致，一個原始檔只能有一個主類 ，主方法存在與主類中。 Test.java 原始檔 主類：public class Test 主方法 ： public static void main(Strin

DataBinding系列：DataBinding初認識

轉載自：https://www.jianshu.com/p/53925ccb900e   早在2015谷歌 I/O大會上，就介紹了一個新的框架DataBinding，從名字就可以看出來，這是一個數據繫結框架。我們為什麼要使用DataBinding？1.再也不需要編寫fi

初認識java 之輸出個人資訊（內含過載方法）

public class Peopleinformation{ private String name; private String sex; private int age; private String post; private String tel; private S

argparse的初認識

     argparse模組作為optparse的一個替代被新增到Python2.7。argparse的實現支援一些不易於新增到optparse以及要求向後不相容API變化的特性，因此以一個新模組新增到標準庫。argparse通過在程式中定義好我們需要的引數，其將會

ETL技術入門之ETL初認識，資料倉庫

ETL ，是英文 Extract-Transform-Load 的縮寫，用來描述將資料從來源端經過抽取（extract）、轉換（transform）、載入（load）至目的端的過程。 ETL 一詞較常用在 資料倉庫 ，但其物件並不限於資料倉庫。 ETL是什麼 ET

一、Kafka初認識

一、kafka使用背景 1、Kafka使用背景 在我們大量使用分散式資料庫、分散式計算叢集的時候，是否會遇到這樣的一些問題： 我們想分析下使用者行為（pageviews），以便我們設計出更好的廣告位 我想對使用者的搜尋關鍵詞進行統計，分析出當前的流行趨勢 有些資料，儲存資料庫浪費，直接儲存硬碟效

Java初認識--基本資料型別（int 和byte之間賦值）預設值 型別強轉

主類和主方法 Test.java–是原始檔，原始檔必須與主類名(public class )保持一致，一個原始檔只能有一個主類 ，主方法存在與主類中。 Test.java 原始檔 主類：public class Test 主方法 ： public stat

事件冒泡初認識

說是初認識，其實也不算了，剛學習JS時就已經聽過事件的冒泡和捕獲的大名，但真是不知所云，也是不求甚解，迷惑了很久，今天終決定好好來了解一下這個冒泡。 什麼是冒泡 當事件發生後，這個事件就要開始傳播(從裡到外或者從外向裡)。為什麼要傳播呢？因為事件源本身（可能）並沒有處理

shell指令碼的那點小事兒--shell初認識(一)

1.第一個shell指令碼 1.1建立一個shell指令碼 touch xxx.sh 標配格式 #!/bin/bash ->這一行是標準頭部，不可以去掉 echo "hello world!" 1.2.mac終端檢視檔案 ls -l hello.sh e.g:[e

git（分散式版本控制工具） 初認識

 軟體安裝 git的安裝問題： 永久有效（百度雲盤/安裝包） 在安裝過程中建議使用 git bash 作為命令列工具,safest  配置： 首先 開啟命令列 進入git的bin下 進行全域性配置 git config -