锁组件
编辑本页锁组件
锁组件创建和管理锁,一种提供对共享资源的独占访问的机制。
如果您正在使用Symfony框架,请阅读ob娱乐下载ob娱乐下载Symfony框架锁文档欧宝官网下载app.
安装
1
$作曲家需要symfony/lockob娱乐下载
请注意
如果在Symfony应用程序外部安装此组件,则必须要求ob娱乐下载供应商/ autoload.php
文件,以启用Composer提供的类自动加载机制。读这篇文章欲知详情。
使用
锁用于保证对某些共享资源的独占访问。例如,ob娱乐下载在Symfony应用程序中,您可以使用锁来确保一个命令不会在同一时间(在相同或不同的服务器上)执行多次。
类创建锁LockFactory类,这又需要另一个类来管理锁的存储:
1 2 3 4 5
使用ob娱乐下载\组件\锁\LockFactory;使用ob娱乐下载\组件\锁\商店\SemaphoreStore;$商店=新SemaphoreStore ();$工厂=新LockFactory ($商店);
方法创建锁createLock ()方法。它的第一个参数是表示锁定资源的任意字符串。然后,调用获得()方法将尝试获取锁:
1 2 3 4 5 6 7 8 9
/ /……$锁=$工厂->createLock (“pdf-creation”);如果($锁->获得()){// pdf-creation资源被锁定。//您可以在这里安全地计算和生成发票。$锁->release ();}
如果无法获取锁,则该方法返回假
.的获得()
方法可以安全地重复调用,即使已经获得了锁。
请注意
与其他实现不同的是,即使是为同一资源创建的锁实例,Lock Component也能区分它们。这意味着对于给定的作用域和资源,可以多次获取一个锁实例。如果一个锁必须被多个服务使用,那么它们应该共享同一个锁锁
实例返回的LockFactory: createLock
方法。
提示
如果您没有显式地释放锁,它将在实例销毁时自动释放。在某些情况下,跨多个请求锁定一个资源可能很有用。属性的第三个参数,可禁用自动释放行为createLock ()
方法假
.
序列化锁
的关键控件的状态锁并且可以序列化。这允许用户通过获取锁在一个进程中开始一个长任务,并使用相同的锁在另一个进程中继续该任务:
12 3 4 5 6 7 8 9 10 11 12 13
使用ob娱乐下载\组件\锁\关键;使用ob娱乐下载\组件\锁\锁;$关键=新键(“文章”。.$文章->getId ());$锁=新锁($关键,$这->商店,300,/ / ttl假/ /生成);$锁->获得(真正的);$这->公共汽车->调度(新RefreshTaxonomy ($文章,$关键));
请注意
别忘了设置生成
参数假
在锁
构造函数,以避免在调用析构函数时释放锁。
并不是所有的存储都与序列化和跨进程锁兼容:例如,内核将自动释放由线程获取的信号量SemaphoreStore商店。如果使用不兼容的存储(请参见锁店对于受支持的存储),当应用程序试图序列化该键时将抛出异常。
阻塞锁
缺省情况下,当无法获取锁时,将使用收购
方法返回假
立即。要等待(无限期地)直到可以创建锁,请通过真正的
作为论证获得()
方法。这叫做阻塞锁因为在获得锁之前,应用程序的执行会停止:
1 2 3 4 5 6 7 8
使用ob娱乐下载\组件\锁\LockFactory;使用ob娱乐下载\组件\锁\商店\RedisStore;$商店=新RedisStore (新\ Predis \客户端(“tcp: / / localhost: 6379”));$工厂=新LockFactory ($商店);$锁=$工厂->createLock (“pdf-creation”);$锁->获得(真正的);
当存储区不支持阻塞锁时,可以实现BlockingStoreInterface界面(见锁店对于受支持的商店)锁
类将以非阻塞的方式重试获取锁,直到获得锁为止。
到期的锁
远程创建的锁很难管理,因为没有远程的方法商店
以了解储物柜进程是否仍然存在。由于bug,致命错误或分割错误,不能保证release ()
方法,这将导致资源被无限锁定。
在这种情况下,最好的解决办法就是创造到期的锁,在经过一段时间后自动释放(对于活着的时间).属性的第二个参数,单位为秒createLock ()
方法。方法也可以提前释放这些锁release ()
方法。
处理过期锁时最棘手的部分是选择正确的TTL。如果它太短,其他进程可能会在完成任务之前获得锁;如果时间过长,进程在调用release ()
方法,资源将保持锁定直到超时:
12 3 4 5 6 7 8 9 10 11 12
/ /……//创建一个持续30秒的过期锁(默认为300.0)$锁=$工厂->createLock (“pdf-creation”ttl:30.);如果(!$锁->获得()){返回;}试一试{//在30秒内完成一个任务}最后{$锁->release ();}
提示
为了避免锁处于锁定状态,建议将作业封装在try/catch/finally块中,以便始终尝试释放即将到期的锁。
对于长时间运行的任务,最好从一个不太长的TTL开始,然后使用refresh ()方法将TTL重置为原始值:
12 3 4 5 6 7 8 9 10 11 12 13 14 15 16
/ /……$锁=$工厂->createLock (“pdf-creation”ttl:30.);如果(!$锁->获得()){返回;}试一试{而(!$完成了) {//完成工作的一小部分。//更新锁30秒。$锁->refresh ();}}最后{$锁->release ();}
提示
类的参数传递自定义TTL,这是长时间运行任务的另一个有用技术refresh ()
方法修改默认锁TTL:
1 2 3 4 5 6 7
$锁=$工厂->createLock (“pdf-creation”ttl:30.);/ /……//刷新锁30秒$锁->refresh ();/ /……//刷新锁600秒(下一次refresh()调用将再次为30秒)$锁->刷新(600);
该组件还提供了两个与过期锁相关的有用方法:getRemainingLifetime ()
(返回零
或者一个浮动
作为秒)和isExpired ()
(返回一个布尔值)。
自动释放锁
当锁的Lock对象被销毁时,锁会自动释放。这是在进程间共享锁时非常重要的实现细节。在下面的例子中,pcntl_fork ()
创建了两个进程,当一个进程结束时,锁就会自动释放:
12 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
/ /……$锁=$工厂->createLock (“pdf-creation”);如果(!$锁->获得()){返回;}$pid= pcntl_fork ();如果(1===$pid) {//无法分叉退出(1);}elseif($pid) {//父进程睡眠(30.);}其他的{//子进程回声“现在解锁了。”;退出(0);}/ /……
若要禁用此行为,请设置生成
的观点LockFactory: createLock ()
来假
.这将使锁获得3600秒或直到锁::释放()
被称为:
1 2 3 4 5
$锁=$工厂->createLock (“pdf-creation”,3600,/ / ttl假/ /生成);
共享锁
共享的或readers-writer锁是一个同步原语,允许对只读操作进行并发访问,而写操作需要独占访问。这意味着多个线程可以并行地读取数据,但写入或修改数据需要一个排他锁。例如,它们用于不能自动更新且在更新完成之前无效的数据结构。
使用acquireRead ()方法获取只读锁,并且获得()方法获取写锁:
1 2 3 4
$锁=$工厂->createLock (“用户- - - - - -”.$用户->id);如果(!$锁->acquireRead ()) {返回;}
类似于获得()
方法,通过真正的
作为论证acquireRead ()
使用实例以阻塞方式获取锁。
1 2
$锁=$工厂->createLock (“用户- - - - - -”.$用户->id);$锁->acquireRead (真正的);
请注意
的优先政策Symob娱乐下载fony的共享锁取决于底层存储(例如,Redis存储优先考虑读取器和写入器)。
方法获取只读锁时acquireRead ()
方法,是可能的促进方法,并将其更改为写锁获得()
方法:
1 2 3 4 5 6 7 8 9
$锁=$工厂->createLock (“用户- - - - - -”.$用户标识);$锁->acquireRead (真正的);如果(!$这->shouldUpdate ($用户标识)) {返回;}$锁->获得(真正的);//将锁提升为写锁$这->更新($用户标识);
同样的,也有可能降级方法将其更改为只读锁acquireRead ()
方法。
方法时,所提供的存储区没有实现SharedLockStoreInterface界面(见锁店对于受支持的商店)锁
类将回退到写锁获得()
方法。
锁的主人
对象第一次获得的锁为[1]_锁
获取它的实例。如果需要检查电流是否锁
实例仍然是锁的所有者,您可以使用isAcquired ()
方法:
1 2 3
如果($锁->isAcquired ()) {//我们仍然拥有这把锁}
因为一些锁存储有到期的锁,实例可能会失去它自动获得的锁:
12 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
//如果我们自己无法获取,就意味着其他进程已经在处理它了如果(!$锁->获得()){返回;}$这->beginTransaction ();//执行一个很长的进程,可能超过锁的生存时间如果($锁->isAcquired ()) {//一切正常,在此期间没有其他实例获得锁,我们是安全的$这->commit ();}其他的{/ /懒汉!我们的锁显然已经超过了TTL,另一个进程已经开始//在此期间,所以它对我们来说是不安全的。$这->rollback ();扔新\异常(“过程失败”);}
谨慎
一个常见的缺陷可能是使用isAcquired ()
方法检查某个锁是否已被任何进程获取。正如你在这个例子中看到的,你必须使用获得()
对于这个。的isAcquired ()
方法用于检查锁是否已由当前进程只有。
-
..[1]从技术上讲,锁的真正所有者是那些共享相同实例的人
关键
, -
不
锁
.但从用户的角度来看,关键
是内部的,您可能只与锁
实例,这样更容易想到锁
实例作为锁的所有者。
可用的商店
在其中创建和管理锁商店
,它们是实现的类PersistingStoreInterface可选地,BlockingStoreInterface.
该组件包括以下内置存储类型:
商店 | 范围 | 阻塞 | 即将到期的 | 分享 |
---|---|---|---|---|
FlockStore | 当地的 | 是的 | 没有 | 是的 |
MemcachedStore | 远程 | 没有 | 是的 | 没有 |
MongoDbStore | 远程 | 没有 | 是的 | 没有 |
PdoStore | 远程 | 没有 | 是的 | 没有 |
DoctrineDbalStore | 远程 | 没有 | 是的 | 没有 |
PostgreSqlStore | 远程 | 是的 | 没有 | 是的 |
DoctrineDbalPostgreSqlStore | 远程 | 是的 | 没有 | 是的 |
RedisStore | 远程 | 没有 | 是的 | 是的 |
SemaphoreStore | 当地的 | 是的 | 没有 | 没有 |
ZookeeperStore | 远程 | 没有 | 没有 | 没有 |
提示
一个特殊的InMemoryStore
可用于在进程期间将锁保存在内存中,并可用于测试。
FlockStore
FlockStore使用本地计算机上的文件系统创建锁。它不支持过期,但是当锁对象超出作用域时,锁会自动释放,并由垃圾收集器释放(例如当PHP进程结束时):
1 2 3 4 5
使用ob娱乐下载\组件\锁\商店\FlockStore;//参数是创建锁的目录的路径//如果没有,则在内部使用sys_get_temp_dir()。$商店=新FlockStore (/ var /商店的);
谨慎
注意,某些文件系统(例如某些类型的NFS)不支持锁定。在这些情况下,最好使用本地磁盘驱动器或远程存储上的目录。
MemcachedStore
MemcachedStore将锁保存在Memcached服务器上,它需要一个Memcached连接来实现\ Memcached
类。这个存储不支持阻塞,并期望TTL来避免锁被卡住:
1 2 3 4 5 6
使用ob娱乐下载\组件\锁\商店\MemcachedStore;$memcached=新\ Memcached ();$memcached->addServer (“localhost”,11211);$商店=新MemcachedStore ($memcached);
请注意
Memcached不支持TTL小于1秒。
MongoDbStore
MongoDbStore在MongoDB服务器上保存锁> = 2.2
,它需要一个\ MongoDB \集合
或\ MongoDB \客户
从mongodb / mongodb或者一个MongoDB连接字符串.该存储不支持阻塞,并期望TTL来避免锁被卡住:
1 2 3 4 5 6 7 8 9 10 11
使用ob娱乐下载\组件\锁\商店\MongoDbStore;$蒙戈=mongodb: / / localhost /数据库?收集=锁';$选项= (“gcProbablity”= >0.001,“数据库”= >“myapp”,“收集”= >“锁”,“uriOptions”= > [],“driverOptions”=> [],];$商店=新MongoDbStore ($蒙戈,$选项);
的MongoDbStore
执行以下操作选择美元
(取决于第一个参数类型):
选项 | 描述 |
---|---|
gcProbablity | 是否应该创建一个TTL索引,表示为从0.0到1.0的概率(默认为0.001 ) |
数据库 | 数据库的名称 |
集合 | 集合的名称 |
uriOptions | 的URI选项数组MongoDBClient: __construct |
driverOptions | 的驱动程序选项数组MongoDBClient: __construct |
当第一个参数为a时:
MongoDB \集合
:
美元的选项(“数据库”)
被忽略美元的选项(“收集”)
被忽略
MongoDB \客户
:
美元的选项(“数据库”)
是强制性的美元的选项(“收集”)
是强制性的
MongoDB连接字符串:
美元的选项(“数据库”)
用于其他情况/路径
从DSN,至少一个是强制性的美元的选项(“收集”)
用于其他情况收集? =
从DSN,至少一个是强制性的
请注意
的集合
查询字符串参数不是MongoDB连接字符串定义。它用于构造MongoDbStore
使用一个数据源名称(DSN)没有选择美元
.
PdoStore
PdoStore将锁保存在SQL数据库中。它与DoctrineDbalStore相同,但需要一个PDO连接或数据源名称(DSN).这个存储不支持阻塞,并期望TTL来避免锁被卡住:
1 2 3 4 5
使用ob娱乐下载\组件\锁\商店\PdoStore;//通过PDO进行延迟连接的PDO或DSN$databaseConnectionOrDSN=“mysql:主机= 127.0.0.1;dbname =应用';$商店=新PdoStore ($databaseConnectionOrDSN, (“db_username”= >“myuser”,“db_password”= >“我的密码”]);
请注意
此商店不支持TTL低于1秒。
DoctrineDbalStore
DoctrineDbalStore将锁保存在SQL数据库中。它与PdoStore相同,但需要一个原则DBAL连接,或原则DBAL URL.这个存储不支持阻塞,并期望TTL来避免锁被卡住:
1 2 3 4 5
使用ob娱乐下载\组件\锁\商店\DoctrineDbalStore;// a Doctrine DBAL连接或DSN$connectionOrURL=“mysql: / / myuser: mypassword@127.0.0.1 /应用程序;$商店=新DoctrineDbalStore ($connectionOrURL);
请注意
此商店不支持TTL低于1秒。
类的第一次调用时自动创建存储值的表save ()方法。还可以通过调用将该表添加到模式中configureSchema ()方法显式创建此表不知道()方法。
PostgreSqlStore
PostgreSqlStore和DoctrineDbalPostgreSqlStore使用咨询锁由PostgreSQL提供。它与DoctrineDbalPostgreSqlStore相同,但需要PDO连接或数据源名称(DSN).它支持本地阻塞,以及共享锁:
1 2 3 4 5
使用ob娱乐下载\组件\锁\商店\PostgreSqlStore;//通过PDO进行延迟连接的PDO实例或DSN$databaseConnectionOrDSN=“pgsql:主机= localhost;端口= 5634;dbname =应用';$商店=新PostgreSqlStore ($databaseConnectionOrDSN, (“db_username”= >“myuser”,“db_password”= >“我的密码”]);
相对于PdoStore
,PostgreSqlStore
不需要表来存储锁,而且不会过期。
DoctrineDbalPostgreSqlStore
DoctrineDbalPostgreSqlStore使用咨询锁由PostgreSQL提供。它与PostgreSqlStore相同,但需要一个原则DBAL连接或者一个原则DBAL URL.它支持本地阻塞,以及共享锁:
1 2 3 4 5
使用ob娱乐下载\组件\锁\商店\DoctrineDbalPostgreSqlStore;// a Doctrine Connection或DSN$databaseConnectionOrDSN=“postgresql +咨询:/ / myuser: mypassword@127.0.0.1:5634 /锁”;$商店=新DoctrineDbalPostgreSqlStore ($databaseConnectionOrDSN);
相对于DoctrineDbalStore
,DoctrineDbalPostgreSqlStore
不需要表来存储锁,并且不会过期。
RedisStore
RedisStore将锁保存在Redis服务器上,它需要一个Redis连接来实现\复述,
,\ RedisArray
,\ RedisCluster
或\ Predis
类。这个存储不支持阻塞,并期望TTL来避免锁被卡住:
1 2 3 4 5 6
使用ob娱乐下载\组件\锁\商店\RedisStore;$复述,=新\复述();$复述,->连接(“localhost”);$商店=新RedisStore ($复述,);
SemaphoreStore
SemaphoreStore使用PHP信号量函数要创建锁:
1 2 3
使用ob娱乐下载\组件\锁\商店\SemaphoreStore;$商店=新SemaphoreStore ();
CombinedStore
组合商店是为高可用性应用程序设计的,因为它同步管理多个商店(例如,几个Redis服务器)。当获得锁时,它将调用转发给所有托管存储,并收集它们的响应。如果绝大多数商店都获得了该锁,则认为该锁已获得:
12 3 4 5 6 7 8 9 10 11 12 13
使用ob娱乐下载\组件\锁\商店\CombinedStore;使用ob娱乐下载\组件\锁\商店\RedisStore;使用ob娱乐下载\组件\锁\策略\ConsensusStrategy;$商店= [];foreach([“server1”,server2的,“server3”]作为$服务器) {$复述,=新\复述();$复述,->连接($服务器);$商店[] =新RedisStore ($复述,);}$商店=新CombinedStore ($商店,新ConsensusStrategy ());
而不是简单多数策略(ConsensusStrategy
)一个UnanimousStrategy
可用于要求在所有商店中获取锁:
1 2 3 4
使用ob娱乐下载\组件\锁\商店\CombinedStore;使用ob娱乐下载\组件\锁\策略\UnanimousStrategy;$商店=新CombinedStore ($商店,新UnanimousStrategy ());
谨慎
为了在使用时获得高可用性ConsensusStrategy
时,最小集群大小必须为3台服务器。这允许集群在单个服务器出现故障时继续工作(因为此策略要求为超过一半的服务器获取锁)。
ZookeeperStore
ZookeeperStore保存锁动物园管理员服务器。它需要一个ZooKeeper连接来实现\动物园管理员
类。这个store不支持阻塞和过期,但是当PHP进程终止时,锁会自动释放:
1 2 3 4 5 6 7
使用ob娱乐下载\组件\锁\商店\ZookeeperStore;$动物园管理员=新\管理员(“localhost: 2181”);//使用以下命令定义高可用性集群:// $zookeeper = new \ zookeeper ('localhost1:2181,localhost2:2181,localhost3:2181');$商店=新ZookeeperStore ($动物园管理员);
请注意
Zookeeper不需要TTL,因为用于锁定的节点是短暂的,当PHP进程终止时就会死亡。
可靠性
只要以以下方式使用该组件,该组件就保证同一资源不会被锁定两次。
远程存储
远程存储(MemcachedStore,MongoDbStore,PdoStore,PostgreSqlStore,RedisStore而且ZookeeperStore)使用唯一令牌来识别锁的真正所有者。标记存储在关键对象在内部使用锁
.
每个并发进程必须存储锁
在同一个服务器上。否则两台不同的机器可能允许两个不同的进程获得相同的数据锁
.
谨慎
为了保证同一台服务器始终是安全的,不要在LoadBalancer、集群或轮询DNS后面使用Memcached。即使主服务器关闭,也不能将调用转发到备份或故障转移服务器。
到期的商店
即将到期的储存区(MemcachedStore,MongoDbStore,PdoStore而且RedisStore)保证只在规定的时间内获得锁。如果任务需要更长的时间才能完成,那么锁可以由存储释放,并由其他人获取。
的锁
提供几种检查其运行状况的方法。的isExpired ()
方法检查其生命周期是否结束getRemainingLifetime ()
方法返回以秒为单位的时间。
使用上述方法,一个健壮的代码将是:
12 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/ /……$锁=$工厂->createLock (“pdf-creation”,30.);如果(!$锁->获得()){返回;}而(!$完成了) {如果($锁->getRemainingLifetime () < =5) {如果($锁->isExpired ()) {//锁丢失,执行回滚或发送通知扔新\ RuntimeException (“锁在整个过程中丢失”);}$锁->refresh ();}//执行耗时小于5分钟的任务}
谨慎
明智地选择你的一生锁
并检查其剩余的生存时间是否足够执行任务。
谨慎
存储锁
通常需要几毫秒,但网络条件可能会大大增加这个时间(最多几秒)。在选择正确的TTL时要考虑到这一点。
按照设计,锁存储在具有定义的生命周期的服务器上。如果机器的日期或时间发生了变化,锁可能会比预期更快地释放。
谨慎
为了保证日期不会改变,NTP服务应该被禁用,并且在服务停止时应该更新日期。
FlockStore
通过使用文件系统,这商店
只要并发进程使用相同的物理目录存储锁,它就可靠。
进程必须运行在同一台机器、虚拟机或容器上。更新Kubernetes或Swarm服务时要小心,因为在短时间内,可能会有两个容器并行运行。
目录的绝对路径必须保持不变。小心可能随时改变的符号链接:Capistrano和蓝/绿部署经常使用这个技巧。当到该目录的路径在两次部署之间发生变化时要小心。
某些文件系统(例如某些类型的NFS)不支持锁定。
谨慎
所有并发进程必须使用相同的物理文件系统,运行在同一台机器上,并使用到锁目录的相同绝对路径。
使用一个FlockStore
在HTTP上下文中与多个前端服务器不兼容,除非确保同一资源始终锁定在同一台机器上,或者使用配置良好的共享文件系统。
文件系统中的文件可以在维护操作时删除。例如,清理/ tmp
目录或重新启动计算机后使用的目录tmpfs
.如果在进程结束时释放锁,这不是问题,但如果发生锁
在请求之间重用。
谨慎
如果需要在多个请求中重用volatile文件系统上的锁,则不要将它们存储在volatile文件系统上。
MemcachedStore
Memcached的工作方式是将项存储在内存中。这意味着通过使用MemcachedStore锁不是持久的,并且可能在任何时候错误地消失。
如果Memcached服务或承载它的机器重新启动,每个锁都将丢失,而不会通知正在运行的进程。
谨慎
为了避免重启后被其他人获得锁,建议延迟服务启动,等待时间至少等于最长锁TTL。
默认情况下,当服务需要空间来添加新项时,Memcached使用LRU机制删除旧项。
谨慎
必须控制存储在Memcached中的项的数量。如果不可能,应该禁用LRU,并将Lock存储在专用的Memcached服务中,远离Cache。
当Memcached服务被共享并用于多个用途时,锁可能会被错误地删除。例如PSR-6的一些实现clear ()
方法使用Memcached的冲洗()
清除和删除所有内容的方法。
谨慎
该方法冲洗()
不能被调用,或者锁应该存储在专用的Memcached服务中,远离Cache。
MongoDbStore
谨慎
锁定资源名在_id
锁集合的字段。注意,在MongoDB中索引字段的值可能是长度不超过1024字节包括结构开销。
必须使用TTL索引来自动清除过期的锁。这样的索引可以手动创建:
1 2 3 4
db.lock。方法createIndex ({“expires_at”:1}, {“expireAfterSeconds”:0})
或者,方法MongoDbStore::createTtlIndex(int $expireAfterSeconds = 0)
可以在数据库设置期间调用一次来创建TTL索引。阅读更多通过设置TTL使集合中的数据过期在MongoDB。
提示
MongoDbStore
将尝试自动创建一个TTL索引。建议设置构造函数optiongcProbablity
来0.0
如果已手动处理TTL索引创建,则禁用此行为。
谨慎
此存储依赖于所有PHP应用程序和数据库节点具有同步时钟,以便在正确的时间发生锁过期。确保锁不会过早过期;锁的TTL应该被设置为有足够的额外时间expireAfterSeconds
考虑节点之间的时钟漂移。
writeConcern
而且readConcern
没有被MongoDbStore指定,这意味着集合的设置将生效。readPreference
是主要的
对于所有查询。阅读更多副本设置读写语义在MongoDB。
PdoStore
PdoStore依赖酸SQL引擎属性。
谨慎
在配置了多个主的集群中,确保同步地将写操作传播到每个节点,或者始终使用相同的节点。
谨慎
一些SQL引擎(如MySQL)允许禁用唯一约束检查。确保不是这种情况设置unique_checks = 1;
.
为了清除旧锁,该存储使用当前datetime来定义过期日期引用。该机制依赖于所有服务器节点具有同步时钟。
谨慎
确保锁不会过早过期;ttl应该设置足够的额外时间,以考虑节点之间的任何时钟漂移。
PostgreSqlStore
PdoStore依赖咨询锁PostgreSQL数据库属性。这意味着通过使用PostgreSqlStore锁将在会话结束时自动释放,以防客户端因任何原因无法解锁。
如果PostgreSQL服务或承载它的机器重新启动,每个锁都会丢失,而不会通知正在运行的进程。
如果TCP连接丢失,PostgreSQL可能在不通知应用程序的情况下释放锁。
RedisStore
Redis的工作方式是将项目存储在内存中。这意味着通过使用RedisStore锁不是持久的,并且可能在任何时候错误地消失。
如果Redis服务或承载它的机器重新启动,每个锁都将丢失,而不通知正在运行的进程。
谨慎
为了避免重启后被其他人获得锁,建议延迟服务启动,等待时间至少等于最长锁TTL。
提示
Redis可以配置为将项目持久化在磁盘上,但是这个选项会减慢对服务的写操作。这可能与服务器的其他用途相冲突。
当Redis服务被共享并用于多个用途时,锁可能会被错误地删除。
谨慎
命令FLUSHDB
必须不被调用,或者锁应该存储在一个专用的Redis服务远离缓存。
CombinedStore
合并存储允许跨多个后端存储锁。认为锁定机制会更可靠是一个常见的错误。这是错误的。的CombinedStore
最好的情况下,将与所有托管存储中最不可靠的存储一样可靠。一旦某个托管存储返回错误信息,则CombinedStore
不可靠。
谨慎
所有并发进程必须使用相同的配置,具有相同数量的托管存储和相同的端点。
提示
与其使用Redis或Memcached服务器集群,不如使用CombinedStore
每个托管存储都有一个服务器。
SemaphoreStore
信号量由内核级处理。为了保证可靠性,进程必须运行在同一台机器、虚拟机或容器上。更新Kubernetes或Swarm服务时要小心,因为在短时间内,可能会有两个并行运行的容器。
谨慎
所有并发进程必须使用同一台机器。在新机器上启动并发进程之前,请检查旧机器上的其他进程是否已停止。
谨慎
使用非系统用户和选项在systemd上运行时RemoveIPC = yes
(默认值),当用户注销时,systemd将删除锁。检查进程是否使用系统用户(UID <= SYS_UID_MAX)运行SYS_UID_MAX
中定义的/etc/login.defs
,或设置该选项RemoveIPC =了
在/etc/systemd/logind.conf
.
ZookeeperStore
zookeeper的工作方式是将锁作为服务器上的临时节点来维护。这意味着通过使用ZookeeperStore锁将在会话结束时自动释放,以防客户端因任何原因无法解锁。
如果ZooKeeper服务或承载它的机器重新启动,每个锁都会丢失,而不会通知正在运行的进程。
提示
为了使用ZooKeeper的高可用性特性,你可以设置多个服务器的集群,这样在其中一个服务器宕机的情况下,大多数服务器仍然是正常的,并为请求服务。集群中的所有可用服务器都将看到相同的状态。
请注意
由于此存储不支持多级节点锁,因此清理中间节点成为一种开销,因此所有锁都在根级别维护。
整体
更改存储的配置应该非常谨慎。例如,在部署新版本期间。当具有旧配置的旧进程仍在运行时,不能启动具有新配置的进程。