同步服务器web页面

2026-03-11 12:07:08 +08:00
parent 092e6178a2
commit 7c7e83eda8
3 changed files with 486 additions and 0 deletions
--- a/web_page_2/http_server.py
+++ b/web_page_2/http_server.py
@@ -0,0 +1,98 @@
+from http.server import ThreadingHTTPServer, SimpleHTTPRequestHandler
+import os
+import urllib.parse
+import socket
+
+class APIHandler(SimpleHTTPRequestHandler):
+    # 设置超时，避免长时间占用连接
+    timeout = 30
+    
+    def log_message(self, format, *args):
+        # 自定义日志格式
+        print(f"[{self.log_date_time_string()}] {self.address_string()} - {format % args}")
+    
+    def do_GET(self):
+        try:
+            # 解析路径和查询参数
+            parsed_path = urllib.parse.urlparse(self.path)
+            path = parsed_path.path
+            query = parsed_path.query
+            
+            # 检查是否是API接口
+            api_param = None
+            if path.startswith('/api/'):
+                api_param = path[5:]  # 提取 /api/ 后面的数字
+            
+            # 生成带参数的index.html URL
+            if api_param:
+                # 使用HTML文件并附加api参数
+                self.serve_file('index.html', query=f'api={api_param}')
+            elif path == '/' or path == '/index.html':
+                # 默认访问使用 api=1
+                self.serve_file('index.html', query='api=1')
+            else:
+                self.send_error(404, 'Not Found')
+        except Exception as e:
+            print(f"Error handling request: {e}")
+            self.send_error(500, 'Internal Server Error')
+    
+    def serve_file(self, filename, query=None):
+        try:
+            file_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), filename)
+            if os.path.exists(file_path):
+                self.send_response(200)
+                self.send_header('Content-type', 'text/html; charset=utf-8')
+                self.end_headers()
+                
+                with open(file_path, 'rb') as f:
+                    content = f.read()
+                
+                # 如果有查询参数，修改HTML中的URL参数解析部分
+                if query:
+                    try:
+                        content = content.decode('utf-8')
+                        # 修改URL参数行，替换默认值为实际参数
+                        content = content.replace(
+                            "const apiParam = urlParams.get('api') || '1';",
+                            f"const apiParam = '{query.split('=')[1]}';"
+                        )
+                        content = content.encode('utf-8')
+                    except Exception as e:
+                        print(f"Error modifying HTML content: {e}")
+                
+                self.wfile.write(content)
+            else:
+                self.send_error(404, f'{filename} not found')
+        except Exception as e:
+            print(f"Error serving file: {e}")
+            raise
+
+def check_port_available(port):
+    """检查端口是否可用"""
+    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+        try:
+            s.bind(('', port))
+            return True
+        except socket.error:
+            return False
+
+def run():
+    port = 8086
+    if not check_port_available(port):
+        print(f"错误: 端口 {port} 已被占用")
+        return
+    
+    server_address = ('', port)
+    httpd = ThreadingHTTPServer(server_address, APIHandler)
+    print(f'Server running on http://localhost:{port}')
+    print(f'支持的接口: /, /api/1, /api/2, /api/3, /api/4, /api/5, /api/6, /api/7, /api/11-16')
+    print('按 Ctrl+C 停止服务器')
+    
+    try:
+        httpd.serve_forever()
+    except KeyboardInterrupt:
+        print('\n服务器已停止')
+        httpd.server_close()
+
+if __name__ == '__main__':
+    run()