swoole websocket客户端 断线自动重连

在Swoole中，WebSocket客户端可以通过设置`Swoole\Client`的`onClose`事件来实现断线自动重连。具体步骤如下：

1. 首先创建WebSocket客户端对象：

$client = new Swoole\Client(SWOOLE_SOCK_TCP | SWOOLE_SSL);

2. 设置WebSocket客户端的连接参数：

$client->set([
    'open_websocket_protocol' => true,
    'websocket_compression' => true,
    'websocket_mask' => true,
    'websocket_subprotocol' => 'chat',
]);

3. 设置WebSocket客户端的事件回调函数：

$client->on('connect', function ($client) {
    echo "Connected successfully.\n";
});

$client->on('receive', function ($client, $data) {
    echo "Received data: $data \n";
});

$client->on('error', function ($client) {
    echo "Error occurred.\n";
});

$client->on('close', function ($client) {
    echo "Connection closed.\n";
    // 断线重连
    swoole_timer_after(5000, function () use ($client) {
        $client->connect('127.0.0.1', 9501);
    });
});

4. 连接WebSocket服务器：

$client->connect('127.0.0.1', 9501);

在`onClose`事件中，使用`swoole_timer_after`函数实现5秒后自动重连，即断线自动重连的功能。

完整代码示例：

<?php

$client = new Swoole\Client(SWOOLE_SOCK_TCP | SWOOLE_SSL);

$client->set([
    'open_websocket_protocol' => true,
    'websocket_compression' => true,
    'websocket_mask' => true,
    'websocket_subprotocol' => 'chat',
]);

$client->on('connect', function ($client) {
    echo "Connected successfully.\n";
});

$client->on('receive', function ($client, $data) {
    echo "Received data: $data \n";
});

$client->on('error', function ($client) {
    echo "Error occurred.\n";
});

$client->on('close', function ($client) {
    echo "Connection closed.\n";
    // 断线重连
    swoole_timer_after(5000, function () use ($client) {
        $client->connect('127.0.0.1', 9501);
    });
});

$client->connect('127.0.0.1', 9501);