Netty入门到超神系列-Netty使用Protobuf编码解码

//定义版本syntax="proto3";
//生成的代码的类名和文件名optionjava_outer_classname="UserPOJO";
//使用messae管理数据，注意名字不要和java_outer_classname冲突messageUser{
//定义ID属性，int32对应java的,注意这里的1指的是需要而不是值int64id=1;
//定义一个name属性，类型为字符串String,注意这里的2指的是需要而不是值stringname=2;
//定义一个数组,爱好repeatedstringfavorite=3;
}

publicclassNettyServer {
publicstaticvoidmain(String[] args) {
NioEventLoopGroupbossGroup=newNioEventLoopGroup();
NioEventLoopGroupworkGroup=newNioEventLoopGroup();
ServerBootstrapbootstrap=newServerBootstrap();
try {
bootstrap.group(bossGroup,workGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(newChannelInitializer<SocketChannel>() {
@OverrideprotectedvoidinitChannel(SocketChannelch) throwsException {
ChannelPipelinepipeline=ch.pipeline();
//服务端:使用protobuf解码器，需要指定解码器解码哪种类型pipeline.addLast("decoder",newProtobufDecoder(UserPOJO.User.getDefaultInstance()));
pipeline.addLast(newServerHandler());
                    }
                });
//启动服务器ChannelFuturesync=bootstrap.bind(2000).sync();
sync.channel().closeFuture().sync();
        } catch (InterruptedExceptione) {
e.printStackTrace();
        }finally {
bossGroup.shutdownGracefully();
workGroup.shutdownGracefully();
        }
    }
}

publicclassServerHandlerextendsChannelInboundHandlerAdapter {
@OverridepublicvoidchannelRead(ChannelHandlerContextctx, Objectmsg) throwsException {
//把消息强转成UserPOJO.UserUserPOJO.Useruser= (UserPOJO.User) msg;
System.out.println("拿到数据："+user.getName());
    }
@OverridepublicvoidexceptionCaught(ChannelHandlerContextctx, Throwablecause) throwsException {
ctx.channel().close();
    }
}

publicclassNettyClient {
publicstaticvoidmain(String[] args) {
NioEventLoopGroupeventLoopGroup=newNioEventLoopGroup();
Bootstrapbootstrap=newBootstrap();
bootstrap.group(eventLoopGroup)
                .channel(NioSocketChannel.class)
                .handler(newChannelInitializer<SocketChannel>() {
@OverrideprotectedvoidinitChannel(SocketChannelch) throwsException {
ChannelPipelinepipeline=ch.pipeline();
//给客户端增加编码器，使用ProtobufEncoder编码器pipeline.addLast("encoder",newProtobufEncoder());
pipeline.addLast(newClientHandler());
                    }
                });
try {
ChannelFuturesync=bootstrap.connect("127.0.0.1", 2000).sync();
sync.channel().closeFuture().sync();
        } catch (InterruptedExceptione) {
e.printStackTrace();
        }finally {
eventLoopGroup.shutdownGracefully();
        }
    }
}

publicclassClientHandlerextendsChannelInboundHandlerAdapter {
@OverridepublicvoidchannelRead(ChannelHandlerContextctx, Objectmsg) throwsException {
    }
@OverridepublicvoidchannelActive(ChannelHandlerContextctx) throwsException {
//当建立连接，就发送一个对象给服务端UserPOJO.Useruser=UserPOJO.User.newBuilder().setId(1).setName("zs").build();
ctx.writeAndFlush(user);
System.out.println("客户端发送 user="+user.getName());
    }
@OverridepublicvoidexceptionCaught(ChannelHandlerContextctx, Throwablecause) throwsException {
ctx.channel().close();
    }
}