實(shí)現(xiàn)了一個(gè)不太好的方案如下，但是該方案會(huì)有一個(gè)問(wèn)題，不會(huì)關(guān)閉連接。請(qǐng)問(wèn)官方有沒(méi)有計(jì)劃支持類似的場(chǎng)景

新建文件
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, // 每個(gè)地址最多維持多少并發(fā)連接
            'keepalive_timeout' => 15,  // 連接多長(zhǎng)時(shí)間不通訊就關(guān)閉
            'connect_timeout'   => 30,  // 連接超時(shí)時(shí)間
            'timeout'           => 30,  // 等待響應(yīng)的超時(shí)時(shí)間
        ];

        $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; // 恢復(fù)舊的protocol

            $conn->send(response($body)); // <--- 異步發(fā)送給客戶端

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

        return '不會(huì)發(fā)送到客戶端';   // <-- 修改protocol后，這部分內(nèi)容不會(huì)再發(fā)送到客戶端
    }
}

異步請(qǐng)請(qǐng)求建議用自定義進(jìn)程去做。

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.wtbis.cn/
 * @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, // 每個(gè)地址最多維持多少并發(fā)連接
                'keepalive_timeout' => 15,  // 連接多長(zhǎng)時(shí)間不通訊就關(guān)閉
                'connect_timeout'   => 30,  // 連接超時(shí)時(shí)間
                'timeout'           => 30,  // 等待響應(yīng)的超時(shí)時(shí)間
            ];
            $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,
    ]
];

訪問(wèn) http://127.0.0.1:8686/test/test

nginx做個(gè)代理，將需要異步的接口比如/test/test轉(zhuǎn)發(fā)到端口8686即可

現(xiàn)在可以用php8.1 workerman V5 協(xié)程了，賊屌