PHP:如何防止代码的多次执行(如果它已经在处理中)

2024-01-01

解释

通常需要 10-20 秒响应的 API 调用(对另一个服务)存储在数据库中,

存储后,系统会立即尝试使用API​​将结果显示给用户,但可能会失败(并显示失败,但我们会自动重试),因此还有一个Cron Job设置为每 30 秒运行一次并再次尝试(失败的)查询。

如果API返回成功(无论是即时使用还是使用Cron Job),数据库中的标志将更改为成功,并且不会再次运行。

Issue

我的问题是Instant CallAPI 正在处理中,Cron Job也可以尝试另一个调用,因为它尚未标记为成功,

此外,在极少数情况下,当上一个 Cron 作业正在进行时,下一个 Cron 作业可能会再次运行代码。

我已经尝试过防止该问题发生的方法

我尝试存储In Process数据库表中的 API 调用Status=1当 API 调用成功时删除它们,或者如果失败则将状态设置为 0,

 if ($status === 0)
 {
     
     // Set Status to 1 in Database First (or die() if database update failed)
     
     // Then Call The API

     // If Failed Set Status to 0 so Cron Job can try again
     
     // If Successful Change Flag to success and remove from queue

 }
     

但如果Instant CallCron Job Call完全在同一时间发生?他们都检查状态是否为 0(确实如此),然后都将状态设置为 1 并执行 API 调用...

问题

  1. 我尝试过的处理方法是正确的吗?

  2. 如果有很多呼叫(有时+500/秒),我是否应该担心它们在确切的时间发生(我在上面的黄色引用中解释的问题)

赏金前更新

难道 PHP 端就没有一种简单的方法来处理这种情况吗?如果不是,专家认为哪种方式更好?下面是一些方法,但没有一个足够详细,也没有一个有任何反对/赞成票。

附:数据库有很多更新/插入,我认为锁定不是一个有效的想法,并且我不确定其余的想法。


这就是为什么信号 http://php.net/manual/en/intro.sem.php是为.

在php中,可以通过以下方式使用: 在 PHP 中使用信号量实际上非常简单。信号量函数只有 4 个:

sem_acquire() – Attempt to acquire control of a semaphore.
sem_get() – Creates (or gets if already present) a semaphore.
sem_release() – Releases the a semaphore if it is already acquired.
sem_remove() – Removes (deletes) a semaphore.

那么它们是如何协同工作的呢?

  1. 首先,你打电话sem_get()获取信号量的标识符。
  2. 之后,您的进程之一将调用sem_acquire()尝试获取信号量。如果当前无法使用,sem_acquire()将阻塞,直到信号量被另一个进程释放。
  3. 一旦获得信号量,您就可以访问您正在用它控制的资源。
  4. 使用完资源后,请致电sem_release()以便另一个进程可以获取信号量。
  5. 当一切都说了又做了,并且您已经确保您的进程不再需要信号量时,您可以调用sem_remove()完全删除信号量。

您可以在以下位置找到更多信息和示例:本文 http://www.re-cycledair.com/php-dark-arts-semaphores.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

PHP:如何防止代码的多次执行(如果它已经在处理中) 的相关文章

  • PHP 可以解压缩使用 .NET GZipStream 类压缩的文件吗?

    我有一个 C 应用程序 它与基于 PHP 的 SOAP Web 服务进行通信以进行更新和许可 我现在正在开发一个反馈系统 供用户通过软件自动提交错误和跟踪日志 根据我之前发布的问题 我认为 Web 服务将是实现此目的的最佳方法 最有可能以最
  • MySQL解释更新

    作为我大学复习的一部分 我试图回答以下问题 至少在表的一个属性上创建索引 employees 数据库 您可以在其中使用 MySQL EXPLAIN 工具 清楚地显示好处 在条款或检索方面 和负面 在 更新条款 创建相关索引的信息 对于第一部
  • 计算帖子中使用 WordPress 短代码的次数

    我有以下 WordPress 短代码功能 function wp shortcode static i 1 return i i return return add shortcode shortcode wp shortcode 这很好用
  • VIEW for 表结合 UNION ALL 的 MySQL 性能

    假设我有 2 张桌子MySQL create table persons id bigint unsigned not null auto increment first name varchar 64 surname varchar 64
  • Symfony2 实体字段在选项为空时显示所有条目

    我的 Symfony2 项目中有一个实体类型表单字段 builder this gt createFormBuilder projects this gt getProjects builder gt add project entity
  • Mysql关于重复键更新+子查询

    使用这个问题的答案 需要 MySQL INSERT SELECT 查询具有数百万条记录的表 https stackoverflow com questions 662877 need mysql insert select query fo
  • 将我的 Laravel 连接到外部数据库

    如何将 Laravel 连接到外部数据库 示例 我的本地计算机上有一个 Laravel 它在 xampp 上运行 我希望它连接到云服务器数据库 打开 env文件并编辑它 只需设置正确的外部数据库凭据 DB CONNECTION mysql
  • SQL 查询结果为字符串(或变量)

    是否可以将SQL查询结果输出到一个字符串或变量中 我的php和mysql不好 假设我有数据库 agents 其中包含列 agent id agent fname agent lname agent dept 使用此查询 sql SELECT
  • 重用 PDO 语句 var 会使进程崩溃

    我重用一个变量来存储两个不同的 PDO mysql 语句 stmt dbh gt prepare SELECT stmt gt execute stmt dbh gt prepare UPDATE crash here Error in o
  • Symfony 4 生产模式错误处理页面内存耗尽

    我将我的项目设置为prod模式在 env除了自定义错误页面之外的所有内容似乎都有效 我将此作为我的 404 树枝模板 templates bundles TwigBundle Exception error404 html twig inc
  • PHP cURL 看不到 /etc/hosts 文件

    我在让 PHP cURL 库识别我在我的文件中创建的别名时遇到了麻烦 etc hosts file 这就是我的 etc hosts现在归档 192 168 0 20 www example dev 在另一端 192 168 0 20 Apa
  • 一次用 \r\n & \n & \r 分解字符串? [复制]

    这个问题在这里已经有答案了 我想按行分割字符串 但我希望它基于所有主要使用的换行符 n r n r 并返回一个包含每一行的数组 您可以使用正则表达式和preg split http php net preg split反而 lines pr
  • 如何处理致命错误:cURL错误7:无法连接到xxxx端口443

    我有一个连接到第三方 API 的脚本 它是并且应该在 24 7 不间断循环上运行 我在重新启动循环之前在最后使用睡眠 问题是 有时第三方 API 会被拒绝 或者连接会因以下错误而中断 致命错误 未捕获的异常 GuzzleHttp Ring
  • 如何下载临时文件

    我正在尝试创建一个简短的 PHP 脚本 该脚本采用 JSON 字符串 将其转换为 CSV 格式 使用fputcsv 并使该 CSV 可作为下载的 csv 文件使用 我的想法是使用tmpfile 不用担心 cronjobs 或磁盘空间不足 但
  • 验证 LDAPS 连接的自签名证书

    我想从 Linux Linux 3 2 0 4 amd64 1 SMP Debian 3 2 51 1 x86 64 GNU Linux 客户端到 Windows 2012 服务器建立安全的 ldap 连接 ldaps 以更改活动中的用户密
  • Laravel 5 命名约定

    我对 Laravel 约定有点困惑 因为我是这个框架的新手 我正在关注 Jeffrey Way 他使用的 Laracasts 视频Plural对于控制器名称 E g 页面控制器 卡片控制器 帖子控制器 但如果我参考官方文档Laravel g
  • 检查字符串是否编码为 UTF-8

    function seems utf8 str length strlen str for i 0 i lt length i c ord str i if c lt 0x80 n 0 0bbbbbbb elseif c 0xE0 0xC0
  • Symfony VS CakePHP:哪一个最接近 PHP [关闭]

    Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我主要是一名 Rails 开发人员 但有时 我必须使用 PHP 进行编码 因为 stackoverflow com更喜欢可以回答的问题 我想知道
  • MySqlConnectionStringBuilder - 使用证书连接

    我正在尝试连接到 Google Cloud Sql 这是一个 MySql 解决方案 我能够使用 MySql Workbench 进行连接 我如何使用 C 连接MySqlConnectionStringBuilder 我找不到提供这三个证书的
  • 如何获取所有mysql元组结果并转换为json

    我能够从表中获取单个数据 但是当我试图获取表上的所有数据时 我只得到一行 cnn execute sql rows cnn fetchall column t 0 for t in cnn description for row in ro

随机推荐

  • Javascript正则表达式日期提取和分组问题

    我有这些行的文本行 Il Messaggero Roma 22 settembre 2023 Il Messaggero Roma 21 settembre 2023 Il Messaggero 22 settembre 2023 Il M
  • 异常类型可以通用吗?

    我尝试过以下方法 但不起作用 exception MyError lt a gt of a exception a MyError of a 我必须使用长形式吗 type MyError lt a gt value inherit Syst
  • 有人可以通过某种方式操作客户端应用程序来访问我的 Firestore 数据库吗?

    我真的很担心我将存储在 Firestore 中的数据的安全性 我想知道是否有人可以从我的 Android 应用程序中提取 google services json 文件或使用其他一些工具来访问我的 Firestore 数据库 有可能吗 如果
  • 安装rails时找不到Gem存储库

    我的 Windows 计算机上安装了 Ruby 1 8 7 和 Ruby 1 9 2 当我这样做时在我的控制台中ruby v它给了我 Ruby 1 8 7 现在当我尝试时 gem install rails v 2 3 8 我收到这个错误
  • 当 WPF ProgressBar 达到 100% 时,如何停止它的脉冲/动画?

    我有一个基于 MVVM 的 WPF 4 应用程序 它使用进度条 http msdn microsoft com en us library system windows controls progressbar aspx显示长时间运行的操作
  • C++ 运算符 []

    我正在尝试实现运算符 该运算符用于 Set 一次 用于 Get 一次 我需要区分这两种情况 就像 get 的情况一样 如果返回值相等 我需要抛出异常至 1 而在 Set 的情况下 我只是覆盖该值 苹果 2 X y 苹果 2 我不知道如何区分
  • 伊莎贝尔:setprod 的问题

    以下等式在伊莎贝尔中是否成立 setprod f UNIV n finite set setprod x x f UNIV n finite set 如果是 我该如何证明 tested with Isabelle2013 2 theory
  • 操作系统错误:没有这样的文件或目录,errno = 2

    我无法加载存储在资产文件夹中的 html 文件 我已经搜索了两天了 但似乎无法找出原因 我已确保将其也包含在 pubspec yaml 中 并具有适当的缩进并且所有构建都很好 我在 pubspec yaml 中加载的图像资源加载没有问题 所
  • 在 Javafx 中为新的 ListView 条目添加动画

    问题 Hi 我正在尝试编写一个应用程序 其中 ListView 中的每个新条目都会动画化 这是我的代码 public class BookCell extends ListCell
  • AS3 生成动态 SWF?

    是否可以使用 AS3 以编程方式生成 swf 文件 我的小应用程序的作用是使用 FileReference 加载一堆图像 现在我想将它们编译成用户可以下载的独立 swf swf 将是幻灯片 edit 似乎对我的要求有一些误解 我想要一个已编
  • 如何在 Visual Studio 2010 中创建测试证书?

    我正在使用 Visual Studio 2010 我需要在 签名 选项卡中添加 测试证书 但 创建测试证书 按钮被禁用 有什么问题吗 如何激活它或如何创建测试证书 分步说明可在以下位置找到 https learn microsoft com
  • 使用 R 扩展 netCDF 文件中的维度

    我想使用 R 编写一个具有 无限 维度的 netCDF 文件 以便稍后扩展 这是我尝试过的 创建 netcdf文件 library ncdf4 define lat lon time dimensions lat lt ncdim def
  • Moxy 不尊重超类/接口属性

    enter code here我的客户属性分布在两个接口上 如下所示 我使用子接口 ICustomer 定义了外部 xml 绑定 当我将 pojo 编组到 xml 时 Moxy 似乎忽略了超级接口的属性名 这是一个错误还是我需要在 xml
  • 如何在 C# 中将 Null 值赋给 Non-Nullable 类型变量?

    正如我所声明的 双x 现在我想分配 x NULL 我该怎么做 我看过其他一些答案 但无法理解它们 这就是打开此线程的原因 您必须将其声明为可为空类型 double x x null 不可为 null 的类型 例如 double 不能为 nu
  • 为什么我必须提供默认ctor?

    如果我想创建我类型的对象数组 为什么必须提供默认构造函数 感谢您的解答 因为它们必须被初始化 考虑一下是否情况并非如此 struct foo foo int void bar void foo a 10 foo f a 0 not defa
  • JQuery - 添加 onclick 到动态生成的 img 标签

    我正在使用以下代码动态创建多个图像 function refresh gallery galleryidentifier albumid ajax type POST url Photos Thumbnails albumid data s
  • Python 2.7 - 使用 Xvfb 进行 Selenium 无头测试不起作用

    注意我已经查看了以下来源 easyprocess EasyProcessCheckInstalledError cmd Xvfb help OSError Errno 2 没有这样的文件或目录 https stackoverflow com
  • 无法在 Azure 中访问我的 X509Certificate 2 私钥

    我将我的 X509Certificate 存储在数据库中 在byte 以便我的应用程序可以检索证书并使用它来签署我的 JWT 我的 x509Certificate 是通过我在计算机上生成的 pfx 文件传递 的 但现在它作为字节字符串位于数
  • 通过 AirDrop 发送即时创建的 QR 码 UIImage 失败

    我正在动态创建一个 QR 码并将其存储为 UIImage 现在我希望能够使用 UIActivityViewController 发送它 但不知何故它失败了 func generateQRCode from string String gt
  • PHP:如何防止代码的多次执行(如果它已经在处理中)

    解释 通常需要 10 20 秒响应的 API 调用 对另一个服务 存储在数据库中 存储后 系统会立即尝试使用API 将结果显示给用户 但可能会失败 并显示失败 但我们会自动重试 因此还有一个Cron Job设置为每 30 秒运行一次并再次尝