ФАЙЛ «SERVER_CONTROLLER.PY»
Файл «Server_controller.py» представляет собой инструмент для взаимодействия с серверами реле и сервоприводов, а также для запуска и остановки серверных процессов. Этот файл включает два класса: Attachments и Site_run. Каждый класс выполняет специфические функции, обеспечивающие управление и взаимодействие с различными компонентами системы.
ИНИЦИАЛЗАЦИЯ БИБЛИОТЕК
import logging
import socket
import os
import re
import subprocess
import sys
import time
logging: Эта библиотека предоставляет гибкую систему для вывода сообщений журнала (логирования) из программ на Python. Она позволяет настроить уровни логирования (например, DEBUG, INFO, WARNING, ERROR, CRITICAL) и выводить сообщения в различные места, такие как консоль, файлы, сетевые сервисы и т.д.
socket: Эта библиотека предоставляет низкоуровневые интерфейсы для работы с сетью. Она позволяет создавать сокеты для отправки и получения данных по сети, поддерживая различные протоколы, такие как TCP и UDP.
os: Эта библиотека предоставляет функции для взаимодействия с операционной системой. Она включает в себя функции для работы с файловой системой, управление процессами, переменными окружения и другими системными ресурсами.
re: Эта библиотека предоставляет операции для работы с регулярными выражениями. Она позволяет выполнять поиск, замену и другие манипуляции с текстом на основе шаблонов, заданных регулярными выражениями.
subprocess: Эта библиотека позволяет запускать новые процессы, подключаться к их каналам ввода-вывода-ошибок и получать их коды возврата. Она предоставляет более мощные средства для работы с подпроцессами по сравнению с
os.system
и другими подобными функциями.sys: Эта библиотека предоставляет доступ к некоторым переменным и функциям, используемым интерпретатором Python, а также к функциям, которые взаимодействуют с интерпретатором. Например,
sys.argv
содержит список аргументов командной строки,sys.exit()
позволяет выйти из программы, и т.д.time: Эта библиотека предоставляет различные функции для работы со временем. Она позволяет измерять время выполнения кода, задерживать выполнение программы на заданное количество секунд (с помощью
time.sleep
), и выполнять другие операции, связанные с временем и датой.
ИНИЦИАЛИЗАЦИЯ КЛАССА Attachments
class Attachments:
# Конструктор класса, инициализирующий соединения с серверами
def __init__(self, ip, port_rele, port_servo) -> None:
host = ip
# Попытка подключения к серверу реле
try:
self.client_socket_rele = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.client_socket_rele.connect((host, port_rele))
print("подключенно rele")
except:
print("error connect server rele")
# Попытка подключения к серверу сервопривода
try:
self.client_socket_servo = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.client_socket_servo.connect((host, port_servo))
print("подключенно servo")
except:
print("error connect server servo")
Конструктор класса Attachments инициализирует соединения с серверами реле и сервоприводов. Он создает два сокета и пытается подключиться к серверам по указанным IP-адресу и портам. В случае успеха выводится сообщение о подключении, в случае ошибки - сообщение об ошибке.
АСИНХРОННАЯ ФУНКЦИЯ rele_status (прописывается в классе Attachments)
async def rele_status(self, gradus):
try:
self.client_socket_rele.sendall(f"{gradus}".encode('utf-8'))
except Exception as e:
print("error rele: ", e)
Функция rele_status отправляет статус реле (градус) на сервер реле. В случае ошибки выводится сообщение об ошибке.
АСИНХРОННАЯ ФУНКЦИЯ servo_grad (прописывается в классе Attachments)
async def servo_grad(self, status):
try:
self.client_socket_servo.sendall(f"{int(status)}".encode('utf-8'))
except Exception as e:
print("error servo: ", e)
Функция servo_grad отправляет угол поворота сервопривода на сервер сервоприводов. В случае ошибки выводится сообщение об ошибке.
АСИНХРОННАЯ ФУНКЦИЯ rele_status_never
async def rele_status_never(self):
self.client_socket_rele.sendall(f"return".encode('utf-8'))
data = self.client_socket_rele.recv(self.buffer_size).decode('utf-8')
return data
Функция rele_status_never запрашивает и получает статус реле с сервера реле.
АСИНХРОННАЯ ФУНКЦИЯ servo_status
async def servo_status(self):
self.client_socket_servo.sendall(f"return".encode('utf-8'))
data = self.client_socket_servo.recv(self.buffer_size).decode('utf-8')
return data
Функция servo_status запрашивает и получает статус сервопривода с сервера сервоприводов.
ИНИЦИАЛИЗАЦИЯ КЛАССА Site_run
class Site_run:
# Конструктор класса, запускающий серверный процесс
def __init__(self, ip_site, port_site, ip_serv, port_serv, rtsp):
# Формирование строки с данными о портах
port_data = f'{ip_site}:{port_site},{ip_serv}:{port_serv},{rtsp}'
# Добавление данных о портах в аргументы командной строки
sys.argv.append(port_data)
self.port = port_site
# Формирование и выполнение команды для запуска сервера
command = f'python3.11 Server_site.py {" ".join(sys.argv[1:])}'
self.processes = subprocess.Popen(command, shell=True)
# Ожидание для установления процесса
time.sleep(3)
Конструктор класса Site_run запускает серверный процесс. Он формирует строку с данными о портах, добавляет её в аргументы командной строки и запускает серверный процесс с помощью subprocess.Popen. После запуска процесса происходит задержка для его установления.
ФУНКЦИЯ stop
def stop(self):
# Формирование и выполнение команды для поиска PID процесса
command = f'netstat -a -n -o | find "{self.port}"'
output = subprocess.check_output(command, shell=True, text=True)
pattern = r'LISTENING\s+(\d+)'
pids = re.findall(pattern, output)
# Формирование и выполнение команды для остановки процесса
sys = 'taskkill /F /PID ' + str(pids[0])
os.system(sys)
Метод stop останавливает серверный процесс. Он формирует и выполняет команду для поиска PID процесса по порту, затем останавливает процесс с найденным PID с помощью команды taskkill. Процесс подготовки кода:
Создайте файл и назовите его Server_Controller.py

Поэтапно добавьте код в файл



В данном случае все библиотеки предустановлены в Python.
Запускать данный файл не нужно.
Last updated