最近公司使用Jfinal开发项目,不知道什么原因Jfinal和其他的几个插件集成的时候,事物管理并不那么随心,所以就选择了Spring作为Jfinal的插件来管理事物.废话不多说,直接上代码.

public class MyConfig extends JFinalConfig{@Overridepublic void configConstant(Constants me) {IocKit.processJFinalConfig(this);loadPropertyFile("db.properties");me.setEncoding("UTF-8");me.setDevMode(getPropertyToBoolean("devMode", true));}@Overridepublic void configRoute(Routes me) {System.out.println("configRoute");me.add("/blog", BlogController.class);}@Overridepublic void configPlugin(Plugins me) {SpringPlugin springPlugin = new SpringPlugin("classpath*:spring/applicationContext-*.xml");me.add(springPlugin);SpringDataSourceProvider prov = new SpringDataSourceProvider(springPlugin);// 配置ActiveRecord插件,将jfinal的事物交给Spring管理ActiveRecordPlugin arp = new ActiveRecordPlugin(prov);me.add(arp);arp.addMapping("system_admin", SystemAdmin.class);}@Overridepublic void configInterceptor(Interceptors me) {System.out.println("configInterceptor");}@Overridepublic void configHandler(Handlers me) {System.out.println("configHandler");}@Overridepublic void configEngine(Engine me) {System.out.println("configEngine");}}

IocKit.java

public class IocKit {// ioc @Inject @Value @Autowiredstatic AutowiredAnnotationBeanPostProcessor autowiredAnnotationBeanPostProcessor;// ioc @Resourcestatic CommonAnnotationBeanPostProcessor commonAnnotationBeanPostProcessor;public static AutowiredAnnotationBeanPostProcessor getAutowiredAnnotationBeanPostProcessor() {Assert.notNull(autowiredAnnotationBeanPostProcessor,"The main autowiredAnnotationBeanPostProcessor is null, initialize SpringPlugin first");return autowiredAnnotationBeanPostProcessor;}public static CommonAnnotationBeanPostProcessor getCommonAnnotationBeanPostProcessor() {Assert.notNull(commonAnnotationBeanPostProcessor,"The main commonAnnotationBeanPostProcessor is null, initialize SpringPlugin first");return commonAnnotationBeanPostProcessor;}// --------------------------------------------------// JFinalConfig// --------------------------------------------------/*** @Title: 处理 JFinalConfig*/public static void processJFinalConfig(JFinalConfig finalConfig) {ApplicationContext ctx = org.springframework.web.context.support.WebApplicationContextUtils.getWebApplicationContext(JFinal.me().getServletContext());processJFinalConfig(finalConfig, ctx);}/*** @Title: 处理 JFinalConfig*/public static void processJFinalConfig(JFinalConfig jfinalConfig, ApplicationContext ctx) {Assert.notNull(ctx, "ApplicationContext not be null");Assert.notNull(jfinalConfig, "jfinalConfig not be null");AutowiredAnnotationBeanPostProcessor autowiredAnnotationBeanPostProcessor = setBeanFactory(new AutowiredAnnotationBeanPostProcessor(), ctx);CommonAnnotationBeanPostProcessor commonAnnotationBeanPostProcessor = setBeanFactory(new CommonAnnotationBeanPostProcessor(), ctx);processInjection(jfinalConfig, commonAnnotationBeanPostProcessor, autowiredAnnotationBeanPostProcessor);}/*** @Title: 注入 bean 调用*/public static void invokeForProcessInjection(Object invocation) {Invocation inv = as(invocation, Invocation.class);Controller controller = inv.getController();processInjection(controller);inv.invoke();}public static void processInjection(Object bean) {processInjection(bean, commonAnnotationBeanPostProcessor, autowiredAnnotationBeanPostProcessor);}// ---------------------------------------------------------// function// ---------------------------------------------------------static void init(ApplicationContext ctx) {autowiredAnnotationBeanPostProcessor = setBeanFactory(new AutowiredAnnotationBeanPostProcessor(), ctx);commonAnnotationBeanPostProcessor = setBeanFactory(new CommonAnnotationBeanPostProcessor(), ctx);}static <T extends BeanFactoryAware> T setBeanFactory(T beanPostProcessor, ApplicationContext ctx) {beanPostProcessor.setBeanFactory(ctx.getAutowireCapableBeanFactory());return beanPostProcessor;}static void processInjection(Object bean, CommonAnnotationBeanPostProcessor commonAnnotationBeanPostProcessor,AutowiredAnnotationBeanPostProcessor autowiredAnnotationBeanPostProcessor) {commonAnnotationBeanPostProcessor.postProcessPropertyValues(null, null, bean, null);autowiredAnnotationBeanPostProcessor.processInjection(bean);}// ----------------------------------------------------------------// as proxy// ----------------------------------------------------------------private final static Map<String, Method> methodCache = new HashMap<String, Method>(16);private static Method cachedMethod(Class<?> type, Method method) throws NoSuchMethodException {String name = method.getName();String key = type.getName() + "." + name;Method m = methodCache.get(key);if (m == null) {synchronized (methodCache) {m = methodCache.get(key);if (m == null) {Class<?>[] parameterTypes = method.getParameterTypes();try {// Actual method name matches always come firstm = type.getMethod(name, parameterTypes);} catch (SecurityException ignore) {m = type.getDeclaredMethod(name, parameterTypes);}methodCache.put(key, m);}}}return m;}/*** Create a proxy for the wrapped object allowing to typesafely invoke* methods on it using a custom interface** @param proxyType*            The interface type that is implemented by the proxy* @return A proxy for the wrapped object*/@SuppressWarnings("unchecked")private static <P> P as(final Object object, Class<P> proxyType) {final Class<?> clazz = object.getClass();final InvocationHandler handler = new InvocationHandler() {public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {Method m = cachedMethod(clazz, method);boolean accessible = m.isAccessible();try {if (!accessible) m.setAccessible(true);return m.invoke(object, args);} finally {m.setAccessible(accessible);}}};return (P) Proxy.newProxyInstance(proxyType.getClassLoader(), new Class[] { proxyType }, handler);}private static interface Invocation {void invoke();Controller getController();}
}

SpringDataSourceProvider.java

public class SpringDataSourceProvider implements IDataSourceProvider {private static final String proxyDsName = "proxyDataSource";private SpringPlugin springPlugin;private String beanName;public SpringDataSourceProvider(SpringPlugin springPlugin, String beanName) {this.springPlugin = springPlugin;this.beanName = beanName;}public SpringDataSourceProvider(SpringPlugin springPlugin) {this.springPlugin = springPlugin;this.beanName = proxyDsName;}public DataSource getDataSource() {ApplicationContext ctx = springPlugin.getApplicationContext();return (DataSource)ctx.getBean(beanName,TransactionAwareDataSourceProxy.class);}
}

SpringPlugin.java

private static boolean isStarted = false;private String[] configurations;private ApplicationContext ctx;public SpringPlugin() {}public SpringPlugin(ApplicationContext ctx) {this.setApplicationContext(ctx);}public SpringPlugin(String... configurations) {this.configurations = configurations;}public void setApplicationContext(ApplicationContext ctx) {Assert.notNull(ctx, "ApplicationContext can not be null.");this.ctx = ctx;}public ApplicationContext getApplicationContext() {return this.ctx ;}public boolean start() {if (isStarted) {return true;}else if (!isStarted && configurations != null){ctx = new FileSystemXmlApplicationContext(configurations);}else {ctx = new FileSystemXmlApplicationContext(PathKit.getWebRootPath() + "/WEB-INF/applicationContext.xml");}Assert.notNull(ctx, "ApplicationContext can not be null.");IocKit.init(ctx);return isStarted = true;}public boolean stop() {ctx = null;isStarted = false;return true;}
}

applicationContext-core.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context" default-autowire="byName"xmlns:aop="http://www.springframework.org/schema/aop" xmlns:p="http://www.springframework.org/schema/p"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsdhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsdhttp://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd"><!-- 引入配置文件 --><bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="location" value="classpath:db.properties"/></bean><!-- dataSource配置 --><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"init-method="init" destroy-method="close"><property name="driverClassName" value="${jdbc.driverClassName}"/><property name="url" value="${jdbc.url}"/><property name="username" value="${jdbc.username}"/><property name="password" value="${jdbc.password}"/><property name="filters" value="log4j"/><property name="maxActive" value="5"/><property name="initialSize" value="1"/><property name="maxWait" value="6000"/></bean><bean id="proxyDataSource" class="org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy"><constructor-arg><ref bean="dataSource" /></constructor-arg></bean><!-- 声明式事务的配置 --><!-- 事务管理器 --><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!-- 配置事务通知 --><tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="delete*" propagation="REQUIRED" read-only="false" /><tx:method name="insert*" propagation="REQUIRED" read-only="false" /><tx:method name="update*" propagation="REQUIRED" read-only="false" /><tx:method name="find*" propagation="SUPPORTS" /><tx:method name="get*" propagation="SUPPORTS" /><tx:method name="select*" propagation="SUPPORTS" /></tx:attributes></tx:advice><!-- 把事务控制在Service层 --><aop:config><aop:pointcut id="pointcut" expression="execution(public * cn.minions.testSpring.Service.impl.*.*(..))" /><aop:advisor pointcut-ref="pointcut" advice-ref="txAdvice" /></aop:config><context:component-scan base-package="cn.minions.testSpring" />
</beans>

完整测试项目的地址:https://gitee.com/fhcspring/jfinal-spring

测试环境还集成了activiti mybatis