我有一个由班级python BaseHTTPRequestHandler
调用的HTTPServer
班级。基本上BaseHTTPRequestHandler
只是运行一个基本算法,然后响应一个Get
请求。问题是,每次我发出Get
请求时,我都会得到正确的响应,但所有收集到的数据BaseHTTPRequestHandler
都会被重置,就好像每次将请求发送到HTTPServer
它都会创建一个新的BaseHTTPRequestHandler
. 我在网上找不到任何能真正解释幕后发生的事情的东西。我附上了我的代码的简化版本。任何帮助或解释将不胜感激。
在任何人建议创建类或全局变量之前,我正在使用一个线程一次创建该类的多个实例,这样做会使每个线程上的所有实例共享并替换彼此的数据。
代码(复制和粘贴时缩进关闭)
BaseHTTPRequestHandler
这个简化版本只是跟踪已发生的警报数量。问题是当我调用Get
请求时计数总是重置为 0,就好像类的实例被重置一样。
class SimulationServer(BaseHTTPRequestHandler):
def __init__(self, address, port, randomNumberMax, *args):
self.IP_ADDRESS = address
self.PORT = port
self.RANDOM_NUMBER_MAX = randomNumberMax
self.COUNT = 0
BaseHTTPRequestHandler.__init__(self, *args)
def do_GET(self):
if self.headers['Authorization'] == 'Basic ' + str(key):
print("send response")
self.do_HEAD()
randomNumberMax = self.RANDOM_NUMBER_MAX
response = ""
if randint(0, randomNumberMax) == 0:
self.generateAlert()
base_path = urlparse(self.path).path
print('base_path: ' + base_path)
if base_path == '/count':
response = self.getCount()
self.wfile.write(bytes(response, 'utf-8'))
def getCount(self):
count = self.COUNT
jsonString = '{"_sig": "","count": ' + str(count) + '}'
return jsonString
def generateAlert(self):
newAlert = {}
newAlert['siteId'] = "siteId"+ str(self.COUNT)
newAlert['mesg'] = "Simulated Alert"
newAlert['when'] = int(time.time())
self.COUNT += 1
HTTP服务器
class CustomHTTPServer(HTTPServer):
key = ''
def __init__(self, address, handlerClass=SimulationServer):
super().__init__(address, handlerClass)
def set_auth(self, username, password):
self.key = base64.b64encode(
bytes('%s:%s' % (username, password), 'utf-8')).decode('ascii')
def get_auth_key(self):
return self.key
主要的
此类创建HTTPServer
并附加handler
class RunSimulator(object):
def run(self, alertFrequency=50, port=9000):
ipAddress="127.0.0.1"
def handler(*args):
SimulationServer(ipAddress, port, alertFrequency, *args)
simulationServer = CustomHTTPServer((ipAddress, port), handler)
simulationServer.set_auth('username', 'password')
try:
simulationServer.serve_forever()
except KeyboardInterrupt:
pass
simulationServer.server_close()
print(time.asctime(), "Server Stops - %s:%s" % (ipAddress, port))
if __name__ == "__main__":
from sys import argv
simu = RunSimulator()
simu.run()