我的 API 中有一个路由，例如，我们将其称为/users/:userId/updateBalance。此路由将获取用户当前余额，添加来自请求的任何内容，然后使用新计算的余额更新余额。像这样的请求每 30 分钟进入一个特定用户的服务器，所以直到最近，我认为并发问题是不可能的。
最终发生的事情是，某处发送的请求失败，并且仅在 30 分钟后再次发送，大约在另一个请求的一秒内。结果是，正如我在数据库中看到的那样，这两个请求都从数据库中获取了相同的余额，并且都添加了各自的金额。本质上，第二个请求实际上读取了过时的余额，因为它通常应该在请求 1 执行后执行。
为了更清楚地给出一个数字示例，假设请求 1 是向余额中添加 2 美元，请求 2 是向余额中添加 5 美元，用户的余额为 10 美元。如果请求并行执行，则用户余额将以 12 美元或 15 美元结束，具体取决于请求 1 或请求 2 分别先完成，因为两个请求都从数据库中获取了 10 美元的余额。然而，显然预期的行为是我们希望请求 1 执行，将用户余额更新为 12 美元，然后请求 2 执行并将余额从 12 美元更新为 17 美元。
为了更好地了解这个过程的整体执行情况:收到请求，调用一个函数，该函数必须等待来自数据库的余额，然后该函数计算新的余额并更新数据库，之后执行完成。
所以我有几个问题。第一个是， Node 在等待异步请求(如 MySQL 数据库读取)时如何处理传入请求。鉴于我观察到的结果，我假设当第一个请求正在等待数据库时，第二个请求可以开始处理？否则我不确定在像 Node 这样的单线程环境中如何体验这种异步行为。
其次，我该如何控制和预防它。我曾想使用带有 forUpdate 锁的 MySQL 事务，但由于当前编写代码的方式，这似乎是不可能的。有没有办法告诉 Node 某个代码块不能“并行”执行？或者任何其他选择？
最佳答案
你是对的，当 Node 等待数据库查询返回时，它将处理任何传入的请求并在第一个请求完成之前开始请求数据库调用。
防止此 IMO 的最简单方法是使用队列。路由处理程序可以将事件推送到队列(在 Redis、AWS SQS、RabbitMQ 等中)和您应用程序中的其他地方(甚至在完全不同的服务中)，而不是直接在路由处理程序中处理余额更新会有一个消费者监听该队列中的新事件。如果更新失败，将其添加回队列的开头，增加一些等待时间，然后重试。
这样，无论您的第一个请求失败多少次，您的余额都将是正确的，并且对该余额的未决更改将以正确的顺序排列。如果队列中的事件反复失败，您甚至可以向某人发送电子邮件或通知以查看它，当问题已解决时，待处理的余额更改将添加到队列中，一旦它已修复，一切都将得到正确处理。
您甚至可以读取该队列并向您的用户显示信息，例如告诉用户余额有待更新，因此它可能不准确。
希望这对您有所帮助!
关于mysql - 当事件循环等待数据库操作时，如何处理对 nodejs 服务器的传入请求，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56344533/
我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..
我脑子里浮现出一些关于一种新编程语言的想法，所以我想我会尝试实现它。一位friend建议我尝试使用Treetop(Rubygem)来创建一个解析器。Treetop的文档很少，我以前从未做过这种事情。我的解析器表现得好像有一个无限循环，但没有堆栈跟踪；事实证明很难追踪到。有人可以指出入门级解析/AST指南的方向吗？我真的需要一些列出规则、常见用法等的东西来使用像Treetop这样的工具。我的语法分析器在GitHub上，以防有人希望帮助我改进它。class{initialize=lambda(name){receiver.name=name}greet=lambda{IO.puts("He
我有多个ActiveRecord子类Item的实例数组，我需要根据最早的事件循环打印。在这种情况下，我需要打印付款和维护日期，如下所示:ItemAmaintenancerequiredin5daysItemBpaymentrequiredin6daysItemApaymentrequiredin7daysItemBmaintenancerequiredin8days我目前有两个查询，用于查找maintenance和payment项目(非排他性查询)，并输出如下内容:paymentrequiredin...maintenancerequiredin...有什么方法可以改善上述(丑陋的)代
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru
我在理解Enumerator.new方法的工作原理时遇到了一些困难。假设文档中的示例:fib=Enumerator.newdo|y|a=b=1loopdoy[1,1,2,3,5,8,13,21,34,55]循环中断条件在哪里，它如何知道循环应该迭代多少次(因为它没有任何明确的中断条件并且看起来像无限循环)？ 最佳答案 Enumerator使用Fibers在内部。您的示例等效于:require'fiber'fiber=Fiber.newdoa=b=1loopdoFiber.yieldaa,b=b,a+bendend10.times.m
在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo
我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样？我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用，需要1秒才能返回，我有100,000多个页面要访问，所以我试图运行多个线程来解决这个问题。有更好的方法吗？classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("
有时我需要处理键/值数据。我不喜欢使用数组，因为它们在大小上没有限制(很容易不小心添加超过2个项目，而且您最终需要稍后验证大小)。此外，0和1的索引变成了魔数(MagicNumber)，并且在传达含义方面做得很差(“当我说0时，我的意思是head...”)。散列也不合适，因为可能会不小心添加额外的条目。我写了下面的类来解决这个问题:classPairattr_accessor:head,:taildefinitialize(h,t)@head,@tail=h,tendend它工作得很好并且解决了问题，但我很想知道:Ruby标准库是否已经带有这样一个类？ 最佳
您如何在Rails中的实时服务器上进行有效调试，无论是在测试版/生产服务器上？我试过直接在服务器上修改文件，然后重启应用，但是修改好像没有生效，或者需要很长时间(缓存？)我也试过在本地做“脚本/服务器生产”，但是那很慢另一种选择是编码和部署，但效率很低。有人对他们如何有效地做到这一点有任何见解吗？ 最佳答案 我会回答你的问题，即使我不同意这种热修补服务器代码的方式:)首先，你真的确定你已经重启了服务器吗？您可以通过跟踪日志文件来检查它。您更改的代码显示的View可能会被缓存。缓存页面位于tmp/cache文件夹下。您可以尝试手动删除
