Java EE银行转账业务开发与事务管理实战-育师

1. Java EE银行转账业务开发概述

银行转账业务作为金融系统的核心功能之一，在Java EE体系中的实现涉及事务管理、数据一致性、并发控制等关键技术要点。本章将基于Java EE 3规范，从零开始构建一个完整的银行转账模拟系统，重点解析在没有使用MVC框架的情况下如何保证业务逻辑的完整性和数据安全性。

银行转账看似简单的"转出账户扣款，转入账户加款"操作，在实际开发中需要考虑以下核心问题：

如何确保两个账户的金额变更要么同时成功，要么同时失败（事务原子性）
在高并发场景下如何避免出现超额转账（并发控制）
不使用ThreadLocal时如何保持数据库连接的一致性
业务异常时的处理机制与回滚策略

提示：虽然现代Java开发普遍采用Spring等框架，但理解原生Java EE的事务处理机制对掌握底层原理至关重要。本章的实现方案可以直接应用于Servlet+JSP的传统架构项目。

2. 基础环境搭建与数据库设计

2.1 数据库表结构设计

银行转账业务至少需要两张核心表：账户表(account)和交易记录表(transaction)。以下是推荐的MySQL建表语句：

CREATE TABLE account ( id BIGINT PRIMARY KEY AUTO_INCREMENT, account_number VARCHAR(20) UNIQUE NOT NULL, account_name VARCHAR(50) NOT NULL, balance DECIMAL(15,2) NOT NULL DEFAULT 0.00, version INT DEFAULT 0 COMMENT '乐观锁版本号' ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; CREATE TABLE transaction ( id BIGINT PRIMARY KEY AUTO_INCREMENT, from_account VARCHAR(20) NOT NULL, to_account VARCHAR(20) NOT NULL, amount DECIMAL(15,2) NOT NULL, transaction_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, status TINYINT NOT NULL DEFAULT 0 COMMENT '0-处理中 1-成功 2-失败', remark VARCHAR(200) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

关键设计要点：

账户表使用version字段实现乐观锁，防止并发修改导致余额错误
金额字段使用DECIMAL类型而非FLOAT/DOUBLE，避免浮点数精度问题
交易记录表完整保存每笔转账的元数据，满足审计要求

2.2 Java EE项目基础配置

在非MVC架构下，我们需要手动配置数据库连接池和事务管理。以Tomcat 9 + JDK 8环境为例：

在META-INF/context.xml中配置JNDI数据源：

<Context> <Resource name="jdbc/BankDB" auth="Container" type="javax.sql.DataSource" maxTotal="50" maxIdle="10" maxWaitMillis="10000" username="bank_user" password="secure_password" driverClassName="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost:3306/bank_db?useSSL=false&amp;serverTimezone=UTC"/> </Context>

在web.xml中添加资源引用：

<resource-ref> <description>Bank Database</description> <res-ref-name>jdbc/BankDB</res-ref-name> <res-type>javax.sql.DataSource</res-type> <res-auth>Container</res-auth> </resource-ref>

3. 核心转账业务实现

3.1 不使用ThreadLocal的事务管理方案

在没有Spring等框架支持的情况下，我们需要手动管理数据库连接和事务边界。以下是典型的转账服务实现：

public class TransferService { public boolean transfer(String fromAccount, String toAccount, BigDecimal amount, String remark) { Connection conn = null; try { // 获取JNDI数据源连接 Context ctx = new InitialContext(); DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/BankDB"); conn = ds.getConnection(); // 关闭自动提交，开启事务 conn.setAutoCommit(false); // 执行转账操作 AccountDAO accountDAO = new AccountDAO(conn); TransactionDAO transactionDAO = new TransactionDAO(conn); // 1. 检查转出账户余额是否充足 Account from = accountDAO.findByAccountNumber(fromAccount); if(from.getBalance().compareTo(amount) < 0) { throw new InsufficientBalanceException("余额不足"); } // 2. 创建交易记录(状态为处理中) Transaction tx = new Transaction(); tx.setFromAccount(fromAccount); tx.setToAccount(toAccount); tx.setAmount(amount); tx.setStatus(0); tx.setRemark(remark); transactionDAO.create(tx); // 3. 执行账户金额变更 accountDAO.decreaseBalance(fromAccount, amount); accountDAO.increaseBalance(toAccount, amount); // 4. 更新交易状态为成功 tx.setStatus(1); transactionDAO.updateStatus(tx); // 提交事务 conn.commit(); return true; } catch (Exception e) { // 回滚事务 if(conn != null) { try { conn.rollback(); } catch (SQLException ex) { ex.printStackTrace(); } } return false; } finally { // 关闭连接 if(conn != null) { try { conn.setAutoCommit(true); // 恢复自动提交 conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } } }

3.2 并发控制与乐观锁实现

在高并发场景下，需要防止多个转账请求同时修改同一账户导致的余额不一致问题。我们在AccountDAO中实现乐观锁机制：

public class AccountDAO { private Connection conn; public AccountDAO(Connection conn) { this.conn = conn; } public void decreaseBalance(String accountNumber, BigDecimal amount) throws SQLException { String sql = "UPDATE account SET balance = balance - ?, version = version + 1 " + "WHERE account_number = ? AND version = ?"; Account account = findByAccountNumber(accountNumber); try(PreparedStatement stmt = conn.prepareStatement(sql)) { stmt.setBigDecimal(1, amount); stmt.setString(2, accountNumber); stmt.setInt(3, account.getVersion()); int affectedRows = stmt.executeUpdate(); if(affectedRows == 0) { throw new OptimisticLockException("并发修改冲突，请重试"); } } } // increaseBalance方法实现类似 }

4. 业务异常处理与事务回滚

银行转账业务需要处理多种异常情况，每种情况需要不同的回滚策略：

4.1 常见异常类型及处理

余额不足异常：

public class InsufficientBalanceException extends RuntimeException { public InsufficientBalanceException(String message) { super(message); } }

账户不存在异常：

public class AccountNotFoundException extends RuntimeException { public AccountNotFoundException(String accountNumber) { super("账户不存在: " + accountNumber); } }

并发修改异常：

public class OptimisticLockException extends RuntimeException { public OptimisticLockException(String message) { super(message); } }

4.2 事务回滚最佳实践

在纯Java EE环境下，事务回滚需要注意以下要点：

连接对象一致性：确保DAO层所有操作使用同一个Connection对象
异常捕获范围：在事务边界处捕获所有异常，包括RuntimeException
资源清理：finally块中正确关闭连接并恢复自动提交模式
事务日志：在回滚时记录失败原因，便于后续排查

改进后的异常处理代码示例：

try { // 转账业务逻辑... } catch (InsufficientBalanceException e) { log.error("转账失败：余额不足", e); conn.rollback(); transactionDAO.updateStatus(txId, 2, "余额不足"); throw new BusinessException("转账失败：余额不足"); } catch (AccountNotFoundException e) { log.error("转账失败：账户不存在", e); conn.rollback(); transactionDAO.updateStatus(txId, 2, "账户不存在"); throw new BusinessException("转账失败：账户不存在"); } catch (OptimisticLockException e) { log.error("转账失败：并发冲突", e); conn.rollback(); throw new BusinessException("系统繁忙，请稍后重试"); } catch (Exception e) { log.error("转账失败：系统异常", e); conn.rollback(); transactionDAO.updateStatus(txId, 2, "系统异常"); throw new BusinessException("转账失败：系统异常"); }

5. 性能优化与安全考量

5.1 批量转账处理优化

当需要处理批量转账时，可以优化为一次事务处理多个转账请求：

public class BatchTransferService { public void batchTransfer(List<TransferRequest> requests) { Connection conn = null; try { // 获取连接并开始事务 Context ctx = new InitialContext(); DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/BankDB"); conn = ds.getConnection(); conn.setAutoCommit(false); AccountDAO accountDAO = new AccountDAO(conn); TransactionDAO transactionDAO = new TransactionDAO(conn); for(TransferRequest request : requests) { // 执行单笔转账逻辑 // 注意：任一失败将导致整个批次回滚 } conn.commit(); } catch (Exception e) { // 异常处理... } finally { // 资源清理... } } }

5.2 安全防护措施

SQL注入防护：
- 始终使用PreparedStatement
- 对用户输入进行正则验证
- 账户号码等字段限制字符集（如只允许数字）
金额校验：
- 转账金额必须为正数
- 设置单笔转账限额
- 大额转账需要额外验证
日志审计：
- 记录完整操作日志
- 敏感信息脱敏处理
- 日志文件权限控制

6. 传统架构下的前端交互实现

在不使用现代前端框架的情况下，可以通过JSP+Servlet实现简单的转账界面：

6.1 转账表单页面(transfer.jsp)

<%@ page contentType="text/html;charset=UTF-8" %> <html> <head> <title>银行转账</title> </head> <body> <h2>银行转账</h2> <form action="transfer" method="post"> 转出账号: <input type="text" name="fromAccount" required pattern="\d{10,20}"><br> 转入账号: <input type="text" name="toAccount" required pattern="\d{10,20}"><br> 转账金额: <input type="number" name="amount" min="0.01" max="1000000" step="0.01" required><br> 备注: <input type="text" name="remark"><br> <input type="submit" value="确认转账"> </form> <c:if test="${not empty message}"> <div style="color:${success ? 'green' : 'red'}"> ${message} </div> </c:if> </body> </html>

6.2 转账处理Servlet(TransferServlet.java)

@WebServlet("/transfer") public class TransferServlet extends HttpServlet { private TransferService transferService = new TransferService(); protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String fromAccount = req.getParameter("fromAccount"); String toAccount = req.getParameter("toAccount"); BigDecimal amount = new BigDecimal(req.getParameter("amount")); String remark = req.getParameter("remark"); try { boolean success = transferService.transfer( fromAccount, toAccount, amount, remark); req.setAttribute("message", "转账成功"); req.setAttribute("success", true); } catch (BusinessException e) { req.setAttribute("message", e.getMessage()); req.setAttribute("success", false); } req.getRequestDispatcher("/transfer.jsp").forward(req, resp); } }

7. 测试策略与常见问题排查

7.1 单元测试要点

正常流程测试：
- 余额充足的转账请求
- 不同金额范围的转账(小额、大额、边界值)
异常流程测试：
- 余额不足的情况
- 账户不存在的情况
- 并发修改冲突的情况
- 数据库连接失败的情况
并发测试：
- 使用JMeter模拟多用户并发转账
- 验证乐观锁的正确性
- 检查最终余额一致性

7.2 常见问题与解决方案

事务未生效：
- 检查是否调用了setAutoCommit(false)
- 确认所有DAO使用同一个Connection
- 查看数据库日志确认事务边界
并发修改导致余额错误：
- 检查乐观锁版本号是否正常递增
- 验证重试机制是否有效
- 考虑添加数据库行锁
性能瓶颈：
- 检查数据库连接池配置
- 优化事务隔离级别(通常使用READ_COMMITTED)
- 考虑批量处理减少事务提交次数