JDBC 事务中如何配置读写分离

在 jdbc 中实现批量操作的读写分离，核心在于维护两个独立的 connection 对象：一个用于写操作的主库连接，另一个用于读操作的从库连接。通过手动管理这两个连接的 autocommit 状态，可以确保在同一业务逻辑下，写操作在主库提交，而读操作在从库执行，从而实现数据隔离与负载均衡。

具体做法是创建主库连接并开启事务，同时创建从库连接并关闭自动提交。在执行批量写入时，使用主库连接；在需要读取中间结果或验证数据时，使用从库连接。需要注意的是，由于数据库复制存在延迟，从库可能无法立即读到主库的最新数据，因此这种模式适用于对实时一致性要求不高的场景。

JDBC 批量操作的具体代码实现

JDBC 批量操作通过 addBatch() 和 executeBatch() 方法实现，能显著减少网络往返次数。结合读写分离，我们需要在一个方法中同时处理主库的写入和从库的查询，并确保两者的事务独立性。

import java.sql.*;

public class JdbcReadWriteBatch {
    public static void main(String[] args) {
        Connection masterConn = null;
        Connection slaveConn = null;
        try {
            // 1. 获取主库连接（写）
            masterConn = DriverManager.getConnection("jdbc:mysql://master:3306/db", "user", "pass");
            masterConn.setAutoCommit(false);

            // 2. 获取从库连接（读）
            slaveConn = DriverManager.getConnection("jdbc:mysql://slave:3306/db", "user", "pass");
            slaveConn.setAutoCommit(false); // 显式关闭，便于控制

            // 3. 批量写入主库
            String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
            PreparedStatement pstmt = masterConn.prepareStatement(sql);
            for (int i = 0; i <p>上述代码展示了完整的流程。首先分别获取主从连接并关闭自动提交。接着使用主库连接进行批量插入，调用 <code>executeBatch()</code> 后提交事务。随后使用从库连接执行查询。最后务必在 <code>finally</code> 块中关闭所有连接，防止资源泄露。</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill13063" title="Java Development Man"><img
														src="https://img.php.cn/upload/skill/001/246/273/6adaf20e695c2374.jpg" alt="Java Development Man" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/skill13063" title="Java Development Man" class="overflowclass">Java Development Man</a>
													<p class="overflowclass">Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。</p>
												</div>
												<a rel="nofollow" href="/xiazai/skill13063" title="Java Development Man" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div><h2>主库提交后从库查询结果的延迟问题</h2><p>当主库完成 <code>commit()</code> 后，立即在从库执行查询，返回的结果可能不包含最新插入的数据。这是因为 MySQL 的主从复制通常是异步的，从库需要通过 I/O 线程接收主库的 binlog，再由 SQL 线程重放，这个过程存在毫秒到秒级的延迟。</p><p><img src="https://img.php.cn/upload/article/001/242/473/179478248246983.png?x-oss-process=image/resize,p_40" alt="Java JDBC 事务管理怎么实现批量操作读写分离"></p><p>为了解决这个问题，可以在代码中加入重试机制，或者在强一致性要求的场景下，强制从库路由到主库。但在本例的批量操作场景中，如果业务允许最终一致性，可以直接忽略短暂的不一致。若必须读取最新数据，应复用主库连接进行查询，但这会破坏读写分离的性能优势。因此，设计时需权衡性能与数据实时性。</p>

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南