webman明明还有空闲子进程，为什么接收到新请求时却分配不到空闲进程

问题描述

webman明明还有空闲子进程，为什么接收到新请求时却分配不到空闲进程？

进程（webman子进程）
客户端（发起请求的IP+发起请求时所使用的端口号）

经过测试发现一个现象，webman在处理请求时，似乎会把该进程和客户端做一个绑定关系，该客户端下次发起请求时，webman会用该客户端上一次使用过的子进程进行处理；

这样就会出现一个问题，可能这一个子进程绑定了多个客户端，假设该子进程在处理某一次请求时耗时30秒钟，在此期间与该子进程绑定的客户端发起新的请求就都会阻塞住（直到30秒钟后才能响应请求，因为此时子进程处于阻塞状态），但是此时还有很多其它的空闲子进程，要怎样才能把请求分配给空闲子进程处理呢？(就像php-fpm那样，一个子进程只处理一个请求，请求结束后进程销毁，这样就不会因为一个请求影响到另外一个请求)

同时发起10个请求，其中端口42610发起的请求被分配到了子进程12086上面（12806进程此时还在处理42612端口的请求）所以此时42610只能等待12806进程处理完42612的请求，30秒后，42610发起的请求得到响应

请求头

响应头

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;
     }

测试模拟业务耗时20秒，开启10个进程并发请求，一共发起2轮请求

//模拟业务耗时场景
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 通过作者的帮助问题得到解决

1、自定义进程中添加一个处理请求进程(config/process.php)

<?php
return [
    'server' => [
        'handler'     => \app\Server::class,
        'listen'      => 'http://0.0.0.0:8686',
        'count'       => 500, // 启动进程数
        'constructor' => [
            'request_class' => \support\Request::class, // request类设置
            'logger'        => \support\Log::channel('default'), // 日志实例
            'app_path'      => app_path(), // app目录位置
            'public_path'   => public_path() // public目录位置
        ]
    ]
];

2、处理请求类源码(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、把原来执行8787端口的请求指向8686

经过测试，已经达到目的，最大并发量等于启动的server进程数，并发高的时候增加config/process.php 里server进程的count启动进程数量就行