这个例子参与http://netty.io/wiki/user-guide-for-4.x.html文档实现,主要是服务器接收并打印命令行输入的字符,例子简单直接上代码:
import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; 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; import io.netty.util.ReferenceCountUtil; public class DemoServer1 { public static void main(String[] args) throws InterruptedException { ServerBootstrap bootstrap = new ServerBootstrap(); EventLoopGroup bossGroup = new NioEventLoopGroup(1); // (1) EventLoopGroup workerGroup = new NioEventLoopGroup(1); try{ bootstrap.group(bossGroup, workerGroup); bootstrap.channel(NioServerSocketChannel.class); bootstrap.childHandler(new ChannelInitializer<SocketChannel>(){ @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new MyHandler()); } }); bootstrap.option(ChannelOption.SO_BACKLOG, 128); bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true); ChannelFuture cfuture = bootstrap.bind(8080).sync(); cfuture.channel().closeFuture().sync(); }finally{ workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } } } class MyHandler extends ChannelInboundHandlerAdapter { private int index = 1; @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { cause.printStackTrace(); ctx.close(); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //super.channelRead(ctx, msg); try { System.out.println(((ByteBuf)msg).readableBytes()); // System.out.println(((ByteBuf)msg).toString()); System.out.println( ((ByteBuf)msg).toString(io.netty.util.CharsetUtil.US_ASCII)); System.out.println( ((ByteBuf)msg).toString(io.netty.util.CharsetUtil.US_ASCII)); //ctx.write(msg); //ctx.flush(); } finally { ReferenceCountUtil.release(msg); } } @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { super.channelActive(ctx); } }
服务启动后,直接使用telnet就可以和服务进行通信。
后边的章节写一下Netty4怎么实现整个NIO通信过程。
相关推荐
在本篇文章中,我们将深入探讨如何使用Netty4开发第一个Netty应用程序,以此来理解其核心概念和工作原理。 首先,我们要明白Netty的基本架构。Netty基于NIO(非阻塞I/O)设计,通过EventLoop(事件循环)和Channel...
第一个例子是"服务端"。在Netty中,服务端通常由`ServerBootstrap`类初始化。`ServerBootstrap`负责配置服务器,并创建一个`Bootstrap`实例来绑定监听端口。我们会在`ChannelInitializer`中设置管道(Pipeline),这...
1. **Channel**:在 Netty 中,Channel 表示一个连接,它可以是 TCP、UDP 或其他协议。Channel 用于读写数据,并且可以注册监听器来处理 I/O 事件。 2. **Bootstrap**:Bootstrap 是启动服务器或客户端的辅助类。它...
在本篇关于“Netty框架学习——第一个Netty应用”的文章中,我们将深入理解如何使用Netty构建一个简单的Echo服务器和客户端。Netty是一个高性能、异步事件驱动的网络应用程序框架,广泛应用于Java领域的服务器开发。...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这本书籍《Netty 权威指南》深入浅出地介绍了 Netty 的核心概念、设计模式以及实际应用,是 IT 开发者深入...
Netty,作为一个高性能、异步事件驱动的网络应用框架,被广泛应用于Java领域,尤其是对于高并发、低延迟的网络应用开发。这本书的源码提供了深入理解Netty工作原理的机会,同时也揭示了如何构建高效、可扩展的网络...
这个资源包含了支持 Netty 5.0.0.Alpha1 版本的源码,这是一个早期的开发版本,可能包含了一些新的特性和改进,对于开发者来说是研究和学习 Netty 进化过程的宝贵资料。 首先,让我们来了解 Netty 的核心概念和组件...
1. **Netty的Channel**: Channel是Netty中的基础概念,它代表了一个网络连接,可以是TCP连接、UDP连接或者一个本地文件通道。Channel提供了读写数据、注册到EventLoop以及获取连接状态等方法。 2. **EventLoop与...
这里我们关注的是 Netty 的第五个主要版本,即 Netty 5.0。尽管在撰写本文时,Netty 的最新稳定版本是 4.x 系列,但了解早期版本对于理解其发展历程和基本原理仍然很有价值。 标题 "jboss netty5.0" 提及了 JBoss,...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这本书《Netty权威指南》的第二版,提供了丰富的实例代码,帮助读者深入理解并掌握Netty的核心概念和技术。...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。在这个“netty传输对象源码”的主题中,我们将深入理解如何使用Netty来传输自定义的对象,同时结合Spring和...
Netty是一个高性能、异步事件驱动的网络应用框架,它为Java开发人员提供了构建服务器和客户端应用的强大工具。在Netty第五版中,作者深入探讨了如何利用Java NIO(非阻塞I/O)技术来实现高效的网络通信。 1. Netty...
#### 第一个Netty应用 - **设置开发环境**:为了开始使用Netty,首先需要配置合适的开发环境,如安装Java环境、集成开发环境(IDE)等。 - **Netty客户端/服务端总览**:通过概述客户端和服务端的基本结构,帮助读者...
当一个事件(如数据接收)发生时,它会从第一个处理器开始,沿着Pipeline向后传递,直到最后一个处理器。每个处理器都有机会处理这个事件,或者将事件传递给下一个处理器。这种设计使得我们可以灵活地组合和定制...
描述中提到的知识点包括Netty异步和数据驱动的基本概念、如何设置开发环境、构建第一个Netty应用,以及编写echo服务器和客户端的示例。这些内容是初学者掌握Netty的基础。描述还提到了Netty的编解码器框架,包括解码...
在第一次会议上,你得知该系统必须要能够扩展到支撑 100000 名并发用户,并且不能有任何的性能损失,这时所有的目光都投向了你。你会怎么说呢? 你可以自信地说:“当然,没问题。”然后留下一顿崇拜的目光离开,...
- **1.7.2 第一个解决方案**:介绍如何解决上文提到的问题的第一个方法。 - **1.7.3 第二个解决方案**:提供第二种方法来处理基于流的传输问题。 - **1.8 使用 POJO 而不是 ChannelBuffer**:这里介绍了如何使用...