一种Service方法为Spring事务调用内部多重方法 [英] One Service method invoke inner multiple method for Spring transaction
问题描述
package com.bluesky;
public interface FooServiceIface {
public void insertA();
public void insertB();
}
package com.bluesky;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
public class FooServiceImpl extends JdbcDaoSupport implements FooServiceIface {
public void insertA() {
this.getJdbcTemplate().execute("insert student(name) values('stuA')");
insertB();
int i=10/0;
}
public void insertB() {
this.getJdbcTemplate().execute("insert student(name) values('stuB')");
}
}
public class Client {
public static void main(String[] args) {
ApplicationContext appContxt = new ClassPathXmlApplicationContext("applicationContext.xml");
FooServiceIface fService= (FooServiceIface)appContxt.getBean("fooService");
fService.insertA();
}
}
<?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:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</bean>
<bean id="fooService" class="com.bluesky.FooServiceImpl">
<property name="dataSource" ref="dataSource"/>
</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="insertA" propagation="REQUIRED" />
<tx:method name="insertB" propagation="REQUIRES_NEW" />
</tx:attributes>
</tx:advice>
<aop:config proxy-target-class="true">
<aop:pointcut id="interceptorPointCuts" expression="execution(* com.bluesky.*Service*.*(..))" />
<aop:advisor advice-ref="txAdvice" pointcut-ref="interceptorPointCuts" />
</aop:config>
</beans>
对不起,您的复杂代码
当我运行Client blow调试日志时,会显示:
21:44:19,546 DEBUG TransactionSynchronizationManager:183 - Bound value [org.springframework.jdbc.datasource.ConnectionHolder@ba86ef] for key [org.springframework.jdbc.datasource.DriverManagerDataSource@1b9658e] to thread [main] 21:44:19,546 DEBUG TransactionSynchronizationManager:258 - Initializing transaction synchronization 21:44:19,547 DEBUG TransactionInterceptor:362 - Getting transaction for [com.bluesky.FooServiceImpl.insertA] 21:44:19,547 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuA')] 21:44:19,592 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuB')] 21:44:19,594 DEBUG TransactionInterceptor:406 - Completing transaction for [com.bluesky.FooServiceImpl.insertA] after exception: java.lang.ArithmeticException: / by zero 21:44:19,594 DEBUG RuleBasedTransactionAttribute:130 - Applying rules to determine whether transaction should rollback on java.lang.ArithmeticException: / by zero 21:44:19,594 DEBUG RuleBasedTransactionAttribute:147 - Winning rollback rule is: null 21:44:19,595 DEBUG RuleBasedTransactionAttribute:152 - No relevant rollback rule found: applying default rules 21:44:19,595 DEBUG DataSourceTransactionManager:938 - Triggering beforeCompletion synchronization 21:44:19,595 DEBUG DataSourceTransactionManager:843 - Initiating transaction rollback 21:44:19,596 DEBUG DataSourceTransactionManager:279 - Rolling back JDBC transaction on Connection [com.mysql.jdbc.JDBC4Connection@167f4bf] 21:44:19,598 DEBUG DataSourceTransactionManager:967 - Triggering afterCompletion synchronization 21:44:19,598 DEBUG TransactionSynchronizationManager:316 - Clearing transaction synchronization
我发现,当调用insertA()
方法时,此方法启动事务,当代码到达insertB()
时,没有用于启动的事务.
我没有配置任何东西吗?还是我弄错了任何担忧
我的目的是当insertA()
调用insertB(
时)有一个REQUIRES_NEW
事务开始.
KLE关于重构代码的建议很合理,但是对于为什么不起作用,Spring AOP使用 JDK动态代理提供AOP.这意味着,当您将服务注入某些东西时,真正注入的是实现服务接口的Proxy实例.在此代理上调用方法时,它会在委派给您的实际服务实例之前运行事务代码.但是,一旦控制流进入您的服务,则通过this.foo()
调用另一个方法(即使this
是隐式的)也只会在同一实例上调用一个方法:您的服务.它不会返回到代理,这是唯一了解事务的信息. 如果您切换使用AspectJ来构建或加载字节码编织,然后您可以执行此操作,并且它可以按预期工作,因为事务调用代码将直接编织到您的服务代码中,而不是驻留在单独的对象中./p>
package com.bluesky;
public interface FooServiceIface {
public void insertA();
public void insertB();
}
package com.bluesky;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
public class FooServiceImpl extends JdbcDaoSupport implements FooServiceIface {
public void insertA() {
this.getJdbcTemplate().execute("insert student(name) values('stuA')");
insertB();
int i=10/0;
}
public void insertB() {
this.getJdbcTemplate().execute("insert student(name) values('stuB')");
}
}
public class Client {
public static void main(String[] args) {
ApplicationContext appContxt = new ClassPathXmlApplicationContext("applicationContext.xml");
FooServiceIface fService= (FooServiceIface)appContxt.getBean("fooService");
fService.insertA();
}
}
<?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:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</bean>
<bean id="fooService" class="com.bluesky.FooServiceImpl">
<property name="dataSource" ref="dataSource"/>
</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="insertA" propagation="REQUIRED" />
<tx:method name="insertB" propagation="REQUIRES_NEW" />
</tx:attributes>
</tx:advice>
<aop:config proxy-target-class="true">
<aop:pointcut id="interceptorPointCuts" expression="execution(* com.bluesky.*Service*.*(..))" />
<aop:advisor advice-ref="txAdvice" pointcut-ref="interceptorPointCuts" />
</aop:config>
</beans>
Sorry for the Complicated code
When i run Client blow debug logs are showing:
21:44:19,546 DEBUG TransactionSynchronizationManager:183 - Bound value [org.springframework.jdbc.datasource.ConnectionHolder@ba86ef] for key [org.springframework.jdbc.datasource.DriverManagerDataSource@1b9658e] to thread [main] 21:44:19,546 DEBUG TransactionSynchronizationManager:258 - Initializing transaction synchronization 21:44:19,547 DEBUG TransactionInterceptor:362 - Getting transaction for [com.bluesky.FooServiceImpl.insertA] 21:44:19,547 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuA')] 21:44:19,592 DEBUG JdbcTemplate:416 - Executing SQL statement [insert student(name) values('stuB')] 21:44:19,594 DEBUG TransactionInterceptor:406 - Completing transaction for [com.bluesky.FooServiceImpl.insertA] after exception: java.lang.ArithmeticException: / by zero 21:44:19,594 DEBUG RuleBasedTransactionAttribute:130 - Applying rules to determine whether transaction should rollback on java.lang.ArithmeticException: / by zero 21:44:19,594 DEBUG RuleBasedTransactionAttribute:147 - Winning rollback rule is: null 21:44:19,595 DEBUG RuleBasedTransactionAttribute:152 - No relevant rollback rule found: applying default rules 21:44:19,595 DEBUG DataSourceTransactionManager:938 - Triggering beforeCompletion synchronization 21:44:19,595 DEBUG DataSourceTransactionManager:843 - Initiating transaction rollback 21:44:19,596 DEBUG DataSourceTransactionManager:279 - Rolling back JDBC transaction on Connection [com.mysql.jdbc.JDBC4Connection@167f4bf] 21:44:19,598 DEBUG DataSourceTransactionManager:967 - Triggering afterCompletion synchronization 21:44:19,598 DEBUG TransactionSynchronizationManager:316 - Clearing transaction synchronization
I found that when invoked insertA()
method , this method start a transaction, when the code arrive insertB()
, there is not transaction for starting.
Is there anything did i not configured or any concern i made mistaken
My intention is to when insertA()
call insertB(
) there is an REQUIRES_NEW
transaction start.
KLE's advice about refactoring your code is right on the money, but as for why it's not working, Spring AOP uses JDK dynamic proxies by default to provide AOP. That means that when you inject your service into something, what's really getting injected is a Proxy instance that implements your service interface. When a method is invoked on this proxy, it runs the transaction code before delegating to your actual service instance. Once the control flow is inside your service, though, calling another method via this.foo()
(even if the this
is implicit) just invokes a method on that same instance: your service. It doesn't go back to the proxy, which is the only thing that knows about transactions. If you switched to build- or load-time bytecode weaving with AspectJ, then you could do this, and it would work as expected, since the transaction-invoking code would be woven directly into your service code instead of living in a separate object.
这篇关于一种Service方法为Spring事务调用内部多重方法的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!