如何实现Workerman文档中的反向代理功能

composer require workerman/workerman

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;
use WorkermanConnectionTcpConnection;

$proxy = new Worker('tcp://0.0.0.0:8080');

$proxy->onConnect = function (TcpConnection $connection) {
    // 获取客户端请求头信息
    $headers = $connection->getHeaders();
    
    // 根据请求头信息设置后端服务器地址
    $backend_server = getBackendServer($headers);
    
    // 创建反向代理连接
    $backend_connection = new TcpConnection($backend_server);
    
    // 将客户端请求转发到后端服务器
    $connection->pipe($backend_connection);
    $backend_connection->pipe($connection);
};

// 启动反向代理服务器
Worker::runAll();

function getBackendServer($headers)
{
    // 根据请求头信息动态设置后端服务器地址
    // 这里可以根据具体业务需求进行灵活配置
    
    // 示例1：负载均衡
    $servers = ['tcp://server1:80', 'tcp://server2:80', 'tcp://server3:80'];
    $backend_server = $servers[array_rand($servers)];
    
    // 示例2：根据请求路径选择服务器
    if (strpos($headers['GET'], '/api1/') !== false) {
        $backend_server = 'tcp://server1:80';
    } elseif (strpos($headers['GET'], '/api2/') !== false) {
        $backend_server = 'tcp://server2:80';
    } elseif (strpos($headers['GET'], '/api3/') !== false) {
        $backend_server = 'tcp://server3:80';
    }
    
    return $backend_server;
}