|
对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
JDBC 锁注册表
4.3 版引入了JdbcLockRegistry.
某些组件（例如，聚合器和重排序器）使用从LockRegistry实例，以确保一次只有一个线程作一个组。
这DefaultLockRegistry在单个组件中执行此功能。
现在可以在这些组件上配置外部锁注册表。
与共享的MessageGroupStore，您可以使用JdbcLockRegistry跨多个应用程序实例提供此功能，以便一次只有一个实例可以作该组。
当本地线程释放锁时，另一个本地线程通常可以立即获取锁。 如果使用其他注册表实例的线程释放锁，则获取锁最多可能需要 100 毫秒。
这JdbcLockRegistry基于LockRepository抽象，它有一个DefaultLockRepository实现。
数据库架构脚本位于org.springframework.integration.jdbc包，它为特定的 RDBMS 提供商划分。
例如，以下列表显示了锁表的 H2 DDL：
CREATE TABLE INT_LOCK (
LOCK_KEY CHAR(36),
REGION VARCHAR(100),
CLIENT_ID CHAR(36),
CREATED_DATE TIMESTAMP NOT NULL,
constraint INT_LOCK_PK primary key (LOCK_KEY, REGION)
);这INT_可根据目标数据库设计要求进行更改。
因此，您必须使用prefix属性DefaultLockRepositorybean 定义。
有时，一个应用程序已进入无法释放分布式锁并删除数据库中的特定记录的状态。
为此，此类死锁可以由其他应用程序在下一次锁定调用时过期。
这timeToLive（TTL） 选项DefaultLockRepository为此目的而提供。
您可能还需要指定CLIENT_ID对于为给定存储的锁DefaultLockRepository实例。
如果是这样，您可以指定id与DefaultLockRepository作为构造函数参数。
从 5.1.8 版开始，JdbcLockRegistry可以使用idleBetweenTries-一个Duration在锁定记录插入/更新执行之间休眠。
默认情况下，它是100毫秒级，并且在某些环境中，非领导者过于频繁地污染与数据源的连接。
从 5.4 版本开始，RenewableLockRegistry接口已被引入并添加到JdbcLockRegistry.
这renewLock()方法必须在锁定进程期间调用，以防锁定进程将比锁定的生存时间长。
因此，生存时间可以大大缩短，部署可以快速重新获得丢失的锁。
| 仅当锁由当前线程持有时，才能完成锁更新。 |
从 5.5.6 版本开始，JdbcLockRegistry支持自动清理缓存 JdbcLock inJdbcLockRegistry.locks通过JdbcLockRegistry.setCacheCapacity().
有关更多信息，请参阅其 JavaDocs。
从 6.0 版开始，DefaultLockRepository可以提供PlatformTransactionManager而不是依赖应用程序上下文中的主 Bean。
从 6.1 版开始，DefaultLockRepository可配置为自定义insert,update和renew查询。
为此，暴露了各自的 setter 和 getter。
例如，PostgreSQL 提示的插入查询可以如下配置：
lockRepository.setInsertQuery(lockRepository.getInsertQuery() + " ON CONFLICT DO NOTHING");