我正在使用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中创建与客户端关联的流。是这样吗 我怎样才能做到这一点？
您正在使用低级原语，但没有在这些原语上放置协议。无论如何，您真的不需要去那里。这是您要执行的操作：
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")
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句