Java 怎么通过动态代理实现事务的自动开启与提交-java教程-PHP中文网

java动态代理实现事务的核心是通过invocationhandler拦截方法调用，在@transactional标注方法执行前开启事务、成功后提交、异常时回滚，并借助threadlocal复用connection；spring的@transactional即基于此原理。

java 怎么通过动态代理实现事务的自动开启与提交

Java 中通过动态代理实现事务的自动开启与提交，核心是利用 代理对象拦截目标方法调用，在方法执行前开启事务、执行后提交（或回滚）。这正是 Spring 的 @Transactional 底层原理之一（基于 JDK 动态代理或 CGLIB）。下面以纯 Java + JDBC 为例，说明关键步骤和实现逻辑。

1. 定义事务管理器接口与实现

事务控制需要统一入口，比如：

beginTransaction()：获取连接、关闭自动提交
commit()：提交事务
rollback()：回滚事务
getConnection()：复用当前事务连接（避免多线程/嵌套问题需结合 ThreadLocal）

示例简版实现：

public class JdbcTransactionManager { private static final ThreadLocal connectionHolder = new ThreadLocal(); public void beginTransaction() throws SQLException { Connection conn = DriverManager.getConnection("jdbc:h2:mem:test", "sa", ""); conn.setAutoCommit(false); connectionHolder.set(conn); } public void commit() throws SQLException { Connection conn = connectionHolder.get(); if (conn != null) conn.commit(); cleanup(); } public void rollback() throws SQLException { Connection conn = connectionHolder.get(); if (conn != null) conn.rollback(); cleanup(); } private void cleanup() { Connection conn = connectionHolder.get(); if (conn != null) { try { conn.close(); } catch (SQLException ignored) {} } connectionHolder.remove(); } public Connection getConnection() { return connectionHolder.get(); } }

2. 创建事务注解与代理处理器

定义一个自定义注解标记需要事务的方法：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface Transactional { }

再写一个 InvocationHandler，在 invoke() 中织入事务逻辑：

public class TransactionInvocationHandler implements InvocationHandler { private final Object target; private final JdbcTransactionManager txManager = new JdbcTransactionManager(); public TransactionInvocationHandler(Object target) { this.target = target; } @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 检查方法是否标注 @Transactional if (method.isAnnotationPresent(Transactional.class)) { try { txManager.beginTransaction(); Object result = method.invoke(target, args); txManager.commit(); return result; } catch (Exception e) { txManager.rollback(); throw e; } } else { return method.invoke(target, args); } } }

3. 使用动态代理包装服务类

假设有一个 DAO 或 Service 接口及其实现：

public interface UserService { void createUser(String name); } public class UserServiceImpl implements UserService { @Override public void createUser(String name) { Connection conn = JdbcTransactionManager.getInstance().getConnection(); // 使用 conn 执行 INSERT（注意：必须用同一个 conn！） try (PreparedStatement ps = conn.prepareStatement("INSERT INTO users(name) VALUES (?)")) { ps.setString(1, name); ps.executeUpdate(); } } }

创建代理并调用：

UserService service = new UserServiceImpl(); UserService proxy = (UserService) Proxy.newProxyInstance( UserService.class.getClassLoader(), new Class[]{UserService.class}, new TransactionInvocationHandler(service) ); proxy.createUser("Alice"); // 自动开启→执行→提交