webman如何实现把异步请求上游的结果发送给下游？

实现了一个不太好的方案如下，但是该方案会有一个问题，不会关闭连接。请问官方有没有计划支持类似的场景

新建文件
support\HoldConnetion.php, 代码如下：

<?php

namespace support;

use Workerman\Connection\TcpConnection;

class HoldConnetion
{
    public static function encode($response, TcpConnection $connection)
    {
        return '';
    }
}

修改TestController的代码如下：

use support\HoldConnetion;
use support\Request;
use Webman\App;
use Workerman\Http\Client;

class TestController
{

    public function test(Request $r)
    {
        $options = [
            'max_conn_per_addr' => 128, // 每个地址最多维持多少并发连接
            'keepalive_timeout' => 15,  // 连接多长时间不通讯就关闭
            'connect_timeout'   => 30,  // 连接超时时间
            'timeout'           => 30,  // 等待响应的超时时间
        ];

        $http = new Client($options);
        $conn = App::connection();
        $url = $r->input('url');

        $protocol = $conn->protocol; // 保留旧的protocol
        $conn->protocol = new HoldConnetion();

        $http->get($url, function($response) use ($conn, $protocol) {
            $body = $response->getBody();

            $conn->protocol = $protocol; // 恢复旧的protocol

            $conn->send(response($body)); // <--- 异步发送给客户端

        }, function($exception){
            echo $exception;
        });

        return '不会发送到客户端';   // <-- 修改protocol后，这部分内容不会再发送到客户端
    }
}

异步请请求建议用自定义进程去做。

process/api.php

<?php
/**
 * This file is part of webman.
 *
 * Licensed under The MIT License
 * For full copyright and license information, please see the MIT-LICENSE.txt
 * Redistributions of files must retain the above copyright notice.
 *
 * @author    walkor<walkor@workerman.net>
 * @copyright walkor<walkor@workerman.net>
 * @link      http://www.workerman.net/
 * @license   http://www.opensource.org/licenses/mit-license.php MIT License
 */

namespace process;

use Workerman\Connection\TcpConnection;
use Workerman\Http\Client;
use Workerman\Protocols\Http\Request;

class Api
{
    public function onMessage(TcpConnection $connection, Request $request)
    {
        if ($request->path() == '/test/test') {
            $options = [
                'max_conn_per_addr' => 128, // 每个地址最多维持多少并发连接
                'keepalive_timeout' => 15,  // 连接多长时间不通讯就关闭
                'connect_timeout'   => 30,  // 连接超时时间
                'timeout'           => 30,  // 等待响应的超时时间
            ];
            $http = new Client($options);

            $http->get('http://www.baidu.com', function($response) use ($connection) {
                $body = (string)$response->getBody();
                echo $body;
                $connection->send(response($body));
            }, function($exception){
                echo $exception;
            });
            return;
        }
        $connection->send(response('404 not found'), 404);
    }
}

config/process.php

return [
    // ....

    'api' => [
        'handler' => \process\Api::class,
        'listen' => 'http://0.0.0.0:8686',
        'count' => 4,
    ]
];

访问 http://127.0.0.1:8686/test/test

nginx做个代理，将需要异步的接口比如/test/test转发到端口8686即可

现在可以用php8.1 workerman V5 协程了，贼屌