python负载均衡的简单实现方法
提到分发请求，相信大多数人首先会想到Nginx，Nginx作为一种多功能服务器，不仅提供了反向代理隐藏主机ip的能力，还拥有简单的缓存加速功能。当然Nginx最强大的功能还是分发请求，不仅提供了哈希，一致性哈希，负载均衡等多种请求分发模式，还保证了自己服务的轻量和稳定。一台Nginx服务器常年工作在高并发请求的环境下，也极少宕机。
在Nginx负载均衡模式下，请求会发送到压力最小的未宕机服务器上。今天我们不考虑目标服务器的压力，用python实现最简单的负载均衡方法，即将请求发送到未宕机的服务器上。
我们想调用module_b模块中的接口，module_b服务在10.10.10.115服务器上的10081，10082，10083，10084这4个端口上。
#!/usr/bin/python
#-*-coding:utf-8-*-
importrequests
importrandom
importos
importsys
importtime
importConnectionError
importModule_bException
module_b="10.10.10.115:10081,10.10.10.115:10082,10.10.10.115:10083,10.10.10.115:10084"
classModule_b():
def__init__(self):
self.url_prefix=[val.strip()forvalinmodule_b.split(',')]
def_request(self,short_uri,payload):
res=None
try_count=1
url_prefixs=self.url_prefix[:]
url_prefixs.sort(key=lambdaf:random.randint(0,100))
forcurr_url_prefixinurl_prefixs:
url=os.path.join(curr_url_prefix,short_uri)
try:
res=requests.post(url,data=payload)
break
exceptConnectionErrorase:
try_count+=1
sys.stderr.write('cannotconnecttoModule_b,retry...\n')
time.sleep(1)
iftry_count==len(url_prefixs):
raisee
ifres.status_code!=200:
raiseModule_bException('HTTPERROR:%s'%res.text)
result=res.json()
ifresult['status']!='0':
raiseModule_bException(result['errstr'])
returnresult['result']
ConnecttionError和Module_bException为封装好的报错类无需在意。
整个负载均衡的实现也很简单，传入api和参数，然后从所有的module_b地址中随机选出一个，拼接成完整的requests请求，如果无法访问到module_b服务，那么将换到另一个未访问过的module_b服务地址，直到访问过全部的module_b服务。
总结
以上所述是小编给大家介绍的python负载均衡的简单实现方法，希望对大家有所帮助，如果大家有任何疑问欢迎给我留言，小编会及时回复大家的！