\u5c0a\u656c\u7684\u5404\u4f4d\u6280\u672f\u540c\u4ec1\uff0c\u5927\u5bb6\u597d\uff01<\/p>\n
\u6b22\u8fce\u6765\u5230\u4eca\u5929\u7684\u6280\u672f\u8bb2\u5ea7\uff0c\u6211\u4eec\u5c06\u6df1\u5165\u63a2\u8ba8\u8d1f\u8f7d\u5747\u8861\u7684\u827a\u672f\u4e0e\u79d1\u5b66\u3002\u5728\u5f53\u4eca\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u7684\u4e92\u8054\u7f51\u5e94\u7528\u65f6\u4ee3\uff0c\u8d1f\u8f7d\u5747\u8861\u6280\u672f\u5df2\u6210\u4e3a\u6784\u5efa\u5065\u58ee\u3001\u53ef\u4f38\u7f29\u7cfb\u7edf\u4e0d\u53ef\u6216\u7f3a\u7684\u4e00\u73af\u3002\u5b83\u4e0d\u4ec5\u4ec5\u662f\u7b80\u5355\u5730\u5c06\u8bf7\u6c42\u5206\u53d1\u5230\u591a\u53f0\u670d\u52a1\u5668\uff0c\u66f4\u662f\u4e00\u95e8\u5173\u4e8e\u5982\u4f55\u667a\u80fd\u3001\u9ad8\u6548\u5730\u5229\u7528\u6709\u9650\u8d44\u6e90\uff0c\u786e\u4fdd\u670d\u52a1\u8d28\u91cf\u7684\u5b66\u95ee\u3002<\/p>\n
\u6211\u4eec\u5c06\u4ece\u6700\u57fa\u7840\u7684\u8d1f\u8f7d\u5747\u8861\u7b97\u6cd5\u2014\u2014\u8f6e\u8be2\u548c\u6700\u5c11\u8fde\u63a5\u2014\u2014\u51fa\u53d1\uff0c\u9010\u6b65\u8fc7\u6e21\u5230\u66f4\u9ad8\u7ea7\u7684\u52a0\u6743\u7b97\u6cd5\uff0c\u5e76\u6700\u7ec8\u805a\u7126\u4e8e\u4e00\u4e2a\u6781\u5177\u5b9e\u7528\u4ef7\u503c\u7684\u52a8\u6001\u6743\u91cd\u5206\u914d\u7b56\u7565\uff1a\u57fa\u4e8e\u670d\u52a1\u5668 CPU \u8d1f\u8f7d\u7684\u52a8\u6001\u6743\u91cd\u5206\u914d\u3002\u6211\u5c06\u7ed3\u5408\u4ee3\u7801\u793a\u4f8b\uff0c\u529b\u6c42\u903b\u8f91\u4e25\u8c28\uff0c\u8ba9\u5927\u5bb6\u5bf9\u8fd9\u4e9b\u7b97\u6cd5\u7684\u539f\u7406\u3001\u4f18\u7f3a\u70b9\u53ca\u5b9e\u9645\u5e94\u7528\u6709\u66f4\u6df1\u523b\u7684\u7406\u89e3\u3002<\/p>\n
\u60f3\u8c61\u4e00\u4e0b\uff0c\u60a8\u7684\u7f51\u7ad9\u6216\u670d\u52a1\u4e00\u591c\u4e4b\u95f4\u7528\u6237\u91cf\u66b4\u589e\uff0c\u4e00\u53f0\u670d\u52a1\u5668\u5df2\u7ecf\u65e0\u6cd5\u627f\u53d7\u6d77\u91cf\u7684\u5e76\u53d1\u8bf7\u6c42\u3002\u54cd\u5e94\u65f6\u95f4\u53d8\u957f\uff0c\u751a\u81f3\u51fa\u73b0\u670d\u52a1\u4e2d\u65ad\uff0c\u7528\u6237\u4f53\u9a8c\u76f4\u7ebf\u4e0b\u964d\u3002\u6b64\u65f6\uff0c\u60a8\u9700\u8981\u505a\u7684\u4e0d\u4ec5\u4ec5\u662f\u589e\u52a0\u670d\u52a1\u5668\u6570\u91cf\uff0c\u66f4\u91cd\u8981\u7684\u662f\uff0c\u8981\u6709\u4e00\u4e2a\u673a\u5236\u6765\u667a\u80fd\u5730\u5206\u914d\u8fd9\u4e9b\u8bf7\u6c42\uff0c\u786e\u4fdd\u6bcf\u4e00\u53f0\u670d\u52a1\u5668\u90fd\u80fd\u88ab\u6709\u6548\u5229\u7528\uff0c\u5e76\u4e14\u6ca1\u6709\u5355\u70b9\u6545\u969c\u3002\u8fd9\u5c31\u662f\u8d1f\u8f7d\u5747\u8861\u7684\u6838\u5fc3\u4ef7\u503c\u3002<\/p>\n
\u8d1f\u8f7d\u5747\u8861\u5668\uff08Load Balancer\uff09\u626e\u6f14\u7740\u201c\u4ea4\u901a\u8b66\u5bdf\u201d\u7684\u89d2\u8272\uff0c\u5b83\u63a5\u6536\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u6240\u6709\u8bf7\u6c42\uff0c\u7136\u540e\u6839\u636e\u9884\u8bbe\u7684\u7b56\u7565\uff08\u7b97\u6cd5\uff09\uff0c\u5c06\u8fd9\u4e9b\u8bf7\u6c42\u8f6c\u53d1\u7ed9\u540e\u7aef\u7684\u591a\u53f0\u670d\u52a1\u5668\uff08\u901a\u5e38\u79f0\u4e3a\u670d\u52a1\u5668\u6c60\u6216\u96c6\u7fa4\uff09\u3002\u5176\u4e3b\u8981\u76ee\u6807\u5305\u62ec\uff1a<\/p>\n
\u8d1f\u8f7d\u5747\u8861\u53ef\u4ee5\u53d1\u751f\u5728\u4e0d\u540c\u7684\u7f51\u7edc\u5c42\u7ea7\uff1a<\/p>\n
\u4eca\u5929\u7684\u8ba8\u8bba\u5c06\u4fa7\u91cd\u4e8e\u8d1f\u8f7d\u5747\u8861\u7684\u201c\u5927\u8111\u201d\u2014\u2014\u5206\u53d1\u7b97\u6cd5\uff0c\u8fd9\u4e9b\u7b97\u6cd5\u65e0\u8bba\u5728\u56db\u5c42\u8fd8\u662f\u4e03\u5c42\u8d1f\u8f7d\u5747\u8861\u4e2d\u90fd\u6709\u5176\u9002\u7528\u6027\u548c\u53d8\u4f53\u3002<\/p>\n
\u5728\u6df1\u5165\u590d\u6742\u7b97\u6cd5\u4e4b\u524d\uff0c\u6211\u4eec\u5148\u4ece\u6700\u7b80\u5355\u3001\u6700\u76f4\u89c2\u7684\u8d1f\u8f7d\u5747\u8861\u7b97\u6cd5\u5f00\u59cb\u3002\u8fd9\u4e9b\u7b97\u6cd5\u8981\u4e48\u4e0d\u8003\u8651\u540e\u7aef\u670d\u52a1\u5668\u7684\u5b9e\u65f6\u72b6\u6001\uff0c\u8981\u4e48\u53ea\u8003\u8651\u975e\u5e38\u6709\u9650\u7684\u72b6\u6001\u4fe1\u606f\u3002<\/p>\n
\u539f\u7406\uff1a \u8f6e\u8be2\u7b97\u6cd5\u662f\u6700\u7b80\u5355\u7684\u4e00\u79cd\u8d1f\u8f7d\u5747\u8861\u7b56\u7565\u3002\u5b83\u5c06\u4f20\u5165\u7684\u8bf7\u6c42\u6309\u987a\u5e8f\u4f9d\u6b21\u5206\u53d1\u7ed9\u540e\u7aef\u670d\u52a1\u5668\u5217\u8868\u4e2d\u7684\u6bcf\u4e00\u53f0\u670d\u52a1\u5668\u3002\u5f53\u5230\u8fbe\u5217\u8868\u672b\u5c3e\u65f6\uff0c\u5b83\u4f1a\u5faa\u73af\u56de\u5230\u5217\u8868\u7684\u5f00\u5934\u3002<\/p>\n
\u4f18\u70b9\uff1a<\/p>\n
\u7f3a\u70b9\uff1a<\/p>\n
\u9002\u7528\u573a\u666f\uff1a<\/p>\n
\u4ee3\u7801\u793a\u4f8b\uff1a<\/p>\n
\u6211\u4eec\u7528 Python \u6765\u6a21\u62df\u4e00\u4e2a\u7b80\u5355\u7684\u8f6e\u8be2\u8d1f\u8f7d\u5747\u8861\u5668\u3002<\/p>\n
import threading
\nimport time<\/p>\n
class Server:
\n \\”\\”\\”\u6a21\u62df\u540e\u7aef\u670d\u52a1\u5668\\”\\”\\”
\n def __init__(self, id, weight=1):
\n self.id = id
\n self.active_connections = 0 # \u6d3b\u8dc3\u8fde\u63a5\u6570
\n self.weight = weight # \u6743\u91cd\uff0c\u8fd9\u91cc\u6682\u65f6\u4e0d\u7528\u4e8e\u8f6e\u8be2\uff0c\u4f46\u540e\u7eed\u7b97\u6cd5\u4f1a\u7528\u5230
\n self.is_healthy = True # \u5065\u5eb7\u68c0\u67e5\u72b6\u6001
\n self.cpu_load = 0.0 # \u6a21\u62dfCPU\u8d1f\u8f7d<\/p>\n
def __str__(self):
\n return f\\”Server(ID:{self.id}, Conn:{self.active_connections}, Weight:{self.weight}, Healthy:{self.is_healthy})\\”<\/p>\n
def increment_connections(self):
\n \\”\\”\\”\u589e\u52a0\u6d3b\u8dc3\u8fde\u63a5\u6570\\”\\”\\”
\n self.active_connections += 1<\/p>\n
def decrement_connections(self):
\n \\”\\”\\”\u51cf\u5c11\u6d3b\u8dc3\u8fde\u63a5\u6570\\”\\”\\”
\n if self.active_connections > 0:
\n self.active_connections -= 1<\/p>\n
class RoundRobinLoadBalancer:
\n def __init__(self, servers):
\n self.servers = servers
\n self.current_server_index = -1 # \u5f53\u524d\u6307\u5411\u7684\u670d\u52a1\u5668\u7d22\u5f15
\n self.lock = threading.Lock() # \u4fdd\u8bc1\u7ebf\u7a0b\u5b89\u5168<\/p>\n
def get_next_server(self):
\n \\”\\”\\”\u83b7\u53d6\u4e0b\u4e00\u4e2a\u8981\u5206\u53d1\u8bf7\u6c42\u7684\u670d\u52a1\u5668\\”\\”\\”
\n with self.lock:
\n # \u8fc7\u6ee4\u6389\u4e0d\u5065\u5eb7\u7684\u670d\u52a1\u5668
\n healthy_servers = [s for s in self.servers if s.is_healthy]
\n if not healthy_servers:
\n return None # \u6ca1\u6709\u5065\u5eb7\u7684\u670d\u52a1\u5668\u53ef\u7528<\/p>\n
self.current_server_index = (self.current_server_index + 1) % len(healthy_servers)
\n return healthy_servers[self.current_server_index]<\/p>\n
# \u6a21\u62df\u5ba2\u6237\u7aef\u8bf7\u6c42
\nclass ClientRequest(threading.Thread):
\n def __init__(self, request_id, load_balancer, processing_time_min=0.1, processing_time_max=0.5):
\n super().__init__()
\n self.request_id = request_id
\n self.load_balancer = load_balancer
\n self.processing_time_min = processing_time_min
\n self.processing_time_max = processing_time_max<\/p>\n
def run(self):
\n server = self.load_balancer.get_next_server()
\n if server:
\n # print(f\\”Request {self.request_id} routed to Server {server.id}\\”)
\n server.increment_connections() # \u6a21\u62df\u8fde\u63a5\u5efa\u7acb
\n try:
\n time.sleep(random.uniform(self.processing_time_min, self.processing_time_max)) # \u6a21\u62df\u5904\u7406\u65f6\u95f4
\n finally:
\n server.decrement_connections() # \u6a21\u62df\u8fde\u63a5\u5173\u95ed
\n # else:
\n # print(f\\”Request {self.request_id}: No healthy servers available.\\”)<\/p>\n
# \u8f85\u52a9\u51fd\u6570\uff1a\u6253\u5370\u670d\u52a1\u5668\u72b6\u6001
\ndef print_server_status(servers, lb_type=\\”\\”):
\n print(f\\”n— {lb_type} Server Status —\\”)
\n for s in servers:
\n # \u5bf9\u4e8e\u52a8\u6001\u6743\u91cd\uff0c\u989d\u5916\u6253\u5370 dynamic_weight
\n if hasattr(s, \\’dynamic_weight\\’):
\n print(f\\”Server {s.id}: Conn={s.active_connections}, CPU={s.cpu_load:.2f}%, Healthy={s.is_healthy}, Weight={s.weight}, DynamicWeight={s.dynamic_weight}\\”)
\n else:
\n print(f\\”Server {s.id}: Conn={s.active_connections}, CPU={s.cpu_load:.2f}%, Healthy={s.is_healthy}, Weight={s.weight}\\”)
\n print(\\”———————————n\\”)<\/p>\n
# # \u6a21\u62df\u4f7f\u7528
\n# if __name__ == \\”__main__\\”:
\n# servers = [Server(1), Server(2), Server(3)]
\n# lb = RoundRobinLoadBalancer(servers)
\n#
\n# requests = []
\n# for i in range(10):
\n# req = ClientRequest(i, lb, processing_time_min=0.05, processing_time_max=0.1)
\n# requests.append(req)
\n# req.start()
\n#
\n# for req in requests:
\n# req.join()
\n#
\n# print_server_status(servers, \\”Round Robin\\”) <\/p>\n
\u539f\u7406\uff1a \u6700\u5c11\u8fde\u63a5\u7b97\u6cd5\u662f\u8f6e\u8be2\u7b97\u6cd5\u7684\u4e00\u4e2a\u91cd\u8981\u6539\u8fdb\u3002\u5b83\u4e0d\u518d\u7b80\u5355\u5730\u987a\u5e8f\u5206\u53d1\u8bf7\u6c42\uff0c\u800c\u662f\u5c06\u65b0\u7684\u8bf7\u6c42\u53d1\u9001\u5230\u5f53\u524d\u6d3b\u52a8\u8fde\u63a5\u6570\u6700\u5c11\u7684\u540e\u7aef\u670d\u52a1\u5668\u3002\u8fd9\u79cd\u7b56\u7565\u8003\u8651\u4e86\u670d\u52a1\u5668\u7684\u5b9e\u65f6\u8d1f\u8f7d\uff08\u4ee5\u8fde\u63a5\u6570\u8861\u91cf\uff09\uff0c\u529b\u6c42\u5c06\u8bf7\u6c42\u5206\u914d\u7ed9\u76f8\u5bf9\u7a7a\u95f2\u7684\u670d\u52a1\u5668\u3002<\/p>\n
\u4f18\u70b9\uff1a<\/p>\n
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb744\u6b21\uff0c\u70b9\u8d5e21\u6b21\uff0c\u6536\u85cf27\u6b21\u3002\u5c0a\u656c\u7684\u5404\u4f4d\u6280\u672f\u540c\u4ec1\uff0c\u5927\u5bb6\u597d\uff01\u6b22\u8fce\u6765\u5230\u4eca\u5929\u7684\u6280\u672f\u8bb2\u5ea7\uff0c\u6211\u4eec\u5c06\u6df1\u5165\u63a2\u8ba8\u8d1f\u8f7d\u5747\u8861\u7684\u827a\u672f\u4e0e\u79d1\u5b66\u3002\u5728\u5f53\u4eca\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u7684\u4e92\u8054\u7f51\u5e94\u7528\u65f6\u4ee3\uff0c\u8d1f\u8f7d\u5747\u8861\u6280\u672f\u5df2\u6210\u4e3a\u6784\u5efa\u5065\u58ee\u3001\u53ef\u4f38\u7f29\u7cfb\u7edf\u4e0d\u53ef\u6216\u7f3a\u7684\u4e00\u73af\u3002\u5b83\u4e0d\u4ec5\u4ec5\u662f\u7b80\u5355\u5730\u5c06\u8bf7\u6c42\u5206\u53d1\u5230\u591a\u53f0\u670d\u52a1\u5668\uff0c\u66f4\u662f\u4e00\u95e8\u5173\u4e8e\u5982\u4f55\u667a\u80fd\u3001\u9ad8\u6548\u5730\u5229\u7528\u6709\u9650\u8d44\u6e90\uff0c\u786e\u4fdd\u670d\u52a1\u8d28\u91cf\u7684\u5b66\u95ee\u3002\u6211\u4eec\u5c06\u4ece\u6700\u57fa\u7840\u7684\u8d1f\u8f7d\u5747\u8861\u7b97\u6cd5\u2014\u2014\u8f6e\u8be2\u548c\u6700\u5c11\u8fde\u63a5\u2014\u2014\u51fa\u53d1\uff0c\u9010\u6b65\u8fc7\u6e21\u5230\u66f4\u9ad8\u7ea7\u7684\u52a0\u6743\u7b97\u6cd5\uff0c\u5e76\u6700\u7ec8\u805a\u7126\u4e8e\u4e00\u4e2a\u6781\u5177\u5b9e\u7528\u4ef7\u503c\u7684\u52a8\u6001\u6743\u91cd\u5206\u914d\u7b56\u7565\uff1a\u57fa\u4e8e\u670d\u52a1\u5668 CPU \u8d1f\u8f7d\u7684\u52a8\u6001\u6743\u91cd\u5206\u914d\u3002<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"topic":[],"class_list":["post-59263","post","type-post","status-publish","format-standard","hentry","category-server"],"yoast_head":"\n