
本文旨在解决java桌面应用中多用户同时访问单一数据库的挑战,特别是针对apache derby嵌入式数据库的场景。我们将深入探讨嵌入式与客户端/服务器模式的区别,指出常见问题如“sealing violation”的根源,并提供实现多连接的正确方法,包括部署数据库服务器、选择合适的事务隔离级别以及利用现代化数据访问框架来简化并发控制。
在构建多用户应用时,首先需要理解数据库的两种基本连接模式:嵌入式(Embedded)和客户端/服务器(Client/Server)。这对于正确处理并发访问至关重要。
Apache Derby、H2、HSQLDB等数据库都支持嵌入式模式。在这种模式下,数据库引擎作为应用程序的一部分,在同一个Java虚拟机(JVM)中运行,并直接访问数据库文件。其主要特点和局限性包括:
对于多用户或多应用程序并发访问的需求,客户端/服务器模式是标准且推荐的解决方案。在这种模式下:
解决多用户并发访问问题的最直接且推荐的方法是,将数据库部署为独立的服务器进程。
立即学习“Java免费学习笔记(深入)”;
Apache Derby 可以轻松配置为网络服务器模式。一旦以服务器模式运行,多个Java应用程序就可以通过JDBC网络驱动程序连接到它。
启动Derby网络服务器的步骤:
java -jar %DERBY_HOME%/lib/derbyrun.jar server start
或者指定监听地址和端口:
java -Dderby.drda.host=0.0.0.0 -Dderby.drda.port=1527 -jar %DERBY_HOME%/lib/derbyrun.jar server start
这将启动一个Derby服务器,默认监听 localhost:1527。
# 在服务器启动后,客户端连接时指定数据库路径 # 或者通过系统属性指定默认数据库目录 # java -Dderby.system.home=/path/to/your/databases -jar %DERBY_HOME%/lib/derbyrun.jar server start
Java客户端连接代码示例:
当Derby服务器启动后,客户端应用程序需要使用不同的JDBC URL来连接。
import java.sql.*;
import javax.swing.JOptionPane;
public class DerbyClientConnect {
public Connection connectToDerbyServer() {
Connection con = null;
try {
// 加载Derby网络客户端驱动
Class.forName("org.apache.derby.jdbc.ClientDriver");
// 连接到运行在localhost:1527的Derby服务器上的VERe数据库
// create=true 参数会在数据库不存在时创建它(仅第一次连接时有效)
String host = "jdbc:derby://localhost:1527/C:\DATABSE_SUB\VERe;create=true";
String uName = "josh";
String uPass = "1234";
con = DriverManager.getConnection(host, uName, uPass);
System.out.println("成功连接到Derby网络服务器。");
return con;
} catch (ClassNotFoundException e) {
JOptionPane.showMessageDialog(null, "Derby客户端驱动未找到: " + e.getMessage());
} catch (SQLException err) {
JOptionPane.showMessageDialog(null, "数据库连接错误: " + err.getMessage());
}
return null;
}
public static void main(String[] args) {
DerbyClientConnect client = new DerbyClientConnect();
Connection connection1 = client.connectToDerbyServer();
Connection connection2 = client.connectToDerbyServer(); // 模拟第二个客户端连接
if (connection1 != null && connection2 != null) {
System.out.println("两个连接都已建立,可以并发操作。");
try {
connection1.close();
connection2.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}除了Derby,还有许多更成熟、功能更强大的关系型数据库适合多用户环境,例如:
如果由于某种限制,必须在不部署独立服务器的情况下实现“多用户”访问,且这些“用户”实际上是同一台机器上的多个Java应用程序,那么需要一个更复杂的策略:
一旦数据库运行在服务器模式下,并支持多连接,接下来就需要关注并发控制和事务隔离级别,以确保数据的一致性和完整性。
JDBC提供了多种事务隔离级别,用于定义事务之间如何相互影响:
对于涉及读取后写入(Read-Modify-Write)的复杂业务逻辑(如银行转账),TRANSACTION_READ_COMMITTED 或更低级别是不安全的。例如,在两个并发事务中,如果都读取了账户余额,然后各自进行扣款,最终可能会导致余额错误。
SERIALIZABLE 隔离级别是确保数据一致性的最强保证。它强制事务表现得如同它们是串行执行的一样,从而避免了各种并发异常。
然而,SERIALIZABLE 也有其挑战:
示例:不安全的转账操作(即使有 TRANSACTION_READ_COMMITTED)
// 假设在两个并发线程中执行以下代码
Connection con = getConnection();
con.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED); // 不安全
con.setAutoCommit(false);
try (Statement stmt = con.createStatement()) {
// 1. 读取余额
ResultSet rs = stmt.executeQuery("SELECT balance FROM account WHERE accountId = 1");
if (rs.next()) {
int balance = rs.getInt("balance");
int requestedAmount = 100; // 假设请求扣款100
if (balance >= requestedAmount) {
// 2. 更新余额
int newBalance = balance - requestedAmount;
stmt.executeUpdate("UPDATE account SET balance = " + newBalance + " WHERE accountId = 1");
con.commit();
System.out.println("扣款成功,新余额: " + newBalance);
} else {
con.rollback();
System.out.println("余额不足。");
}
}
} catch (SQLException e) {
con.rollback();
e.printStackTrace();
} finally {
con.setAutoCommit(true);
con.close();
}在 TRANSACTION_READ_COMMITTED 下,两个事务可能同时读取到相同的初始余额,然后都尝试扣款,导致最终余额错误。
为了在某些情况下避免 SERIALIZABLE 的性能开销,可以采用乐观锁。乐观锁不依赖数据库的显式锁定,而是在更新数据时检查数据是否已被其他事务修改。
实现方式: 通常通过在表中添加一个版本号(version)或时间戳(last_updated_at)字段。更新时,检查该版本号是否与读取时一致:
UPDATE account SET balance = ?, version = version + 1 WHERE accountId = ? AND version = ?;
如果 WHERE 子句匹配失败(即 version 不再是读取时的旧值),则说明数据已被修改,当前事务需要回滚并重试。
直接使用JDBC进行数据库操作,尤其是在处理事务、并发和错误重试时,会非常繁琐且容易出错。因此,强烈建议使用现代化数据访问框架。
这些框架通常内置了对事务管理、重试机制(特别是针对 SERIALIZABLE 失败)和乐观锁的支持,极大地简化了开发工作。
以JDBI为例,它允许你通过Lambda表达式定义事务,并可以配置自动重试逻辑:
import org.jdbi.v3.core.Jdbi;
import org.jdbi.v3.core.transaction.TransactionIsolationLevel;
public class JdbiExample {
public static void main(String[] args) {
// 假设已经配置好Jdbi实例,连接到Derby服务器
Jdbi jdbi = Jdbi.create("jdbc:derby://localhost:1527/C:\DATABSE_SUB\VERe", "josh", "1234");
// 注册插件以支持事务和重试
jdbi.installPlugins();
try {
// 使用JDBI的事务API,并指定SERIALIZABLE隔离级别
// JDBI可以配置自动重试逻辑,处理SerializationFailureException
jdbi.useTransaction(TransactionIsolationLevel.SERIALIZABLE, handle -> {
// 模拟转账操作
long accountId1 = 1;
long accountId2 = 2;
int amount = 50;
// 获取账户1余额
int balance1 = handle.createQuery("SELECT balance FROM account WHERE id = ?")
.bind(0, accountId1)
.mapTo(Integer.class)
.one();
if (balance1 < amount) {
throw new IllegalArgumentException("账户1余额不足");
}
// 更新账户1
handle.execute("UPDATE account SET balance = balance - ? WHERE id = ?", amount, accountId1);
// 更新账户2
handle.execute("UPDATE account SET balance = balance + ? WHERE id = ?", amount, accountId2);
System.out.println("转账成功: 从账户" + accountId1 + "到账户" + accountId2 + "转账" + amount);
});
} catch (Exception e) {
System.err.println("转账失败: " + e.getMessage());
}
}
}通过JDBI,事务管理变得更加简洁,并且可以集成重试策略,优雅地处理 SERIALIZABLE 隔离级别可能引发的并发异常。
要实现Java桌面应用的多用户并发访问单一数据库,请遵循以下最佳实践:
遵循这些指导原则,您将能够构建出健壮、高效且能够支持多用户并发访问的Java桌面应用程序。
以上就是如何实现多连接访问单一数据库:Java与Derby实践指南的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号