當(dāng)前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

网络应用框架Netty快速入门

發(fā)布時(shí)間：2025/3/17 编程问答 45 豆豆

生活随笔收集整理的這篇文章主要介紹了网络应用框架Netty快速入门小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

一初遇Netty

Netty是什么？

Netty 是一個(gè)提供 asynchronous event-driven （異步事件驅(qū)動(dòng)）的網(wǎng)絡(luò)應(yīng)用框架，是一個(gè)用以快速開發(fā)高性能、可擴(kuò)展協(xié)議的服務(wù)器和客戶端。

Netty能做什么？

Netty 是一個(gè) NIO 客戶端服務(wù)器框架，使用它可以快速簡單地開發(fā)網(wǎng)絡(luò)應(yīng)用程序，比如服務(wù)器(HTTP服務(wù)器，FTP服務(wù)器，WebSocket服務(wù)器，Redis的Proxy服務(wù)器等等)和客戶端的協(xié)議。Netty 大大簡化了網(wǎng)絡(luò)程序的開發(fā)過程比如 TCP 和 UDP 的 socket 服務(wù)的開發(fā)。

Netty為什么好？

Netty是建立在NIO基礎(chǔ)之上，Netty在NIO之上又提供了更高層次的抽象，使用它你可以更容易利用Java NIO提高服務(wù)端和客戶端的性能。

Netty的特性：

1. 設(shè)計(jì)

1.1 統(tǒng)一的API，適用于不同的協(xié)議（阻塞和非阻塞）1.2 基于可擴(kuò)展和靈活的事件驅(qū)動(dòng)模型1.3高度可定制的線程模型 - 單線程，一個(gè)或多個(gè)線程池，如SEDA1.4真正的無連接數(shù)據(jù)報(bào)套接字支持（自3.1以來）

2. 性能

2.1更好的吞吐量，低延遲2.2更省資源2.3盡量減少不必要的內(nèi)存拷貝

3. 安全

完整的SSL / TLS和StartTLS協(xié)議的支持

4. 易用性

4.1 官方有詳細(xì)的使用指南4.2 對環(huán)境要求很低 NIO和IO的區(qū)別是什么？

1. 一個(gè)面向字節(jié)一個(gè)面向緩沖；

IO面向流意味著每次從流中讀一個(gè)或多個(gè)字節(jié)，直至讀取所有字節(jié)，它們沒有被緩存在任何地方。此外，它不能前后移動(dòng)流中的數(shù)據(jù)。如果需要前后移動(dòng)從流中讀取的數(shù)據(jù)，需要先將它緩存到一個(gè)緩沖區(qū)。 Java NIO的緩沖導(dǎo)向方法略有不同。數(shù)據(jù)讀取到一個(gè)它稍后處理的緩沖區(qū)，需要時(shí)可在緩沖區(qū)中前后移動(dòng)。這就增加了處理過程中的靈活性。但是，還需要檢查是否該緩沖區(qū)中包含所有您需要處理的數(shù)據(jù)。而且，需確保當(dāng)更多的數(shù)據(jù)讀入緩沖區(qū)時(shí)，不要覆蓋緩沖區(qū)里尚未處理的數(shù)據(jù)。

2. NIO是非阻塞IO，IO是阻塞IO

阻塞意味著當(dāng)一個(gè)線程調(diào)用read() 或 write()時(shí)，該線程被阻塞，直到有一些數(shù)據(jù)被讀取，或數(shù)據(jù)完全寫入，該線程在此期間不能再干任何事情了。而非阻塞不會(huì)這樣。

二 Netty使用

環(huán)境要求：

JDK 7+
Maven 3.2.x
Netty 4.x

Maven依賴：

<dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.0.32.Final</version></dependency>

以下Netty examples來源： 官方文檔

2.1 寫個(gè)拋棄服務(wù)器

DiscardServerHandler.java

import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter;/*** handler 是由 Netty 生成用來處理 I/O 事件的。*/ public class DiscardServerHandler extends ChannelInboundHandlerAdapter { // (1)/*** 這里我們覆蓋了 chanelRead() 事件處理方法。* 每當(dāng)從客戶端收到新的數(shù)據(jù)時(shí)，這個(gè)方法會(huì)在收到消息時(shí)被調(diào)用。*((ByteBuf) msg).release()：丟棄數(shù)據(jù)*/@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) { // (2)// 默默地丟棄收到的數(shù)據(jù)((ByteBuf) msg).release(); // (3)}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { // (4)// 當(dāng)出現(xiàn)異常就關(guān)閉連接cause.printStackTrace();ctx.close();} }

目前我們已經(jīng)實(shí)現(xiàn)了 DISCARD 服務(wù)器的一半功能，剩下的需要編寫一個(gè) main() 方法來啟動(dòng)服務(wù)端的 DiscardServerHandler。

DiscardServer.java

import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel;/*** 啟動(dòng)服務(wù)端的 DiscardServerHandler*/ public class DiscardServer {private int port;public DiscardServer(int port) {this.port = port;}public void run() throws Exception {//在這個(gè)例子中我們實(shí)現(xiàn)了一個(gè)服務(wù)端的應(yīng)用，因此會(huì)有2個(gè) NioEventLoopGroup 會(huì)被使用。//第一個(gè)經(jīng)常被叫做‘boss’，用來接收進(jìn)來的連接。//第二個(gè)經(jīng)常被叫做‘worker’，用來處理已經(jīng)被接收的連接，一旦‘boss’接收到連接，就會(huì)把連接信息注冊到‘worker’上。EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup();try {//啟動(dòng) NIO 服務(wù)的輔助啟動(dòng)類ServerBootstrap serverBootstrap = new ServerBootstrap(); //用于處理ServerChannel和Channel的所有事件和IO。serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class) // (3).childHandler(new ChannelInitializer<SocketChannel>() { // (4)@Overridepublic void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new DiscardServerHandler());}}).option(ChannelOption.SO_BACKLOG, 128) // (5).childOption(ChannelOption.SO_KEEPALIVE, true); // (6)// 綁定端口，開始接收進(jìn)來的連接ChannelFuture f = serverBootstrap.bind(port).sync(); // (7)// 等待服務(wù)器 socket 關(guān)閉。// 在這個(gè)例子中，這不會(huì)發(fā)生，但你可以優(yōu)雅地關(guān)閉你的服務(wù)器。f.channel().closeFuture().sync();} finally {workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();}}public static void main(String[] args) throws Exception {int port;if (args.length > 0) {port = Integer.parseInt(args[0]);} else {port = 8080;}new DiscardServer(port).run();} }

2.2 查看收到的數(shù)據(jù)

我們剛剛已經(jīng)編寫出我們第一個(gè)服務(wù)端，我們需要測試一下他是否真的可以運(yùn)行。最簡單的測試方法是用 telnet 命令。例如，你可以在命令行上輸入telnet localhost 8080 或者其他類型參數(shù)。

然而我們能說這個(gè)服務(wù)端是正常運(yùn)行了嗎？事實(shí)上我們也不知道，因?yàn)樗且粋€(gè) discard 服務(wù)，你根本不可能得到任何的響應(yīng)。為了證明他仍然是在正常工作的，讓我們修改服務(wù)端的程序來打印出他到底接收到了什么。

我們已經(jīng)知道 channelRead() 方法是在數(shù)據(jù)被接收的時(shí)候調(diào)用。讓我們放一些代碼到 DiscardServerHandler 類的 channelRead() 方法。

修改DiscardServerHandler類的channelRead(ChannelHandlerContext ctx, Object msg)方法如下：

@Override public void channelRead(ChannelHandlerContext ctx, Object msg) {ByteBuf in = (ByteBuf) msg;try {while (in.isReadable()) { // (1)System.out.print((char) in.readByte());System.out.flush();}} finally {ReferenceCountUtil.release(msg); // (2)} }

再次驗(yàn)證，cmd下輸入：telnet localhost 8080。你將會(huì)看到服務(wù)端打印出了他所接收到的消息。

如下：

你在dos界面輸入的消息會(huì)被顯示出來

2.3 寫個(gè)應(yīng)答服務(wù)器

到目前為止，我們雖然接收到了數(shù)據(jù)，但沒有做任何的響應(yīng)。然而一個(gè)服務(wù)端通常會(huì)對一個(gè)請求作出響應(yīng)。讓我們學(xué)習(xí)怎樣在 ECHO 協(xié)議的實(shí)現(xiàn)下編寫一個(gè)響應(yīng)消息給客戶端，這個(gè)協(xié)議針對任何接收的數(shù)據(jù)都會(huì)返回一個(gè)響應(yīng)。

和 discard server 唯一不同的是把在此之前我們實(shí)現(xiàn)的 channelRead() 方法，返回所有的數(shù)據(jù)替代打印接收數(shù)據(jù)到控制臺上的邏輯。因此，需要把 channelRead() 方法修改如下：

@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) {ctx.write(msg); ctx.flush(); }

再次驗(yàn)證，cmd下輸入：telnet localhost 8080。你會(huì)看到服務(wù)端會(huì)發(fā)回一個(gè)你已經(jīng)發(fā)送的消息。
如下：

下一篇我們會(huì)學(xué)習(xí)如何用Netty實(shí)現(xiàn)聊天功能。

歡迎關(guān)注我的微信公眾號:"Java 面試通關(guān)手冊"（堅(jiān)持原創(chuàng)，分享美文，分享各種Java學(xué)習(xí)資源，面試題，以及企業(yè)級Java實(shí)戰(zhàn)項(xiàng)目回復(fù)關(guān)鍵字免費(fèi)領(lǐng)取）：

總結(jié)

以上是生活随笔為你收集整理的网络应用框架Netty快速入门的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： Linux rsyslog 转存至日志服
下一篇： Swift解决【闭包引起的循环强引用】