Netty 客户端发送消息委托类开发与实现

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/client/NettyPluginClient.java

+package com.byit.client;
+
+import com.byit.client.handler.NettyPluginConnectionClient;
+import com.byit.client.handler.PluginConnectClient;
+import com.byit.packet.request.PluginRpcRequestPacket;
+import com.byit.rpc.remoting.net.common.ConnectClient;
+import com.byit.rpc.remoting.net.impl.netty.client.NettyConnectClient;
+
+/**
+ * Netty 插件客户端
+ * @author huangfu
+ */
+public class NettyPluginClient extends PluginClient  {
+    private Class<? extends PluginConnectClient> pluginConnectClientImpl = NettyPluginConnectionClient.class;
+
+    @Override
+    public void send(String address, PluginRpcRequestPacket pluginRpcRequestPacket) throws Exception {
+        PluginConnectClient.send(pluginRpcRequestPacket,address,pluginConnectClientImpl,pluginClientInitialization);
+    }
+}

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/client/PluginClient.java

+package com.byit.client;
+
+import com.byit.client.handler.PluginConnectClient;
+import com.byit.init.PluginClientInitialization;
+import com.byit.packet.request.PluginRpcRequestPacket;
+import com.byit.rpc.remoting.net.params.RpcRequest;
+
+/**
+ * 客户端服务接口
+ * @author huangfu
+ */
+public abstract class PluginClient {
+    protected PluginClientInitialization pluginClientInitialization;
+
+    public void init(PluginClientInitialization pluginClientInitialization){
+        this.pluginClientInitialization = pluginClientInitialization;
+    }
+
+    /**
+     * 发送方法
+     * @param address 发送的地址
+     * @param pluginRpcRequestPacket 信息包
+     * @throws Exception 抛出异常
+     */
+    public abstract void send(String address, PluginRpcRequestPacket pluginRpcRequestPacket) throws Exception;
+
+}