python - 用于发送字符串数据的简单 rpyc 客户端和服务器

Question

我正在使用 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 中创建一个与客户端关联的流。是这样吗？我怎样才能实现这一目标？

Answer 1

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

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")

进行连接