我就廢話不多說了，直接上代碼吧：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
package main import ( "flag" "fmt" "io" "net" "os" "strings" "sync") var lock sync.Mutexvar trueList []stringvar ip stringvar list string func main() { flag.StringVar(&ip, "l", ":9897", "-l=0.0.0.0:9897 指定服務(wù)監(jiān)聽的端口") flag.StringVar(&list, "d", "127.0.0.1:1789,127.0.0.1:1788", "-d=127.0.0.1:1789,127.0.0.1:1788 指定后端的IP和端口,多個(gè)用','隔開") flag.Parse() trueList = strings.Split(list, ",") if len(trueList) <= 0 { fmt.Println("后端IP和端口不能空,或者無效") os.Exit(1) } server()} func server() { lis, err := net.Listen("tcp", ip) if err != nil { fmt.Println(err) return } defer lis.Close() for { conn, err := lis.Accept() if err != nil { fmt.Println("建立連接錯(cuò)誤:%v\n", err) continue } fmt.Println(conn.RemoteAddr(), conn.LocalAddr()) go handle(conn) }} func handle(sconn net.Conn) { defer sconn.Close() ip, ok := getIP() if !ok { return } dconn, err := net.Dial("tcp", ip) if err != nil { fmt.Printf("連接%v失敗:%v\n", ip, err) return } ExitChan := make(chan bool, 1) go func(sconn net.Conn, dconn net.Conn, Exit chan bool) { _, err := io.Copy(dconn, sconn) fmt.Printf("往%v發(fā)送數(shù)據(jù)失敗:%v\n", ip, err) ExitChan <- true }(sconn, dconn, ExitChan) go func(sconn net.Conn, dconn net.Conn, Exit chan bool) { _, err := io.Copy(sconn, dconn) fmt.Printf("從%v接收數(shù)據(jù)失敗:%v\n", ip, err) ExitChan <- true }(sconn, dconn, ExitChan) <-ExitChan dconn.Close()} func getIP() (string, bool) { lock.Lock() defer lock.Unlock() if len(trueList) < 1 { return "", false } ip := trueList[0] trueList = append(trueList[1:], ip) return ip, true} |
以上這篇golang 實(shí)現(xiàn)tcp轉(zhuǎn)發(fā)代理的方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/fyxichen/article/details/51505542
