用于多个节点的spring集成jdbc适配器

Question

我使用 jdbc inbound-channel-adapter 和下面的典型配置从 MYSQL DB 中检索记录。问题是如何让 jdbc inbound-channel-adapter 在多节点环境中工作？不同的节点将有机会获得一个相同的记录来处理。我知道这可能是一个老问题，但到目前为止我找不到解决方案。

<int-jdbc:inbound-channel-adapter query="select * from messages where state='NEW'"
    channel="jdbcChannel" data-source="datasource" update="update messages set state='PROCESSING' where id in (:id)"
    row-mapper="messageRowMapper" max-rows-per-poll="1">
</int-jdbc:inbound-channel-adapter>

Answer 1

是的，您应该为<poller> 提供交易，正如 Gary 指出的那样，但此外，您应该保证一个交易会阻塞另一个交易，直到它完成。为此，您应该为您的SELECT 提供FOR UPDATE 或LOCK IN SHARE MODE 提示。

更多信息在MySQL Docs 或这个答案中：MySQL 'select for update' behaviour。

Answer 2

你需要使用transactions;另见the appendix about transactions。