Openresty中的并发模型是什么?

我正在努力理解 openresty(或 nginx)的并发模型。我阅读了[Lua变量作用域](http://wiki.nginx.org/HttpLuaModule#Lua_Variable_Scope),它解释了变量的生命周期,但它没有关于并发访问它们的任何内容。

这很难用言语解释,所以让我试着用代码来解释。想象一下我有这个 Lua 模块:

local counter = {count = 0}

function counter.incr(amount)
  counter.count = counter.count + (amount 或 1)
end

return counter

然后我在 openresty 中这样使用它:

server {
  location /incr {
    content_by_lua '
      local counter = require 'counter'
      counter.incr(1)
    '
  }
  location /decr {
    content_by_lua '
      local counter = require 'counter'
      counter.incr(-1)
    '
  }
  location /count {
    content_by_lua '
      local counter = require 'counter'
      ngx.write(counter.count)
    '
  }
}

我想要理解并发模型,以便回答以下问题:

  • 如果我对/incr进行10个并发调用,然后稍后调用/count,我可以确定结果将为10吗(我认为不是,但为什么)?
  • 如果我同时对/incr进行10个并发调用,并且同时对/decr进行另外10个调用,我可以确定/count将返回0吗?
  • 工作线程数如何影响结果?
  • 代码发生的阶段如何影响结果(即init_by_lua而不是content_by_lua)?
点赞
用户1442917
用户1442917

nginx采用基于事件的架构,这意味着它使用单线程1和事件循环来处理套接字,当套接字变得可读或可写时处理它们。这意味着请求实际上并不是同时处理的,但是如果存在任何套接字/IO延迟,即使有延迟,也可以快速一一处理几个请求。

如果我对/ incr进行10个并发调用,稍后我调用/ count,我可以确定结果将为10吗?(我认为不是,但是为什么?)

是的。只要所有/ incr请求都完成后再调用/ count,结果就会是10。想象一下,有9个请求已经完成,但是由于某种原因第10个请求被发送者延迟了,如果在nginx处理第10个请求之前处理了/ count,您应该得到9作为结果。

如果我对/ incr进行10个并发调用,并且与此同时我对/ decr进行了另外10个调用,我可以确定/ count将返回0吗?

是的,但是不能保证这些请求的处理顺序。请注意,在这种情况下,您不需要锁定状态或使用全局信号量或任何类似的东西。如果读取状态并在将其写回之前进行了一些I/O调用(因为在此期间可能会处理不同的请求),则可能会遇到问题,但是您的示例不是这样做的。

工作人员数量如何影响结果?

Lua实例在同一工作进程中处理的请求之间共享,因此多个工作进程不会给您相同的结果。您的所有/ incr请求可以转到一个工作进程,但是您的/ count请求可以转到具有不同Lua实例的不同工作进程,该实例仍将count设置为0。如果需要在实例之间共享数据,您可能需要使用类似[lua_shared_dict](http://wiki.nginx.org/HttpLuaModule#lua_shared_dict)的东西。请查看有关数据共享的部分(http://wiki.nginx.org/HttpLuaModule#Data_Sharing_within_an_Nginx_Worker)以获取其他选项。

代码发生的阶段(即init_by_lua而不是content_by_lua)如何影响结果?

当主进程加载配置文件时,才会执行init_by_lua

1我进行了简单化,因为据我所知,它也可以生成多个实例以处理多核系统和某些其他情况。

2014-01-19 07:03:18