swoole_client->close

最后更新于:2022-04-02 06:36:46

# swoole\_client->close [TOC] 关闭连接,函数原型为: ~~~ bool $swoole_client->close(bool $force = false); ~~~ 操作成功返回**true**。当一个swoole\_client连接被close后不要再次发起connect。正确的做法是销毁当前的swoole\_client,重新创建一个swoole\_client并发起新的连接。 * 第一个参数设置为`true`表示强制关闭连接,可用于关闭`SWOOLE_KEEP`长连接 > swoole\_client对象在析构时会自动close ## 异步客户端 客户端`close`会立即关闭连接,如果发送队列中仍然有待数据,底层会丢弃。请勿在大量发送数据后,立即`close`,否则发送的数据未必能真正到达服务器端。 #### 错误实例 ~~~ $client = new swoole_client(SWOOLE_TCP | SWOOLE_ASYNC); $client->on("connect", function(swoole_client $cli) { }); $client->on("receive", function(swoole_client $cli, $data){ $cli->send(str_repeat('A', 1024*1024*4)."\n"); $cli->close(); }); $client->on("error", function(swoole_client $cli){ echo "error\n"; }); $client->on("close", function(swoole_client $cli){ echo "Connection close\n"; }); $client->connect('127.0.0.1', 9501); ~~~ 客户端发送了`4M`数据,实际传输可能需要一段时间。这是立即进行了`close`操作,可能只有小部分数据传输成功。大部分数据在发送队列中排队等待发送,`close`时会丢弃这些数据。 #### 解决方案 * 配合使用`onBufferEmpty`,等待发送队列为空时进行`close`操作 * 协议设计为`onReceive`收到数据后主动关闭连接,发送数据时对端主动关闭连接 ~~~ $client = new swoole_client(SWOOLE_TCP | SWOOLE_ASYNC); $client->on("connect", function(swoole_client $cli) { }); $client->on("receive", function(swoole_client $cli, $data){ $cli->send(str_repeat('A', 1024*1024*4)."\n"); }); $client->on("error", function(swoole_client $cli){ echo "error\n"; }); $client->on("close", function(swoole_client $cli){ echo "Connection close\n"; }); $client->on("bufferEmpty", function(swoole_client $cli){ $cli->close(); }); $client->connect('127.0.0.1', 9501); ~~~
';