本文共 4070 字，大约阅读时间需要 13 分钟。

在Netty中实现了2种拆包方式：分隔符方式，定长方式，这里介绍分隔符方式。实现起来很简单：

server：

package 网络编程_netty2;import io.netty.bootstrap.ServerBootstrap;import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;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.DelimiterBasedFrameDecoder;import io.netty.handler.codec.string.StringDecoder;public class Server {	private int port;		public Server(int port){		this.port = port;	}	public void run()throws Exception{		EventLoopGroup boss = new NioEventLoopGroup();		EventLoopGroup workers = new NioEventLoopGroup();		ServerBootstrap bootstrap = new ServerBootstrap();		bootstrap.group(boss, workers)				 .channel(NioServerSocketChannel.class)				 .childHandler(new ChannelInitializer
   
    () {					@Override					public void initChannel(SocketChannel ch) throws Exception {						ByteBuf buf = Unpooled.copiedBuffer("$_".getBytes());						ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, buf));						ch.pipeline().addLast(new StringDecoder());						ch.pipeline().addLast(new ServerHandler());					}				});		ChannelFuture f = bootstrap.bind(port).sync();		f.channel().closeFuture().sync();		workers.shutdownGracefully();		boss.shutdownGracefully();	}	public static void main(String[] args) throws Exception {		new Server(8888).run();	}}
   

package 网络编程_netty2;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelHandlerAdapter;import io.netty.channel.ChannelHandlerContext;public class ServerHandler extends ChannelHandlerAdapter{	@Override	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {		cause.printStackTrace();		ctx.close();	}	@Override	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {		String request = (String) msg;		System.out.println(request);		ctx.writeAndFlush(Unpooled.copiedBuffer("你好，服务端已经接收到你的请求$_".getBytes()));	}	}

package 网络编程_netty2;import io.netty.bootstrap.Bootstrap;import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelInitializer;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.DelimiterBasedFrameDecoder;import io.netty.handler.codec.string.StringDecoder;public class client {	public static void main(String[] args) throws InterruptedException {		EventLoopGroup worker = new NioEventLoopGroup();		Bootstrap bootstrap = new Bootstrap();		bootstrap.group(worker)				 .channel(NioSocketChannel.class)				 .handler(new ChannelInitializer
   
    () {					@Override					public void initChannel(SocketChannel ch) throws Exception {						ByteBuf buf = Unpooled.copiedBuffer("$_".getBytes());						ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, buf));						ch.pipeline().addLast(new StringDecoder());						ch.pipeline().addLast(new ClientHandler());					}				});		ChannelFuture f = bootstrap.connect("127.0.0.1", 8888).sync();		f.channel().writeAndFlush(Unpooled.wrappedBuffer("aaa$_".getBytes()));		f.channel().writeAndFlush(Unpooled.wrappedBuffer("bbbb$_".getBytes()));		f.channel().writeAndFlush(Unpooled.wrappedBuffer("ccccccc$_".getBytes()));		f.channel().closeFuture().sync();		worker.shutdownGracefully();	}	}
   

package 网络编程_netty2;import io.netty.channel.ChannelHandlerAdapter;import io.netty.channel.ChannelHandlerContext;public class ClientHandler extends ChannelHandlerAdapter{	@Override	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {		cause.printStackTrace();		ctx.close();	}	@Override	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {		String response = (String) msg;		System.out.println(response);	}	}

转载地址：https://blog.csdn.net/Lee_Ho_/article/details/78135903 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！