Возможно ли подключиться к ранее закрытому сокету?

Question

[Клим Куликов]

Всем привет, столкнулся с такой проблемой. Суть задачи такая: я по TCP подключаюсь к контроллеру, контроллер проводит тесты своих систем и кидает мне результаты этих тестов. Я эти данные принимаю через сокет, обрабатываю и вывожу на экран проги. Соответственно после окончания тестов я закрываю сокет и поток приёма данных вырубается. В проге есть кнопка перезапустить тестирование, она нужна, чтобы при замене контроллера не перезапускать программу. При нажатии на эту кнопку я перезапускаю поток приёма данных и, соответственно, пытаюсь подключиться к уже закрытому сокету и вижу такую ошибку
[WinError 10056] Сделан запрос на подключение для уже подключенного сокета
или
[WinError 10038] Сделана попытка выполнить операцию на объекте, не являющемся сокетом

так вот вопрос, как быть?

код:

Файл tcp_receive.py В нём как раз таки и находится сокет

import socket
from PyQt5.QtCore import QObject, pyqtSignal

class TCP_Receiver(QObject):
    connect_signal = pyqtSignal(bool)
    error_signal = pyqtSignal(str)
    
    def __init__(self):
        super().__init__()
        self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.stop_flag = False

    def kill(self):
        try:
            self.stop_flag = True
            self.client_socket.close()
        except Exception as e:
            print(f"Произошла ошибка при закрытии сокета: {e}")
        finally:
            print("Сокет успешно закрыт")

    def Connect_to_controller(self, data_queue):
        host = '10.55.6.170'
        port = 23

        try:
            print("Успешно подключено")
            self.client_socket.connect((host, port))
            print("Успешно подключено")
            self.connect_signal.emit(True)

            while not self.stop_flag:
                response = self.client_socket.recv(1440)
                data_to_send = "Ваши данные для контроллера"
                self.send_data_to_controller(data_to_send)
                print(response)
                data_queue.put(response)   
                
                if self.stop_flag == True:
                    break            
                
        except Exception as e:
            # error_message = "Тестирование успешно завершено!"
            # self.error_signal.emit(error_message)
            print(e)
            
        finally:
            print("Поток подключения к контроллеру завершен")

    def send_data_to_controller(self, data):
        try:
            self.client_socket.send(data.encode("utf-8"))  # Здесь data - это строка данных для отправки
            print("Данные успешно отправлены")
        except Exception as e:
            print(f"Произошла ошибка при отправке данных: {e}")

Если нужно будет, то могу докинуть код остальных файлов, просто хабр не даёт отправить больше 10к символов

ОСТОРОЖНО ВОЗМОЖЕН ГОВНОКОД!

Answer 1

[Алексей Черемисин]

К уже закрытому сокету подключиться нельзя. Создавайте новый, и уже к нему подключайтесь.

Comments

[Клим Куликов]

в том то и дело, что, как я понимаю, мне тогда придётся создавать миллионы сокетов, смотря сколько контроллеров выпустит завод, а это уже какая-то порнография питоновская получается. Потому что логика проги такая, что тестеру не нужно переоткрывать прогу. Он пришёл, авторизовался и начал тестировать контроллеры один за другим

[Алексей Черемисин]

Клим Куликов, Так в чем проблема создать новый сокет? Ну будет у Вас на каждое устройство по сокету, он закрылся, и убился сборщиком мусора питоновским. Чтобы это точно произошло, просто занулите его после закрытия. Типа:

....
class XXXX:
   socket = None
   ....
   def begin_test(self, blablabla):
      self.socket = socket.connect(......)
   .....
   def close_socket(self, blablabla):
      if is self.socket:
        self.socket.close()
        self.socket = None

[Алексей Черемисин]

Дополню, тот же прокси-сервер у меня например, за раз кушает от 15000 до 600000 открытых сокетов, и ничего, нормально.

[Клим Куликов]

Алексей Черемисин, суть то ещё в том, что контроллеры будут выпускаться серийно, сколько сокетов создавать - непонятно, в зависимости от того, сколько контроллеров будет выпускать завод, а это количество неизвестно никому. Может мы поймём, что это не самое удачное решение и выпустим их 2, а может они будут выпускаться ещё 10 лет по 10000 штук в день, никто не знает

[Клим Куликов]

Алексей Черемисин, или подождите, разве можно несколько раз создавать сокеты с одинаковым именем. Если сокет закрыт, то он уже не считается или как это работает? Я чего-то не совсем понял

[Алексей Черемисин]

Клим Куликов, Сокет - это ниточка, протянутая от одного компухтера (Ваше приложение), к другому (контроллеру).
Вы предполагаете, что все 100к контроллеров будут включены одновременно? В принципе такое возможно, и если они в течении 10 лет не будут выключаться (и даже такое возможно), то все равно, сокеты будут ломаться, и нужно уже немного по другому организовывать работу с сокетами, например через select.
Но что-то мне подсказывает, что это совсем не ваш случай. И работа строится по принципу: включил контроллер, соединился с ним, взял/передал данные, выключил контроллер.
Вот в это случае, если одновремменно включен только один контроллер, то мы: создаем сокет, коннектимся, работаем, закрываем сокет, и так по кругу.
Если же предполагается работать сразу с несколькими одновременно включенными контроллерами, то можно создать переменную dict, куда класть открытые сокеты, а затем после закрытия их оттуда удалять.

[Алексей Черемисин]

И да, в одну и ту же переменную можно класть последовательно разные новые открытые сокеты.

[Алексей Черемисин]

Клим Куликов Давайте поясню

my_socket = None  #  переменная, в которую положим открытый сокет
my_socket = socket.connect(....)  #  переменная c открытым сокетом
my_socket.close() #  закрыли сокет
my_socket = None #  На всякий случай занулили переменную, чтобы сборщик мусора почистил неиспользуемые объекты
## прошло каке-то время
my_socket = socket.connect(....)  #  опять положили в переменную новый открытый сокет
my_socket.close() #  закрыли еще один новый сокет
my_socket = None # опять почистили (хотя это можно и не делать по идее, но лучше так)

[Клим Куликов]

Алексей Черемисин, спасибо, дошло, теперь работает всё

Answer 2

[Максим Д.]

Возможно не до конца понял суть проблемы. Но есть идея открыть порт для отстука, при получении запроса по нему поднимать сокет

на стороне сервера:

routes = web.RouteTableDef()

@routes.post('/websocket')
async def websocketUp(request):
    try:
        <здесь открываем сокет>
        print("Сокет открыт")
        return web.Response(text="success")
    except:
        print("Ошибка открытия сокета")
        return web.Response(text="error")

app = web.Application()
app.add_routes(routes)
web.run_app(app)

на стороне клиента сперва стучать в порт, затем подключаться к сокету
ну или в цикле

Comments

[Клим Куликов]

не думаю, что выйдет открыть порт, прошивкой контроллеров занимаюсь не я, а кто-то другой