【BlossomRPC】编解码器的实现

RPC项目

配置中心项目

网关项目

在前面的文章了解完毕之后，我们以及设计了一个基本的RPC协议，之后，我们要做的就是基于这个RPC协议，去实现一个能解析这个RPC协议的编解码器。

这里编解码器比较容易写，按照前面几篇文章中讲解的方式来编写即可。

@Slf4j
public class RpcEncode extends MessageToByteEncoder<RpcDto<Object>> {
    @Override
    protected void encode(ChannelHandlerContext ctx, RpcDto<Object> msg, ByteBuf out) throws Exception {
        log.info("Start encoding the data");
        //判断请求头合法性
        if (Objects.isNull(msg)) {
            log.warn("the RpcDto msg is Null!!!");
            return;
        }
        RpcHeader RpcHeader=msg.getHeader();
        out.writeByte(RpcHeader.getVersionId());
        out.writeByte(RpcHeader.get
1
2
3
4
5
6
7
8
9
10
11
12