基于netty5的自定义协议Demo

package com.luck.client; import java.util.UUID; import com.luck.codec.LuckDecoder; import com.luck.codec.LuckEncoder; import com.luck.pojo.LuckHeader; import com.luck.pojo.LuckMessage; import io.netty.bootstrap.Bootstrap; import io.netty.channel.Channel; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelPipeline; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioSocketChannel; public class LuckClient { public static void main(String[] args) throws InterruptedException { EventLoopGroup group = new NioEventLoopGroup(); try { Bootstrap bootstrap = new Bootstrap(); bootstrap.group(group); bootstrap.channel(NioSocketChannel.class); bootstrap.handler(new ChannelInitializer<Channel>() { @Override protected void initChannel(Channel channel) throws Exception { ChannelPipeline pipeline = channel.pipeline(); pipeline.addLast(new LuckEncoder()); pipeline.addLast(new LuckDecoder()); pipeline.addLast(new LuckClientHandler()); } }); Channel channel = bootstrap.connect("127.0.0.1", 8080).sync().channel(); int version = 1; String sessionId = UUID.randomUUID().toString(); String content = "I'm the luck protocol"; LuckHeader header = new LuckHeader(version, content.length(), sessionId); LuckMessage message = new LuckMessage(header, content); channel.writeAndFlush(message); channel.close(); } finally { group.shutdownGracefully(); } } }