RPC服务器

在前面的实现中，我们只实现了RPC服务器的最简易模型——单进程单线程。

为了能让RPC服务器同时处理多个客户端的请求，提升性能，我们可以改写服务器，采用多线程、多进程等。

在此我们仅实现多线程模型，其余不再赘述。

多线程服务器

import threadingclass ThreadServer(object):def __init__(self, host, port, handlers):self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)# RPC基本原理* RPC简介
* RPC结构组成
* RPC消息协议
* 二进制消息协议实现
* RPC传输控制
* RPC完整实现
* RPC服务器  # 分布式系统基础## 1. 优点[Kivy 文档](https://kivy.org/doc/stable/)[Tkinter 文档](https://docs.python.org/3/library/tkinter.html)单机的RPC服务无论是在**可靠性**还是在**扩展性**都能力有限。[PyPDF2 文档](https://pypdf2.readthedocs.io/)![](https://s2.51cto.com/images/blog/front/202508/a80df0899410a3bd13139515a8dee537a5bdac.png)[threading 文档](https://docs.python.org/3/library/threading.html)为了提升RPC服务的可靠性和扩展性，我们可以增加多台RPC服务器提供RPC服务。[Python Package Index](https://pypi.org/)![](https://s2.51cto.com/images/blog/front/202508/b96fa7493a64b47ae8e643e4ef23b6e683fdbe.png)[Scrapy 文档](https://docs.scrapy.org/)## 2. 需要解决的问题[loguru 文档](https://loguru.readthedocs.io/)虽然增加服务器能提升整体的性能，但是多台服务器对外提供RPC服务的时候，还需要管理好这些服务才能有效的提供服务，这是我们所说的服务治理的问题。### 容灾如果在多台服务器中，出现了故障机器，不能提供RPC服务了，如何让客户端还能正确的获取到RPC服务。![](https://s2.51cto.com/images/blog/front/202508/21404538517d20b9151746ca8af83957de20b5.png)### 服务发现