Обнаружить остановленный серверный процесс через rpyc.Connection

Question

Предположим, у меня есть служба:

import rpyc

class MyService(rpyc.Service):
    my_dict = {}

    def exposed_put(self, key, val):
        MyService.my_dict[key] = val

    def exposed_get(self, key):
        return MyService.my_dict[key]

    def exposed_delete(self, key):
        del MyService.my_dict[key]

Теперь я запускаю службу, работающую на сервере ThreadedServer:

from rpyc.utils.server import ThreadedServer
server = ThreadedServer(MyService, port=8000)
server.start()

Теперь в другом процессе на том же компьютере, я открываю новое соединение с сервером:

import rpyc
c = rpyc.connect('localhost', 8000)

... но до получения доступа к корню соединения серверный процесс по какой-то причине останавливается, например, Ctrl-Z в управляющем терминале серверного процесса. Теперь, когда я пытаюсь получить доступ к корню через:

c.root

... Питон зависает. Ctrl-C на стороне клиента показывает это:

In [31]: c.root
^C---------------------------------------------------------------------------
KeyboardInterrupt                         Traceback (most recent call last)
<ipython-input-31-856a441cc51a> in <module>()
----> 1 c.root

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/protocol.pyc in root(self)
    465         """Fetches the root object (service) of the other party"""
    466         if self._remote_root is None:
--> 467             self._remote_root = self.sync_request(consts.HANDLE_GETROOT)
    468         return self._remote_root
    469

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/protocol.pyc in sync_request(self, handler, *args)
    436         seq = self._send_request(handler, args)
    437         while seq not in self._sync_replies:
--> 438             self.serve(0.1)
    439         isexc, obj = self._sync_replies.pop(seq)
    440         if isexc:

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/protocol.pyc in serve(self, timeout)
    385                   otherwise.
    386         """
--> 387         data = self._recv(timeout, wait_for_lock = True)
    388         if not data:
    389             return False

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/protocol.pyc in _recv(self, timeout, wait_for_lock)
    342             return None
    343         try:
--> 344             if self._channel.poll(timeout):
    345                 data = self._channel.recv()
    346             else:

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/channel.pyc in poll(self, timeout)
     41     def poll(self, timeout):
     42         """polls the underlying steam for data, waiting up to *timeout* seconds"""
---> 43         return self.stream.poll(timeout)
     44     def recv(self):
     45         """Receives the next packet (or *frame*) from the underlying stream.

/home/mack/anaconda/lib/python2.7/site-packages/rpyc/core/stream.pyc in poll(self, timeout)
     39             while True:
     40                 try:
---> 41                     rl, _, _ = select([self], [], [], timeout)
     42                 except select_error as ex:
     43                     if ex[0] == errno.EINTR:

KeyboardInterrupt:

Таким образом, кажется, что вызов Stream.poll завершается бесконечным циклом, если процесс сервера остановлен, но все еще подключен (базовый сокет все еще открыт). Правильно ли я считаю, что это неожиданный случай в реализации Stream? Я использую версию 3.3.0. Как я могу обнаружить этот случай и избежать зависания клиента?

Answer 1

Если существует риск взлома сервера, вы можете просто проверить значение c.closed вы также можете предоставить на стороне клиента функцию обратного вызова, чтобы уведомить вас о том, что она закрылась, и передать ее инициализатору с именем on_exit возможно, затем зарегистрируйте его с помощью atexit.

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