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);
~~~
';