代码有坑

[Deleted user]

pass_length := int(b[2+user_length])
lpass := string(b[(3 + user_length):(3 + user_length + pass_length)])

package main

import (
	"flag"
	"io"
	"log"
	"net"
	"strconv"
)

var (
	auth = flag.Bool("auth", true, "if use auth")
	port = flag.String("port", "1080", "socks5 proxy port")
	user = flag.String("user", "user", "auth user")
	pass = flag.String("pass", "pass", "auth pass")
)

var (
	no_auth   = []byte{0x05, 0x00}
	with_auth = []byte{0x05, 0x02}

	auth_success = []byte{0x05, 0x00}
	auth_failed  = []byte{0x05, 0x01}

	connect_success = []byte{0x05, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00}
)

type Socks5ProxyHandler struct{}

type Handler interface {
	Handle(connect net.Conn)
}

func (socks5 *Socks5ProxyHandler) Handle(connect net.Conn) {
	defer connect.Close()
	if connect == nil {
		return
	}

	b := make([]byte, 1024)

	n, err := connect.Read(b)
	if err != nil {
		return
	}

	if b[0] == 0x05 {

		if *auth == false {
			connect.Write(no_auth)
		} else {
			connect.Write(with_auth)

			n, err = connect.Read(b)
			if err != nil {
				return
			}

			user_length := int(b[1])
			luser := string(b[2:(2 + user_length)])
			pass_length := int(b[2+user_length])
			lpass := string(b[(3 + user_length):(3 + user_length + pass_length)])

			if luser == *user && lpass == *pass {
				connect.Write(auth_success)
			} else {
				connect.Write(auth_failed)
				return
			}
		}

		n, err = connect.Read(b)
		var host string
		switch b[3] {
		case 0x01: //IP V4
			host = net.IPv4(b[4], b[5], b[6], b[7]).String()
		case 0x03: //domain
			host = string(b[5 : n-2]) //b[4] length of domain
		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()
		default:
			return
		}
		lport := strconv.Itoa(int(b[n-2])<<8 | int(b[n-1]))

		server, err := net.Dial("tcp", net.JoinHostPort(host, lport))
		if server != nil {
			defer server.Close()
		}
		if err != nil {
			return
		}
		connect.Write(connect_success)

		go io.Copy(server, connect)
		io.Copy(connect, server)
	}
}

func main() {
	flag.Parse()
	socket, err := net.Listen("tcp", ":"+*port)
	if err != nil {
		return
	}
	log.Printf("socks5 proxy server running on port [:%s], listening ...\n", *port)

	for {
		client, err := socket.Accept()

		if err != nil {
			return
		}

		var handler Handler = new(Socks5ProxyHandler)

		go handler.Handle(client)

		log.Println(client, " request handling...")
	}

}