golang端口转发流量统计

在现代的网络环境中，很多时候我们需要对网络流量进行转发和统计。比如，我们可能需要将来自不同地区的用户请求转发到不同的后端服务器上，并且需要对这些流量进行统计和分析。在Golang中实现端口转发并统计流量非常方便，让我们来看看如何做到。

使用net包实现端口转发

Golang提供了net包，该包可以用于创建网络服务器和客户端。我们可以使用该包中的函数来创建一个TCP服务器，并在接收到客户端请求后，将请求转发到其他服务器。下面是一个简单的示例代码：

package main

import (
    "io"
    "log"
    "net"
)

func main() {
    // 创建一个TCP服务器
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal(err)
    }

    for {
        // 接收客户端请求
        conn, err := listener.Accept()
        if err != nil {
            log.Fatal(err)
        }

        // 启动一个新的goroutine处理连接
        go handleConnection(conn)
    }
}

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

    // 连接到目标服务器
    targetConn, err := net.Dial("tcp", "www.example.com:80")
    if err != nil {
        log.Println(err)
        return
    }
    defer targetConn.Close()

    // 将客户端请求转发到目标服务器
    go io.Copy(targetConn, conn)

    // 将目标服务器的响应转发回客户端
    io.Copy(conn, targetConn)
}

统计转发流量

现在我们已经实现了一个简单的端口转发服务器，但是我们还需要对流量进行统计。幸运的是，Golang提供了一些简单且强大的工具来完成这个任务。我们可以使用net包中的Conn接口的Read和Write方法来统计发送和接收的字节数。

首先，我们需要创建一个结构体来保存转发的流量统计信息：

type Stats struct {
    TotalBytesSent     int64
    TotalBytesReceived int64
}

func (s *Stats) IncrementBytesSent(n int) {
    atomic.AddInt64(&s.TotalBytesSent, int64(n))
}

func (s *Stats) IncrementBytesReceived(n int) {
    atomic.AddInt64(&s.TotalBytesReceived, int64(n))
}

func (s *Stats) GetTotalBytesSent() int64 {
    return atomic.LoadInt64(&s.TotalBytesSent)
}

func (s *Stats) GetTotalBytesReceived() int64 {
    return atomic.LoadInt64(&s.TotalBytesReceived)
}

然后，在handleConnection函数中调用统计方法以获取流量信息：

func handleConnection(conn net.Conn, stats *Stats) {
    defer conn.Close()

    // 连接到目标服务器
    targetConn, err := net.Dial("tcp", "www.example.com:80")
    if err != nil {
        log.Println(err)
        return
    }
    defer targetConn.Close()

    // 将客户端请求转发到目标服务器
    go func() {
        bytesSent, err := io.Copy(targetConn, conn)
        if err != nil {
            log.Println(err)
            return
        }
        stats.IncrementBytesSent(int(bytesSent))
    }()

    // 将目标服务器的响应转发回客户端
    bytesReceived, err := io.Copy(conn, targetConn)
    if err != nil {
        log.Println(err)
        return
    }
    stats.IncrementBytesReceived(int(bytesReceived))
}

输出统计结果

最后，我们可以在服务器中添加一个API接口来输出流量统计结果。以下是一个简单的示例代码：

// 创建一个HTTP服务器
http.ListenAndServe(":8888", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    // 输出流量统计结果
    fmt.Fprintf(w, "Total Bytes Sent: %d\n", stats.GetTotalBytesSent())
    fmt.Fprintf(w, "Total Bytes Received: %d\n", stats.GetTotalBytesReceived())
}))

现在，我们已经实现了一个能够转发并统计流量的Golang服务器。通过使用net包提供的功能和统计方法，我们可以很方便地实现这个功能。当然，根据具体应用场景的需求，我们还可以对代码进行进一步的优化和完善。