@@ -0,0 +1,648 @@
+package com.demo2do.app.mediator;%0A%0Aimport com.demo2do.entity.protocol.proto.Demo2doPb.SampleAppPb;%0Aimport com.demo2do.netty.mediator.ProtocolBufferMediator;%0Aimport com.google.protobuf.MessageLite;%0A%0A/**%0A * %E9%92%88%E5%AF%B9%E5%BA%94%E7%94%A8%E7%9A%84%E8%87%AA%E5%AE%9A%E4%B9%89%E4%B8%AD%E4%BB%8B%E5%99%A8%0A *%0A * @author David%0A */%0Apublic class EchoMediator extends ProtocolBufferMediator %7B%0A%0A    @Override%0A    public String getActionKeyByRequest(Object request) %7B%0A        SampleAppPb protocolModel = (SampleAppPb) request;%0A        SampleAppPb.ActionType type = protocolModel.getActionType();%0A        return type.name();%0A    %7D%0A%0A    @Override%0A    public MessageLite getPbInstance() %7B%0A        return SampleAppPb.getDefaultInstance();%0A    %7D%0A%7D%0A

add application customized mediator