0

当它的大小超过某个阈值时，我无法从 Pyro4 服务器（版本 4.39，serializer=pickle）取回一个简单的 numpy 数组。服务器处理请求并回复，但客户端保持挂起

代码如下：

服务器代码：

   import numpy as np, Pyro4

   class U(object):
       def __init__(self):
           self.Data = np.arange(10000000).reshape(200,50000)
           print self.Data.shape

       def get(self,name):
           print '%s Requested' % name
           return self.Data


   def run():
       Uni         = U()
       daemon      = Pyro4.Daemon(host='localhost')
       ns          = Pyro4.locateNS()
       uri         = daemon.register(Uni)
       ns.register("test",uri)
       print 'Up and waiting ...'
       daemon.requestLoop()

   if __name__ == '__main__':
       run()

客户代码：

   import Pyro4
   ns = Pyro4.locateNS()
   uri = ns.lookup('test')
   U=Pyro4.Proxy(uri)
   Data = U.get('Data')

服务器输出：(200, 50000) Up and waiting ... 数据请求

所以看起来 Pyro 服务器处理来自客户端的请求并返回数据，但客户端永远不会得到它并且无限期地挂起等待接收消息。

PS：-相同的代码适用于较小的数组（200,5000）

有谁知道可能是什么问题？

非常感谢您的帮助，

4

1 回答 1

0

当我运行它时，客户端停止

Traceback (most recent call last):
  File "client.py", line 5, in <module>
    Data = U.get('Data')
  File "C:\python34\lib\site-packages\Pyro4\core.py", line 171, in __call__
    return self.__send(self.__name, args, kwargs)
  File "C:\python34\lib\site-packages\Pyro4\core.py", line 426, in _pyroInvoke
    raise data
TypeError: don't know how to serialize class <class 'numpy.ndarray'>. Give it vars() or an appropriate __getstate__
于 2015-10-06T13:29:34.437 回答