Rpc 插件的启动方式更改为Spring的启动方式的测试用例

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.BaseJobHandler;
+import com.byit.task.annotations.TaskHandler;
+import com.byit.task.handler.BaseJobHandler;
 
+@TaskHandler(taskName = "sendEmailTest")
 public class SendEmailTest extends BaseJobHandler {
     @Override
     public ReturnResult<String> execute(String param) throws Exception {

demo-client/byit-plugin-server/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>demo-client</artifactId>
+        <groupId>myth-job</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>byit-plugin-server</artifactId>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>myth-job</groupId>
+            <artifactId>myth-plugin-rpc-server</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file

demo-client/byit-plugin-server/src/main/java/com/byit/PluginServerApplication.java

+package com.byit;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author huangfu
+ */
+@SpringBootApplication
+public class PluginServerApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(PluginServerApplication.class,args);
+    }
+}

demo-client/byit-plugin-server/src/main/java/com/byit/conf/PluginConf.java

+package com.byit.conf;
+
+import com.byit.factory.RpcSpringPluginServerFactory;
+import com.byit.server.netty.NettyPluginServer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author huangfu
+ */
+@Configuration
+public class PluginConf {
+
+    @Bean
+    public RpcSpringPluginServerFactory rpcSpringPluginServerFactory(){
+        RpcSpringPluginServerFactory rpcSpringPluginServerFactory = new RpcSpringPluginServerFactory();
+        rpcSpringPluginServerFactory.setPluginServerClass(NettyPluginServer.class);
+        return rpcSpringPluginServerFactory;
+    }
+}

demo-client/byit-plugin-server/src/main/java/com/byit/server/SenEmailServer.java

+package com.byit.server;
+
+import com.byit.dto.web.ReturnResult;
+import com.byit.task.annotations.TaskHandler;
+import com.byit.task.handler.BaseJobHandler;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Administrator
+ */
+@Component
+@TaskHandler(taskName = "01Test")
+public class SenEmailServer extends BaseJobHandler {
+    @Override
+    public ReturnResult<String> execute(String param) throws Exception {
+        return null;
+    }
+}

demo-client/byit-plugin-server/src/main/resources/application.yml

+server:
+  port: 8970
+
+myth:
+  plugin:
+    env: plugin_test
+    biz: byit-myth-job
+    port: 8971
+  register:
+    url: http://localhost:8080/myth-register

demo-client/pom.xml

@@ -15,6 +15,7 @@
         <module>byit-demo-api</module>
         <module>byit-demo-client</module>
         <module>byit-demo-service</module>
+        <module>byit-plugin-server</module>
     </modules>