`
liujiekasini0312
  • 浏览: 147280 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Netty使用实例

 
阅读更多

贴上两个自己写好的例子，以便备注，以下两个例子基于netty-3.5.7.Final.jar用Junit进行测试

第一个例子：简单的发送字符串，接收字符串“Hello, World”

Java代码收藏代码
  1. packagecom.wujintao.netty;
  3. importjava.net.InetSocketAddress;
  4. importjava.util.concurrent.Executors;
  6. importorg.jboss.netty.bootstrap.ClientBootstrap;
  7. importorg.jboss.netty.bootstrap.ServerBootstrap;
  8. importorg.jboss.netty.channel.ChannelFuture;
  9. importorg.jboss.netty.channel.ChannelHandlerContext;
  10. importorg.jboss.netty.channel.ChannelPipeline;
  11. importorg.jboss.netty.channel.ChannelPipelineFactory;
  12. importorg.jboss.netty.channel.ChannelStateEvent;
  13. importorg.jboss.netty.channel.Channels;
  14. importorg.jboss.netty.channel.ExceptionEvent;
  15. importorg.jboss.netty.channel.MessageEvent;
  16. importorg.jboss.netty.channel.SimpleChannelHandler;
  17. importorg.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
  18. importorg.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
  19. importorg.jboss.netty.handler.codec.string.StringDecoder;
  20. importorg.jboss.netty.handler.codec.string.StringEncoder;
  21. importorg.junit.Test;
  23. classHelloWorldServerHandlerextendsSimpleChannelHandler{
  24. publicvoidchannelConnected(ChannelHandlerContextctx,ChannelStateEvente)
  25. throwsException{
  26. e.getChannel().write("Hello,World");
  27. }
  29. publicvoidexceptionCaught(ChannelHandlerContextctx,ExceptionEvente){
  30. System.out.println("Unexpectedexceptionfromdownstream."
  31. +e.getCause());
  32. e.getChannel().close();
  33. }
  34. }
  36. classHelloWorldClientHandlerextendsSimpleChannelHandler{
  38. publicvoidmessageReceived(ChannelHandlerContextctx,MessageEvente){
  39. Stringmessage=(String)e.getMessage();
  40. System.out.println(message);
  41. e.getChannel().close();
  42. }
  44. publicvoidexceptionCaught(ChannelHandlerContextctx,ExceptionEvente){
  45. System.out.println("Unexpectedexceptionfromdownstream."
  46. +e.getCause());
  47. e.getChannel().close();
  48. }
  49. }
  52. /**
  53. *NettyVSMinaNetty基于Pipeline处理，Mina基于Filter过滤
  54. *Netty的事件驱动模型具有更好的扩展性和易用性
  55. *Https，SSL，PB，RSTP，Text&Binary等协议支持
  56. *Netty中UDP传输有更好的支持官方测试Netty比Mina性能更好
  57. *@authorAdministrator
  58. *
  59. */
  60. publicclassTestCase{
  62. publicvoidtestServer(){
  63. //初始化channel的辅助类，为具体子类提供公共数据结构
  64. ServerBootstrapbootstrap=newServerBootstrap(
  65. newNioServerSocketChannelFactory(
  66. Executors.newCachedThreadPool(),
  67. Executors.newCachedThreadPool()));
  68. bootstrap.setPipelineFactory(newChannelPipelineFactory(){
  69. publicChannelPipelinegetPipeline(){
  70. ChannelPipelinepipeline=Channels.pipeline();
  71. pipeline.addLast("decoder",newStringDecoder());
  72. pipeline.addLast("encoder",newStringEncoder());
  73. pipeline.addLast("handler",newHelloWorldServerHandler());
  74. returnpipeline;
  75. }
  76. });
  77. //创建服务器端channel的辅助类,接收connection请求
  78. bootstrap.bind(newInetSocketAddress(8080));
  79. }
  83. publicvoidtestClient(){
  84. //创建客户端channel的辅助类,发起connection请求
  85. ClientBootstrapbootstrap=newClientBootstrap(
  86. newNioClientSocketChannelFactory(
  87. Executors.newCachedThreadPool(),
  88. Executors.newCachedThreadPool()));
  89. //ItmeansonesameHelloWorldClientHandlerinstanceisgoingtohandlemultipleChannelsandconsequentlythedatawillbecorrupted.
  90. //基于上面这个描述，必须用到ChannelPipelineFactory每次创建一个pipeline
  91. bootstrap.setPipelineFactory(newChannelPipelineFactory(){
  92. publicChannelPipelinegetPipeline(){
  93. ChannelPipelinepipeline=Channels.pipeline();
  94. pipeline.addLast("decoder",newStringDecoder());
  95. pipeline.addLast("encoder",newStringEncoder());
  96. pipeline.addLast("handler",newHelloWorldClientHandler());
  97. returnpipeline;
  98. }
  99. });
  100. //创建无连接传输channel的辅助类(UDP),包括client和server
  101. ChannelFuturefuture=bootstrap.connect(newInetSocketAddress(
  102. "localhost",8080));
  103. future.getChannel().getCloseFuture().awaitUninterruptibly();
  104. bootstrap.releaseExternalResources();
  105. }
  108. @Test
  109. publicvoidtestNetty(){
  110. testServer();
  111. testClient();
  112. }
  114. }

第二个例子，实际应用中会用到这个，发送POJO类Persons [name=周杰伦123, age=31, salary=10000.44]

Java代码收藏代码
  1. packagecom.wujintao.netty;
  3. importstaticorg.jboss.netty.buffer.ChannelBuffers.dynamicBuffer;
  5. importjava.net.InetSocketAddress;
  6. importjava.util.concurrent.Executors;
  8. importorg.jboss.netty.bootstrap.ClientBootstrap;
  9. importorg.jboss.netty.bootstrap.ServerBootstrap;
  10. importorg.jboss.netty.buffer.ChannelBuffer;
  11. importorg.jboss.netty.channel.Channel;
  12. importorg.jboss.netty.channel.ChannelFactory;
  13. importorg.jboss.netty.channel.ChannelFuture;
  14. importorg.jboss.netty.channel.ChannelFutureListener;
  15. importorg.jboss.netty.channel.ChannelHandlerContext;
  16. importorg.jboss.netty.channel.ChannelPipeline;
  17. importorg.jboss.netty.channel.ChannelPipelineFactory;
  18. importorg.jboss.netty.channel.ChannelStateEvent;
  19. importorg.jboss.netty.channel.Channels;
  20. importorg.jboss.netty.channel.MessageEvent;
  21. importorg.jboss.netty.channel.SimpleChannelHandler;
  22. importorg.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
  23. importorg.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
  24. importorg.jboss.netty.handler.codec.frame.FrameDecoder;
  25. importorg.junit.Test;
  27. /**
  28. *用POJO代替ChannelBuffer
  29. */
  31. classTimeServerHandler3extendsSimpleChannelHandler{
  33. @Override
  34. publicvoidchannelConnected(ChannelHandlerContextctx,ChannelStateEvente)
  35. throwsException{
  36. Personsperson=newPersons("周杰伦123",31,10000.44);
  37. ChannelFuturefuture=e.getChannel().write(person);
  38. future.addListener(ChannelFutureListener.CLOSE);
  39. }
  40. }
  42. classTimeClientHandler3extendsSimpleChannelHandler{
  44. @Override
  45. publicvoidmessageReceived(ChannelHandlerContextctx,MessageEvente)
  46. throwsException{
  47. Personsperson=(Persons)e.getMessage();
  48. System.out.println(person);
  49. e.getChannel().close();
  50. }
  51. }
  53. /**
  54. *FrameDecoderandReplayingDecoderallowyoutoreturnanobjectofanytype.
  55. *
  56. */
  57. classTimeDecoderextendsFrameDecoder{
  58. privatefinalChannelBufferbuffer=dynamicBuffer();
  60. @Override
  61. protectedObjectdecode(ChannelHandlerContextctx,Channelchannel,
  62. ChannelBufferchannelBuffer)throwsException{
  63. if(channelBuffer.readableBytes()<4){
  64. returnnull;
  65. }
  66. if(channelBuffer.readable()){
  67. //读到,并写入buf
  68. channelBuffer.readBytes(buffer,channelBuffer.readableBytes());
  69. }
  70. intnamelength=buffer.readInt();
  71. Stringname=newString(buffer.readBytes(namelength).array(),"GBK");
  72. intage=buffer.readInt();
  73. doublesalary=buffer.readDouble();
  74. Personsperson=newPersons(name,age,salary);
  75. returnperson;
  76. }
  78. }
  80. classTimeEncoderextendsSimpleChannelHandler{
  81. privatefinalChannelBufferbuffer=dynamicBuffer();
  83. @Override
  84. publicvoidwriteRequested(ChannelHandlerContextctx,MessageEvente)
  85. throwsException{
  86. Personsperson=(Persons)e.getMessage();
  87. buffer.writeInt(person.getName().getBytes("GBK").length);
  88. buffer.writeBytes(person.getName().getBytes("GBK"));
  89. buffer.writeInt(person.getAge());
  90. buffer.writeDouble(person.getSalary());
  91. Channels.write(ctx,e.getFuture(),buffer);
  92. }
  93. }
  95. classPersons{
  96. privateStringname;
  97. privateintage;
  98. privatedoublesalary;
  100. publicPersons(Stringname,intage,doublesalary){
  101. this.name=name;
  102. this.age=age;
  103. this.salary=salary;
  104. }
  106. publicStringgetName(){
  107. returnname;
  108. }
  109. publicvoidsetName(Stringname){
  110. this.name=name;
  111. }
  112. publicintgetAge(){
  113. returnage;
  114. }
  115. publicvoidsetAge(intage){
  116. this.age=age;
  117. }
  118. publicdoublegetSalary(){
  119. returnsalary;
  120. }
  121. publicvoidsetSalary(doublesalary){
  122. this.salary=salary;
  123. }
  125. @Override
  126. publicStringtoString(){
  127. return"Persons[name="+name+",age="+age+",salary="+salary
  128. +"]";
  129. }
  132. }
  134. publicclassTestCase5{
  135. publicvoidtestServer(){
  136. ChannelFactoryfactory=newNioServerSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool());
  137. ServerBootstrapbootstrap=newServerBootstrap(factory);
  138. bootstrap.setPipelineFactory(newChannelPipelineFactory(){
  140. publicChannelPipelinegetPipeline()throwsException{
  141. returnChannels.pipeline(newTimeEncoder(),newTimeServerHandler3());
  142. }
  143. });
  144. bootstrap.setOption("child.tcpNoDelay",true);
  145. bootstrap.setOption("child.keepAlive",true);
  147. bootstrap.bind(newInetSocketAddress("localhost",9999));
  148. }
  150. publicvoidtestClient(){
  151. //创建客户端channel的辅助类,发起connection请求
  152. ClientBootstrapbootstrap=newClientBootstrap(
  153. newNioClientSocketChannelFactory(
  154. Executors.newCachedThreadPool(),
  155. Executors.newCachedThreadPool()));
  156. bootstrap.setPipelineFactory(newChannelPipelineFactory(){
  157. publicChannelPipelinegetPipeline(){
  158. ChannelPipelinepipeline=Channels.pipeline();
  159. pipeline.addLast("decoder",newTimeDecoder());
  160. pipeline.addLast("encoder",newTimeEncoder());
  161. pipeline.addLast("handler",newTimeClientHandler3());
  162. returnpipeline;
  163. }
  164. });
  165. //创建无连接传输channel的辅助类(UDP),包括client和server
  166. ChannelFuturefuture=bootstrap.connect(newInetSocketAddress(
  167. "localhost",9999));
  168. future.getChannel().getCloseFuture().awaitUninterruptibly();
  169. bootstrap.releaseExternalResources();
  170. }
  172. @Test
  173. publicvoidtestNetty(){
  174. testServer();
  175. testClient();
  176. }
  177. }
分享到：
| Dubbo与Zookeeper、SpringMVC整合和使用 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    NettyDemo Netty使用实例，对象传递调用

    在本文中，我们将深入探讨Netty在实际应用中的实例——对象传递调用，以及如何解决TCP粘包问题。同时，我们还会讨论Java序列化方案在Netty中的编解码对比。 首先，让我们来看看TCP粘包问题。在TCP协议中，由于其...

    netty简单实例

    当有新的连接建立时，Netty 将为每个连接创建一个新的 Channel 实例，并在该 Channel 上设置我们配置的 Pipeline。 4. **连接到服务器**：在客户端，我们使用 Bootstrap 连接到服务器的指定地址和端口。同样，...

    android netty使用demo

    总之，"android netty使用demo"提供了一个基础的Android Netty应用实例，展示了如何在Android环境中使用Netty实现长连接通信。然而，实际开发中，还需要考虑更多的细节和优化，以满足复杂的网络应用场景。

    netty各种例子

    基于netty各种例子。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。...

    netty的入门经典例子的使用

    这个“netty的入门经典例子的使用”很可能是为了引导初学者了解和掌握 Netty 的基本用法和核心概念。下面将详细阐述 Netty 的基础知识及其在实际应用中的关键点。 首先，Netty 提供了一个高度可定制的事件驱动的...

    Netty 使用Disruptor机制的处理源代码

    标题 "Netty 使用Disruptor机制的处理源代码" 暗示我们将探讨如何在 Netty 中集成并利用 Disruptor 来优化消息处理流程。Disruptor 的核心是其环形缓冲区（Ring Buffer），这个缓冲区能够在无锁或极少锁的情况下实现...

    Netty4.0 官网例子（免费）

    4. **Pipeline**：Netty 使用 ChannelPipeline 来处理进来的数据。Pipeline 是一系列处理器（ChannelHandler）的链，每个处理器可以处理特定类型的数据或事件，如解码、编码、业务逻辑处理等。 5. **...

    netty-demo实例

    也就是说，Netty 是一个基于NIO的客户，服务器端编程框架，使用Netty 可以确保你快速和简单的开发出一个网络应用，例如实现了某种协议的客户，服务端应用。Netty相当简化和流线化了网络应用的编程开发过程，例如，...

    Netty5完整例子

    Netty5完整例子,里面包含编码，解码，心跳处理等，代码可用。 例子的内容是：服务端启动,客户端启动,客户端连接服务器后服务器发一个Message的对象给客户端，客户端接受并打印Message里边的内容。编解码的处理为：...

    Netty的入门经典例子

    "Netty 入门经典例子" Netty 是一个异步的、事件驱动的网络编程框架和工具，使用 Netty 可以快速开发出可维护的、high-performance 的协议服务及其客户端应用。Netty 相当简化和流线化了网络应用的编程开发过程，...

    Netty 聊天 例子

    在本“Netty 聊天例子”中，我们将深入探讨如何利用 Netty 构建一个简单的聊天应用，这对于初学者来说是一个很好的起点。 **Netty 基础** Netty 的核心组件包括 Channel、Bootstrap、Pipeline 和 EventLoopGroup。...

    netty实现websocket例子

    在"Netty实现WebSocket例子"中，我们将探讨如何使用Netty来搭建WebSocket服务器，并实现客户端与服务器之间的双向通信。首先，我们需要理解WebSocket的基本概念和工作原理。WebSocket协议是基于TCP的，它通过HTTP的...

    netty各种例子(基于netty各种例子。).zip

    这个压缩包“netty各种例子(基于netty各种例子。).zip”显然是一个包含Netty示例代码的资源包，可以帮助开发者更好地理解和使用Netty框架。 在Java世界中，Netty因其高效、易用和丰富的特性而被广泛应用于多种场景...

    spring+netty+mybatis整合实例

    在IT行业中，Spring、Netty和MyBatis是三个非常重要的框架，它们分别在不同的领域发挥着关键作用。Spring是一个全面的Java应用框架，提供强大的依赖注入、AOP（面向切面编程）以及丰富的功能模块；Netty则是一个高...

    netty4.0源码，netty例子，netty api文档

    总结起来，这个压缩包为学习和使用Netty提供了一套完整的资源。通过研究源码、阅读API文档和运行示例，开发者可以掌握Netty的精髓，提升网络编程能力，并在实际项目中发挥出Netty的强大性能。无论你是初学者还是经验...

    SpringBoot_Netty实例(参照文本网址)

    在"SpringBoot_Netty实例"中，开发者尝试将这两个强大的工具结合在一起，以实现更高效、灵活的网络通信服务。SpringBoot的使用可以帮助我们快速构建基于Netty的应用，并且通过Spring的依赖注入和自动配置能力，使得...

    Netty 官方例子

    通过在 IntelliJ IDEA（简称 IDEA）中运行这些例子，我们可以深入学习 Netty 的核心特性和使用方式。 1. **异步事件驱动模型** Netty 基于非阻塞 I/O 模型，利用 Java NIO (Non-blocking Input/Output) 库，实现了...

    netty原理及例子

    本篇文章将深入探讨Netty的原理，并通过实例帮助你快速入门和提高。 1. **Netty的基本概念** - **NIO（Non-blocking I/O）**：Netty是基于Java NIO构建的，NIO允许单线程处理多个通道，减少了线程创建和销毁的开销...

    Netty3.5代码例子

    通过实践Netty 3.5的入门实例，你可以学习如何设置服务器、建立连接、定义消息处理流程，以及如何优雅地处理异常。这些基础将帮助你理解Netty的工作原理，为后续学习更高级的功能打下坚实基础。在实践中，你可能会...

    java Netty 框架例子源码.rar

    这个压缩包文件"java Netty 框架例子源码.rar"很可能包含了一系列示例代码，帮助我们了解和学习如何在实际项目中使用 Netty。 Netty 的核心组件包括： 1. **Channel**：是 Netty 中的基本概念，代表一个打开的连接...

Magicbox
Global site tag (gtag.js) - Google Analytics