首先，我们用webpy写一个简单的网站，监听8080端口，返回“hello, everet.org”的页面。
然后我们使用我们的forwarding.py，在80端口和8080端口中间建立两条通信管道用于双向通信。
此时，我们通过80端口访问我们的服务器。
浏览器得到：
然后，我们在forwarding.py的输出结果中可以看到浏览器和webpy之间的通信内容。
代码：
#!/usr/bin/env python
import sys, socket, time, threading
loglock = threading.lock()
def log(msg):
loglock.acquire()
try:
print ‘[%s]: \n%s\n’ % (time.ctime(), msg.strip())
sys.stdout.flush()
finally:
loglock.release()
class pipethread(threading.thread):
def __init__(self, source, target):
threading.thread.__init__(self)
self.source = source
self.target = target
def run(self):
while true:
try:
data = self.source.recv(1024)
log(data)
if not data: break
self.target.send(data)
except:
break
log(‘pipethread done’)
class forwarding(threading.thread):
def __init__(self, port, targethost, targetport):
threading.thread.__init__(self)
self.targethost = targethost
self.targetport = targetport
self.sock = socket.socket(socket.af_inet, socket.sock_stream)
self.sock.bind((‘0.0.0.0’, port))
self.sock.listen(10)
def run(self):
while true:
client_fd, client_addr = self.sock.accept()
target_fd = socket.socket(socket.af_inet, socket.sock_stream)
target_fd.connect((self.targethost, self.targetport))
log(‘new connect’)
# two direct pipe
pipethread(target_fd, client_fd).start()
pipethread(client_fd, target_fd).start()
if __name__ == ‘__main__’:
print ‘starting’
import sys
try:
port = int(sys.argv[1])
targethost = sys.argv[2]
try: targetport = int(sys.argv[3])
except indexerror: targetport = port
except (valueerror, indexerror):
print ‘usage: %s port targethost [targetport]’ % sys.argv[0]
sys.exit(1)
#sys.stdout = open(‘forwaring.log’, ‘w’)
forwarding(port, targethost, targetport).start()