发表新帖

Channel实现的协程版TcpClient连接池无法复用

### 问题描述
Channel实现的协程版TcpClient连接池无法复用, 如代码中, 只能成功send与recv 16次, 之后重新从channel push 再pop的连接实例无法正常send, 不知道什么原因

### Swoole版本，PHP版本，以及操作系统版本信息
```bash
swoole

Swoole => enabled
Author => Swoole Team <team@swoole.com>
Version => 4.4.18
Built => Apr 30 2020 19:27:06
coroutine => enabled
epoll => enabled
eventfd => enabled
signalfd => enabled
spinlock => enabled
rwlock => enabled
sockets => enabled
http2 => enabled
pcre => enabled
zlib => 1.2.11
mutex_timedlock => enabled
pthread_barrier => enabled
futex => enabled
mysqlnd => enabled
async_redis => enabled

Directive => Local Value => Master Value
swoole.enable_coroutine => On => On
swoole.enable_library => On => On
swoole.enable_preemptive_scheduler => Off => Off
swoole.display_errors => On => On
swoole.use_shortname => On => On
swoole.unixsock_buffer_size => 8388608 => 8388608
```

### 相关代码
```php
<?php
use Swoole\Coroutine\Channel;
use Swoole\Coroutine\Client;
use Swoole\Coroutine\Server;
use Swoole\Process;

function run() {
    $process = new Process(function () {
        $server = new Server('unix:/var/run/rpc.sock', 0);
//        $server = new Server('0.0.0.0', 9505);
        //收到15信号关闭服务
        Process::signal(SIGTERM, function () use ($server) {
            $server->shutdown();
        });
        $server->handle(function (Server\Connection $connection) {
            try {
                $requestData = $connection->recv();
                var_dump('receive', $requestData);
                $connection->send($requestData);
            } catch (Throwable $exception) {
                echo "RpcException {$exception->getMessage()}\n";
            }
        });
        $server->start();
    }, 0, 1, true);
    $process->start();

usleep(100000);

for ($i = 0; $i < 200; $i ++ ) {
        go(function () {
            clientTest();
        });
    }
}

function clientTest() {
//        $instance = new Client(SWOOLE_SOCK_UNIX_STREAM);
//        $instance->connect(RpcUtility::DEFAULT_TCP_HOST, 0);
    $instance = simplePool()->pop();
    $rand = mt_rand();
    var_dump('send', $rand);
    if (! $instance->send($rand)) {
        var_dump('err', $rand, $instance->errMsg, $instance->errCode);
    }
    $response = $instance->recv(-1);
    if ($instance->errCode > 0) {
//        var_dump('err', $instance->errMsg, $instance->errCode);
    }
    var_dump('result', $response);
    simplePool()->push($instance);
//        $instance->close();
}

function simplePool() : Channel {
    static $pool = null;
    if (null === $pool) {
        $pool = new Channel(100);
        for ($i = 0; $i < 16; $i ++) {
            $instance = new Client(SWOOLE_SOCK_UNIX_STREAM);
//            $instance = new Client(SWOOLE_SOCK_UDP);
            $instance->connect('/var/run/rpc.sock', 0);
//            $instance->connect('0.0.0.0', 9505);
            $pool->push($instance);
        }
    }
    return $pool;
}

run();
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
希望能一直反复利用, 200个循环全部成功, 但实际上每个连接用了一次就失效或断开了

发布于4年前 · 1 次浏览 · 来自提问

### 问题描述
Channel实现的协程版TcpClient连接池无法复用, 如代码中, 只能成功send与recv 16次, 之后重新从channel push 再pop的连接实例无法正常send, 不知道什么原因

### Swoole版本，PHP版本，以及操作系统版本信息
```bash
swoole

Swoole => enabled
Author => Swoole Team <team@swoole.com>
Version => 4.4.18
Built => Apr 30 2020 19:27:06
coroutine => enabled
epoll => enabled
eventfd => enabled
signalfd => enabled
spinlock => enabled
rwlock => enabled
sockets => enabled
http2 => enabled
pcre => enabled
zlib => 1.2.11
mutex_timedlock => enabled
pthread_barrier => enabled
futex => enabled
mysqlnd => enabled
async_redis => enabled

Directive => Local Value => Master Value
swoole.enable_coroutine => On => On
swoole.enable_library => On => On
swoole.enable_preemptive_scheduler => Off => Off
swoole.display_errors => On => On
swoole.use_shortname => On => On
swoole.unixsock_buffer_size => 8388608 => 8388608
```

### 相关代码
```php
<?php
use Swoole\Coroutine\Channel;
use Swoole\Coroutine\Client;
use Swoole\Coroutine\Server;
use Swoole\Process;

function run() {
    $process = new Process(function () {
        $server = new Server('unix:/var/run/rpc.sock', 0);
//        $server = new Server('0.0.0.0', 9505);
        //收到15信号关闭服务
        Process::signal(SIGTERM, function () use ($server) {
            $server->shutdown();
        });
        $server->handle(function (Server\Connection $connection) {
            try {
                $requestData = $connection->recv();
                var_dump('receive', $requestData);
                $connection->send($requestData);
            } catch (Throwable $exception) {
                echo "RpcException {$exception->getMessage()}\n";
            }
        });
        $server->start();
    }, 0, 1, true);
    $process->start();

usleep(100000);

for ($i = 0; $i < 200; $i ++ ) {
        go(function () {
            clientTest();
        });
    }
}

function clientTest() {
//        $instance = new Client(SWOOLE_SOCK_UNIX_STREAM);
//        $instance->connect(RpcUtility::DEFAULT_TCP_HOST, 0);
    $instance = simplePool()->pop();
    $rand = mt_rand();
    var_dump('send', $rand);
    if (! $instance->send($rand)) {
        var_dump('err', $rand, $instance->errMsg, $instance->errCode);
    }
    $response = $instance->recv(-1);
    if ($instance->errCode > 0) {
//        var_dump('err', $instance->errMsg, $instance->errCode);
    }
    var_dump('result', $response);
    simplePool()->push($instance);
//        $instance->close();
}

function simplePool() : Channel {
    static $pool = null;
    if (null === $pool) {
        $pool = new Channel(100);
        for ($i = 0; $i < 16; $i ++) {
            $instance = new Client(SWOOLE_SOCK_UNIX_STREAM);
//            $instance = new Client(SWOOLE_SOCK_UDP);
            $instance->connect('/var/run/rpc.sock', 0);
//            $instance->connect('0.0.0.0', 9505);
            $pool->push($instance);
        }
    }
    return $pool;
}

run();
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
希望能一直反复利用, 200个循环全部成功, 但实际上每个连接用了一次就失效或断开了

评论

2020-05-20

Twosee

2020-05-20

Drunk 回复 Twosee

微信公众号

Swoole官方公众号

作者其它话题

- http_autoindex参数导致启用ssl时功能异常

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。