創(chuàng)新互聯(lián)www.cdcxhl.cn八線動(dòng)態(tài)BGP香港云服務(wù)器提供商，新人活動(dòng)買多久送多久，劃算不套路！

創(chuàng)新互聯(lián)建站是專業(yè)的邵武網(wǎng)站建設(shè)公司，邵武接單;提供成都網(wǎng)站建設(shè)、成都做網(wǎng)站,網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行邵武網(wǎng)站開(kāi)發(fā)網(wǎng)頁(yè)制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛(ài)的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來(lái)合作!

這篇文章主要講解了Python如何通過(guò)zookeeper實(shí)現(xiàn)分布式服務(wù)，內(nèi)容清晰明了，對(duì)此有興趣的小伙伴可以學(xué)習(xí)一下，相信大家閱讀完之后會(huì)有幫助。

借助zookeeper可以實(shí)現(xiàn)服務(wù)器的注冊(cè)與發(fā)現(xiàn),有需求的時(shí)候調(diào)用zookeeper來(lái)發(fā)現(xiàn)可用的服務(wù)器,將任務(wù)均勻分配到各個(gè)服務(wù)器上去.

這樣可以方便的隨任務(wù)的繁重程度對(duì)服務(wù)器進(jìn)行彈性擴(kuò)容,客戶端和服務(wù)端是非耦合的,也可以隨時(shí)增加客戶端.

zk_server.py

import threading
import json
import socket
import sys
from kazoo.client import KazooClient


# TCP服務(wù)端綁定端口開(kāi)啟監(jiān)聽(tīng)，同時(shí)將自己注冊(cè)到zk
class ZKServer(object):
  def __init__(self, host, port):
    self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    self.host = host
    self.port = port
    self.sock.bind((host, port))
    self.zk = None

  def serve(self):
    """
    開(kāi)始服務(wù)，每次獲取得到一個(gè)信息，都新建一個(gè)線程處理
    """
    self.sock.listen(128)
    self.register_zk()
    print("開(kāi)始監(jiān)聽(tīng)")
    while True:
      conn, addr = self.sock.accept()
      print("建立鏈接%s" % str(addr))
      t = threading.Thread(target=self.handle, args=(conn, addr))
      t.start()

  # 具體的處理邏輯,只要接收到數(shù)據(jù)就立即投入工作，下次沒(méi)有數(shù)據(jù)本次鏈接結(jié)束
  def handle(self, conn, addr):
    while True:
      data=conn.recv(1024)
      if not data or data.decode('utf-8') == 'exit':
        break
      print(data.decode('utf-8'))
    conn.close()
    print('My work is done!!!')

  # 將自己注冊(cè)到zk，臨時(shí)節(jié)點(diǎn)，所以連接不能中斷
  def register_zk(self):
    """
    注冊(cè)到zookeeper
    """
    self.zk = KazooClient(hosts='127.0.0.1:2181')
    self.zk.start()
    self.zk.ensure_path('/rpc') # 創(chuàng)建根節(jié)點(diǎn)
    value = json.dumps({'host': self.host, 'port': self.port})
    # 創(chuàng)建服務(wù)子節(jié)點(diǎn)
    self.zk.create('/rpc/server', value.encode(), ephemeral=True, sequence=True)

if __name__ == '__main__':
  if len(sys.argv) < 3:
    print("usage:python server.py [host] [port]")
    exit(1)
  host = sys.argv[1]
  port = sys.argv[2]
  server = ZKServer(host, int(port))
  server.serve()

網(wǎng)頁(yè)題目：Python如何通過(guò)zookeeper實(shí)現(xiàn)分布式服務(wù)-創(chuàng)新互聯(lián)
文章出自：http://weahome.cn/article/cdhsid.html