81 lines
2.7 KiB
Python
81 lines
2.7 KiB
Python
import socket
|
||
import logging
|
||
import time
|
||
import json
|
||
import struct
|
||
import threading
|
||
from fuadmin import settings
|
||
from system import apps
|
||
from vdes_utils.vdes_data_parsing import VdesDataParsing
|
||
|
||
logger = logging.getLogger(__name__)
|
||
|
||
class VDESSocketMonitor:
|
||
_instance = None
|
||
_lock = threading.Lock()
|
||
|
||
def __new__(cls):
|
||
with cls._lock:
|
||
if not cls._instance:
|
||
cls._instance = super().__new__(cls)
|
||
cls._instance._initialized = False
|
||
return cls._instance
|
||
|
||
def __init__(self):
|
||
if self._initialized:
|
||
return
|
||
self._initialized = True
|
||
|
||
self.host = getattr(settings, 'VDES_MONITOR_HOST', 'localhost')
|
||
self.port = getattr(settings, 'VDES_MONITOR_PORT', 8083)
|
||
self.buffer_size = getattr(settings, 'VDES_BUFFER_SIZE', 4096)
|
||
|
||
self.running = False
|
||
self.thread = None
|
||
self.vdes_data_parsing = VdesDataParsing()
|
||
logger.info(f"VDES 监控服务初始化完成 - {self.host}:{self.port}")
|
||
|
||
def start(self):
|
||
if self.running:
|
||
logger.warning("监控服务已在运行中")
|
||
return
|
||
|
||
self.running = True
|
||
self.thread = threading.Thread(
|
||
target=self._monitor_loop,
|
||
name="VDES-Monitor-Thread",
|
||
daemon=False
|
||
)
|
||
self.thread.start()
|
||
logger.info("VDES 监控服务已启动")
|
||
|
||
def stop(self):
|
||
self.running = False
|
||
if self.thread and self.thread.is_alive():
|
||
self.thread.join(timeout=5)
|
||
logger.info("VDES 监控服务已停止")
|
||
|
||
def _monitor_loop(self):
|
||
while self.running:
|
||
try:
|
||
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
|
||
sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
|
||
print(f"尝试连接到服务器 {self.host}:{self.port}")
|
||
sock.connect((self.host, self.port))
|
||
print(f"成功连接到服务器 {self.host}:{self.port}")
|
||
while self.running:
|
||
data = sock.recv(self.buffer_size)
|
||
if data:
|
||
# print(data)
|
||
self.vdes_data_parsing.parse_vdes_data(data)
|
||
except (ConnectionRefusedError, TimeoutError) as e:
|
||
print(f"连接失败: {e}")
|
||
except Exception as e:
|
||
print(f"连接异常: {e}")
|
||
|
||
# 如果服务仍在运行，则等待30秒后重新尝试连接
|
||
if self.running:
|
||
print("等待30秒后重新尝试连接...")
|
||
time.sleep(30)
|
||
|