>  기사  >  백엔드 개발  >  Python은 TCP/IP 프로토콜에서 포트 전달 및 리디렉션 예제를 구현합니다.

Python은 TCP/IP 프로토콜에서 포트 전달 및 리디렉션 예제를 구현합니다.

大家讲道理
大家讲道理원래의
2016-11-07 11:31:591789검색

먼저 webpy를 사용하여 간단한 웹사이트를 작성하고, 포트 8080을 수신하고, "Hello, EverET.org" 페이지를 반환합니다.

그런 다음 Forwarding.py를 사용하여 양방향 통신을 위해 포트 80과 포트 8080 사이에 두 개의 통신 파이프를 설정합니다.

이 시점에서 우리는 포트 80을 통해 서버에 접속합니다.

브라우저의 내용은 다음과 같습니다.

Python은 TCP/IP 프로토콜에서 포트 전달 및 리디렉션 예제를 구현합니다.

그러면 Forwarding.py의 출력에서 ​​브라우저와 webpy의 차이점을 확인할 수 있습니다. 사이의 통신 내용.

Python은 TCP/IP 프로토콜에서 포트 전달 및 리디렉션 예제를 구현합니다.


코드:

#!/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()


성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.