{"id":49990,"date":"2020-03-12T09:53:04","date_gmt":"2020-03-12T01:53:04","guid":{"rendered":"http:\/\/4563.org\/?p=49990"},"modified":"2020-03-12T09:53:04","modified_gmt":"2020-03-12T01:53:04","slug":"%e8%af%b7%e6%95%99python%e4%bb%a3%e7%a0%81%e9%97%ae%e9%a2%98","status":"publish","type":"post","link":"http:\/\/4563.org\/?p=49990","title":{"rendered":"\u8bf7\u6559python\u4ee3\u7801\u95ee\u9898"},"content":{"rendered":"\n

\t\t\t\t\t\u5927\u5e05\u9505<\/strong> \t\t\t\t\u5927\u4f6c\u6709\u8bdd\u8bf4 : \t<\/p>\n

\u8bf7\u6559python\u4ee3\u7801\u95ee\u9898<\/h3>\n

\t\t#!\/usr\/bin\/env python
# coding:utf-8
import sys
import BaseHTTPServer
import httplib
import SocketServer
import struct
import socket
import select
import threading
import logging
import urlparse<\/p>\n

import flashGet<\/p>\n

BIND_IP = ‘0.0.0.0’
BIND_PORT = 27015# I love Counter-Strike<\/p>\n

# flashGet.debuglevel = 1
logging._srcfile = None
logging.logProcesses = 0
logging.basicConfig(level=logging.INFO, format='[%(levelname)s] %(asctime)s – %(message)s’, datefmt=’%H:%M:%S’)<\/p>\n

urlparse.MAX_CACHE_SIZE = 100<\/p>\n

class ProxyServer(SocketServer.ThreadingTCPServer):
    allow_reuse_address = True
    daemon_threads = True<\/p>\n

class ProxyRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler, object):
    # Set this to HTTP\/1.1 to enable automatic keepalive
    protocol_version = ‘HTTP\/1.1’
   
    def parse_request(self):
      if not super(ProxyRequestHandler, self).parse_request():
                return False<\/p>\n

      pconntype = self.headers.get(‘Proxy-Connection’, ”)
      if ‘close’ in pconntype.lower():# some say closed
                self.close_connection = 1
      elif (pconntype.lower() == ‘keep-alive’ and
                  self.protocol_version >= ‘HTTP\/1.1’):
                self.close_connection = 0
      return True<\/p>\n

    def handle_one_request(self):
      self.stopped = threading.Event() #TODO: need refine
      self.raw_requestline = self.rfile.readline()
      if not self.raw_requestline:
                self.close_connection = 1
                return
      if not self.parse_request():
                # An error code has been sent, just exit
                return<\/p>\n

      if self.get_scheme() != ‘http’:
                self.send_error(501, ‘%s is not supported, only http works.’ % self.get_scheme())
                return<\/p>\n

      # self.headers = BaseHTTPRequestHandler.headers = instance of mimetools.Message
      fg = flashGet.FlashGet(
                method=self.command,
                url=self.path,
                payload=self.client_request_body(),
                headers=self.headers.dict,
                stopped = self.stopped
      )
      for data in fg.download():
                self.wfile.write(data)<\/p>\n

      self.wfile.flush()# actually send the response if not already done.<\/p>\n

    def handle(self):
      """Handle multiple requests if necessary."""
      self.close_connection = 1<\/p>\n

      try:
                self.handle_one_request()
                # while not self.close_connection:
                #      self.handle_one_request()
      except socket.error as e:
                self.stopped.set()
                self.send_error(500, str(e))<\/p>\n

    def client_request_body(self):
      content_length = int(self.headers.get(‘Content-Length’, 0))
      return self.rfile.read(content_length) if content_length else None<\/p>\n

    def get_scheme(self):
      url_obj = urlparse.urlparse(self.path, scheme=’grass-mud-horse’)
      if url_obj.scheme == ‘grass-mud-horse’:
            self.path = ‘http:\/\/’+self.path
            return ‘http’
      return url_obj.scheme<\/p>\n

    def send_error(self, code, message):
      #TODO: use logging for thread-safe
      super(ProxyRequestHandler, self).send_error(code, message)<\/p>\n

def main():
    if sys.argv:
      port = int(sys.argv)
    else:
      port = BIND_PORT
            
    server_address = (BIND_IP, port)
    httpd = ProxyServer(server_address, ProxyRequestHandler)<\/p>\n

    sa = httpd.server_address
    print "Serving proxy on", sa, "port", sa, "…"
    httpd.serve_forever()<\/p>\n

if __name__ == ‘__main__’:
    main()<\/p>\n

\u8fd9\u6bb5\u4ee3\u7801\u5982\u4f55\u4fee\u6539\u8ba9\u5176\u652f\u6301https\u7684\u8bbf\u95ee\uff1f\u76ee\u524d\u53ea\u80fd\u8bbf\u95eehttp\t\t\t\t<\/p>\n

\t\t\t\t\tusbcdrom<\/strong> \t\t\t\t\u5927\u4f6c\u6709\u8bdd\u8bf4 : \t<\/p>\n

<\/h3>\n

\t\tBUZHIDAO\t\t\t <\/p>\n","protected":false},"excerpt":{"rendered":"

\u5927\u5e05\u9505 \u5927\u4f6c\u6709\u8bdd\u8bf4 : \u8bf7\u6559pyt…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[],"tags":[],"_links":{"self":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/49990"}],"collection":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=49990"}],"version-history":[{"count":0,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/49990\/revisions"}],"wp:attachment":[{"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=49990"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=49990"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=49990"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}