Netty 结果自动以回调开发

byit-plugin-core/byit-plugin-rpc-common/src/main/java/com/byit/param/ResultCallback.java

+package com.byit.param;
+
+import com.byit.packet.response.PluginRpcResponsePacket;
+import io.netty.channel.ChannelHandlerContext;
+
+import java.io.Serializable;
+
+/**
+ * @author 结果集回调  用户自定义实现 执行完成后的结果返回操作
+ */
+public interface ResultCallback extends Serializable {
+    /**
+     * 对于服务器处理完的数据  用户自定义定义返回操作
+     * @param ctx
+     * @param pluginRpcResponsePacket
+     */
+    void resultCallback(ChannelHandlerContext ctx, PluginRpcResponsePacket pluginRpcResponsePacket);
+}

byit-plugin-core/byit-plugin-rpc-common/src/main/java/com/byit/param/defaultparam/DefaultResultCallback.java

+package com.byit.param.defaultparam;
+
+import com.alibaba.fastjson.JSON;
+import com.byit.packet.response.PluginRpcResponsePacket;
+import com.byit.param.ResultCallback;
+import io.netty.channel.ChannelHandlerContext;
+
+/**
+ * 默认的回调方式
+ * @author huangfu
+ */
+public class DefaultResultCallback implements ResultCallback {
+    @Override
+    public void resultCallback(ChannelHandlerContext ctx, PluginRpcResponsePacket pluginRpcResponsePacket) {
+        System.out.println(pluginRpcResponsePacket);
+        System.out.println(JSON.toJSONString(pluginRpcResponsePacket));
+    }
+}