Возврат удаленного объекта в rpyc - PullRequest
Новая
       21

Возврат удаленного объекта в rpyc

2 голосов
/ 03 февраля 2012

У меня есть удаленный сервер, как показано ниже, который уже имеет инициализированный класс, и я установил настройки протокола, чтобы разрешить публичные атрибуты True. 

import rpyc

class SharedClass(object):
    def __init__(self,string):
        print string

    def action(self):
        print 'i am doing something'

s=SharedClass('hi')

class MyService(rpyc.Service):
    def on_connect(self):
        pass

    def on_disconnect(self):
        pass

    def exposed_get_shared(self):
        return s

if __name__=='__main__:
    from rpyc.utils.server import ThreadedServer
    t=ThreadedServer(MyService,port=18861,protocol_config={"allow_public_attrs":True})
    t.start()

На стороне клиента, если я пытаюсь подключиться напрямую, он работаеттогда как при попытке установить соединение внутри функции и вернуть объект я получаю сообщение об ошибке

** Клиент **

** Прямое соединение **

>>>Python 2.7.2 (default, Jun 12 2011, 15:08:59) [MSC v.1500 32 bit (Intel)] on win32
>>>Type "help", "copyright", "credits" or "license" for more information.
>>>conn=rpyc.connect('localhost',18861)
>>>share=getattr(conn.root,'get_shared')
>>>share
<bound method MyService.exposed_get_shared of <__main__.MyService
object at 0x011BA698>>
>>>share=getattr(conn.root,'get_shared')()
>>>share
<__main__.SharedClass object at 0x00B6ED30>
>>>share.action()
i am doing something

Если я пытаюсь сделать это в функции, я получаю ошибку; (

>>>def returnObject(objName, host, port):
...    conn = rpyc.connect(host, port)
...    print conn
...    attr = getattr(conn.root, 'get_' + objName)()
...    print attr
...    return attr
>>>share=returnObject('shared','localhost',18861)
<rpyc.core.protocol.Connection 'conn2' object at 0x0108AAD0>
<__main__.SharedClass object at 0x00B6ED30>
>>>share
Traceback (most recent call last):
 File "<stdin>", line 1, in <module>
 File "C:\Python27\lib\site-packages\rpyc\core\netref.py", line 168,
in __repr__
   return syncreq(self, consts.HANDLE_REPR)
 File "C:\Python27\lib\site-packages\rpyc\core\netref.py", line 69,
in syncreq
   return conn().sync_request(handler, oid, *args)
AttributeError: 'NoneType' object has no attribute 'sync_request'

Моя цель - инициализировать объект на сервере и получить к нему доступ многих клиентов. Инициализированный класс является потокомбезопасно, и поэтому его могут использовать несколько клиентов.

Я понимаю, что при этом что-то упускаю.

-

Адхитья

1 Ответ

2 голосов
/ 04 февраля 2012

Хотя у меня нет реального опыта работы с rpyc, из вашего примера кажется, что единственное реальное отличие состоит в том, что при выполнении функции returnObject ссылка 'conn' не сохраняется, поэтому я предполагаю, что ситуация связана с сборкой мусора любого ссылается на «conn». С небольшим изменением функции returnObject, так что 'conn' возвращается и сохраняется вне функции, пример, кажется, выполняется. 

>>> import rpyc
>>> def returnObject(objName, host, port):
...     conn = rpyc.connect(host, port)
...     print conn
...     attr = getattr(conn.root, 'get_' + objName)()
...     print attr
...     return conn, attr
... 
>>> conn, share = returnObject('shared', 'localhost', 18861)
<rpyc.core.protocol.Connection 'conn1' object at 0x10b0676d0>
<__main__.SharedClass object at 0x1091ff790>
>>> share
<__main__.SharedClass object at 0x1091ff790>
>>> share.action()

Поскольку я участвую в разработке другого решения для удаленного объекта Python Versile Python , просто для забавы приведу альтернативную реализацию, использующую это решение (требуется VPy dev выпуск 0.7.2, в следующей версии будет несколько конфликтующие изменения API). Удаленный сервис, обеспечивающий доступ к SharedClass: 

from versile.quick import *
from versile.vse.native.python import VPythonObject
VSEResolver.add_imports()

class SharedClass(object):
    def action(self):
        return u'I am doing something'

shared = SharedClass()

class Gateway(VExternal):
    @publish(show=True, ctx=False)
    def get_shared(self):
        return VPythonObject(shared)

service = VTPService(lambda: Gateway(), auth=None)
service.start()

Код клиента для доступа к услуге: 

>>> from versile.quick import *
>>> VSEResolver.add_imports()
>>> gw = VUrl.resolve('vtp://localhost/')
>>> shared = gw.get_shared()
>>> shared._v_activate() # required for activating as remote-python proxy
>>> shared.action()
u'I am doing something'
>>> gw._v_link.shutdown()
...