問(wèn)題描述

webman明明還有空閑子進(jìn)程，為什么接收到新請(qǐng)求時(shí)卻分配不到空閑進(jìn)程？

進(jìn)程（webman子進(jìn)程）
客戶端（發(fā)起請(qǐng)求的IP+發(fā)起請(qǐng)求時(shí)所使用的端口號(hào)）

經(jīng)過(guò)測(cè)試發(fā)現(xiàn)一個(gè)現(xiàn)象，webman在處理請(qǐng)求時(shí)，似乎會(huì)把該進(jìn)程和客戶端做一個(gè)綁定關(guān)系，該客戶端下次發(fā)起請(qǐng)求時(shí)，webman會(huì)用該客戶端上一次使用過(guò)的子進(jìn)程進(jìn)行處理；

這樣就會(huì)出現(xiàn)一個(gè)問(wèn)題，可能這一個(gè)子進(jìn)程綁定了多個(gè)客戶端，假設(shè)該子進(jìn)程在處理某一次請(qǐng)求時(shí)耗時(shí)30秒鐘，在此期間與該子進(jìn)程綁定的客戶端發(fā)起新的請(qǐng)求就都會(huì)阻塞住（直到30秒鐘后才能響應(yīng)請(qǐng)求，因?yàn)榇藭r(shí)子進(jìn)程處于阻塞狀態(tài)），但是此時(shí)還有很多其它的空閑子進(jìn)程，要怎樣才能把請(qǐng)求分配給空閑子進(jìn)程處理呢？(就像php-fpm那樣，一個(gè)子進(jìn)程只處理一個(gè)請(qǐng)求，請(qǐng)求結(jié)束后進(jìn)程銷毀，這樣就不會(huì)因?yàn)橐粋€(gè)請(qǐng)求影響到另外一個(gè)請(qǐng)求)

同時(shí)發(fā)起10個(gè)請(qǐng)求，其中端口42610發(fā)起的請(qǐng)求被分配到了子進(jìn)程12086上面（12806進(jìn)程此時(shí)還在處理42612端口的請(qǐng)求）所以此時(shí)42610只能等待12806進(jìn)程處理完42612的請(qǐng)求，30秒后，42610發(fā)起的請(qǐng)求得到響應(yīng)

請(qǐng)求頭

響應(yīng)頭

Nginx代理配置

      location ~* /v2 {
        proxy_buffering on;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header Host $host;
        proxy_buffer_size 256k;
        proxy_buffers 64 128k;
        proxy_busy_buffers_size 512k;
        proxy_temp_file_write_size 256k;
        proxy_http_version 1.1;
        proxy_set_header Connection "";
        proxy_read_timeout 600;
        proxy_connect_timeout 600;
        proxy_send_timeout 600;
        proxy_pass http://172.19.0.2:8787;
        #proxy_pass http://webman1;
        rewrite  "^/v2/(.*)$" /$1;
        break;
     }

測(cè)試模擬業(yè)務(wù)耗時(shí)20秒，開啟10個(gè)進(jìn)程并發(fā)請(qǐng)求，一共發(fā)起2輪請(qǐng)求

//模擬業(yè)務(wù)耗時(shí)場(chǎng)景
public function test(Request $request)
{
    Log::info(['runTest' => posix_getpid(), 'port' => $request->getRemotePort(), 'time' => time()]);
    Db::select('select sleep(20);');
    return json(['data' => date('Y-m-d H:i:s')]);
}

2023-04-03 通過(guò)作者的幫助問(wèn)題得到解決

1、自定義進(jìn)程中添加一個(gè)處理請(qǐng)求進(jìn)程(config/process.php)

<?php
return [
    'server' => [
        'handler'     => \app\Server::class,
        'listen'      => 'http://0.0.0.0:8686',
        'count'       => 500, // 啟動(dòng)進(jìn)程數(shù)
        'constructor' => [
            'request_class' => \support\Request::class, // request類設(shè)置
            'logger'        => \support\Log::channel('default'), // 日志實(shí)例
            'app_path'      => app_path(), // app目錄位置
            'public_path'   => public_path() // public目錄位置
        ]
    ]
];

2、處理請(qǐng)求類源碼(app/server.php)

<?php

namespace app;

use Webman\App;
use Workerman\Connection\TcpConnection;

class Server extends App
{
    public function onConnect(TcpConnection $connection)
    {
        $connection->worker->pauseAccept();
    }

    public function onMessage($connection, $request)
    {
        parent::onMessage($connection, $request);
        $connection->worker->resumeAccept();
    }

    public function onClose($connection)
    {
        $connection->worker->resumeAccept();
    }
}

3、把原來(lái)執(zhí)行8787端口的請(qǐng)求指向8686

經(jīng)過(guò)測(cè)試，已經(jīng)達(dá)到目的，最大并發(fā)量等于啟動(dòng)的server進(jìn)程數(shù)，并發(fā)高的時(shí)候增加config/process.php 里server進(jìn)程的count啟動(dòng)進(jìn)程數(shù)量就行