提供demo

build.xml

@@ -0,0 +1,130 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<project basedir="." default="jar" name="plugin">
+    <!-- JDK路径，根据自己机器上实际位置修改-->
+    <property name="jdk.home" value="/Library/Java/JavaVirtualMachines/jdk1.8.0_191.jdk/Contents/Home"/>
+
+    <property name="libs" value="${basedir}/lib/report"/>
+    <property name="publicLibs" value=""/>
+    <property name="reportLibs" value="${basedir}/../env/webroot/WEB-INF/lib"/>
+    <property name="destLoc" value="."/>
+    <property name="classes" value="classes"/>
+    <xmlproperty file="${basedir}/plugin.xml"/>
+    <property name="current-version" value="${plugin.version}"/>
+
+    <!-- 插件版本-->
+    <property name="plugin-version" value="${current-version}"/>
+    <!-- 插件名字-->
+    <property name="plugin-name" value="rpc-print"/>
+    <property name="plugin-jar" value="fr-plugin-${plugin-name}-${plugin-version}.jar"/>
+
+    <target name="prepare">
+        <delete dir="${classes}"/>
+        <delete dir="fr-plugin-${plugin-name}-${plugin-version}"/>
+        <xmlproperty file="${basedir}/plugin.xml"/>
+        <delete dir="${destLoc}/${plugin.name}"/>
+    </target>
+    <path id="compile.classpath">
+        <fileset dir="${libs}">
+            <include name="**/*.jar"/>
+        </fileset>
+        <fileset dir="${publicLibs}">
+            <include name="**/*.class"/>
+        </fileset>
+        <fileset dir="${reportLibs}">
+            <include name="**/*.jar"/>
+        </fileset>
+    </path>
+    <patternset id="resources4Jar">
+        <exclude name="**/.settings/**"/>
+        <exclude name=".classpath"/>
+        <exclude name=".project"/>
+
+        <exclude name="**/*.java"/>
+        <exclude name="**/*.db"/>
+        <exclude name="**/*.g"/>
+        <exclude name="**/package.html"/>
+    </patternset>
+    <target name="copy_resources">
+        <echo message="从${resources_from}拷贝图片,JS,CSS等资源文件"/>
+        <delete dir="tmp"/>
+        <copy todir="tmp">
+            <fileset dir="${resources_from}/src/main/resources">
+                <patternset refid="resources4Jar"/>
+            </fileset>
+        </copy>
+        <copy todir="${classes}">
+            <fileset dir="tmp"/>
+        </copy>
+        <delete dir="tmp"/>
+    </target>
+    <target name="compile_javas">
+        <echo message="编译${compile_files}下的Java文件"/>
+        <javac destdir="${classes}" debug="false" optimize="on" source="${source_jdk_version}"
+               target="${target_jdk_version}"
+               fork="true" memoryMaximumSize="512m" listfiles="false" srcdir="${basedir}"
+               executable="${compile_jdk_version}/bin/javac">
+            <src path="${basedir}/src/main/java"/>
+            <exclude name="**/.svn/**"/>
+            <compilerarg line="-encoding UTF8 "/>
+            <classpath refid="compile.classpath"/>
+        </javac>
+        <taskdef name="pretreatment" classname="com.fr.plugin.pack.PluginPretreatmentTask">
+            <classpath refid="compile.classpath"/>
+        </taskdef>
+        <pretreatment baseDir="${basedir}"/>
+    </target>
+
+    <target name="jar_classes">
+        <echo message="打Jar包:${jar_name}"/>
+        <delete file="${basedir}/${jar_name}"/>
+        <jar jarfile="${basedir}/${jar_name}">
+            <fileset dir="${classes}">
+            </fileset>
+        </jar>
+    </target>
+
+    <target name="super_jar" depends="prepare">
+        <antcall target="copy_resources">
+            <param name="resources_from" value="${basedir}"/>
+        </antcall>
+        <antcall target="compile_javas">
+            <param name="source_jdk_version" value="1.6"/>
+            <param name="target_jdk_version" value="1.6"/>
+            <param name="compile_jdk_version" value="${jdk.home}"/>
+            <param name="compile_files" value="${basedir}/src"/>
+        </antcall>
+        <echo message="compile plugin success!"/>
+
+        <antcall target="jar_classes">
+            <param name="jar_name" value="${plugin-jar}"/>
+        </antcall>
+        <delete dir="${classes}"/>
+
+    </target>
+
+    <target name="jar" depends="super_jar">
+        <antcall target="zip"/>
+    </target>
+
+    <target name="zip">
+        <property name="plugin-folder" value="fr-plugin-${plugin-name}-${plugin-version}"/>
+        <echo message="----------zip files----------"/>
+        <mkdir dir="${plugin-folder}"/>
+        <copy todir="${plugin-folder}">
+            <fileset dir=".">
+                <include name="${plugin-jar}"/>
+                <include name="plugin.xml"/>
+            </fileset>
+            <fileset dir="${libs}">
+                <include name="*.jar"/>
+                <include name="*.dll"/>
+            </fileset>
+        </copy>
+        <zip destfile="${basedir}/${plugin-folder}.zip" basedir=".">
+            <include name="${plugin-folder}/*.jar"/>
+            <include name="${plugin-folder}/*.dll"/>
+            <include name="${plugin-folder}/plugin.xml"/>
+        </zip>
+        <move file="${plugin-folder}.zip" todir="${destLoc}/install"/>
+    </target>
+</project>

plugin.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<plugin>
+    <id>com.fr.plugin.rpc.print</id>
+    <name><![CDATA[插件支持RPC]]></name>
+    <active>yes</active>
+    <hidden>no</hidden>
+    <version>1.0</version>
+    <env-version>10.0~</env-version>
+    <jartime>2020-8-10</jartime>
+    <vendor>zed</vendor>
+    <description><![CDATA[插件可以注册集群入场卷了]]></description>
+    <change-notes><![CDATA[
+        <p>[2020-08-21]实现</p>
+    ]]></change-notes>
+    <function-recorder class="com.fr.plugin.rpc.MyTicket"/>
+    <extra-core>
+        <ClusterTicketProvider class="com.fr.plugin.rpc.MyTicket"/>
+    </extra-core>
+    <extra-decision>
+        <ControllerRegisterProvider class="com.fr.plugin.rpc.RPCControllerRegister"/>
+    </extra-decision>
+</plugin>

pom.xml

@@ -0,0 +1,41 @@
+<?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">
+    <modelVersion>4.0.0</modelVersion>
+    <dependencies>
+        <dependency>
+            <groupId>com.fr.decision</groupId>
+            <artifactId>decision-feature</artifactId>
+            <version>10.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.fr.decision</groupId>
+            <artifactId>decision-feature</artifactId>
+            <version>10.0</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+    <parent>
+        <groupId>com.fr.plugin</groupId>
+        <artifactId>starter</artifactId>
+        <version>10.0</version>
+    </parent>
+    <packaging>jar</packaging>
+    <artifactId>decision.message.event</artifactId>
+    <build>
+        <!---如果要更改调试插件，改这里的配置就可以了-->
+        <outputDirectory>${project.basedir}/../webroot/WEB-INF/plugins/plugin-com.fr.plugin.decision.batch.role-1.0/classes</outputDirectory>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>6</source>
+                    <target>6</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>

readme.md

@@ -0,0 +1,9 @@
+# 插件rpc实现
+让插件支持注册集群入场券，实现rpc代理
+
+# 效果截图
+
+![result](screenshots/result1.png)
+
+
+

rpc-print.iml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_7">
+    <output url="file://$MODULE_DIR$/../env/webroot/WEB-INF/plugins/plugin-com.fr.plugin.rpc.print-1.0/classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="module" module-name="decision-feature" />
+    <orderEntry type="module" module-name="decision-base" />
+    <orderEntry type="module" module-name="decision-web" />
+    <orderEntry type="module" module-name="base-cluster-engine" />
+    <orderEntry type="module" module-name="core-cluster-interface" />
+    <orderEntry type="module" module-name="finekit" />
+    <orderEntry type="library" name="lib" level="project" />
+  </component>
+</module>

src/main/java/com/fr/plugin/rpc/MyTicket.java

@@ -0,0 +1,21 @@
+package com.fr.plugin.rpc;
+
+import com.fr.cluster.entry.ClusterTicket;
+import com.fr.plugin.transform.FunctionRecorder;
+import com.fr.cluster.engine.fun.impl.AbstractClusterTicketProvider;
+
+/**
+ * @author Zed
+ * @version 10.0
+ * Created by Zed on 2020/8/21
+ * <p>
+ * 插件接口的实现
+ */
+@FunctionRecorder
+public class MyTicket extends AbstractClusterTicketProvider {
+
+    @Override
+    public ClusterTicket getTicket() {
+        return PrintImpl.INSTANCE.getTicket();
+    }
+}

src/main/java/com/fr/plugin/rpc/Print.java

@@ -0,0 +1,14 @@
+package com.fr.plugin.rpc;
+
+import com.fr.cluster.rpc.proxy.filter.BroadCast;
+
+/**
+ * @author Zed
+ * @version 10.0
+ * Created by Zed on 2020/8/21
+ */
+public interface Print {
+
+    @BroadCast
+    void print();
+}

src/main/java/com/fr/plugin/rpc/PrintImpl.java

@@ -0,0 +1,22 @@
+package com.fr.plugin.rpc;
+
+import com.fr.cluster.engine.core.jchannel.MachineMarker;
+import com.fr.cluster.rpc.proxy.Ticket;
+import com.fr.cluster.rpc.proxy.TicketProxyBuilder;
+
+/**
+ * @author Zed
+ * @version 10.0
+ * Created by Zed on 2020/8/21
+ */
+@Ticket
+public class PrintImpl extends TicketProxyBuilder<Print> implements Print {
+
+    public static final PrintImpl INSTANCE = new PrintImpl();
+
+    @Override
+    public void print() {
+        System.out.println("hi zed! this is " + MachineMarker.currentID());
+    }
+
+}

src/main/java/com/fr/plugin/rpc/RPCController.java

@@ -0,0 +1,30 @@
+package com.fr.plugin.rpc;
+
+import com.fr.decision.webservice.Response;
+import com.fr.third.springframework.stereotype.Controller;
+import com.fr.third.springframework.web.bind.annotation.RequestMapping;
+import com.fr.third.springframework.web.bind.annotation.RequestMethod;
+import com.fr.third.springframework.web.bind.annotation.ResponseBody;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * @author Zed
+ * @version 10.0
+ * Created by Zed on 2020/8/21
+ *
+ * 测试用的rest api
+ */
+@Controller
+public class RPCController {
+
+    @RequestMapping(value = "/print", method = RequestMethod.GET)
+    @ResponseBody
+    public Response batch(HttpServletRequest req,
+                          HttpServletResponse res) throws Exception {
+
+        PrintImpl.INSTANCE.getProxy().print();
+        return Response.success();
+    }
+}

src/main/java/com/fr/plugin/rpc/RPCControllerRegister.java

@@ -0,0 +1,18 @@
+package com.fr.plugin.rpc;
+
+import com.fr.decision.fun.impl.AbstractControllerRegisterProvider;
+
+/**
+ * @author Zed
+ * @version 10.0
+ * Created by Zed on 2020/8/21
+ *
+ * 注册rest api
+ */
+public class RPCControllerRegister extends AbstractControllerRegisterProvider {
+
+    @Override
+    public Class<?>[] getControllers() {
+        return new Class[]{RPCController.class};
+    }
+}