서버와의 비동기 연결을 다시 설정하는 방법 (해결됨)

Question

C로 작성된 서버와 상호 작용하는 asyncore 클라이언트가 있습니다. 서버가 연결을 닫고 연결을 계속 시도 할 때이를 감지 할 수 있어야합니다 다시 사용할 수있게 될 때까지 여기에 내가 가지고있는 코드는 다음과 같습니다. 이것은 다른 스레드 모듈에서 실행되는 다른 스레드 모듈 (ReceiverBoard)을 시작하는 asyncore 클라이언트입니다. 클래스 DETClient (asyncore.dispatcher) :

내 첫 번째 문제는 연결이 될 때까지 내가 소켓을 통해 (ANSI C 개발) 서버에 연결 재 시도를 유지하기 위해 (위) 클라이언트를 원이었다

buffer = "" 
t = None 

def __init__(self, host, port): 

    asyncore.dispatcher.__init__(self) 
    self.create_socket(socket.AF_INET, socket.SOCK_STREAM) 
    self.connect((host,port)) 
    self.host=host 
    self.port=port 
    self.t = ReceiverBoard(self) 
    self.t.start() 

def sendCommand(self, command): 
    self.buffer = command 

def handle_error(self): 
    self.t.stop() 
    self.close() 

def handle_write(self): 
    sent=self.send(self.buffer.encode()) 
    self.buffer="" 

def handle_read(self): 
    ##there is code here to parse the received message and call the appropriate 
    ##method in the threaded module ReceiverBoard 

.

Answer 1

내가 만든 변경 사항은 위의 asyncore에서 handle_error 메서드를 재정 의하여 단순히 소켓을 닫지 않고 연결을 다시 초기화하려고 시도하는 다른 메서드를 호출하는 것입니다. 아래에서와 같이이이 코드가 실행될 때 서버를 사용할 수없는 문제를 해결

def initiate_connection_with_server(self): 
    print("trying to initialize connection with server...") 
    asyncore.dispatcher.__init__(self) 
    self.create_socket(socket.AF_INET, socket.SOCK_STREAM) 
    self.connect((self.host,self.port)) 

def handle_error(self): 
    print("problem reaching server.") 
    self.initiate_connection_with_server() 

(다음 코드는 위의 DETClient 추가됩니다). 예외가 발생하고 handle_error가 호출되어 단순히 initiate_connection 메소드를 호출하고 소켓을 다시 열려고 시도합니다. 또한 연결이 초기에 설정된 후 어떤 이유로 소켓을 잃어 버리면 코드가 handle_error를 호출하고 연결을 다시 시도합니다. 문제가 해결되었습니다. 여기

는 스레드 모듈 (ReceiverBoard)

class ReceiverBoard(threading.Thread): 
    _stop = False   
    def __init__(self, client): 
     self.client=client 
     super(ReceiverBoard,self).__init__() 
    def run(self): 
     while True: 
      block_to_send = "" 
      ##code here to generate block_to_send 
      self.client.sendCommand(block_to_send) 

    def stop(self): 
     self._stop = True