如何实现Spring Integration同步入站通道适配器轮询器以避免数据库锁

核心问题 #

现有10个JPA入站通道适配器轮询同一张表，每5秒触发一次，服务激活器处理时会更新该表，导致数据库锁冲突。需要实现当前批次处理完成后再取下一批次的串行执行逻辑，避免并发锁问题。

具体解决方案 #

1. 单适配器串行处理配置 #

将轮询器改为单线程执行，确保同一适配器的批次处理完成后再触发下一轮：

<int-jpa:inbound-channel-adapter 
    id="ProcessingG1" entity-manager="entityManager"
    expect-single-result="false"  
    native-query="SELECT * FROM table1 FETCH FIRST 30 ROWS ONLY"
    entity-class="org.entities.Table1"
    >
    <int:poller fixed-delay="0" task-executor="singleThreadExecutor">
        <int:transactional />
    </int:poller>
</int-jpa:inbound-channel-adapter>

<!-- 定义单线程任务执行器，保证串行处理 -->
<int:task-executor id="singleThreadExecutor" pool-size="1" />

<int:service-activator input-channel="ProcessingG1" ref="processingService" />

• fixed-delay="0"表示当前批次处理完成后立即启动下一轮轮询
• 单线程执行器确保同一适配器不会并发执行多个批次

2. 多适配器并发控制（保留10个适配器场景） #

如果必须保留10个适配器，需添加全局锁确保同一时间只有一个批次处理表数据：

<!-- 全局锁注册表 -->
<int:lock-registry id="tableLockRegistry" />

<int-jpa:inbound-channel-adapter 
    id="ProcessingG1" entity-manager="entityManager"
    expect-single-result="false"  
    native-query="SELECT * FROM table1 FETCH FIRST 30 ROWS ONLY FOR UPDATE SKIP LOCKED"
    entity-class="org.entities.Table1"
    >
    <int:poller fixed-rate="5000" task-executor="singleThreadExecutor">
        <int:transactional />
        <int:advice-chain>
            <!-- 全局锁拦截器，所有适配器共用同一锁键 -->
            <int:locker lock-registry="tableLockRegistry" lock-key="'table1-processing-lock'" />
        </int:advice-chain>
    </int:poller>
</int-jpa:inbound-channel-adapter>

• SQL中FOR UPDATE SKIP LOCKED可跳过已被锁定的行，避免锁等待超时
• 全局锁保证多个适配器不会同时处理同一张表的数据

3. 优化建议：合并适配器+调整批次大小 #

如果10个适配器是为了提升吞吐量，建议合并为一个适配器，增大批次大小（如FETCH FIRST 300 ROWS ONLY），配合单线程串行处理，既避免锁冲突，又保证处理效率。

关键说明 #

• 数据库锁冲突的核心原因是多线程同时更新同表行数据，串行执行可从根源解决该问题
• 单线程执行器是控制批次串行的核心配置，结合轮询器的fixed-delay可严格控制执行顺序

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