zl程序教程

您现在的位置是:首页 >  数据库

当前栏目

多线程环境下SQLite数据库并发死锁问题(database is locked)

2023-09-11 14:14:13 时间

(203条消息) 多线程环境下SQLite数据库并发死锁问题(database is locked)_sqlite死锁_汣栀的博客-CSDN博客

 

Java使用sqllite报错: SQLITE_BUSY The database file is locked (database is locked)解决办法

问题的根本原因
sqllite不支持多线程写入数据,并且写数据时,其他线程读取数据也不支持,只支持多个线程读取数据。

解决办法
aop拦截数据库操作的接口,加上同步锁。我使用的是读写锁,读写锁只有读线程并不会阻塞,当有一个线程写的时候才会阻塞读线程,相比效率更高。因此对数据库写操作save,del等方法加上写锁,对读操作加上读锁,实际操作是aop拦截repo下的JPA操作数据库的接口添加读写锁。

@Aspect
@Component
@Slf4j
public class SqlLiteSyncAspect {

ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

@Pointcut("execution(public * com.xxx.repo.*.*(..))")
public void pointCut() {

}

@Around("pointCut()")
public Object around(ProceedingJoinPoint pjp) throws Throwable {
String name = pjp.getSignature().getName();

log.debug("方法环绕proceed,class - {}, 方法是 - {}", pjp.getTarget().getClass().getName(), name);
if (name.contains("save") || name.contains("del") || name.contains("update")) {

readWriteLock.writeLock().lock();
try {
Object proceed = pjp.proceed();
return proceed;
} catch (Exception e) {
log.error("写锁保护代码发生异常", e);
throw e;
} finally {
readWriteLock.writeLock().unlock();
}

} else {
try {
readWriteLock.readLock().lock();
Object proceed = pjp.proceed();
return proceed;
} catch (Exception e) {
log.error("读锁保护代码发生异常", e);
throw e;
} finally {
readWriteLock.readLock().unlock();
}

}

}
}
文章知识点与
————————————————
版权声明:本文为CSDN博主「如此的肤浅」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/longddechuanren/article/details/124276337