设计：Spring集成：集群环境中的Jdbc入站适配器

Question

我们在Oracle Weblogic 10.3.6服务器中有两个节点的集群环境，它是循环的。

我有一个服务，它从外部系统获取消息并将它们放入数据库（Oracle DB）。

我正在使用jdbc入站适配器转换这些消息并将其传递到通道。一条消息只处理一次。我计划在DB表中有一列（NODE\u NAME）。当从外部系统获取消息的第一个服务也使用NODE_名称（weblogic.NAME）更新列时。在jdbc入站适配器的SELECT查询中，如果我指定NODE_名称，那么消息将只处理一次。

i、 e.如果（节点1的）服务1将消息保存在DB中，则（节点1的）入站适配器1将消息传递到通道。

Example: 
<si-jdbc:inbound-channel-adapter id="jdbcInboundAdapter"
    channel="queueChannel" data-source="myDataSource"
    auto-startup="true"
    query="SELECT * FROM STAGE_TABLE WHERE STATUS='WAITING' and NODE_NAME = '${weblogic.Name}'"
    update="UPDATE STAGE_TABLE SET STATUS='IN_PROGRESS' WHERE ID IN (:Id)"
    max-rows-per-poll="100" row-mapper="rowMapper"
    update-per-row="true">

    <si:poller fixed-rate="5000">
        <si:advice-chain> 
            <ref bean="txAdvice"/> 
            <ref bean="inboundAdapterConfiguration"/> 
        </si:advice-chain>
    </si:poller>
</si-jdbc:inbound-channel-adapter>

这个设计好吗？

第二种方法：使用下面的选择SQL在jdbc-inbing-适配器，但我猜这将失败，因为我使用Oracle数据库。

SELECT * FROM TABLE WHERE STATUS='WAITING' FOR UPDATE SKIP LOCKED

如果有人能给我指出正确的方向，那就太好了。

Answer 1

实际上，更新跳过锁定正是Oracle的功能-html" target="_blank">https://asktom.oracle.com/pls/asktom/f?p=100:11:0::::P11_QUESTION_ID:2060739900346201280

如果您对as有疑问，以下是来自Spring Integration的代码：https://github.com/spring-projects/spring-integration/blob/master/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/store/channel/OracleChannelMessageStoreQueryProvider.java#L39