So verwenden Sie Swoole zur Implementierung eines TCP-Relay-Servers

Swoole ist ein leistungsstarkes Netzwerkkommunikations-Framework, das auf der PHP-Sprache basiert. Es bietet asynchrone, parallele, ereignisgesteuerte und andere Funktionen und unterstützt TCP, UDP, HTTP, WebSocket und andere Protokolle. In diesem Artikel untersuchen wir, wie man Swoole zur Implementierung eines TCP-Relay-Servers verwendet, und stellen gleichzeitig spezifische Codebeispiele bereit.

TCP-Relay-Server wird im Allgemeinen zum Weiterleiten von Daten im Netzwerk verwendet. Beispielsweise möchte ein Client A Daten an einen anderen Client B senden, A und B können jedoch nicht direkt über ein TCP-Relay weitergeleitet werden Server.

Bei der Implementierung eines TCP-Relay-Servers müssen Sie auf folgende Punkte achten:

1. Empfangen Sie die Verbindungsanforderung des Clients, erstellen Sie die entsprechende Verbindung
2. Abhören Sie die Daten aller Verbindungen und leiten Sie die Daten an die Zielverbindung weiter
3. Behandeln Sie die Verbindungstrennungssituation rechtzeitig. Bereinigen Sie die Verbindungsressourcen.

Im Folgenden wird anhand eines konkreten Beispiels gezeigt, wie Sie mit Swoole einen TCP-Relay-Server implementieren.

Zuerst definieren wir ein Array, um die Informationen jeder Client-Verbindung zu speichern:

$clients = [];

Dann erstellen wir ein Swoole TCP-Serverobjekt und legen die relevanten Parameter fest:

$server = new swoole_server("0.0.0.0", 9501);

$server->set([
    'worker_num' => 1,         //worker进程数
    'max_request' => 1000,     //每个worker最多处理1000个请求
    'dispatch_mode' => 2,      //使用固定模式
    'debug_mode' => 1,         //调试模式
]);

Wenn der Server startet, registrieren wir die Callback-Funktion, die wir gewohnt sind Verbindungsereignisse verarbeiten:

$server->on('connect', function ($server, $fd) {
    echo "Client: Connect.
";
    //将连接信息存入数组
    $clients[$fd] = [
        'id' => $fd,
        'remote_ip' => $server->getClientInfo($fd)['remote_ip'],
        'remote_port' => $server->getClientInfo($fd)['remote_port'],
        'target_fd' => 0  //默认为0
    ];
});

Wenn ein Client eine Verbindung zum Server herstellt, werden die Informationen „Client: Verbinden“ ausgegeben und die Client-Verbindungsinformationen werden im Array gespeichert.

Als nächstes registrieren wir eine Rückruffunktion, um die empfangenen Daten zu verarbeiten:

$server->on('receive', function ($server, $fd, $from_id, $data) use (&$clients) {
    //如果还没有目标连接，则需要先选择一个
    if (empty($clients[$fd]['target_fd'])) {
        foreach ($clients as $client) {
            if ($client['id'] != $fd && empty($client['target_fd'])) {
                $clients[$fd]['target_fd'] = $client['id'];
                $clients[$client['id']]['target_fd'] = $fd;
                break;
            }
        }
    }

    //将数据转发到目标连接
    $server->send($clients[$fd]['target_fd'], $data);
});

Bei einer Datenübertragung wird der Dateninhalt gemäß den Client-Verbindungsinformationen abgerufen, eine nicht verwendete Zielverbindung gefunden und die Daten weitergeleitet Die Zielverbindung wird weitergeleitet.

Abschließend registrieren wir eine Rückruffunktion, um das Verbindungstrennungsereignis zu verarbeiten:

$server->on('close', function ($server, $fd) use (&$clients) {
    echo "Client: Close.
";
    //清理连接信息
    if (!empty($clients[$fd]['target_fd'])) {
        $target_fd = $clients[$fd]['target_fd'];
        $clients[$target_fd]['target_fd'] = 0;
    }
    unset($clients[$fd]);
});

Wenn eine Clientverbindung getrennt wird, wird die Meldung „Client: Schließen“ ausgegeben und die Verbindungsinformationen werden gelöscht.

Das Obige ist die Implementierung eines einfachen TCP-Relay-Servers. Anhand des obigen Codebeispiels können wir sehen, dass die Verwendung von Swoole zum Implementieren eines TCP-Relay-Servers sehr einfach ist. Sie müssen nur relevante Parameter definieren, Rückruffunktionen registrieren und schreiben Für jedes Ereignis gibt es nur die entsprechende Logik.

Das obige ist der detaillierte Inhalt vonSo verwenden Sie Swoole zur Implementierung eines TCP-Relay-Servers. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!