由于公司經(jīng)常需要異地辦公，在調(diào)試的時(shí)候需要用到內(nèi)網(wǎng)環(huán)境，因此手動(dòng)寫了個(gè)代理轉(zhuǎn)發(fā)服務(wù)器給兄弟們用：socks5proxy。
選型上，語(yǔ)言上就選擇了Go，簡(jiǎn)單清晰，轉(zhuǎn)發(fā)協(xié)議選擇了socks5。
SOCKS5協(xié)議介紹
SOCKS是一種網(wǎng)絡(luò)傳輸協(xié)議，主要用于客戶端與外網(wǎng)服務(wù)器之間通訊的中間傳遞，SOCKS是"SOCKetS"的縮寫。 SOCKS5是SOCKS4的升級(jí)版，其主要多了鑒定、IPv6、UDP支持。
SOCKS5協(xié)議可以分為三個(gè)部分：
(1) 協(xié)議版本及認(rèn)證方式
(2) 根據(jù)認(rèn)證方式執(zhí)行對(duì)應(yīng)的認(rèn)證
(3) 請(qǐng)求信息
（1）協(xié)議版本及認(rèn)證方式
創(chuàng)建與SOCKS5服務(wù)器的TCP連接后客戶端需要先發(fā)送請(qǐng)求來(lái)協(xié)議版本及認(rèn)證方式，
| VER | NMETHODS | METHODS |
|---|---|---|
| 1 | 1 | 1-255 |
服務(wù)器回復(fù)客戶端可用方法：
| VER | METHOD |
|---|---|
| 1 | 1 |
代碼實(shí)現(xiàn)：
type ProtocolVersion struct { VER uint8 NMETHODS uint8 METHODS []uint8}func (s *ProtocolVersion) handshake(conn net.Conn) error { b := make([]byte, 255) n, err := conn.Read(b) if err != nil { log.Println(err) return err } s.VER = b[0] //ReadByte reads and returns a single byte，第一個(gè)參數(shù)為socks的版本號(hào) s.NMETHODS = b[1] //nmethods是記錄methods的長(zhǎng)度的。nmethods的長(zhǎng)度是1個(gè)字節(jié) if n != int(2+s.NMETHODS) { return errors.New("協(xié)議錯(cuò)誤, sNMETHODS不對(duì)") } s.METHODS = b[2:2+s.NMETHODS] //讀取指定長(zhǎng)度信息，讀取正好len(buf)長(zhǎng)度的字節(jié)。如果字節(jié)數(shù)不是指定長(zhǎng)度，則返回錯(cuò)誤信息和正確的字節(jié)數(shù) if s.VER != 5 { return errors.New("該協(xié)議不是socks5協(xié)議") } //服務(wù)器回應(yīng)客戶端消息: //第一個(gè)參數(shù)表示版本號(hào)為5，即socks5協(xié)議， // 第二個(gè)參數(shù)表示服務(wù)端選中的認(rèn)證方法，0即無(wú)需密碼訪問(wèn), 2表示需要用戶名和密碼進(jìn)行驗(yàn)證。 resp :=[]byte{5, 0} conn.Write(resp) return nil} （2）根據(jù)認(rèn)證方式執(zhí)行對(duì)應(yīng)的認(rèn)證
SOCKS5協(xié)議提供5種認(rèn)證方式：
這里就主要介紹用戶名、密碼認(rèn)證。 在客戶端、服務(wù)端協(xié)商使用用戶名密碼認(rèn)證后，客戶端發(fā)出用戶名密碼：
| 鑒定協(xié)議版本 | 用戶名長(zhǎng)度 | 用戶名 | 密碼長(zhǎng)度 | 密碼 |
|---|---|---|---|---|
| 1 | 1 | 動(dòng)態(tài) | 1 | 動(dòng)態(tài) |
服務(wù)器鑒定后發(fā)出如下回應(yīng)：
| 鑒定協(xié)議版本 | 鑒定狀態(tài) |
|---|---|
| 1 | 1 |
其中鑒定狀態(tài) 0x00 表示成功，0x01 表示失敗。
代碼實(shí)現(xiàn)：
type Socks5Auth struct { VER uint8 ULEN uint8 UNAME string PLEN uint8 PASSWD string}func (s *Socks5Auth) authenticate(conn net.Conn) error { b := make([]byte, 128) n, err := conn.Read(b) if err != nil{ log.Println(err) return err } s.VER = b[0] if s.VER != 5 { return errors.New("該協(xié)議不是socks5協(xié)議") } s.ULEN = b[1] s.UNAME = string(b[2:2+s.ULEN]) s.PLEN = b[2+s.ULEN+1] s.PASSWD = string(b[n-int(s.PLEN):n]) log.Println(s.UNAME, s.PASSWD) if username != s.UNAME || passwd != s.PASSWD { return errors.New("賬號(hào)密碼錯(cuò)誤") } /** 回應(yīng)客戶端,響應(yīng)客戶端連接成功 The server verifies the supplied UNAME and PASSWD, and sends the following response: +----+--------+ |VER | STATUS | +----+--------+ | 1 | 1 | +----+--------+ A STATUS field of X'00' indicates success. If the server returns a `failure' (STATUS value other than X'00') status, it MUST close the connection. */ resp := []byte{0x05, 0x00} conn.Write(resp) return nil}但其實(shí)，現(xiàn)在大家都習(xí)慣自己采用加密流的方式進(jìn)行加密，很少采用用戶名密碼的形式進(jìn)行加密，后面章節(jié)會(huì)介紹一種對(duì)SOCKS的混淆加密方式。
（3）請(qǐng)求信息
認(rèn)證結(jié)束后客戶端就可以發(fā)送請(qǐng)求信息。如果認(rèn)證方法有特殊封裝要求，請(qǐng)求必須按照方法所定義的方式進(jìn)行封裝解密，其原始格式如下：
| VER | CMD | RSV | ATYP | DST.ADDR | DST.PORT |
|---|---|---|---|---|---|
| 1 | 1 | 0x00 | 1 | 動(dòng)態(tài) | 2 |
代碼實(shí)現(xiàn)：
type Socks5Resolution struct { VER uint8 CMD uint8 RSV uint8 ATYP uint8 DSTADDR []byte DSTPORT uint16 DSTDOMAIN string RAWADDR *net.TCPAddr}func (s *Socks5Resolution) lstRequest(conn net.Conn) error { b := make([]byte, 128) n, err := conn.Read(b) if err != nil || n < 7 { log.Println(err) return errors.New("請(qǐng)求協(xié)議錯(cuò)誤") } s.VER = b[0] if s.VER != 5 { return errors.New("該協(xié)議不是socks5協(xié)議") } s.CMD = b[1] if s.CMD != 1 { return errors.New("客戶端請(qǐng)求類型不為代理連接, 其他功能暫時(shí)不支持.") } s.RSV = b[2] //RSV保留字端，值長(zhǎng)度為1個(gè)字節(jié) s.ATYP = b[3] switch s.ATYP { case 1: // IP V4 address: X'01' s.DSTADDR = b[4 : 4+net.IPv4len] case 3: // DOMAINNAME: X'03' s.DSTDOMAIN = string(b[5:n-2]) ipAddr, err := net.ResolveIPAddr("ip", s.DSTDOMAIN) if err != nil { return err } s.DSTADDR = ipAddr.IP case 4: // IP V6 address: X'04' s.DSTADDR = b[4 : 4+net.IPv6len] default: return errors.New("IP地址錯(cuò)誤") } s.DSTPORT = binary.BigEndian.Uint16(b[n-2:n]) // DSTADDR全部換成IP地址，可以防止DNS污染和封殺 s.RAWADDR = &net.TCPAddr{ IP: s.DSTADDR, Port: int(s.DSTPORT), } /** 回應(yīng)客戶端,響應(yīng)客戶端連接成功 +----+-----+-------+------+----------+----------+ |VER | REP | RSV | ATYP | BND.ADDR | BND.PORT | +----+-----+-------+------+----------+----------+ | 1 | 1 | X'00' | 1 | Variable | 2 | +----+-----+-------+------+----------+----------+ */ resp := []byte{0x05, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00} conn.Write(resp) return nil}（4）最后將信息進(jìn)行轉(zhuǎn)發(fā)即可
代碼實(shí)現(xiàn):
wg := new(sync.WaitGroup) wg.Add(2) go func() { defer wg.Done() defer dstServer.Close() io.Copy(dstServer, client) }() go func() { defer wg.Done() defer client.Close() io.Copy(client, dstServer) }() wg.Wait()
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持VEVB武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
