发表新帖

我想问下我这边有个需求应该怎么样处理

### 问题描述
就是我需要同时用到服务端和客户端。也就是代理服务器

比如我要开启个服务端，这个服务端onworkerstart的时候创建一个客户端并和一个外部的服务器保持长连接。可能需要开启N个WORKER。每个WORKER里都需要作为客户端连接这个外部服务器

当我的用户请求服务端的时候，在某些业务里我会向外部的服务器请求然后拿到外部服务器返回的数据后，然后在返回给用户。

我应该怎么做？

另外我看了下我做为客户端接收外部服务器的返回的时候，recv的超时设置了1秒。现在的是有点问题。问题是即使我没有发送数据过去。程序也会一直判断我是超时的。我想要的效果是。我发送了数据到外部服务器。外部服务器返回很慢。比如超过了3秒。那么这次请求我就废弃掉。而不是一直报出超时

代码如下

### Swoole版本，PHP版本，以及操作系统版本信息
SWOOLE4.6  PHP7.4  操作系统LINUX

### 相关代码
以前我可以这样写：
```php
class ProxyServer
{
    protected $clients;
    protected $backends;
    protected $serv;

function run()
    {
        $serv = swoole_server_create("127.0.0.1", 9509);
        swoole_server_set($serv, array(
            'timeout' => 1, //select and epoll_wait timeout.
            'poll_thread_num' => 1, //reactor thread num
            'worker_num' => 1, //reactor thread num
            'backlog' => 128, //listen backlog
            'max_conn' => 10000,
            'dispatch_mode' => 2,
            //'open_tcp_keepalive' => 1,
            'log_file' => '/tmp/swoole.log', //swoole error log
        ));
        swoole_server_handler($serv, 'onWorkerStart', array($this, 'onStart'));
        swoole_server_handler($serv, 'onConnect', array($this, 'onConnect'));
        swoole_server_handler($serv, 'onReceive', array($this, 'onReceive'));
        swoole_server_handler($serv, 'onClose', array($this, 'onClose'));
        swoole_server_handler($serv, 'onWorkerStop', array($this, 'onShutdown'));
        //swoole_server_addtimer($serv, 2);
        #swoole_server_addtimer($serv, 10);
        swoole_server_start($serv);
    }

function onStart($serv)
    {
        $this->serv = $serv;
        echo "Server: start.Swoole version is [" . SWOOLE_VERSION . "]\n";
    }

function onShutdown($serv)
    {
        echo "Server: onShutdown\n";
    }

function onClose($serv, $fd, $from_id)
    {
        //backend
        if (isset($this->clients[$fd])) {
            $backend_client = $this->clients[$fd]['socket'];
            unset($this->clients[$fd]);
            $backend_client->close();
            unset($this->backends[$backend_client->sock]);
            echo "client close\n";
        }
    }

function onReceive($serv, $fd, $from_id, $data)
    {
        echo microtime() . ": client receive\n";
        $backend_socket = $this->clients[$fd]['socket'];
        $backend_socket->send($data);
        echo microtime() . ": send to backend\n";
        echo str_repeat('-', 100) . "\n";
    }
}

$serv = new ProxyServer();
$serv->run();
```

但现在升级到4.x版本后 不知道咋弄了。

### 你期待的结果是什么？实际看到的错误信息又是什么？

发布于2年前 · 18 次浏览 · 来自提问