作者：rickiyang
出处：www.cnblogs.com/rickiyang/p/11074237.html
这一节咱们来解说Netty，应用Netty之前咱们先理解一下Netty能做什么，有为而学，岂不是白费力气！
1.应用Netty可能做什么
- 开发异步、非阻塞的TCP网络应用程序；
- 开发异步、非阻塞的UDP网络应用程序；
- 开发异步文件传输应用程序；
- 开发异步HTTP服务端和客户端应用程序；
- 提供对多种编解码框架的集成，包含谷歌的Protobuf、Jboss marshalling、Java序列化、压缩编解码、XML解码、字符串编解码等，这些编解码框架能够被用户间接应用；
- 提供形式多样的编解码根底类库，能够十分不便的实现公有协定栈编解码框架的二次定制和开发；
- 基于职责链模式的Pipeline-Handler机制，用户能够十分不便的对网络事件进行拦挡和定制；
- 所有的IO操作都是异步的，用户能够通过Future-Listener机制被动Get后果或者由IO线程操作实现之后被动Notify后果，用户的业务线程不须要同步期待；
- IP黑白名单管制；
- 打印消息码流；
- 流量管制和整形；
- 性能统计；
- 基于链路闲暇事件检测的心跳检测
2. Netty罕用类解说
在这里咱们就一些咱们罕用到的类做大抵的解说，而后再写入门程序的时候大抵晓得每一行都讲了什么。
EventLoop,EventLoopGroup
EventLoop目标是为Channel解决IO操作，一个EventLoop能够为多个Channel服务,EventLoopGroup会蕴含多个EventLoop。
BootStrap,ServerBootstrap
一个Netty利用通常由一个Bootstrap开始，它次要作用是配置整个Netty程序，串联起各个组件。
ChannelInitializer
当一个链接建设时，咱们须要晓得怎么来接管或者发送数据，当然，咱们有各种各样的Handler实现来解决它，那么ChannelInitializer便是用来配置这些Handler，它会提供一个ChannelPipeline，并把Handler退出到ChannelPipeline。
Handler
为了反对各种协定和解决数据的形式，便诞生了Handler组件。Handler次要用来解决各种事件，这里的事件很宽泛，比方能够是连贯、数据接管、异样、数据转换等。
ChannelInboundHandler
一个最罕用的Handler。这个Handler的作用就是解决接管到数据时的事件，也就是说，咱们的业务逻辑个别就是写在这个Handler外面的，ChannelInboundHandler就是用来解决咱们的外围业务逻辑。
Future
在Netty中所有的IO操作都是异步的，因而，你不能立即得悉音讯是否被正确处理，然而咱们能够过一会等它执行实现或者间接注册一个监听，具体的实现就是通过Future和ChannelFutures,他们能够注册一个监听，当操作执行胜利或失败时监听会主动触发。总之，所有的操作都会返回一个ChannelFuture。
3. 第一个Helloworld
下面咱们曾经对罕用类进行阐明，上面咱们就应用这些类来构建咱们的第一个入门程序，本示例我应用的是maven来构建工程，如果你应用的是一般的我的项目则跳过第一步。
首先引入maven jar包：
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.5.Final</version>
</dependency>上面咱们来写客户端：
public class HelloWorldClient {
private int port;
private String address;
public HelloWorldClient(int port,String address) {
this.port = port;
this.address = address;
}
public void start(){
EventLoopGroup group = new NioEventLoopGroup();
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(group)
.channel(NioSocketChannel.class)
.handler(new ClientChannelInitializer());
try {
Channel channel = bootstrap.connect(address,port).sync().channel();
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
for(;;){
String msg = reader.readLine();
if(msg == null){
continue;
}
channel.writeAndFlush(msg + "\r\n");
}
} catch (Exception e) {
e.printStackTrace();
}finally {
group.shutdownGracefully();
}
}
public static void main(String[] args) {
HelloWorldClient client = new HelloWorldClient(7788,"127.0.0.1");
client.start();
}
}ChannelInitializer用来配置解决数据的handler：
public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {
protected void initChannel(SocketChannel socketChannel) throws Exception {
ChannelPipeline pipeline = socketChannel.pipeline();
/*
* 这个中央的 必须和服务端对应上。否则无奈失常解码和编码
*
* 解码和编码 我将会在下一节为大家具体的解说。临时不做具体的形容
*
* /
pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("encoder", new StringEncoder());
// 咱们本人的handler
pipeline.addLast("handler", new HelloWorldClientHandler());
}
}写一个咱们本人的handler，用本人的形式来解决数据：
public class HelloWorldClientHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println("server say : "+msg.toString());
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("Client is active");
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
System.out.println("Client is close");
}
}客户端咱们写完了，上面开始写服务器端：
public class HelloWordServer {
private int port;
public HelloWordServer(int port) {
this.port = port;
}
public void start(){
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workGroup = new NioEventLoopGroup();
ServerBootstrap server = new ServerBootstrap().group(bossGroup,workGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ServerChannelInitializer());
try {
ChannelFuture future = server.bind(port).sync();
future.channel().closeFuture().sync();
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
bossGroup.shutdownGracefully();
workGroup.shutdownGracefully();
}
}
public static void main(String[] args) {
HelloWordServer server = new HelloWordServer(7788);
server.start();
}
}服务端的ChannelInitializer：
public class ServerChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel socketChannel) throws Exception {
ChannelPipeline pipeline = socketChannel.pipeline();
// 字符串解码 和 编码
pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("encoder", new StringEncoder());
// 本人的逻辑Handler
pipeline.addLast("handler", new HelloWordServerHandler());
}
}服务器端的handler:
public class HelloWordServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println(ctx.channel().remoteAddress()+"===>server: "+msg.toString());
ctx.write("received your msg");
ctx.flush();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
super.exceptionCaught(ctx, cause);
ctx.close();
}
}下面服务器端和客户端的代码都曾经写完，上面咱们先启动服务端，而后启动客户端，程序中我是在客户端让手动输出，输出完结之后回车，服务器端即可承受数据。
客户端：
服务端：
近期热文举荐：
1.1,000+ 道 Java面试题及答案整顿(2021最新版)
2.终于靠开源我的项目弄到 IntelliJ IDEA 激活码了，真香！
3.阿里 Mock 工具正式开源，干掉市面上所有 Mock 工具！
4.Spring Cloud 2020.0.0 正式公布，全新颠覆性版本！
5.《Java开发手册（嵩山版）》最新公布，速速下载！
感觉不错，别忘了顺手点赞+转发哦！
发表回复