加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Python > 正文

Python TCP/IP协议下实现端口转发及重定向菜鸟教程

发布时间:2020-12-17 07:07:39 所属栏目:Python 来源:网络整理
导读:对python这个高级语言感兴趣的小伙伴,下面一起跟随编程之家 jb51.cc的小编两巴掌来看看吧! 首先,我们用webpy写一个简单的网站,监听8080端口,返回Hello,EverET.org的页面。 然后我们使用我们的forwarding.py,在80端口和8080端口中间建立两条通信管道用于
对python这个高级语言感兴趣的小伙伴,下面一起跟随编程之家 52php.cn的小编两巴掌来看看吧!

首先,我们用webpy写一个简单的网站,监听8080端口,返回“Hello,EverET.org”的页面。

然后我们使用我们的forwarding.py,在80端口和8080端口中间建立两条通信管道用于双向通信。

此时,我们通过80端口访问我们的服务器。

浏览器得到:

然后,我们在forwarding.py的输出结果中可以看到浏览器和webpy之间的通信内容。

代码:


# @param Python实现TCP/IP协议下的端口转发及重定向示例
# @author 编程之家 52php.cn|www.52php.cn 

#!/usr/bin/env python
import sys,socket,time,threading
loglock = threading.Lock()
def log(msg):
  loglock.acquire()
  try:
    print '[%s]: n%sn' % (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,targetport).start()

# End www.52php.cn

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读