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

Netty应用基础篇

编解码 
阅读更多

本篇主要介绍Netty解决TCP粘包和拆包问题。

 

概念介绍

TCP是个”流"协议，所谓流，就是没有界限的一串数据。TCP底层并不了解上层业务数据的具体含义，它会根据TCP缓冲区的实际情况进行包的划分，所以在业务上认为，一个完整的包可能会被TCP拆分成多个包进行发送，也有可能把多个小的包封装成一个大的数据包发送，这就是所谓的TCP粘包和拆包问题。

产生原因：

1，应用程序write写入的字节大小大于套接口发送缓冲区大小；

2，进行MSS大小的TCP分段；

3，以太网帧的payload大于MTU进行IP分片。

 

实例如下

 

服务端代码：

 

package com.huawei.netty.test;

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;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyServer
{
    public void bind(int port) throws Exception
    {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try
        {
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup,workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG,1024)
                    .childHandler(new ChildChannelHandler());
            ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
            channelFuture.channel().closeFuture().sync();
        }
        finally
        {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    private class ChildChannelHandler extends ChannelInitializer<SocketChannel>
    {

        @Override
        protected void initChannel(SocketChannel socketChannel) throws Exception
        {
            socketChannel.pipeline().addLast(new NettyServerHandler());
        }
    }

    public static void main(String[] args) throws Exception {
        new NettyServer().bind(8080);
    }
}

 

 

package com.huawei.netty.test;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.util.Date;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyServerHandler extends ChannelInboundHandlerAdapter
{
    private int counter;

    @Override
    public void channelRead(ChannelHandlerContext ctx,Object msg) throws Exception
    {
        ByteBuf byteBuf = (ByteBuf) msg;
        byte[] req = new byte[byteBuf.readableBytes()];
        byteBuf.readBytes(req);
        String body = new String(req,"UTF-8");
        System.out.println("The time server receive order :" + body
            + ";the counter is :"+ ++counter);

        String currentTime = "hello world".equalsIgnoreCase(body)?new Date().toString():"bad order";
        currentTime += System.getProperty("line.separator");
        ByteBuf resp = Unpooled.copiedBuffer(currentTime.getBytes());
        ctx.write(resp);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception
    {
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx,Throwable cause)
    {
        ctx.close();
    }
}

 

客户端代码如下：

 

package com.huawei.netty.test;

import io.netty.bootstrap.Bootstrap;
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.NioSocketChannel;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyClient
{
    public void connect(int port,String host) throws Exception
    {
        EventLoopGroup group = new NioEventLoopGroup();
        try
        {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(group).channel(NioSocketChannel.class)
                    .option(ChannelOption.TCP_NODELAY,true)
                    .handler(new ChannelInitializer<SocketChannel>() {

                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline().addLast(new NettyClientHandler());
                        }
                    });
            ChannelFuture f = bootstrap.connect(host,port).sync();
            f.channel().closeFuture().sync();
        }
        finally {
            group.shutdownGracefully();
        }
    }

    public static void main(String[] args) throws Exception {
        new NettyClient().connect(8080,"127.0.0.1");
    }
}

 

 

package com.huawei.netty.test;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyClientHandler extends ChannelInboundHandlerAdapter
{
    private int counter;

    private final ByteBuf msg;

    public NettyClientHandler()
    {
        byte[] req = ("hello world"+System.getProperty("line.separator")).getBytes();
        msg = Unpooled.buffer(req.length);
        msg.writeBytes(req);
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx)
    {
        ByteBuf message = null;
        byte[] req = ("hello world"+System.getProperty("line.separator")).getBytes();
        for (int i=0;i<100;i++)
        {
            message = Unpooled.buffer(req.length);
            message.writeBytes(req);
            ctx.writeAndFlush(message);
        }
        ctx.writeAndFlush(msg);
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx,Object msg) throws Exception
    {
        ByteBuf buf = (ByteBuf) msg;
        byte[] req = new byte[buf.readableBytes()];
        buf.readBytes(req);

        String body = new String(req,"UTF-8");
        System.out.println("Now is ："+body);
    }
}

 

服务端运行结果：

 

The time server receive order :hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello worl;the counter is :1
The time server receive order :d
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
hello world
;the counter is :2

 

客户端运行结果如下：

 

Now is ：bad order
bad order

 

Netty的解决方法

利用LineBasedFrameDecoder和StringDecoder解决TCP粘包问题。

LineBasedFrameDecoder原理：依次遍历ByteBuf中的可读字节，判断看是否有”\n"或者“\r\n"，如果有，就以此位置为结束位置，从可读索引到结束位置区间的字节就组成了一行。它是以换行符为结束标志的解码器，支持携带结束符或者不携带结束符两种解码方式，同时支持配置单行的最大长度。如果连续读取到最大长度后仍然没有发现换行符，就会抛出异常。

StringDecoder:就是将收到的对象转换成字符串。

 

Netty还支持DelimiterBasedFrameDecoder和FixedLengthFrameDecoder。

DelimiterBasedFrameDecoder：用于对使用分隔符结尾的消息进行自动解码。

FixedLengthFrameDecoder：用于对固定长度的消息进行自动解码。

 

Netty解决方法实例

 

服务端：

package com.huawei.netty.test;

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;
import io.netty.handler.codec.LineBasedFrameDecoder;
import io.netty.handler.codec.string.StringDecoder;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyServer
{
    public void bind(int port) throws Exception
    {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try
        {
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup,workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG,1024)
                    .childHandler(new ChildChannelHandler());
            ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
            channelFuture.channel().closeFuture().sync();
        }
        finally
        {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    private class ChildChannelHandler extends ChannelInitializer<SocketChannel>
    {

        @Override
        protected void initChannel(SocketChannel socketChannel) throws Exception
        {
            socketChannel.pipeline()
                    .addLast(new LineBasedFrameDecoder(1024))
                    .addLast(new StringDecoder())
                    .addLast(new NettyServerHandler());
        }
    }

    public static void main(String[] args) throws Exception {
        new NettyServer().bind(8080);
    }
}

 

package com.huawei.netty.test;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.util.Date;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyServerHandler extends ChannelInboundHandlerAdapter
{
    private int counter;

    @Override
    public void channelRead(ChannelHandlerContext ctx,Object msg) throws Exception
    {
//        ByteBuf byteBuf = (ByteBuf) msg;
//        byte[] req = new byte[byteBuf.readableBytes()];
//        byteBuf.readBytes(req);
//        String body = new String(req,"UTF-8");
        String body = (String) msg;
        System.out.println("The time server receive order :" + body
            + ";the counter is :"+ ++counter);

        String currentTime = "hello world".equalsIgnoreCase(body)?new Date().toString():"bad order";
        currentTime += System.getProperty("line.separator");
        ByteBuf resp = Unpooled.copiedBuffer(currentTime.getBytes());
        ctx.write(resp);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception
    {
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx,Throwable cause)
    {
        ctx.close();
    }
}

 

客户端：

 

package com.huawei.netty.test;

import io.netty.bootstrap.Bootstrap;
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.NioSocketChannel;
import io.netty.handler.codec.LineBasedFrameDecoder;
import io.netty.handler.codec.string.StringDecoder;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyClient
{
    public void connect(int port,String host) throws Exception
    {
        EventLoopGroup group = new NioEventLoopGroup();
        try
        {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(group).channel(NioSocketChannel.class)
                    .option(ChannelOption.TCP_NODELAY,true)
                    .handler(new ChannelInitializer<SocketChannel>() {

                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline()
                                    .addLast(new LineBasedFrameDecoder(1024))
                                    .addLast(new StringDecoder())
                                    .addLast(new NettyClientHandler());
                        }
                    });
            ChannelFuture f = bootstrap.connect(host,port).sync();
            f.channel().closeFuture().sync();
        }
        finally {
            group.shutdownGracefully();
        }
    }

    public static void main(String[] args) throws Exception {
        new NettyClient().connect(8080,"127.0.0.1");
    }
}

 

package com.huawei.netty.test;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * Created by liuzhengqiu on 2017/10/15.
 */
public class NettyClientHandler extends ChannelInboundHandlerAdapter
{
    private int counter;

    private final ByteBuf msg;

    public NettyClientHandler()
    {
        byte[] req = ("hello world"+System.getProperty("line.separator")).getBytes();
        msg = Unpooled.buffer(req.length);
        msg.writeBytes(req);
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx)
    {
        ByteBuf message = null;
        byte[] req = ("hello world"+System.getProperty("line.separator")).getBytes();
        for (int i=0;i<100;i++)
        {
            message = Unpooled.buffer(req.length);
            message.writeBytes(req);
            ctx.writeAndFlush(message);
        }
        ctx.writeAndFlush(msg);
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx,Object msg) throws Exception
    {
//        ByteBuf buf = (ByteBuf) msg;
//        byte[] req = new byte[buf.readableBytes()];
//        buf.readBytes(req);
//
//        String body = new String(req,"UTF-8");
        String body = (String) msg;
        System.out.println("Now is ："+body);
    }
}

 

服务端运行结果：

The time server receive order :hello world;the counter is :1
The time server receive order :hello world;the counter is :2
The time server receive order :hello world;the counter is :3
The time server receive order :hello world;the counter is :4
The time server receive order :hello world;the counter is :5
The time server receive order :hello world;the counter is :6
The time server receive order :hello world;the counter is :7
The time server receive order :hello world;the counter is :8
The time server receive order :hello world;the counter is :9
The time server receive order :hello world;the counter is :10
The time server receive order :hello world;the counter is :11
The time server receive order :hello world;the counter is :12
The time server receive order :hello world;the counter is :13
The time server receive order :hello world;the counter is :14
The time server receive order :hello world;the counter is :15
The time server receive order :hello world;the counter is :16
The time server receive order :hello world;the counter is :17
The time server receive order :hello world;the counter is :18
The time server receive order :hello world;the counter is :19
The time server receive order :hello world;the counter is :20
The time server receive order :hello world;the counter is :21
The time server receive order :hello world;the counter is :22
The time server receive order :hello world;the counter is :23
The time server receive order :hello world;the counter is :24
The time server receive order :hello world;the counter is :25
The time server receive order :hello world;the counter is :26
The time server receive order :hello world;the counter is :27
The time server receive order :hello world;the counter is :28
The time server receive order :hello world;the counter is :29
The time server receive order :hello world;the counter is :30
The time server receive order :hello world;the counter is :31
The time server receive order :hello world;the counter is :32
The time server receive order :hello world;the counter is :33
The time server receive order :hello world;the counter is :34
The time server receive order :hello world;the counter is :35
The time server receive order :hello world;the counter is :36
The time server receive order :hello world;the counter is :37
The time server receive order :hello world;the counter is :38
The time server receive order :hello world;the counter is :39
The time server receive order :hello world;the counter is :40
The time server receive order :hello world;the counter is :41
The time server receive order :hello world;the counter is :42
The time server receive order :hello world;the counter is :43
The time server receive order :hello world;the counter is :44
The time server receive order :hello world;the counter is :45
The time server receive order :hello world;the counter is :46
The time server receive order :hello world;the counter is :47
The time server receive order :hello world;the counter is :48
The time server receive order :hello world;the counter is :49
The time server receive order :hello world;the counter is :50
The time server receive order :hello world;the counter is :51
The time server receive order :hello world;the counter is :52
The time server receive order :hello world;the counter is :53
The time server receive order :hello world;the counter is :54
The time server receive order :hello world;the counter is :55
The time server receive order :hello world;the counter is :56
The time server receive order :hello world;the counter is :57
The time server receive order :hello world;the counter is :58
The time server receive order :hello world;the counter is :59
The time server receive order :hello world;the counter is :60
The time server receive order :hello world;the counter is :61
The time server receive order :hello world;the counter is :62
The time server receive order :hello world;the counter is :63
The time server receive order :hello world;the counter is :64
The time server receive order :hello world;the counter is :65
The time server receive order :hello world;the counter is :66
The time server receive order :hello world;the counter is :67
The time server receive order :hello world;the counter is :68
The time server receive order :hello world;the counter is :69
The time server receive order :hello world;the counter is :70
The time server receive order :hello world;the counter is :71
The time server receive order :hello world;the counter is :72
The time server receive order :hello world;the counter is :73
The time server receive order :hello world;the counter is :74
The time server receive order :hello world;the counter is :75
The time server receive order :hello world;the counter is :76
The time server receive order :hello world;the counter is :77
The time server receive order :hello world;the counter is :78
The time server receive order :hello world;the counter is :79
The time server receive order :hello world;the counter is :80
The time server receive order :hello world;the counter is :81
The time server receive order :hello world;the counter is :82
The time server receive order :hello world;the counter is :83
The time server receive order :hello world;the counter is :84
The time server receive order :hello world;the counter is :85
The time server receive order :hello world;the counter is :86
The time server receive order :hello world;the counter is :87
The time server receive order :hello world;the counter is :88
The time server receive order :hello world;the counter is :89
The time server receive order :hello world;the counter is :90
The time server receive order :hello world;the counter is :91
The time server receive order :hello world;the counter is :92
The time server receive order :hello world;the counter is :93
The time server receive order :hello world;the counter is :94
The time server receive order :hello world;the counter is :95
The time server receive order :hello world;the counter is :96
The time server receive order :hello world;the counter is :97
The time server receive order :hello world;the counter is :98
The time server receive order :hello world;the counter is :99
The time server receive order :hello world;the counter is :100
The time server receive order :hello world;the counter is :101

 

客户端运行结果：

Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017
Now is ：Sat Oct 21 23:17:57 CST 2017

续集

 

了解编解码基础知识之后，后面继续讲解Netty内置编解码框架的使用，例如Java序列化，二进制编解码，谷歌的protobuf和JBoss的Marshalling序列化框架。

 

0
顶
0
踩
分享到：
| Netty入门
评论
发表评论

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

相关推荐

    Netty 框架学习 —— 第一个 Netty 应用（csdn）————程序.pdf

    在本篇关于“Netty框架学习——第一个Netty应用”的文章中，我们将深入理解如何使用Netty构建一个简单的Echo服务器和客户端。Netty是一个高性能、异步事件驱动的网络应用程序框架，广泛应用于Java领域的服务器开发。...

    Netty案例集锦(并发编程篇).pdf

    本资料《Netty案例集锦(并发编程篇)》着重介绍了Netty在并发编程方面的应用，以下将详细阐述其中可能包含的知识点。 1. **Java NIO基础**：Netty基于Java NIO（非阻塞I/O）构建，NIO允许程序选择非阻塞方式读写数据...

    Netty教程用户手册

    - **1.9 应用程序关闭**：了解如何优雅地关闭Netty应用程序。 - **1.10 总结**：回顾本章所学的主要内容。 **2. 架构概述** - **2.1 丰富的缓冲数据结构**：Netty提供了高效的缓冲机制，能够更好地管理数据。 - **...

    Netty最容易懂的实例和教材

    - **基础篇**：介绍Netty的基本架构，如ByteBuf（缓冲区）、ChannelFuture和Promise（异步操作）、ChannelHandlerContext（上下文对象）等概念，以及如何创建服务器和客户端。 - **进阶篇**：深入讲解Netty的...

    learning-netty.zip

    - **基础篇**: 介绍Netty的基本概念和架构，包括Channel、EventLoop、Pipeline等。 - **进阶篇**: 针对ByteBuf的使用、编码与解码、心跳机制等进行深入解析。 - **源码分析篇**: 分析Netty关键组件的内部实现，如...

    Netty权威指南 PDF电子书下载 带目录书签 完整版

    本篇文章将深入探讨 Netty 的核心概念、特性以及其在实际开发中的应用。 Netty 框架由 Java 编写，它提供了一套丰富的预构建的组件，如协议解码器、编码器、处理程序和管道，这些组件可以帮助开发者快速、高效地...

    netty权威指南第2版

    基础篇走进Java NIO 第1章 Java的I/O演进之路 第2章 NIO入门 第3章 Netty入门应用 第4章 TCP粘包/拆包问题解析之道 第5章 分隔符和定长解析码器的应用 第6章 编码技术 第7章 MessagePack 编解码 第8章 Google ...

    Netty案例集锦（并发编程篇）有目录

    本篇重点讨论了Netty在并发编程方面的特性及其实际应用案例。 #### 2. Netty线程模型 ##### 2.1 Java线程模型的演进 Java线程模型经历了从单线程到多线程再到线程池的发展过程： - **单线程**：早期的Java应用...

    基于Netty实现的文件上传

    本篇将深入探讨如何利用Netty实现文件上传功能，并结合Socket通信和UDP协议进行相关知识的扩展。 首先，我们来关注"基于Netty实现的文件上传"这一主题。Netty提供了丰富的ChannelHandler（通道处理器）和ByteBuf...

    netty教程并发编程

    在Netty应用中，如果处理不当可能会导致内存泄漏，尤其是在文件上传下载等长时间占用资源的操作中。解决办法包括： - **释放资源**：确保所有分配出去的ByteBuf都被正确释放。 - **使用ReferenceCountUtil**：利用...

    Netty_in_Action(第五版目录修正)

    5. **构建第一个Netty应用** 6. **Netty从底层构建** 7. **传输层** 8. **缓冲区** 9. **通道处理器(Channel Handler)** 10. **编解码(Codec)** 11. **提供的通道处理器和编解码器** 12. **启动Netty应用程序** 13. ...

    Netty使用初步

    通过选择合适的模型，我们可以最大化地优化Netty应用的性能。 总结起来，Netty是一个强大的网络编程框架，它的异步事件驱动模型、高效的缓冲区机制、丰富的协议处理组件以及灵活的配置选项，都使得开发高性能、可...

    使用jboss netty 创建高性能webservice客户端及服务端

    本篇文章将深入探讨如何利用JBoss Netty创建高效的Web Service客户端和服务端。 首先，我们需要理解Netty的基本工作原理。Netty采用非阻塞I/O模型，基于Java NIO（非阻塞输入/输出）库，允许在网络操作中进行高并发...

    Netty学习教程之基础使用篇

    Netty 是一个强大的 Java 开源框架，由 JBOSS 提供，专为构建高性能、高可靠的网络应用程序而设计。它的核心特性在于其异步、事件驱动的架构，这使得开发者能够轻松地创建出复杂的网络服务，如服务器和客户端程序。...

    netty下载

    在博客链接中提到的 https://qqggcc.iteye.com/blog/2252859，虽然具体内容无法在此直接查看，但可以推测这可能是一篇关于如何使用 Netty 或者在实际项目中应用 Netty 的技术文章。博客可能会涵盖 Netty 的基础概念...

    精通并发与Netty 涉及到的代码

    在Netty应用中，可以集成NSQ客户端库，实现生产者发布消息和消费者接收消息的功能。NSQ提供了消息持久化和多消费者订阅的特性，确保了消息的可靠传递。 Lombok是一个Java库，能自动插入编辑器和构建工具，提供了...

    基于netty的websocket开发小结

    这篇基于Netty的WebSocket开发小结将探讨如何使用Netty实现WebSocket服务端和客户端的交互。 首先，我们要理解WebSocket的基本概念。WebSocket协议定义了一种在单个TCP连接上进行全双工通信的协议。它通过在握手...

    Netty权威指南

    基础篇：java的IO演进之路； BIO ;NIO；伪异步；NIO类库 ； 入门篇：Jetty简单应用入门；TCP粘包拆包；定位符和定长解码器； 中级篇：编解码技术和常用的序列化框架（protobuf /java/Marshalling） 高级篇：Http协议...

    基于Netty实现CometStreaming方式的聊天室

    本篇将深入探讨如何利用Netty实现CometStreaming方式的聊天室。 首先，我们要理解CometStreaming是什么。Comet是一种Web技术，它允许服务器向浏览器推送数据，而不是传统的HTTP请求-响应模式。在聊天室场景中，这种...

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