Netty服务端 main方式启动设计实现测试

byit-plugin-core/myth-plugin-rpc-server/src/main/resources/plugin.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <executor-plugin>
     <serverConfiguration>
-        <port value="8989"/>
-        <registryUrl value="http://slocalhost:8080"/>
+        <port value="8980"/>
+        <registryUrl value="http://localhost:8080/myth-register"/>
         <server-biz value="myth-job"/>
         <server-env value="dev"/>
-        <server-thread core-size="" max-size=""/>
+        <server-thread core-size="30" max-size="100"/>
         <pluginServiceRegistry value="com.byit.registry.DataSourceServiceRegistry"/>
-        <pluginServerClass value="com.byit.server.NettyPluginServer"/>
+        <pluginServerClass value="com.byit.server.netty.MainNettyPluginServer"/>
     </serverConfiguration>
 
-    <!--<classNames>
-        <className jobName="demo" class="com.byit.job.DemoJob"/>
-        <className jobName="demo1" class="com.byit.job.EndNode"/>
-        <className jobName="demo2" class="com.byit.job.StartNode"/>
-    </classNames>-->
+    <classNames>
+        <className jobName="sendEmailTest" class="com.byit.server.SendEmailTest"/>
+    </classNames>
 </executor-plugin>
\ No newline at end of file

byit-plugin-core/myth-plugin-rpc-server/src/test/java/com/byit/server/SendEmailTest.java

+package com.byit.server;
+
+import com.byit.dto.web.ReturnResult;
+import com.byit.executor.handler.interfaces.IJobHandler;
+
+public class SendEmailTest implements IJobHandler {
+    @Override
+    public ReturnResult<String> execute(String param) throws Exception {
+        return null;
+    }
+
+    @Override
+    public void init(String param) {
+        System.out.println("---");
+    }
+
+    @Override
+    public void destroy(String param) {
+        System.out.println("----");
+    }
+}

byit-plugin-core/myth-plugin-rpc-server/src/test/java/com/byit/server/TestServerStart.java

+package com.byit.server;
+
+import com.byit.factory.PluginServerFactory;
+import com.byit.factory.RpcMainPluginServerFactory;
+
+public class TestServerStart {
+
+    public static void main(String[] args) throws Exception {
+        new RpcMainPluginServerFactory("/plugin.xml");
+        System.out.println("----");
+    }
+}