Netty4.x源码分析详解资源-CSDN文库

共1个文件

docx：1个

Netty4源码

5星 · 超过95%的资源需积分: 49 178 浏览量 2016-06-08 11:31:58 上传评论 2 收藏 387KB ZIP 举报

资源详情

资源评论

收起资源包目录

Netty4.x源码分析-详细版.docx.zip （1个子文件）

Netty4.x源码分析-详细版.docx 451KB

ney 4.x 源码分析



   服务端需要经过 socket、bind、accept、read、write 等步骤，客户端需要经过

socket、connect、read、write 等步骤，后续此系列文章会对每一个步骤如何发生进行分析。

以下是服务端和客户端的测试代码，后面的分析以这份代码为基础，目前使用的 Netty 的版本是

4.0.4.Final 及以上



Java 代码<<

1. 服务端：<<

2. /*

3. *Copyright2012TheNettyProject

4. *

5. *TheNettyProjectlicensesthisfiletoyouundertheApacheLicense,

6. *version2.0(the"License");youmaynotusethisfileexceptincompliance

7. *withtheLicense.YoumayobtainacopyoftheLicenseat:

8. *

9. *http://www.apache.org/licenses/LICENSE-2.0

10. *

11. *Unlessrequiredbyapplicablelaworagreedtoinwriting,software

12. *distributedundertheLicenseisdistributedonan"ASIS"BASIS,WITHOUT

13. *WARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied.Seethe

14. *Licenseforthespecificlanguagegoverningpermissionsandlimitations

15. *undertheLicense.

16. */

17. packageio.netty.example.echo;

18. 

19. importio.netty.bootstrap.ServerBootstrap;

20. importio.netty.channel.ChannelFuture;

21. importio.netty.channel.ChannelInitializer;

22. importio.netty.channel.ChannelOption;

23. importio.netty.channel.EventLoopGroup;

24. importio.netty.channel.nio.NioEventLoopGroup;

25. importio.netty.channel.socket.SocketChannel;

26. importio.netty.channel.socket.nio.NioServerSocketChannel;

27. importio.netty.handler.logging.LogLevel;

28. importio.netty.handler.logging.LoggingHandler;

29. 

30. /**

31. *Echoesbackanyreceiveddatafromaclient.

32. */

33. publicclassEchoServer{

34. 

35. privatefinalintport;

36. 

37. publicEchoServer(intport){

38. this.port=port;

39. }

40. 

41. publicvoidrun()throwsException{

42. //Configuretheserver.

43. EventLoopGroupbossGroup=newNioEventLoopGroup();

44. EventLoopGroupworkerGroup=newNioEventLoopGroup();

45. try{

46. ServerBootstrapb=newServerBootstrap();

47. b.group(bossGroup,workerGroup)

48. .channel(NioServerSocketChannel.class)

49. .option(ChannelOption.SO_BACKLOG,100)

50. .handler(newLoggingHandler(LogLevel.INFO))

51. .childHandler(newChannelInitializer<SocketChannel>(){

52. @Override

53. publicvoidinitChannel(SocketChannelch)throwsException{

54. ch.pipeline().addLast(

55. //newLoggingHandler(LogLevel.INFO),

56. newEchoServerHandler());

57. }

58. });

59. 

60. //Starttheserver.

61. ChannelFuturef=b.bind(port).sync();

62. 

63. //Waituntiltheserversocketisclosed.

64. f.channel().closeFuture().sync();

65. }finally{

66. //Shutdownalleventloopstoterminateallthreads.

67. bossGroup.shutdownGracefully();

68. workerGroup.shutdownGracefully();

69. }

70. }

71. 

72. publicstaticvoidmain(String[]args)throwsException{

73. intport;

74. if(args.length>0){

75. port=Integer.parseInt(args[0]);

76. }else{

77. port=8080;

78. }

79. newEchoServer(port).run();

80. }

81. }



Java 代码<<

1. /*

2. *Copyright2012TheNettyProject

3. *

4. *TheNettyProjectlicensesthisfiletoyouundertheApacheLicense,

5. *version2.0(the"License");youmaynotusethisfileexceptincompliance

6. *withtheLicense.YoumayobtainacopyoftheLicenseat:

7. *

8. *http://www.apache.org/licenses/LICENSE-2.0

9. *

10. *Unlessrequiredbyapplicablelaworagreedtoinwriting,software

11. *distributedundertheLicenseisdistributedonan"ASIS"BASIS,WITHOUT

12. *WARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied.Seethe

13. *Licenseforthespecificlanguagegoverningpermissionsandlimitations

14. *undertheLicense.

15. */

16. packageio.netty.example.echo;

17. 

18. importio.netty.channel.ChannelHandler.Sharable;

19. importio.netty.channel.ChannelHandlerContext;

20. importio.netty.channel.ChannelInboundHandlerAdapter;

21. 

22. importjava.util.logging.Level;

23. importjava.util.logging.Logger;

24. 

25. /**

26. *Handlerimplementationfortheechoserver.

27. */

28. @Sharable

29. publicclassEchoServerHandlerextendsChannelInboundHandlerAdapter{

30. 

31. privatestaticfinalLoggerlogger=Logger.getLogger(

32. EchoServerHandler.class.getName());

33. 

34. @Override

35. publicvoidchannelRead(ChannelHandlerContextctx,Objectmsg)throwsException{

36. ctx.write(msg);

37. }

38. 

39. @Override

40. publicvoidchannelReadComplete(ChannelHandlerContextctx)throwsException{

41. ctx.flush();

42. }

43. 

44. @Override

45. publicvoidexceptionCaught(ChannelHandlerContextctx,Throwablecause){

46. //Closetheconnectionwhenanexceptionisraised.

47. logger.log(Level.WARNING,"Unexpectedexceptionfromdownstream.",cause);

48. ctx.close();

49. }

50. }



Java 代码<<

1. 客户端：<<

2. /*

3. *Copyright2012TheNettyProject

4. *

5. *TheNettyProjectlicensesthisfiletoyouundertheApacheLicense,

6. *version2.0(the"License");youmaynotusethisfileexceptincompliance

7. *withtheLicense.YoumayobtainacopyoftheLicenseat:

8. *

9. *http://www.apache.org/licenses/LICENSE-2.0

10. *

11. *Unlessrequiredbyapplicablelaworagreedtoinwriting,software

12. *distributedundertheLicenseisdistributedonan"ASIS"BASIS,WITHOUT

13. *WARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied.Seethe

14. *Licenseforthespecificlanguagegoverningpermissionsandlimitations

15. *undertheLicense.

16. */

17. packageio.netty.example.echo;

18. 

19. importio.netty.bootstrap.Bootstrap;

20. importio.netty.channel.ChannelFuture;

21. importio.netty.channel.ChannelInitializer;

22. importio.netty.channel.ChannelOption;

23. importio.netty.channel.EventLoopGroup;

24. importio.netty.channel.nio.NioEventLoopGroup;

25. importio.netty.channel.socket.SocketChannel;

26. importio.netty.channel.socket.nio.NioSocketChannel;

27. 

28. /**

29. *Sendsonemessagewhenaconnectionisopenandechoesbackanyreceived

30. *datatotheserver.Simplyput,theechoclientinitiatestheping-pong

31. *trafficbetweentheechoclientandserverbysendingthefirstmessageto

32. *theserver.

33. */

34. publicclassEchoClient{

35. 

36. privatefinalStringhost;

37. privatefinalintport;

38. privatefinalintfirstMessageSize;

39. 

40. publicEchoClient(Stringhost,intport,intfirstMessageSize){

41. this.host=host;

42. this.port=port;

43. this.firstMessageSize=firstMessageSize;

44. }

45. 

46. publicvoidrun()throwsException{

47. //Configuretheclient.

48. EventLoopGroupgroup=newNioEventLoopGroup();

49. try{

50. Bootstrapb=newBootstrap();

51. b.group(group)

52. .channel(NioSocketChannel.class)

53. .option(ChannelOption.TCP_NODELAY,true)

54. .handler(newChannelInitializer<SocketChannel>(){

55. @Override

56. publicvoidinitChannel(SocketChannelch)throwsException{

57. ch.pipeline().addLast(

58. //newLoggingHandler(LogLevel.INFO),

59. newEchoClientHandler(firstMessageSize));

60. }

61. });

62. 

63. //Starttheclient.

64. ChannelFuturef=b.connect(host,port).sync();

65. 

66. //Waituntiltheconnectionisclosed.

67. f.channel().closeFuture().sync();

68. }finally{

69. //Shutdowntheeventlooptoterminateallthreads.

70. group.shutdownGracefully();

71. }

72. }

73. 

74. publicstaticvoidmain(String[]args)throwsException{

75. //Printusageifnoargumentisspecified.

76. if(args.length<2||args.length>3){

77. System.err.println(

78. "Usage:"+EchoClient.class.getSimpleName()+

79. "<host><port>[<firstmessagesize>]");

80. return;

81. }

82. 

83. //Parseoptions.

84. finalStringhost=args[0];

85. finalintport=Integer.parseInt(args[1]);

86. finalintfirstMessageSize;

87. if(args.length==3){

评论收藏

内容反馈

sunshine101824

2018-03-07

很详细，很有用！

Netty4.x源码分析详解

评论2

最新资源

Netty4.x源码分析详解

评论2

最新资源

相关推荐

netty源码深入分析

netty4源码

netty4 sources 源码

netty源码解析视频

Netty源码解析.pdf

Netty 5.0架构剖析和源码解读 高清完整版 带目录.pdf

netty源码分析之服务端启动全解析

netty源码剖析视频

Netty5.0架构剖析和源码解读.PDF

高清Netty5.0架构剖析和源码解读

netty4.1源码

Netty源码剖析+视频

Netty 4.1源码包

netty源码 4.*版本

Netty4.X demo

netty源码分析教程视频

netty源码最新版

《Netty5.0架构剖析和源码解读》

Netty4.1实战-手写RPC框架.pdf

Netty全套PDF

netty-4.1 源码包

Netty4.0 jar包 及 源代码 和 例子

netty4.1.15源码

netty视频+源码

netty

《Netty 实战》源码

netty-4.1源代码

Netty权威指南书中案例

Netty4详解二：开发第一个Netty应用程序

Netty 5.0架构剖析和源码解读高清完整版带目录.pdf

Netty4.0 jar包及源代码和例子