Comment utiliser Swoole pour implémenter un serveur relais TCP

Swoole est un framework de communication réseau hautes performances basé sur le langage PHP. Il fournit des fonctionnalités asynchrones, simultanées, basées sur les événements et autres, et prend en charge TCP, UDP, HTTP, WebSocket et d'autres protocoles. Dans cet article, nous explorerons comment utiliser Swoole pour implémenter un serveur relais TCP, tout en fournissant des exemples de code spécifiques.

Le serveur relais TCP est généralement utilisé pour relayer des données sur le réseau. Par exemple, un client A souhaite envoyer des données à un autre client B, mais A et B ne peuvent pas communiquer directement. Dans ce cas, cela peut être transmis via un relais TCP. données du serveur.

Vous devez faire attention aux points suivants lors de la mise en œuvre d'un serveur relais TCP :

1. Recevoir la demande de connexion du client, créer la connexion correspondante
2. Écouter les données de toutes les connexions et transmettre les données à la connexion cible
3. Gérer la situation de déconnexion de connexion en temps opportun Nettoyer les ressources de connexion

Ce qui suit utilise un exemple spécifique pour montrer comment utiliser Swoole pour implémenter un serveur relais TCP.

Tout d'abord, nous définissons un tableau pour stocker les informations de chaque connexion client :

$clients = [];

Ensuite, créons un objet serveur Swoole TCP et définissons les paramètres pertinents :

$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,         //调试模式
]);

Lorsque le serveur démarre, nous enregistrons la fonction de rappel, utilisée pour gérer les événements de connexion :

$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
    ];
});

Lorsqu'un client se connecte au serveur, les informations « Client : Connexion » seront affichées et les informations de connexion du client seront stockées dans le tableau.

Ensuite, nous enregistrons une fonction de rappel pour traiter les données reçues :

$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);
});

Lorsqu'il y a une transmission de données, le contenu des données sera obtenu en fonction des informations de connexion client, une connexion cible inutilisée est trouvée et les données sont transmises. La connexion cible est transférée.

Enfin, nous enregistrons une fonction de rappel pour gérer l'événement de déconnexion de connexion :

$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]);
});

Lorsqu'une connexion client est déconnectée, le message « Client : Fermer ».

Ce qui précède est l'implémentation d'un simple serveur relais TCP. Grâce à l'exemple de code ci-dessus, nous pouvons voir que l'utilisation de Swoole pour implémenter un serveur relais TCP est très simple. Il vous suffit de définir les paramètres pertinents, d'enregistrer les fonctions de rappel et d'écrire. pour chaque événement Juste la logique correspondante.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!