完成第一版

Author: jeferwang

.gitignore

@@ -0,0 +1 @@
+.idea

README.md

@@ -0,0 +1,15 @@
+# GoProxy代理
+
+HttpProxy有点小Bug没修好，Sock5代理几乎完美，可以拿去用了
+
+启动方法 
+
+```
+chmod a+x ./sock5
+
+# 非后台启动
+./sock5 --port=8081
+
+# 后台启动
+nohup ./sock5 --port=8081
+```

bin/darwin/sock5

@@ -0,0 +1,74 @@
+package main
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+	"log"
+	"net"
+	"net/url"
+	"strings"
+)
+
+func main() {
+	log.SetFlags(log.LstdFlags | log.Lshortfile)
+	l, err := net.Listen("tcp", ":8081")
+	if err != nil {
+		log.Panic(err)
+	}
+
+	for {
+		client, err := l.Accept()
+		if err != nil {
+			log.Panic(err)
+		}
+		go handleClientHttpRequest(client)
+	}
+}
+
+func handleClientHttpRequest(client net.Conn) {
+	if client == nil {
+		return
+	}
+	defer client.Close()
+
+	var b [1024]byte
+	_, err := client.Read(b[:])
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	var method, host, address string
+	fmt.Sscanf(string(b[:bytes.IndexByte(b[:], '\n')]), "%s%s", &method, &host)
+	hostPortURL, err := url.Parse(host)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+
+	if hostPortURL.Opaque == "443" { //https访问
+		address = hostPortURL.Scheme + ":443"
+	} else { //http访问
+		if strings.Index(hostPortURL.Host, ":") == -1 { //host不带端口， 默认80
+			address = hostPortURL.Host + ":80"
+		} else {
+			address = hostPortURL.Host
+		}
+	}
+	fmt.Println(address)
+	//获得了请求的host和port，就开始拨号吧
+	server, err := net.Dial("tcp", address)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer server.Close()
+	if method == "CONNECT" {
+		fmt.Fprint(client, "HTTP/1.1 200 Connection established\r\n\r\n")
+	} else {
+		server.Write(b[:])
+	}
+	//进行转发
+	go io.Copy(server, client)
+	io.Copy(client, server)
+}

bin/linux64/sock5

@@ -0,0 +1,68 @@
+package main
+
+import (
+	"io"
+	"log"
+	"net"
+	"strconv"
+	"flag"
+)
+
+func main() {
+	port := "8081"
+	flag.StringVar(&port, "port", "8081", "请输入服务端绑定的端口")
+	flag.Parse()
+	log.SetFlags(log.LstdFlags | log.Lshortfile)
+	l, err := net.Listen("tcp", ":"+port)
+	if err != nil {
+		log.Panic(err)
+	}
+	for {
+		client, err := l.Accept()
+		if err != nil {
+			log.Panic(err)
+		}
+		go handleClientSockRequest(client)
+	}
+}
+func handleClientSockRequest(client net.Conn) {
+	if client == nil {
+		return
+	}
+	defer client.Close()
+	var b [1024]byte
+	n, err := client.Read(b[:])
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	//判断是不是Sock5协议
+	if b[0] == 0x05 {
+		//客户端回应：Socket服务端不需要验证方式
+		client.Write([]byte{0x05, 0x00})
+		n, err = client.Read(b[:])
+		var host, port string
+		switch b[3] {
+		case 0x01: //IP V4
+			host = net.IPv4(b[4], b[5], b[6], b[7]).String()
+		case 0x03:                    //域名
+			host = string(b[5 : n-2]) //b[4]表示域名的长度
+		case 0x04: //IP V6
+			host = net.IP{b[4], b[5], b[6], b[7], b[8], b[9], b[10], b[11], b[12], b[13], b[14], b[15], b[16], b[17], b[18], b[19]}.String()
+		}
+		port = strconv.Itoa(int(b[n-2])<<8 | int(b[n-1]))
+		address := net.JoinHostPort(host, port)
+		server, err := net.Dial("tcp", address)
+		if err != nil {
+			log.Println(err)
+			return
+		}
+		log.Println(address)
+		defer server.Close()
+		//响应客户端连接成功
+		client.Write([]byte{0x05, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00})
+		//进行转发
+		go io.Copy(server, client)
+		io.Copy(client, server)
+	}
+}