Spring应用内存数据库多线程读写性能问题及Hibernate优化咨询

场景描述 #

我正在开发一个基于Spring的内存数据库应用，通过MQ接收大量订单，处理流程为：先检查订单是否存在于数据库中，若不存在则处理业务逻辑后写入数据库。当前架构采用单线程处理读操作（订单存在性检查）与业务逻辑，仅将数据库写入操作交给另一个线程。当订单流入速率提升后，部分读操作耗时剧增，需排查原因并优化。

当前线程分工：

• 线程1：负责读操作（订单存在性检查）+ 业务逻辑
• 线程2：负责数据库写入操作

已为Order实体的Id和isDeleted字段创建索引，Order是Hibernate实体。计划增加读线程提升处理速度，订单写入延迟可接受。

附读操作代码：

@Transactional(propagation = Propagation.REQUIRED, readOnly = true)
public Order findByOrderId(String Id, boolean isDeleted) {
    Session session = Objects.requireNonNull(getSessionFactory()).openSession();
    final List<Order> resultList = session
        .createQuery("from Order o where o.Id = :Id and isDeleted = :isDeleted", Order.class)
        .setParameter("Id", Id)
        .setParameter("isDeleted", isDeleted)
        .list();
    session.close();

    if (resultList.isEmpty()) {
        return null;
    }
    return (resultList.get(0));
}

一、读操作耗时过长的核心原因 #

1. 读写锁冲突：内存数据库通常依赖MVCC或行级锁实现并发控制，线程2的写操作会对目标订单行加写锁，若线程1的读操作是当前读（而非快照读），会被写锁阻塞直至写操作释放锁。订单流入量增大后，写操作排队，读操作的阻塞等待时间会被放大。
2. Session管理混乱：当前代码在@Transactional注解内手动openSession()并close()，但Spring事务管理会自动绑定Session到当前线程，手动创建的Session会绕过事务上下文，既无法利用Session缓存，又增加了Session创建/销毁的开销，还可能导致锁机制异常交互。
3. 单读线程瓶颈：所有读操作和业务逻辑都压在单个线程上，订单量激增时，单线程的处理能力直接成为瓶颈，读请求排队等待处理，表现为读耗时增加。

二、Session使用规范 #

必须确保每个线程使用独立的Session：

• Hibernate的Session是非线程安全的，绝对不能多个线程共享同一个Session，否则会引发缓存混乱、事务状态异常等线程安全问题。
• 修正当前代码的Session管理：去掉手动openSession()和close()，直接使用Spring注入的EntityManager（更符合Spring JPA规范），由Spring事务上下文自动管理Session生命周期。修正后的代码示例：

@Transactional(propagation = Propagation.REQUIRED, readOnly = true, isolation = Isolation.READ_COMMITTED)
public Order findByOrderId(String id, boolean isDeleted) {
    return entityManager.createQuery(
            "from Order o where o.id = :id and o.isDeleted = :isDeleted", Order.class)
        .setParameter("id", id)
        .setParameter("isDeleted", isDeleted)
        .getResultStream()
        .findFirst()
        .orElse(null);
}

三、读写并发的可行性与优化 #

读写操作可以并发执行，但需要调整隔离级别与读取模式：

1. 调整事务隔离级别：将读操作的事务隔离级别设置为READ_COMMITTED（默认）或READ_UNCOMMITTED（业务允许脏读时），让读操作使用快照读，避免被写锁阻塞。
2. 启用快照读支持：确保内存数据库（如H2、HSQLDB）开启MVCC，或用org.hibernate.annotations.NaturalId标记订单ID，让读操作能快速定位且不被写锁阻塞。
3. 增加读线程池：既然订单写入延迟可接受，将读操作和业务逻辑放到线程池处理，线程池大小可按CPU核心数*2配置，避免单线程瓶颈。

四、Hibernate/JDBC属性优化调整 #

1. 连接池配置：使用HikariCP（Spring Boot默认），调整关键参数：
   • spring.datasource.hikari.maximum-pool-size：设置为读线程池大小+写线程数，确保每个线程能获取数据库连接，避免连接等待。
   • spring.datasource.hikari.connection-timeout：缩短连接超时时间，减少线程因等待连接的阻塞时长。
2. 缓存优化：
   • 保留一级缓存（默认开启）：利用线程私有Session的缓存减少重复查询。
   • 启用二级缓存：对频繁查询的订单数据配置Ehcache等二级缓存，同时配置写操作后自动失效对应缓存条目。
   • 开启查询缓存：设置hibernate.cache.use_query_cache=true，相同参数的重复查询直接返回缓存结果。
3. 查询优化：
   • 用getResultStream().findFirst().orElse(null)替代list()后取第一个元素，减少不必要的集合创建开销。
   • 执行EXPLAIN查看查询计划，确认Id和isDeleted的联合索引被命中。
4. Hibernate性能参数：
   • 设置hibernate.read_only=true：在只读事务中开启，跳过脏检查等操作，提升读性能。
   • 设置hibernate.jdbc.batch_size：批量写入时配置该参数，提升写操作效率。

内容的提问来源于stack exchange，提问作者CS1999