新增jfinal类型示例项目；

xuxueli · Dec 21, 2018 · b36a158 · b36a158
1 parent 32d54c9
commit b36a158
Show file tree

Hide file tree

Showing 7 changed files with 212 additions and 0 deletions.
diff --git a/...sample-jfinal-client/src/main/java/com/xxl/rpc/sample/client/config/JFinalCoreConfig.java b/...sample-jfinal-client/src/main/java/com/xxl/rpc/sample/client/config/JFinalCoreConfig.java
@@ -99,6 +99,7 @@ private void destoryXxlRpcClient() throws Exception {
 
 	// ---------------------- jfinal ----------------------
 
+    @Override
 	public void configRoute(Routes route) {
 		route.add("/", IndexController.class);
 	}

diff --git a/xxl-rpc-samples/xxl-rpc-executor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/pom.xml b/xxl-rpc-samples/xxl-rpc-executor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/pom.xml
@@ -9,6 +9,38 @@
         <version>1.3.1</version>
     </parent>
     <artifactId>xxl-rpc-executor-sample-jfinal-server</artifactId>
+    <packaging>war</packaging>
 
+    <dependencies>
+
+        <!-- jfinal -->
+        <dependency>
+            <groupId>com.jfinal</groupId>
+            <artifactId>jfinal</artifactId>
+            <version>2.2</version>
+        </dependency>
+
+        <!-- slf4j -->
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <version>${slf4j-api.version}</version>
+        </dependency>
+
+        <!-- xxl-rpc-core -->
+        <dependency>
+            <groupId>com.xuxueli</groupId>
+            <artifactId>xxl-rpc-core</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- sample-api -->
+        <dependency>
+            <groupId>com.xuxueli</groupId>
+            <artifactId>xxl-rpc-executor-sample-jfinal-api</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+    </dependencies>
 
 </project>
diff --git a/...sample-jfinal-server/src/main/java/com/xxl/rpc/sample/server/config/JFinalCoreConfig.java b/...sample-jfinal-server/src/main/java/com/xxl/rpc/sample/server/config/JFinalCoreConfig.java
@@ -0,0 +1,91 @@
+package com.xxl.rpc.sample.server.config;
+
+import com.jfinal.config.*;
+import com.jfinal.kit.Prop;
+import com.jfinal.kit.PropKit;
+import com.xxl.rpc.registry.impl.XxlRegistryServiceRegistry;
+import com.xxl.rpc.remoting.net.NetEnum;
+import com.xxl.rpc.remoting.provider.XxlRpcProviderFactory;
+import com.xxl.rpc.sample.api.DemoService;
+import com.xxl.rpc.sample.server.service.DemoServiceImpl;
+import com.xxl.rpc.serialize.Serializer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.HashMap;
+
+/**
+ * @author xuxueli 2018-12-21
+ */
+public class JFinalCoreConfig extends JFinalConfig {
+	private Logger logger = LoggerFactory.getLogger(JFinalCoreConfig.class);
+
+
+
+	// ---------------------- xxl-rpc server ----------------------
+
+	private XxlRpcProviderFactory xxlRpcProviderFactory;
+	private void initXxlRpcServer() throws Exception {
+
+		// init invoker factory
+		final Prop xxlJobProp = PropKit.use("xxl-rpc-sample.properties");
+		xxlRpcProviderFactory = new XxlRpcProviderFactory();
+		xxlRpcProviderFactory.initConfig(NetEnum.NETTY, Serializer.SerializeEnum.HESSIAN.getSerializer(), null, 7080, null, XxlRegistryServiceRegistry.class, new HashMap<String, String>(){{
+			put(XxlRegistryServiceRegistry.XXL_REGISTRY_ADDRESS, xxlJobProp.get("xxl-rpc.registry.xxlregistry.address"));
+			put(XxlRegistryServiceRegistry.ENV, xxlJobProp.get("xxl-rpc.registry.xxlregistry.env"));
+		}});
+
+		// add services
+		xxlRpcProviderFactory.addService(DemoService.class.getName(), null, new DemoServiceImpl());
+
+		// start
+		xxlRpcProviderFactory.start();
+	}
+	private void destoryXxlRpcServer() throws Exception {
+		xxlRpcProviderFactory.stop();
+	}
+
+
+	// ---------------------- jfinal ----------------------
+
+	@Override
+	public void afterJFinalStart() {
+		try {
+			initXxlRpcServer();
+		} catch (Exception e) {
+			logger.error(e.getMessage(), e);
+		}
+	}
+
+	@Override
+	public void beforeJFinalStop() {
+		try {
+			destoryXxlRpcServer();
+		} catch (Exception e) {
+			logger.error(e.getMessage(), e);
+		}
+	}
+
+	@Override
+	public void configRoute(Routes routes) {
+
+	}
+
+	public void configConstant(Constants constants) {
+
+	}
+
+	public void configPlugin(Plugins plugins) {
+
+	}
+
+	public void configInterceptor(Interceptors interceptors) {
+
+	}
+
+	public void configHandler(Handlers handlers) {
+
+	}
+
+
+}
diff --git a/...sample-jfinal-server/src/main/java/com/xxl/rpc/sample/server/service/DemoServiceImpl.java b/...sample-jfinal-server/src/main/java/com/xxl/rpc/sample/server/service/DemoServiceImpl.java
@@ -0,0 +1,30 @@
+package com.xxl.rpc.sample.server.service;
+
+import com.xxl.rpc.sample.api.DemoService;
+import com.xxl.rpc.sample.api.dto.UserDTO;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.text.MessageFormat;
+
+/**
+ * @author xuxueli
+ */
+public class DemoServiceImpl implements DemoService {
+	private static Logger logger = LoggerFactory.getLogger(DemoServiceImpl.class);
+
+	@Override
+	public UserDTO sayHi(String name) {
+
+		String word = MessageFormat.format("Hi {0}, from {1} as {2}",
+				name, DemoServiceImpl.class.getName(), String.valueOf(System.currentTimeMillis()));
+
+		if ("error".equalsIgnoreCase(name)) throw new RuntimeException("test exception.");
+
+		UserDTO userDTO = new UserDTO(name, word);
+		logger.info(userDTO.toString());
+
+		return userDTO;
+	}
+
+}
diff --git a/...executor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/resources/log4j.xml b/...executor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/resources/log4j.xml
@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration PUBLIC "-//log4j/log4j Configuration//EN" "log4j.dtd">
+<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/" threshold="null" debug="null">
+
+	<appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">
+		<param name="Target" value="System.out" />
+		<layout class="org.apache.log4j.PatternLayout">
+            <param name="ConversionPattern" value="%-d{yyyy-MM-dd HH:mm:ss} xxl-rpc-executor-sample-jfinal-server [%c]-[%t]-[%M]-[%L]-[%p] %m%n"/>
+		</layout>
+	</appender>
+
+    <appender name="FILE" class="org.apache.log4j.DailyRollingFileAppender">
+        <param name="file" value="/data/applogs/xxl-rpc/xxl-rpc-executor-sample-jfinal-server.log"/>
+        <param name="append" value="true"/>
+        <param name="encoding" value="UTF-8"/>
+        <layout class="org.apache.log4j.PatternLayout">
+            <param name="ConversionPattern" value="%-d{yyyy-MM-dd HH:mm:ss} xxl-rpc-executor-sample-jfinal-server [%c]-[%t]-[%M]-[%L]-[%p] %m%n"/>
+        </layout>
+    </appender>
+
+    <root>
+        <level value="INFO" />
+        <appender-ref ref="CONSOLE" />
+        <appender-ref ref="FILE" />
+    </root>
+
+</log4j:configuration>
diff --git a/...jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/resources/xxl-rpc-sample.properties b/...jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/resources/xxl-rpc-sample.properties
@@ -0,0 +1,3 @@
+# xxl-rpc
+xxl-rpc.registry.xxlregistry.address=http://localhost:8080/xxl-registry-admin
+xxl-rpc.registry.xxlregistry.env=default
diff --git a/...cutor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/webapp/WEB-INF/web.xml b/...cutor-sample-jfinal/xxl-rpc-executor-sample-jfinal-server/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+	id="WebApp_ID" version="2.5">
+
+	<display-name>xxl-rpc-executor-sample-jfinal-client</display-name>
+	<context-param>
+		<param-name>webAppRootKey</param-name>
+		<param-value>xxl-rpc-executor-sample-jfinal-client</param-value>
+	</context-param>
+
+	<!-- jfinal -->
+	<filter>
+		<filter-name>jfinal</filter-name>
+		<filter-class>com.jfinal.core.JFinalFilter</filter-class>
+		<init-param>
+			<param-name>configClass</param-name>
+			<param-value>com.xxl.rpc.sample.server.config.JFinalCoreConfig</param-value>
+		</init-param>
+	</filter>
+	<filter-mapping>
+		<filter-name>jfinal</filter-name>
+		<url-pattern>/*</url-pattern>
+	</filter-mapping>
+
+
+</web-app>