Xiaoxia[PG] Yesterday is history, tomorrow is mistery, today is a gift!

29三/1128

用Python写socks5服务器端

参考自RFC1928: http://xiaoxia.org/?p=2672

直接运行这个程序就给本机建立了一个socks5的代理服务器。

代码如下:

import socket, sys, select, SocketServer, struct, time

class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer): pass
class Socks5Server(SocketServer.StreamRequestHandler):
    def handle_tcp(self, sock, remote):
        fdset = [sock, remote]
        while True:
            r, w, e = select.select(fdset, [], [])
            if sock in r:
                if remote.send(sock.recv(4096)) <= 0: break
            if remote in r:
                if sock.send(remote.recv(4096)) <= 0: break
    def handle(self):
        try:
            print 'socks connection from ', self.client_address
            sock = self.connection
            # 1. Version
            sock.recv(262)
            sock.send(b"\x05\x00");
            # 2. Request
            data = self.rfile.read(4)
            mode = ord(data[1])
            addrtype = ord(data[3])
            if addrtype == 1:       # IPv4
                addr = socket.inet_ntoa(self.rfile.read(4))
            elif addrtype == 3:     # Domain name
                addr = self.rfile.read(ord(sock.recv(1)[0]))
            port = struct.unpack('>H', self.rfile.read(2))
            reply = b"\x05\x00\x00\x01"
            try:
                if mode == 1:  # 1. Tcp connect
                    remote = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                    remote.connect((addr, port[0]))
                    print 'Tcp connect to', addr, port[0]
                else:
                    reply = b"\x05\x07\x00\x01" # Command not supported
                local = remote.getsockname()
                reply += socket.inet_aton(local[0]) + struct.pack(">H", local[1])
            except socket.error:
                # Connection refused
                reply = '\x05\x05\x00\x01\x00\x00\x00\x00\x00\x00'
            sock.send(reply)
            # 3. Transfering
            if reply[1] == '\x00':  # Success
                if mode == 1:    # 1. Tcp connect
                    self.handle_tcp(sock, remote)
        except socket.error:
            print 'socket error'
def main():
    server = ThreadingTCPServer(('', 1080), Socks5Server)
    server.serve_forever()
if __name__ == '__main__':
    main()

已经修正Google SyntaxHighlighter无法正确显示Python代码的问题。问题出自shBrushPython.js中定义regexList数组的时候末尾多了一个","。删去就行了。神奇的是,只有IEcore才报错……

喜欢这个文章吗?

考虑订阅我们的RSS Feed吧!

评论 (28) 引用 (1)
  1. 风骚而简洁的python

  2. 我怎么看不见代码啊。代码呢???

  3. 如何支持用户验证?

    • 然后在Linux下跑的时候data = self.rfile.read(4)这里阻塞了……不知道什么状况,windows跑得很好

      • 你好,read函数是会阻塞的。
        为了避免线程永久阻塞,建议你在这一句的前面给socket设置一个超时树形,代码

        sock.settimeout(5)

  4. 貌似不支持linux 啊,提示19行语法错误

  5. hi,我是新人,目前对python非常感兴趣,希望xiaoxia不吝赐教
    最近有一个问题,想请教下xiaoxia

    对于python的网络部分,我知道一个用Django 和 Python 开发 Web 站点
    但我现在想做的一个项目是cs架构,不是bs架构。。。也就是说web service
    客户端直接和服务器链接
    如果是这样,那么用django是不是就不可以做了

    那是用什么别的架构,那天我听人说道Twisted,稍微看了一点,感觉这个比较适合

    ,请问,还有什么别的推荐的架构或者方法么?
    如果我要学习这方面的知识,应该从哪里系统地下手?

    • django可以呀。你都试试嘛!看你服务器和客户端是怎么通信的,你可以用json或者pickle或者xml或者自定义的协议。据我所知,python有内建的xmlrpc的库。

  6. 在VPS上部署了一下,配置SwichySharp翻墙,就不用另外开一个shell,甚爽!!!
    可是,没happy几分钟,,,报异常了,,,
    Connection reset by peer
    纠结,,,

    • 这个异常直接忽略它不就行了吗?我觉得不影响你正常使用吧!!!这个只是说对方关闭了连接而已。

  7. 这个应该怎么修改,做到只允许本地来访问呢。。。我想配合着stunnel用,这样就不会reset了

    • 只允许本地IP访问吗?绑定到127.0.0.1的IP上就可以了。
      或者也可以用防火墙来设置的。


Leave a comment

(required)