为了简洁，服务端代码我单独放在了server_code.py中：
# 5.RPC Server（被调用者）本地执行后将结果返回给服务端的RPC Proxy class MyCode(object): def sum(self, a, b): return a + b def get_time(self): import time return time.ctime()4.然后再看看重头戏Server Stub:
# server_stub.py import socket class ServerStub(object): def __init__(self, mycode): self.mycode = mycode def convert(self, num, obj): """根据类型编号转换类型""" if num == "1": obj = int(obj) if num == "2": obj = float(obj) if num == "3": obj = str(obj) return obj def unpack(self, data): """3.服务端的RPC Proxy组件把通过网络接收到的数据包按照相应格式进行拆包解码，获取方法名和参数""" msg = data.decode("utf-8") # 格式应该是"格式：func:函数名@params:类型编号-参数,类型编号2-参数2..." array = msg.split("@") func = array[0].split(":")[1] if len(array) > 1: args = list() for item in array[1].split(":")[1].split(","): temps = item.split("-") # 类型转换 args.append(self.convert(temps[0], temps[1])) return (func, tuple(args)) # (func,args) return (func, ) def pack(self, result): """打包：把方法和参数拼接成自定义的协议""" # 格式："data:返回值" return f"data:{result}".encode("utf-8") def exec(self, func, args=None): """4.服务端的RPC Proxy组件根据方法名和参数进行本地调用""" # 如果没有这个方法则返回None func = getattr(self.mycode, func, None) if args: return func(*args) # 解包 else: return func() # 无参函数 def handle(self, client_socket, client_addr): while True: # 获取客户端发送的数据包 data = client_socket.recv(2048) if data: try: data = self.unpack(data) # 解包 if len(data) == 1: data = self.exec(data[0]) # 执行无参函数 elif len(data) > 1: data = self.exec(data[0], data[1]) # 执行带参函数 else: data = "RPC Server Error Code:500" except Exception as ex: data = "RPC Server Function Error" print(ex) # 6.服务端的RPC Proxy组件将返回值打包编码成自定义的协议数据包，并通过网络发送给客户端的RPC Proxy组件 data = self.pack(data) # 把函数执行结果按指定协议打包 # 把处理过的数据发送给客户端 client_socket.send(data) else: print(f"客户端：{client_addr}已断开\n") break再简要说明一下：里面方法其实主要就是解包、执行函数、返回值打包
输出图示：
再贴一下上面的时序图：
课外拓展：
HTTP1.0、HTTP1.1 和 HTTP2.0 的区别 https://www.cnblogs.com/heluan/p/8620312.html 简述分布式RPC框架 https://blog.csdn.net/jamebing/article/details/79610994 分布式基础—RPC下节预估：RPC服务进一步简化与演变、手写一个简单的REST接口