# 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ù)長(zhǎng)度定義為
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é)點(diǎn)存放節(jié)點(diǎn)地址，V-num一個(gè)節(jié)點(diǎn)對(duì)應(yīng),# 默認(rèn)節(jié)點(diǎn)是為2
? ? ? ? self._v_num = v_num # 一個(gè)節(jié)點(diǎn)對(duì)應(yīng)存放節(jié)點(diǎn)地址
? ? ? ? self._vNode_IP = {} #　用于虛擬節(jié)點(diǎn)的hash值與node的對(duì)應(yīng)關(guān)系
? ? ? ? self._vNodeAdd = [] # 用于存放所有的虛擬節(jié)點(diǎn)的hash值，這里需要保持排序
? ? ? ? for node in nodes:
? ? ? ? ? ? self.addNode(node)
? ? ? ? print('\n虛擬節(jié)點(diǎn)哈希值升序排列：\n',self._vNodeAdd) # 對(duì)虛擬節(jié)點(diǎn)哈希地址進(jìn)行從小到大排序

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

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

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

? ? ? ? return Hash_value

# 測(cè)試
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正常情況下，存儲(chǔ)數(shù)據(jù)時(shí)，歸入的節(jié)點(diǎn)地址：')
print(data[0]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[0]))
print(data[1]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[1]))
print(data[2]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[2]))
# 192.168.2.1刪除節(jié)點(diǎn)
print('\n192.168.1.2節(jié)點(diǎn)脫離分布式系統(tǒng)的情況：')
C_H.Del_Node('192.168.1.2') # 刪除節(jié)點(diǎn)
print(data[0]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[0]))
print(data[1]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[1]))
print(data[2]+'存入的節(jié)點(diǎn)IP地址：',C_H.dataNode(data[2]))