Swoole을 사용하여 TCP 릴레이 서버를 구현하는 방법

Swoole은 PHP 언어 기반의 고성능 네트워크 통신 프레임워크로 비동기, 동시성, 이벤트 중심 및 기타 기능을 제공하며 TCP, UDP, HTTP, WebSocket 및 기타 프로토콜을 지원합니다. 이 기사에서는 특정 코드 예제를 제공하면서 Swoole을 사용하여 TCP 릴레이 서버를 구현하는 방법을 살펴보겠습니다.

TCP 릴레이 서버는 일반적으로 네트워크에서 데이터를 중계하는 데 사용됩니다. 예를 들어 클라이언트 A가 다른 클라이언트 B에게 데이터를 보내려고 하는데 A와 B가 직접 통신할 수 없는 경우 TCP 릴레이를 통해 전달할 수 있습니다. 서버.

TCP 릴레이 서버 구현 시 주의할 점은 다음과 같습니다.

1. 클라이언트의 연결 요청을 받아 해당 연결을 생성합니다.
2. 모든 연결의 데이터를 듣고 대상 연결로 데이터를 전달합니다.
3. 연결 끊김 상황을 적시에 처리합니다. 연결 리소스 정리

다음은 구체적인 예를 사용하여 Swoole을 사용하여 TCP 릴레이 서버를 구현하는 방법을 보여줍니다.

먼저 각 클라이언트 연결 정보를 저장할 배열을 정의합니다.

$clients = [];

그런 다음 Swoole TCP 서버 객체를 생성하고 관련 매개변수를 설정합니다.

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

서버가 시작되면 콜백 함수를 등록합니다. 연결 이벤트 처리:

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

클라이언트가 서버에 연결되면 "클라이언트: 연결" 정보가 출력되고 클라이언트 연결 정보가 배열에 저장됩니다.

다음으로 수신된 데이터를 처리하기 위한 콜백 함수를 등록합니다.

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

데이터 전송이 있으면 클라이언트 연결 정보에 따라 데이터 내용을 가져오고 사용되지 않은 대상 연결을 찾아 데이터를 전달합니다. 대상 연결이 전달됩니다.

마지막으로 연결 끊김 이벤트를 처리하기 위한 콜백 함수를 등록합니다.

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

클라이언트 연결이 끊어지면 "클라이언트: 닫기" 메시지가 출력되고 연결 정보가 지워집니다.

위는 간단한 TCP 릴레이 서버의 구현입니다. 위의 코드 예제를 통해 Swoole을 사용하여 TCP 릴레이 서버를 구현하는 것은 매우 간단하다는 것을 알 수 있습니다. 관련 매개 변수를 정의하고 콜백 함수를 등록하고 작성하면 됩니다. 각 이벤트에 대해 해당 논리만 있으면 됩니다.

위 내용은 Swoole을 사용하여 TCP 릴레이 서버를 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!