文档章节

基于go手动写个转发代理服务

Kanonpy
 Kanonpy
发布于 02/02 00:31
字数 1550
阅读 1158
收藏 35

由于公司经常需要异地办公,在调试的时候需要用到内网环境,因此手动写了个代理转发服务器給兄弟们用:socks5proxy

选型上,语言上就选择了Go,简单清晰,转发协议选择了socks5。

SOCKS5协议介绍

SOCKS是一种网络传输协议,主要用于客户端与外网服务器之间通讯的中间传递,SOCKS是"SOCKetS"的缩写。 SOCKS5是SOCKS4的升级版,其主要多了鉴定、IPv6、UDP支持。

SOCKS5协议可以分为三个部分:

  • (1) 协议版本及认证方式
  • (2) 根据认证方式执行对应的认证
  • (3) 请求信息

(1)协议版本及认证方式

创建与SOCKS5服务器的TCP连接后客户端需要先发送请求来协议版本及认证方式,

VERNMETHODSMETHODS
111-255
  • VER是SOCKS版本,这里应该是0x05;
  • NMETHODS是METHODS部分的长度;
  • METHODS是客户端支持的认证方式列表,每个方法占1字节。当前的定义是:
    • 0x00 不需要认证
    • 0x01 GSSAPI
    • 0x02 用户名、密码认证
    • 0x03 - 0x7F由IANA分配(保留)
    • 0x80 - 0xFE为私人方法保留
    • 0xFF 无可接受的方法

服务器回复客户端可用方法:

VERMETHOD
11
  • VER是SOCKS版本,这里应该是0x05;
  • METHOD是服务端选中的方法。如果返回0xFF表示没有一个认证方法被选中,客户端需要关闭连接。

代码实现:

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,第一个参数为socks的版本号
    s.NMETHODS = b[1] //nmethods是记录methods的长度的。nmethods的长度是1个字节
    if n != int(2+s.NMETHODS) {
        return errors.New("协议错误, sNMETHODS不对")
    }
    s.METHODS = b[2:2+s.NMETHODS] //读取指定长度信息,读取正好len(buf)长度的字节。如果字节数不是指定长度,则返回错误信息和正确的字节数

    if s.VER != 5 {
        return errors.New("该协议不是socks5协议")
    }

    //服务器回应客户端消息:
    //第一个参数表示版本号为5,即socks5协议,
    // 第二个参数表示服务端选中的认证方法,0即无需密码访问, 2表示需要用户名和密码进行验证。  
    resp :=[]byte{5, 0} 
    conn.Write(resp)
    return nil
} 

(2)根据认证方式执行对应的认证

SOCKS5协议提供5种认证方式:

  • 0x00 不需要认证
  • 0x01 GSSAPI
  • 0x02 用户名、密码认证
  • 0x03 - 0x7F由IANA分配(保留)
  • 0x80 - 0xFE为私人方法保留

这里就主要介绍用户名、密码认证。 在客户端、服务端协商使用用户名密码认证后,客户端发出用户名密码:

鉴定协议版本用户名长度用户名密码长度密码
11动态1动态

服务器鉴定后发出如下回应:

鉴定协议版本鉴定状态
11

其中鉴定状态 0x00 表示成功,0x01 表示失败。

代码实现:

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("该协议不是socks5协议")
    }

    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("账号密码错误")
    }

    /**
    回应客户端,响应客户端连接成功
    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
}

但其实,现在大家都习惯自己采用加密流的方式进行加密,很少采用用户名密码的形式进行加密,后面章节会介绍一种对SOCKS的混淆加密方式。

(3)请求信息

认证结束后客户端就可以发送请求信息。如果认证方法有特殊封装要求,请求必须按照方法所定义的方式进行封装解密,其原始格式如下:

VERCMDRSVATYPDST.ADDRDST.PORT
110x001动态2
  • VER是SOCKS版本,这里应该是0x05;
  • CMD是SOCK的命令码
    • 0x01表示CONNECT请求
    • 0x02表示BIND请求
    • 0x03表示UDP转发
  • RSV 0x00,保留
  • ATYP DST.ADDR类型
  • DST.ADDR 目的地址
    • 0x01 IPv4地址,DST.ADDR部分4字节长度
    • 0x03 域名,DST.ADDR部分第一个字节为域名长度,DST.ADDR剩余的内容为域名,没有\0结尾。
    • 0x04 IPv6地址,16个字节长度。
  • DST.PORT 网络字节序表示的目的端口

代码实现:

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("请求协议错误")
    }
    s.VER = b[0]
    if s.VER != 5 {
        return errors.New("该协议不是socks5协议")
    }

    s.CMD = b[1]
    if s.CMD != 1 { 
        return errors.New("客户端请求类型不为代理连接, 其他功能暂时不支持.")
    }
    s.RSV = b[2] //RSV保留字端,值长度为1个字节

    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地址错误")
    }

    s.DSTPORT = binary.BigEndian.Uint16(b[n-2:n])
    // DSTADDR全部换成IP地址,可以防止DNS污染和封杀
    s.RAWADDR = &net.TCPAddr{
		IP:   s.DSTADDR,
		Port: int(s.DSTPORT),
    }
    
    /**
    回应客户端,响应客户端连接成功
        +----+-----+-------+------+----------+----------+
        |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)最后将信息进行转发即可

代码实现:

    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()

© 著作权归作者所有

共有 人打赏支持
Kanonpy
粉丝 17
博文 36
码字总数 31024
作品 0
广州
程序员
私信 提问
加载中

评论(7)

Kanonpy
Kanonpy

引用来自“Silvake”的评论

冲着"手动写"进来的😜 莫名的好奇非手动会怎么写 哈哈哈
前面说了原因,自用,安全和可控
Kanonpy
Kanonpy

引用来自“a997093108”的评论

代码精彩
谢谢,喜欢给个fork或star😋
Kanonpy
Kanonpy

引用来自“无踪的烟味”的评论

源码中由判断处理认证方式吗?源码中的client.go仅做流复制吗?
也做了加密编码
无踪的烟味
无踪的烟味
源码中由判断处理认证方式吗?源码中的client.go仅做流复制吗?
a
a997093108
代码精彩
Silvake
Silvake
内容精彩 by the way
Silvake
Silvake
冲着"手动写"进来的😜 莫名的好奇非手动会怎么写 哈哈哈
Java Proxy和CGLIB动态代理原理

动态代理在Java中有着广泛的应用,比如Spring AOP,Hibernate数据查询、测试框架的后端mock、RPC,Java注解对象获取等。静态代理的代理关系在编译时就确定了,而动态代理的代理关系是在编译期...

CarpenterLee
2018/01/08
0
0
iOS - 更轻量级的 AppDelegate - 面向服务

有没有觉得你的 AppDelegate 太过庞大了?一个 iOS 应用可能集成了大量的服务,第三方服务、推送服务等等,大多数服务功能彼此独立,想不想把它们彻底从 AppDelegate 中拆出来? AppDelegat...

力谱宿云
2016/08/09
662
1
Java Proxy 和 CGLIB 动态代理原理

原文出处:CarpenterLee 动态代理在Java中有着广泛的应用,比如Spring AOP,Hibernate数据查询、测试框架的后端mock、RPC,Java注解对象获取等。静态代理的代理关系在编译时就确定了,而动态...

CarpenterLee
2018/01/10
0
0
windows命令行下用netsh实现端口转发(端口映射)

微软Windows的netsh是一个命令行脚本实用工具。使用netsh工具 ,可以查看或更改本地计算机或远程计算机的网络配置。不仅可以在本地计算机上运行这些命令,而且可以在网络上的远程计算机上运行...

shezjl
2015/06/18
0
0
在华为HG255D OpenWrt上安装和配置Shadowsocks并实现智能流量转发

在华为HG255D OpenWrt上安装和配置Shadowsocks并实现智能流量转发 树叶的BLOG2017-12-033 阅读 华为安装shadowsocks配置 概述 Showsocks-libev是Shadowsocks的C语言版本,和Shadowsocks其他版...

树叶的BLOG
2017/12/03
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Httpd 整合 Tomcat 步骤

环境:Tomcat8 + Httpd2.4 工作原理:借助于Tomcat的AJP连接器实现Apache与Tomcat的通信 配置步骤: 1. 配置httpd.conf 新增: Include conf/extra/mod_jk.conf 修改:添加 index.jsp <IfM...

ZeroneLove
昨天
1
0
Docker笔记3——容器命令(未写完,明天整理接着写)

未写完,明天整理接着写 新建并启动容器 docker run docker run [OPTIONS] IMAGE [COMMEND] [ARG...] OPTIONS: --name=[容器新名字] :为容器指定一个名称 -d:后台运行容器,并返回容器ID,...

HappyBKs
昨天
1
0
2018个人年终总结

感谢领导的信任和指导,新的一年获得了很多成长和提高,改掉了很多不好的习惯。 在这一年里,我在领导的帮助下,主要完成了以下功能: 1、完成上海银行版本投资营销相关功能的开发。 2、完成车...

万山红遍
昨天
12
0
保密工作与linux系统的发展

保密工作从性质上可以分成商业方面的保密和国家安全方面的保密。由于自己从事的是IT方面的工作,工作中必然会接触涉及到计算机信息方面的相关文件。加上单位已近通过武器装备科研生产单位二级...

linux-tao
昨天
3
0
Spark共享变量

概述 Spark程序的大部分操作都是RDD操作,通过传入函数给RDD操作函数来计算。这些函数在不同的节点上并发执行,但每个内部的变量有不同的作用域,不能相互访问,所以有时会不太方便,Spark提...

仟昭
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部