|
@@ -20,7 +20,7 @@ def clear_timeout_rules():
|
|
|
global Rules
|
|
|
p_clear = []
|
|
|
for rules_id, r in Rules.items():
|
|
|
- if time.time() - r["time"] > 1800:
|
|
|
+ if time.time() - r["time"] > 5:
|
|
|
p_clear.append(rules_id)
|
|
|
for rules_id in p_clear:
|
|
|
Rules.pop(rules_id)
|
|
@@ -32,7 +32,7 @@ def get_rule(rules_id):
|
|
|
"""
|
|
|
global Rules
|
|
|
global ClearTime
|
|
|
- if time.time() - ClearTime > 1800:
|
|
|
+ if time.time() - ClearTime > 5:
|
|
|
clear_timeout_rules()
|
|
|
ClearTime = time.time()
|
|
|
if rules_id in Rules:
|
|
@@ -73,3 +73,6 @@ def server_start(data: bytes, *args, **kwargs):
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
server_start()
|
|
|
+ # 本地启动服务
|
|
|
+ # python -u quality_server.py -host 192.168.3.240 -port 19090 -subject test_quality_bid -queue main -manager_subject monitorRelease -server_host 127.0.0.1
|
|
|
+ # server_start(host="192.168.3.240",port=19090,subject="test_quality_bid",queue="main")
|