# 1.需要記錄的數(shù)據(jù)
records = [[1,50],[2,6],[3,47],[4,8],[5,9],[6,100]] # 數(shù)據(jù)鍵為日期，值為銷售數(shù)量
# 2.定義存放的地址和數(shù)據(jù)
Sadress1 = {'192.168.1.1':1}
Sadress2 = {'192.168.1.2':2}
Sadress3 = {'192.168.1.3':4}
Sadress4 = {'192.168.1.4':6}

# 數(shù)據(jù)長度定義為
n = 20

# 判斷哈希值，分段為0-1-2-4-6
for one in records:
? ? if one[0] % n <= Sadress1['192.168.1.1']:?
? ? ? ? Sadress1[one[0]]=one[1]
? ? elif one[0] % n <= Sadress2['192.168.1.2']:
? ? ? ? Sadress2[one[0]] = one[1]
? ? elif one[0] % n <= Sadress3['192.168.1.3']:
? ? ? ? Sadress3[one[0]] = one[1]
? ? elif one[0] % n <= Sadress4['192.168.1.4']:
? ? ? ? Sadress4[one[0]] = one[1]

print(Sadress1)
print(Sadress2)
print(Sadress3)
print(Sadress4)

import hashlib # 導(dǎo)入帶shal（）哈希算法的函數(shù)庫
class CHash(object):
? ? def __init__(self,nodes=None,v_num=2):# nodes節(jié)點存放節(jié)點地址，V-num一個節(jié)點對應(yīng),# 默認節(jié)點是為2
? ? ? ? self._v_num = v_num # 一個節(jié)點對應(yīng)存放節(jié)點地址
? ? ? ? self._vNode_IP = {} #　用于虛擬節(jié)點的hash值與node的對應(yīng)關(guān)系
? ? ? ? self._vNodeAdd = [] # 用于存放所有的虛擬節(jié)點的hash值，這里需要保持排序
? ? ? ? for node in nodes:
? ? ? ? ? ? self.addNode(node)
? ? ? ? print('\n虛擬節(jié)點哈希值升序排列：\n',self._vNodeAdd) # 對虛擬節(jié)點哈希地址進行從小到大排序

? ? # 1 建立虛擬節(jié)點環(huán)，順序排列
? ? def addNode(self,node):
? ? ? ? for i in range(self._v_num):
? ? ? ? ? ? vNodeStr = '%s%s'%(node ,i) # 根據(jù)虛擬節(jié)點，為每個節(jié)點建立虛擬節(jié)點
? ? ? ? ? ? key = self._gen_key(vNodeStr) # 產(chǎn)生虛擬節(jié)點IP地址，服務(wù)器節(jié)點IP+i
? ? ? ? ? ? print('虛擬節(jié)點字符串',vNodeStr,'對應(yīng)哈希值',key)
? ? ? ? ? ? self._vNode_IP[key] = node # 虛擬節(jié)點哈希地址為鍵，節(jié)點為IP地址為值
? ? ? ? ? ? self._vNodeAdd.append(key) # 對應(yīng)虛擬節(jié)點哈希地址進行獨立儲存
? ? ? ? ? ? self._vNodeAdd.sort()
? ? # 2 刪除退出節(jié)點地址及對應(yīng)的虛擬地址
? ? def Del_Node(self,node): # 刪除退出節(jié)點地址及對應(yīng)的虛擬地址
? ? ? ? for i in range(self._v_num):
? ? ? ? ? ? vNodeStr = '%s%s'%(node,i)
? ? ? ? ? ? key = self._gen_key(vNodeStr) ?# 產(chǎn)生虛擬節(jié)點的哈希地址
? ? ? ? ? ? del self._vNode_IP[key] # 通過哈希地址刪除字典里面的虛擬節(jié)點信息
? ? ? ? ? ? self._vNodeAdd.remove(key) # 刪除虛擬節(jié)點的哈希地址
? ? # 3 返回數(shù)據(jù)儲存對應(yīng)的服務(wù)器地址
? ? def dataNode(self,data):
? ? ? ? if self._vNodeAdd: # 虛擬節(jié)點的哈希地址列表不為空
? ? ? ? ? ? key = self._gen_key(data) # 產(chǎn)生業(yè)務(wù)數(shù)據(jù)對應(yīng)的哈希地址
? ? ? ? ? ? print(data,'哈希地址',key)
? ? ? ? ? ? for node_key in self._vNodeAdd: # 獲取虛擬節(jié)點的哈希地址
? ? ? ? ? ? ? ? if key <= node_key: # 業(yè)務(wù)數(shù)據(jù)的哈希地址<= 當(dāng)前虛擬節(jié)點的哈希地址
? ? ? ? ? ? ? ? ? ? return self._vNode_IP[node_key] # 返回當(dāng)前虛擬節(jié)點哈希地址對應(yīng)節(jié)點IP
? ? ? ? ? ? return self._vNodeAdd[self._vNodeAdd[0]] # 如果業(yè)務(wù)數(shù)據(jù)的哈希值超過所有節(jié)點的地址，則歸入并返回第一個IP地址

? ? ? ? else:
? ? ? ? ? ? return None # 沒有節(jié)點

? ? # 4 通過shal()產(chǎn)生哈希值
? ? @staticmethod # 裝飾器
? ? def _gen_key(key_str):
? ? ? ? Hash_value = hashlib.sha1(key_str.encode('utf-8')).hexdigest()

? ? ? ? return Hash_value

# 測試
C_H = CHash(['192.168.1.1','192.168.1.2','192.168.1.3','192.168.1.4'])
data =['Mike','Margge','Maria']
print('\n正常情況下，存儲數(shù)據(jù)時，歸入的節(jié)點地址：')
print(data[0]+'存入的節(jié)點IP地址：',C_H.dataNode(data[0]))
print(data[1]+'存入的節(jié)點IP地址：',C_H.dataNode(data[1]))
print(data[2]+'存入的節(jié)點IP地址：',C_H.dataNode(data[2]))
# 192.168.2.1刪除節(jié)點
print('\n192.168.1.2節(jié)點脫離分布式系統(tǒng)的情況：')
C_H.Del_Node('192.168.1.2') # 刪除節(jié)點
print(data[0]+'存入的節(jié)點IP地址：',C_H.dataNode(data[0]))
print(data[1]+'存入的節(jié)點IP地址：',C_H.dataNode(data[1]))
print(data[2]+'存入的節(jié)點IP地址：',C_H.dataNode(data[2]))