标签: preforking

我想知道当Web服务器将自己描述为预分叉Web服务器时它究竟意味着什么.我有一些例子,例如红宝石的独角兽和蟒蛇的gunicorn.

更具体地说,这些是问题:

• 这个模型解决了什么问题？
• 最初启动预分叉Web服务器时会发生什么？
• 它如何处理请求？

此外,一个更具体的问题为独角兽/ gunicorn:

假设我有一个我想用(g)独角兽运行的webapp.在初始化时,webapp将执行一些初始化操作(例如,填写其他数据库条目).如果我用多个worker配置(g)unicorn,初始化的东西会多次运行吗？

我正在研究一些以Apache的MPM prefork服务器为模型的Python代码.我是一名应用程序员而不是网络程序员,自从我读Stevens已经10年了,所以我正努力加快理解代码.

我找到了Sander Temme对Apache的prefork代码如何工作的简短描述.

父进程通常以root身份运行,绑定到套接字(通常是端口80或443).它生成子进程,继承了套接字的打开文件描述符,并将uid和gid更改为非特权用户和组.子节点构造一个侦听器文件描述符的轮询集(如果有多个侦听器)并监视它/它们上的活动.如果找到活动,则子活动在活动套接字上调用accept()并处理连接.完成后,它返回观察pollset(或监听器文件描述符).

由于多个子节点处于活动状态并且它们都继承了相同的套接字文件描述符,因此它们将观察相同的轮询集.接受互斥锁只允许一个孩子实际观察轮询集,一旦找到一个活动套接字,它将解锁互斥锁,以便下一个孩子可以开始观看轮询集.如果只有一个侦听器,则不使用接受互斥锁,并且所有子节点都将挂起在accept()中.

这几乎就是我正在寻找的代码的工作方式,但我不了解一些事情.

1)"孩子"和"听众"之间有什么区别？我认为每个孩子都是一个倾听者,这对我正在看的代码都是如此,但在Temme的描述中,可以有"单个听众"和"孩子".孩子什么时候会有多个听众？

2)(与1相关)这是一个进程互斥锁还是系统互斥锁？就此而言,为什么要使用互斥锁？不接受(2)在所有听众中做自己的互斥量？我的研究表明我确实需要一个互斥锁,并且互斥锁必须跨越整个系统.(羊群,信号量等)

特梅继续说:

儿童在上次提出请求时记录在共享内存区域(记分板)中.空进程可能会被父进程杀死以满足MaxSpareServers.如果太少的孩子闲置,父母将产生孩子以满足MinSpareServers.

3)这个实现是否有一个很好的参考代码(最好是在Python中)？我找到了Perl的Net :: Server :: Prefork,它为记分板使用管道而不是共享内存.我发现了一篇文章兰德尔·施瓦茨只做了preforking但没有做的记分牌.

来自Perl Cookbook的pre-fork示例没有任何关于select的锁定,Chris Siebenmann的Python示例说它基于Apache但是使用成对的套接字用于记分板,而不是共享内存,并使用套接字进行控制,包括控制给定的孩子'a'ccept.这根本不符合Apache描述.

我正在尝试理解并重新创建一个简单的preforking服务器,沿着独角兽的线路,服务器启动分叉4进程,所有进程都在控制套接字上等待(接受).

控制套接字@control_socket绑定到9799并生成4个等待接受连接的worker.对每个工人所做的工作如下

        def spawn_child
            fork do
                $STDOUT.puts "Forking child #{Process.pid}"
                loop do 
                    @client = @control_socket.accept                                        
                    loop do                     
                        request = gets              

                        if request                          
                            respond(@inner_app.call(request))                           
                        else
                            $STDOUT.puts("No Request")
                            @client.close                           
                        end
                    end
                end
            end
        end

        # Reads a file using IO.read_nonblock
        # Returns end of file when using get but doesn't seem to return 
        # while using read_nonblock or readpartial …