골랑 TCP 전달-Golang-php.cn

골랑 TCP 전달

WBOY

풀어 주다： 2023-05-16 13:38:37

원래의

965명이 탐색했습니다.

Golang TCP 포워딩: 기본 및 응용 시나리오 구현

TCP 포워딩은 데이터 전송에 일반적으로 사용되는 기술입니다. 주요 기능은 서버에서 수신한 TCP 연결 요청을 다른 서버로 전달하여 처리함으로써 데이터 트래픽을 분산시키는 것입니다. 시스템의 로드 용량을 향상시키기 위해 서버에 여러 개를 추가합니다. 이 기사에서는 Golang TCP 전달의 구현 기반과 응용 시나리오를 자세히 소개합니다.

1. 구현 기반

Golang TCP 전달 구현 기반을 소개하기 전에 Golang의 TCP 네트워크 프로그래밍을 간략하게 소개하겠습니다. Go 언어는 TCP 네트워크 프로그래밍과 관련된 기능과 인터페이스를 포함하는 일련의 표준 라이브러리를 제공합니다. 이러한 기능과 인터페이스를 통해 Golang TCP 전달 기능을 구현할 수 있습니다. 다음은 간단한 샘플 코드입니다.

package main

import (
    "fmt"
    "net"
)

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer ln.Close()

    for {
        conn, err := ln.Accept()
        if err != nil {
            fmt.Println(err)
            continue
        }
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()

    buf := make([]byte, 4096)
    for {
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println(err)
            return
        }
        fmt.Println(string(buf[:n]))
    }
}

로그인 후 복사

위 코드는 net.Listen 함수를 통해 포트 8080을 수신하는 TCP 서버를 생성하고, ln.Accept 함수를 통해 TCP 연결 요청을 받은 다음 고루틴을 활성화하여 연결을 처리합니다. 연결에 데이터가 있는 경우 읽어들이면 conn.Read 함수를 통해 데이터를 읽어서 콘솔에 출력합니다. 물론 이것만으로는 TCP 포워딩 기능을 구현하기에 충분하지 않습니다. 아래에서는 TCP 포워딩 기능을 구현하는 방법에 대해 자세히 설명합니다.

Golang TCP 전달은 다음 두 가지 방법으로 구현할 수 있습니다.

방법 1: 원래 TCP 전달

원래 TCP 전달의 구현은 주로 net.ListenTCP와 ip를 사용하여 net 패키지에서 제공하는 기능을 통해 매우 간단합니다. 이 함수는 IP와 포트를 수신하는 TCP 서버를 생성한 후 AcceptTCP 메서드를 통해 클라이언트로부터 요청을 받습니다. 요청이 수신되면 즉시 새로운 TCP 연결이 설정되고 클라이언트가 보낸 데이터가 투명하게 대상 서버로 전달되어 TCP 데이터 전달이 실현됩니다.

package main

import (
    "fmt"
    "io"
    "net"
)

func main() {
    listener, err := net.ListenTCP("tcp", &net.TCPAddr{
        IP:   net.ParseIP("0.0.0.0"),
        Port: 8888,
    })
    if err != nil {
        panic(err.Error())
    }
    defer listener.Close()

    targetTcpAddr, err := net.ResolveTCPAddr("tcp", "172.16.100.101:80")
    if err != nil {
        panic(err.Error())
    }

    for {
        clientConn, err := listener.AcceptTCP()
        if err != nil {
            fmt.Println(err)
            continue
        }
        go handleConnection(clientConn, targetTcpAddr)
    }
}

func handleConnection(clientConn *net.TCPConn, targetAddr *net.TCPAddr) {
    defer clientConn.Close()

    targetConn, err := net.DialTCP("tcp", nil, targetAddr)
    if err != nil {
        fmt.Println(err)
        return
    }
    defer targetConn.Close()

    io.Copy(targetConn, clientConn)
    io.Copy(clientConn, targetConn)
}

로그인 후 복사

방법 2: HTTP 프록시 기반 TCP 전달

HTTP 프록시는 클라이언트의 요청을 프록시 서버를 통해 대상 서버로 전달할 수 있는 일반적인 네트워크 전송 프로토콜입니다. TCP 전달을 구현하기 위해 프록시 아이디어를 사용하는 것은 TCP 데이터 패킷을 HTTP 요청으로 캡슐화하고, HTTP 프록시 서버를 사용하여 요청을 대상 서버에 전달한 다음, 대상 서버에서 반환된 데이터를 HTTP 응답으로 캡슐화하고 반환하는 것입니다. 클라이언트에게요.

package main

import (
    "fmt"
    "io"
    "net"
    "net/http"
)

func main() {
    http.HandleFunc("/", handleRequest)
    http.ListenAndServe(":8080", nil)
}

func handleRequest(w http.ResponseWriter, req *http.Request) {
    if req.Method != "CONNECT" {
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }

    targetAddr := req.Host
    targetConn, err := net.Dial("tcp", targetAddr)
    if err != nil {
        fmt.Println(err)
        http.Error(w, "Internal server error", http.StatusInternalServerError)
        return
    }
    defer targetConn.Close()

    w.WriteHeader(http.StatusOK)
    hijacker, ok := w.(http.Hijacker)
    if !ok {
        http.Error(w, "Internal server error", http.StatusInternalServerError)
        return
    }

    clientConn, _, err := hijacker.Hijack()
    if err != nil {
        return
    }
    defer clientConn.Close()

    go func() {
        io.Copy(targetConn, clientConn)
    }()
    io.Copy(clientConn, targetConn)
}

로그인 후 복사

위 코드는 간단한 HTTP 프록시 서버를 구현합니다. 클라이언트가 프록시 서버에 연결되면 프록시 서버는 HTTP 요청 헤더에서 대상 서버의 주소를 구문 분석하고 대상 서버와 TCP 연결을 설정합니다. 클라이언트와 연결을 설정하면 TCP 연결이 클라이언트의 HTTP 요청을 대상 서버로 전달합니다. 대상 서버가 데이터를 반환할 때 HTTP 응답을 통해 클라이언트에도 데이터를 반환합니다.

2. 애플리케이션 시나리오

TCP 전달은 매우 실용적인 네트워크 기술이며 로드 밸런싱, 고가용성, 데이터 가속 및 기타 시나리오에 자주 사용됩니다. 다음은 실제 애플리케이션에서 TCP 전달의 여러 시나리오를 소개합니다.

시나리오 1: HTTP 로드 밸런싱

웹사이트나 애플리케이션에서 사용자 요청의 양이 커지면 하나의 서버가 이러한 큰 압력을 견딜 수 없는 경우가 많습니다. 이때 요청을 분산하려면 TCP 전달 기술을 사용해야 합니다. 로드 밸런싱을 달성하기 위해 각 서버에서 처리됩니다. HTTP 프로토콜은 TCP 프로토콜을 기반으로 하므로 HTTP 프로토콜과 함께 TCP 전달을 사용하는 것을 고려하고 HTTP 로드 밸런싱을 사용하여 구현할 수 있습니다.

시나리오 2: 고가용성 TCP 서비스

분산 시스템에서는 고가용성을 달성하기 위해 동시에 여러 서버에서 동일한 서비스를 제공하는 프로그램을 시작해야 하는 경우가 많습니다. 기존 TCP 프로토콜을 사용하는 경우 모든 서버의 IP 주소와 포트 번호를 클라이언트 프로그램에 하드 코딩해야 합니다. 그러나 서버가 다운되면 새 시스템을 다시 온라인 상태로 가져와야 하며 소프트웨어도 마찬가지입니다. 대규모의 경우 적용하기가 매우 번거롭습니다. TCP 전달 기술을 사용하면 투명하고 가용성이 높은 TCP 서비스를 얻을 수 있습니다. 전달 서버는 연결 요청을 사용 가능한 서버에 전달하고 서버에서 반환한 데이터를 클라이언트에 반환하기만 하면 됩니다. . 원활한 고가용성을 달성합니다.

시나리오 3: 가속화된 데이터 전송

TCP 전송은 세그먼트 단위로 수행되며 데이터 전송 속도를 크게 높일 수 있습니다. 그러나 TCP 데이터 세그먼트의 크기는 기본 프로토콜 스택에 의해 자동으로 제어되므로 사용자 요구 사항을 충족할 수 없는 경우가 많습니다. TCP 전달 기술을 통해 TCP 세그먼트 크기를 사용자 정의하고 분할 후 데이터를 대상 서버로 투명하게 전달하여 데이터 전송 속도를 높일 수 있습니다.

3. 요약

이 글에서는 Golang TCP 포워딩의 구현 기반과 응용 시나리오를 자세히 소개합니다. Golang TCP 전달은 로드 밸런싱, 고가용성, 데이터 가속 및 기타 시나리오에서 자주 사용되는 매우 실용적인 네트워크 기술입니다. TCP 전달을 이해함으로써 네트워크의 데이터 전송 메커니즘을 더 잘 이해할 수 있으며 애플리케이션 및 시스템 개발을 위한 더 많은 아이디어와 솔루션을 제공할 수 있습니다.

위 내용은 골랑 TCP 전달의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!