1

我正在使用 rpyc 在 python 中开发一个程序。我的目标是创建一个简单的服务器，它接受来自客户端的数据字节（字符串）。我是 python 和 rpyc 的新手。这是我的 server.py 代码：

from rpyc.utils.server import ThreadedServer # or ForkingServer

class MyService(rpyc.Service):
    # My service
    pass

if __name__ == "__main__":
    server = ThreadedServer(MyService, port = 18812)
    server.start()

然后是我的 client.py 代码：

from rpyc.core.stream import SocketStream
from rpyc.core.channel import Channel

b = SocketStream.connect("localhost", 18812)
c = Channel(b, compress=True)
c.send("abc")

b.close()
c.close()

然而，当运行我的 client.py 时，控制台出现错误。如果我理解正确，我必须在 server.py 中创建一个与客户端关联的流。是这样吗？我怎样才能做到这一点？

4

1 回答 1

2

您正在使用低级原语，但您没有在这些原语上放置协议。无论如何，你真的不需要去那里。这是您想要执行的操作：

myserver.py

import rpyc
from rpyc.utils.server import ThreadedServer

class MyService(rpyc.Service):
    # My service
    def exposed_echo(self, text):
        print(text)

if __name__ == "__main__":
    server = ThreadedServer(MyService, port = 18812)
    server.start()

然后打开一个python shell并尝试

>>> import rpyc
>>> c = rpyc.connect("localhost", 18812)
>>> c.root.echo("hello")
'hello'

请注意，这是使用面向服务的模式。您也可以使用经典模式。只需运行bin/rpyc_classic.py，然后使用连接rpyc.classic.connect("host")

于 2014-11-14T16:26:37.900 回答