锁组件

安装
使用
序列化锁
阻塞锁
到期的锁
- 自动释放锁
共享锁
锁的所有者
可用的商店
可靠性

锁组件

锁组件创建并管理锁,一个机制来提供独家访问共享资源。

如果你使用Symfony框架,阅读欧宝娱乐app下载地址欧宝娱乐app下载地址Symfony框架锁文件欧宝体育电话。

安装

               1
               美元作曲家需要symfony /锁欧宝娱乐app下载地址
              

请注意

如果你安装这个组件之外的Symfony应用程序,你必须要求欧宝娱乐app下载地址供应商/ autoload.php文件在你的代码,使作曲家提供的类加载机制。读这篇文章为更多的细节。

使用

锁是用来保证独占访问共享资源。例如在欧宝娱乐app下载地址Symfony应用程序中,您可以使用锁来确保一个命令不执行不止一次在同一时间(在相同或不同的服务器上)。

锁是使用创建的LockFactory类,这又需要另一个类来管理存储的锁:

               1 2 3 4 5
               使用欧宝娱乐app下载地址\组件\锁\LockFactory;使用欧宝娱乐app下载地址\组件\锁\商店\SemaphoreStore;美元商店=新SemaphoreStore ();美元工厂=新LockFactory (美元商店);
              

锁是通过调用创建的createLock ()方法。它的第一个参数是一个任意字符串,代表了锁定的资源。然后,调用获得()方法将尝试获得锁:

               1 2 3 4 5 6 7 8 9
               / /……美元锁=美元工厂- >createLock (“pdf-creation”);如果(美元锁- >获得()){/ /资源“pdf-creation”是锁着的。/ /这里可以安全地计算并生成发票。美元锁- >release ();}
              

如果不能获得锁,方法返回假。的获得()方法可以安全地调用多次,即使已经获得锁。

请注意

与其他实现,即使锁组件区分锁实例创建相同的资源。这意味着对于一个给定的范围和资源实例可以多次获得一个锁。如果锁必须使用多个服务,他们应该共享相同的锁返回的实例LockFactory: createLock方法。

提示

如果你不显式地释放锁,它将自动释放实例销毁。在某些情况下,它可以帮助锁定资源跨多个请求。禁用自动释放行为,第三个参数的设置createLock ()方法假。

序列化锁

的关键包含的状态锁并且可以序列化。这允许用户开始长工作过程中通过收购锁,并继续工作在另一个进程使用相同的锁:

               1 2 3 4 5 6 7 8 9 10 11 12 13
               使用欧宝娱乐app下载地址\组件\锁\关键;使用欧宝娱乐app下载地址\组件\锁\锁;美元关键=新键(“文章”。。美元文章- >getId ());美元锁=新锁(美元关键,美元这- >商店,300年,/ / ttl假/ /生成);美元锁- >获得(真正的);美元这- >公共汽车- >调度(新RefreshTaxonomy (美元文章,美元关键));
              

请注意

不要忘记设置生成参数假在锁构造函数,以避免析构函数被调用时释放锁。

并不是所有的商店都兼容序列化和跨进程锁定:例如,内核将自动释放信号量收购SemaphoreStore商店。如果你使用一个不兼容的存储(见锁店为支持商店),会抛出一个异常,当应用程序试图序列化的关键。

阻塞锁

默认情况下,当无法获得一个锁,收购方法返回假立即。等到(无限期)锁可以创建,通过真正的的论点获得()方法。这被称为阻塞锁因为您的应用程序的执行停止,直到锁:

               1 2 3 4 5 6 7 8
               使用欧宝娱乐app下载地址\组件\锁\LockFactory;使用欧宝娱乐app下载地址\组件\锁\商店\RedisStore;美元商店=新RedisStore (新\ Predis \客户端(“tcp: / / localhost: 6379”));美元工厂=新LockFactory (美元商店);美元锁=美元工厂- >createLock (“pdf-creation”);美元锁- >获得(真正的);
              

当商店不支持阻塞锁的实现BlockingStoreInterface界面(见锁店支持商店)锁类将重试以非阻塞方式获得锁,直到锁。

到期的锁

锁创建远程很难管理,因为没有远程方式商店知道柜过程仍然活着。由于错误,致命错误或分割的缺点,它不能保证release ()方法将调用,这将导致资源无限。

在这种情况下是创建最好的解决方案到期的锁一段时间后,自动释放已通过(TTL呼吁生存时间)。这一次,在几秒钟内,第二个参数的配置createLock ()方法。如果需要,还可以释放这些锁的早期release ()方法。

使用锁定到期时最棘手的部分是选择合适的TTL。如果太短了,其他进程可以获得锁之前完成工作;如果太长和过程调用之前崩溃release ()方法,资源将保持锁定,直到超时:

               1 2 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到原来的值:

               1 2 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秒(下刷新()调用将再次30秒)美元锁- >刷新(600年);
               

该组件还提供了两个相关的有用的方法锁:到期getRemainingLifetime ()(返回零或者一个浮动秒)和isExpired ()(返回一个布尔值)。

自动释放锁

锁锁对象销毁时自动释放。这是一个实现细节,进程间共享锁时是很重要的。在下面的示例中,pcntl_fork ()创建两个过程和锁会自动释放一个过程完成:

                1 2 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 (真正的);
              

请注意

的优先政策Sym欧宝娱乐app下载地址fony的共享锁取决于底层存储(例如复述,商店重视读者和作者)。

当一个只读锁获得的acquireRead ()方法,是可能的促进锁,改变写锁,通过调用获得()方法:

               1 2 3 4 5 6 7 8 9
               美元锁=美元工厂- >createLock (“用户- - - - - -”。美元用户标识);美元锁- >acquireRead (真正的);如果(!美元这- >shouldUpdate (美元用户标识)){返回;}美元锁- >获得(真正的);/ /促进写锁的锁美元这- >更新(美元用户标识);
              

以同样的方式,它是可能的降级一个写锁,将其更改为一个只读锁定通过调用acquireRead ()方法。

当所提供的商店没有实现SharedLockStoreInterface界面(见锁店支持商店)锁类将通过调用回退到一个写锁获得()方法。

锁的所有者

首次获得锁是[1]_的拥有锁实例,获得它。如果你需要检查当前是否锁实例(仍然)锁的主人,您可以使用isAcquired ()方法:

               1 2 3
               如果(美元锁- >isAcquired ()) {/ /我们(仍然)自己的锁}
              

因为一些锁商店有到期的锁,有可能失去锁自动获得一个实例:

               1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
               / /如果我们不能获得自己,这意味着一些其他流程已经工作如果(!美元锁- >获得()){返回;}美元这- >beginTransaction ();/ /执行一个非常漫长的过程,可能超过TTL的锁如果(美元锁- >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
                使用欧宝娱乐app下载地址\组件\锁\商店\FlockStore;/ /参数是锁的目录的路径/ /如果没有,sys_get_temp_dir()内部使用。美元商店=新FlockStore (/ var /商店的);
               

谨慎

注意,一些文件系统(比如某些类型的NFS)不支持锁定。在这些情况下,最好使用本地磁盘驱动器上的一个目录或一个远程存储。

MemcachedStore

MemcachedStore保存锁在Memcached服务器上,它需要一个Memcached连接实现\ Memcached类。这家商店不支持阻塞,并预计TTL避免停滞锁:

                1 2 3 4 5 6
                使用欧宝娱乐app下载地址\组件\锁\商店\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
                使用欧宝娱乐app下载地址\组件\锁\商店\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

当第一个参数是:

MongoDB \集合:

美元的选项(“数据库”)被忽略
美元的选项(“收集”)被忽略

MongoDB \客户:

美元的选项(“数据库”)是强制性的
美元的选项(“收集”)是强制性的

MongoDB连接字符串:

美元的选项(“数据库”)否则使用/路径从DSN,至少有一个是强制性的
美元的选项(“收集”)否则使用收集? =从DSN,至少有一个是强制性的

请注意

的集合查询字符串参数的一部分MongoDB连接字符串定义。它是用来允许建造一个MongoDbStore使用一个数据源名称(DSN)没有选择美元。

PdoStore

PdoStore保存锁在一个SQL数据库。DoctrineDbalStore但需要是相同的PDO连接或数据源名称(DSN)。这家商店不支持阻塞,并预计TTL避免停滞锁:

                1 2 3 4 5
                使用欧宝娱乐app下载地址\组件\锁\商店\PdoStore;/ /通过PDO PDO懒惰或DSN连接美元databaseConnectionOrDSN=“mysql:主机= 127.0.0.1;dbname =应用';美元商店=新PdoStore (美元databaseConnectionOrDSN,(“db_username”= >“myuser”,“db_password”= >“我的密码”]);
               

请注意

这家商店不支持TTL低于1秒。

自动创建的表值存储在第一次调用save ()方法。您还可以创建这个表显式地通过调用不知道()方法在您的代码中。

DoctrineDbalStore

DoctrineDbalStore保存锁在一个SQL数据库。PdoStore但需要是相同的教义DBAL连接,或者一个教义DBAL URL。这家商店不支持阻塞,并预计TTL避免停滞锁:

                1 2 3 4 5
                使用欧宝娱乐app下载地址\组件\锁\商店\DoctrineDbalStore;/ /一个教义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
                使用欧宝娱乐app下载地址\组件\锁\商店\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
                使用欧宝娱乐app下载地址\组件\锁\商店\DoctrineDbalPostgreSqlStore;/ /一个教义连接或DSN美元databaseConnectionOrDSN=“postgresql +咨询:/ / myuser: mypassword@127.0.0.1:5634 /锁”;美元商店=新DoctrineDbalPostgreSqlStore (美元databaseConnectionOrDSN);
               

在相反的DoctrineDbalStore,DoctrineDbalPostgreSqlStore不需要一个表来存储锁和不到期。

RedisStore

RedisStore保存复述,服务器上的锁,它需要复述,连接实现\复述,,\ RedisArray,\ RedisCluster或\ Predis类。这家商店不支持阻塞,并预计TTL避免停滞锁:

                1 2 3 4 5 6
                使用欧宝娱乐app下载地址\组件\锁\商店\RedisStore;美元复述,=新\复述();美元复述,- >连接(“localhost”);美元商店=新RedisStore (美元复述,);
               

SemaphoreStore

SemaphoreStore使用PHP信号量函数创建锁:

                1 2 3
                使用欧宝娱乐app下载地址\组件\锁\商店\SemaphoreStore;美元商店=新SemaphoreStore ();
               

CombinedStore

CombinedStore是专为高可用性的应用程序,因为它管理几个店铺同步(例如,几个复述,服务器)。获得一个锁时,它将调用转发给所有的存储管理,并收集他们的反应。如果一个简单多数的商店获得锁,然后被认为是获得锁:

                1 2 3 4 5 6 7 8 9 10 11 12 13
                使用欧宝娱乐app下载地址\组件\锁\商店\CombinedStore;使用欧宝娱乐app下载地址\组件\锁\商店\RedisStore;使用欧宝娱乐app下载地址\组件\锁\策略\ConsensusStrategy;美元商店= [];foreach([“server1”,server2的,“server3”]作为美元服务器){美元复述,=新\复述();美元复述,- >连接(美元服务器);美元商店[]=新RedisStore (美元复述,);}美元商店=新CombinedStore (美元商店,新ConsensusStrategy ());
               

而不是简单多数的策略(ConsensusStrategy)一个UnanimousStrategy可用于需要获得所有的锁店:

                1 2 3 4
                使用欧宝娱乐app下载地址\组件\锁\商店\CombinedStore;使用欧宝娱乐app下载地址\组件\锁\策略\UnanimousStrategy;美元商店=新CombinedStore (美元商店,新UnanimousStrategy ());
               

谨慎

为了得到高可用性时使用ConsensusStrategy,最低必须三个服务器集群大小。这允许集群继续工作当一个服务器失败(因为这一战略要求锁获得一半以上的服务器)。

ZookeeperStore

ZookeeperStore保存锁上动物园管理员服务器。它需要一个动物园管理员连接实现\动物园管理员类。这家商店不支持阻塞和过期但锁是PHP时自动释放过程终止:

                1 2 3 4 5 6 7
                使用欧宝娱乐app下载地址\组件\锁\商店\ZookeeperStore;美元动物园管理员=新\管理员(“localhost: 2181”);/ /定义一个高可用性集群使用以下:/ /管理员美元= new \管理员(“localhost1:2181, localhost2:2181, localhost3:2181”);美元商店=新ZookeeperStore (美元动物园管理员);
               

请注意

动物园管理员不需要TTL节点用于锁定是短暂的和死当PHP进程终止。

可靠性

组件保证相同的资源不能被锁定两次只要组件中使用以下方式。

远程存储

远程商店(MemcachedStore,MongoDbStore,PdoStore,PostgreSqlStore,RedisStore和ZookeeperStore)使用一个独特的标记识别真正的所有者的锁。这令牌存储在关键对象和内部使用的锁。

每个并发进程必须存储锁在同一台服务器上。否则两个不同的机器上可能让两个不同的进程获得相同的锁。

谨慎

保证相同的服务器总是安全的,不使用Memcached loadbalance后面,一个集群或循环DNS。即使主服务器,调用不能转发到一个备份或故障转移服务器。

到期的商店

到期的商店(MemcachedStore,MongoDbStore,PdoStore和RedisStore)保证了锁只对定义的持续时间。如果任务花费的时间完成,然后锁可以存储和发布的被别人收购。

的锁提供了几个方法来检查它的健康。的isExpired ()方法检查是否结束,其一生getRemainingLifetime ()方法返回的时间住在秒。

使用上面的方法,一个健壮的代码是:

                1 2 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时考虑。

通过设计,锁是存储在服务器上定义的生命周期。如果机器的日期或时间变化,锁被释放的时间可能早于预期。

谨慎

保证日期不会改变,国家结核控制规划服务应该禁用和日期应该在服务停止时更新。

FlockStore

通过使用文件系统,这一点商店是可靠的,只要并发进程使用相同的物理目录来存储锁。

过程必须运行在同一台机器上,虚拟机或容器。更新Kubernetes或群服务时要小心,因为很短的时间内,可以有两个容器并行运行。

目录的绝对路径必须是相同的。小心随时可以改变的符号链接:Capistrano和蓝色/绿色部署经常使用这个技巧。该目录路径改变时要小心两个部署。

一些文件系统(比如某些类型的NFS)不支持锁定。

谨慎

所有的并发进程必须使用相同的物理文件系统通过运行在同一台机器上,使用相同的绝对路径锁定目录。

使用一个FlockStore在一个HTTP上下文与多个前端服务器不兼容,除非以确保相同的资源总是被锁定在同一台机器上或者使用一个共享文件系统配置。

文件系统上的文件可以删除在维护操作。例如,清理/ tmp重新引导之后目录或目录使用时机器的tmpfs。这不是一个问题,如果释放锁过程结束后,但在锁请求之间重用。

谨慎

不锁存储在文件系统不稳定,如果他们必须在多个请求中重用。

MemcachedStore

Memcached的工作方式是将物品存储在内存中。这意味着,通过使用MemcachedStore锁不坚持,随时可能消失的错误。

如果Memcached服务或者重启机器托管,每个锁将丢失没有通知正在运行的流程。

谨慎

为了避免别人获得一个锁在重启之后,建议推迟服务开始和等待至少只要TTL最长的锁。

默认Memcached使用LRU机制删除旧条目当服务需要空间来添加新项目。

谨慎

物品的数量必须控制存储在Memcached。如果这是不可能的,应该禁用LRU和锁应存放在一个专门的Memcached远离缓存服务。

当Memcached服务共享和用于多个使用,锁可能是被错误。例如一些PSR-6的实现clear ()方法使用Memcached冲洗()方法清洗并删除一切。

谨慎

该方法冲洗()不能,或锁应存放在一个专门的Memcached远离缓存服务。

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指数。建议设置构造函数的选择gcProbablity来0.0禁用此行为如果你有手动处理TTL创建索引。

谨慎

这家商店依赖于所有PHP应用程序和数据库节点有同步时钟锁失效发生在正确的时间。确保锁不要过早失效;锁TTL应设置足够的额外的时间expireAfterSeconds考虑到任何节点间时钟漂移。

writeConcern和readConcern不指定MongoDbStore意义集合的设置生效。readPreference是主对所有查询。阅读更多关于副本集读和写语义在MongoDB。

PdoStore

PdoStore依赖酸属性的SQL引擎。

谨慎

在一个集群中配置了多个初选,确保写同步传播到每个节点,或者总是使用相同的节点。

谨慎

MySQL允许禁用等一些SQL引擎独特的约束检查。确保事实并非如此设置unique_checks = 1;。

为了清除旧的锁,这个商店使用当前日期时间来定义一个过期日期参考。这种机制依赖于所有服务器节点的时钟同步。

谨慎

确保锁不要过早失效;ttl应设置有足够的额外的时间占任何节点间时钟漂移。

PostgreSqlStore

PdoStore依赖咨询锁PostgreSQL数据库的属性。这意味着,通过使用PostgreSqlStore锁会自动释放会话结束时,以防客户端无法打开任何理由。

如果PostgreSQL服务或者重启机器托管,每个锁将丢失没有通知正在运行的流程。

如果TCP连接丢失,PostgreSQL可以释放锁没有通知应用程序。

RedisStore

复述的工作方式是将物品存储在内存中。这意味着,通过使用RedisStore锁不坚持,随时可能消失的错误。

如果复述,服务或者重启机器托管,每个锁将丢失没有通知正在运行的流程。

谨慎

为了避免别人获得一个锁在重启之后,建议推迟服务开始和等待至少只要TTL最长的锁。

提示

复述,可以配置为存在磁盘上的项目,但这个选项会慢下来写在服务。这可能与其他用途的服务器。

当复述,服务共享和用于多种用途,锁可能是被错误。

谨慎

命令FLUSHDB不能,或锁应存放在一个专门的复述,远离缓存服务。

CombinedStore

结合商店允许锁跨多个后端存储。这是一个常见的错误认为锁机制将更加可靠。这是错误的。的CombinedStore会,在最好的情况下,可靠的所有管理商店是最可靠的。一旦一个托管存储返回的错误信息,CombinedStore不会是可靠的。

谨慎

所有的并发进程必须使用相同的配置,与相同数量的存储和管理相同的端点。

提示

而不是使用一个复述或Memcached服务器集群,这是更好的使用CombinedStore与单个服务器/存储管理。

SemaphoreStore

信号量是由内核级别。为了是可靠的,过程必须运行在同一台机器上,虚拟机或容器。更新Kubernetes或群体服务的时候要小心,因为很短的时间内,可以有两个并行运行的容器。

谨慎

所有的并发进程必须使用相同的机器。在开始新机器上的并发进程之前,检查其他进程在旧的停止。

谨慎

当运行在systemd和非系统的用户选择RemoveIPC = yes(默认值),锁systemd当用户删除的日志。检查过程运行系统用户(UID < = SYS_UID_MAX)SYS_UID_MAX中定义的/etc/login.defs或设置选项RemoveIPC =了在/etc/systemd/logind.conf。

ZookeeperStore

ZookeeperStore的工作方式是通过保持锁短暂的节点服务器上。这意味着,通过使用ZookeeperStore锁会自动释放会话结束时,以防客户端无法打开任何理由。

如果管理员服务或者重启机器托管,每个锁将丢失没有通知正在运行的流程。

提示

使用管理员的高可用性特性,您可以设置多个服务器集群,这样在其中一个服务器宕机情况下,大多数仍将服务请求。所有可用的服务器集群中会看到相同的状态。

请注意

这家商店不支持多级节点锁,因为中间节点成为一个开销的清理,所有的锁都是保持在根级别。

整体

更改配置的商店应该非常仔细地做。例如,在一个新版本的部署。流程与新配置时不得启动旧流程与旧的配置仍然运行。

这项工作,包括代码示例,许可下Creative Commons冲锋队3.0许可证。