anxpp的博客

As they sow , so let them reap .

目录视图
摘要视图
订阅

异步赠书：9月重磅新书升级，本本经典 【观点】：程序员应该如何积累财富？ 程序员9月书讯 节后荐书：Python、PyQt5、Kotlin（评论送书）

Java NIO框架Netty简单使用

2016-08-03 22:37 3866人阅读评论(3) 收藏举报

分类：

编程语言—————Java———（43）

目录(?)[-]

1服务端
2客户端
3用于计算的工具类
4测试
5更多

转载请注明出处：http://blog.csdn.net/anxpp/article/details/52108238，谢谢！

之前写了一篇文章：Java 网络IO编程总结（BIO、NIO、AIO均含完整实例代码），介绍了如何使用Java原生IO支持进行网络编程，本文介绍一种更为简单的方式，即Java NIO框架。

Netty是业界最流行的NIO框架之一，具有良好的健壮性、功能、性能、可定制性和可扩展性。同时，它提供的十分简单的API，大大简化了我们的网络编程。

同Java IO介绍的文章一样，本文所展示的例子，实现了一个相同的功能。

1、服务端

Server：

[java] view plain copy print ?

package com.anxpp.io.calculator.netty;
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;
public class Server {
private int port;
public Server(int port) {
this.port = port;
}
public void run() throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_BACKLOG, 1024)
.childOption(ChannelOption.SO_KEEPALIVE, true)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new ServerHandler());
}
});
ChannelFuture f = b.bind(port).sync();
System.out.println("服务器开启："+port);
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 = 9090;
}
new Server(port).run();
}
}

ServerHandler：

[java] view plain copy print ?

package com.anxpp.io.calculator.netty;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import java.io.UnsupportedEncodingException;
import com.anxpp.io.utils.Calculator;
public class ServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws UnsupportedEncodingException {
ByteBuf in = (ByteBuf) msg;
byte[] req = new byte[in.readableBytes()];
in.readBytes(req);
String body = new String(req,"utf-8");
System.out.println("收到客户端消息:"+body);
String calrResult = null;
try{
calrResult = Calculator.Instance.cal(body).toString();
}catch(Exception e){
calrResult = "错误的表达式：" + e.getMessage();
}
ctx.write(Unpooled.copiedBuffer(calrResult.getBytes()));
}
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
ctx.flush();
}
/**
* 异常处理
*/
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
}

2、客户端

Client：

[java] view plain copy print ?

<li class="alt" style="margin: 0px !important; padding: 0px 3px 0px 10px !important; border-top: none; border-right: none; border-bottom: none; border-left: 3px solid rgb(153, 153, 153); border-image: initial; list-style-type: decimal-leading-zero; list-style-image: initial; color: rgb(238, 238,%

http://blog.csdn.net/anxpp/article/details/52108238相关推荐

https://blog.csdn.net/blmoistawinde/article/details/84329103
背景很多场景需要考虑数据分布的相似度/距离:比如确定一个正态分布是否能够很好的描述一个群体的身高(正态分布生成的样本分布应当与实际的抽样分布接近),或者一个分类算法是否能够很好地区分样本的特 ...
numpy的shape用法（转http://blog.csdn.net/by_study/article/details/67633593）
https://www.bbsmax.com/A/1O5E78b7z7/ https://www.cnblogs.com/lindaxin/p/8074921.html http://blog.csd ...
系统权限管理设计（转：http://blog.csdn.net/chexlong/article/details/37697555）
权限设计(转:http://blog.csdn.net/chexlong/article/details/37697555) 1. 前言: 权限管理往往是一个极其复杂的问题,但也可 ...
http://blog.csdn.net/u011001723/article/details/456210272222
http://blog.csdn.net/u011001723/article/details/45621027
http://blog.csdn.net/xingfuzhijianxia/article/details/6433918
http://blog.csdn.net/xingfuzhijianxia/article/details/6433918
http://blog.csdn.net/luoshengyang/article/details/6651971
文章转载至CSDN社区罗升阳的安卓之旅,原文地址:http://blog.csdn.net/luoshengyang/article/details/6651971 在Android系统中,提供了独特 ...
http://blog.csdn.net/lovejavaydj/article/details/6
2019独角兽企业重金招聘Python工程师标准>>> http://blog.csdn.net/lovejavaydj/article/details/6202610 转载于:ht ...
http://blog.csdn.net/churximi/article/details/61210129
http://blog.csdn.net/churximi/article/details/61210129http://blog.csdn.net/churximi/article/details/ ...
http://blog.csdn.net/java2000_wl/article/details/8627874
http://blog.csdn.net/java2000_wl/article/details/8627874

http://blog.csdn.net/anxpp/article/details/52108238

anxpp的博客

As they sow , so let them reap .

Java NIO框架Netty简单使用

1、服务端

2、客户端

http://blog.csdn.net/anxpp/article/details/52108238相关推荐

最新文章

热门文章