基于python的Paxos算法实现

基于基于python的的Paxos算法实现算法实现

主要介绍了基于python的Paxos算法实现，理解一个算法最快，最深刻的做法，我觉着可能是自己手动实现，虽

然项目中不用自己实现，有已经封装好的算法库，供我们调用，我觉着还是有必要自己亲自实践一下,需要的朋

友可以参考下

理解一个算法最快，最深刻的做法，我觉着可能是自己手动实现，虽然项目中不用自己实现，有已经封装好的算法库，供我们

调用，我觉着还是有必要自己亲自实践一下。

这里首先说明一下，python这种动态语言，对不熟悉的人可能看着比较别扭，不像java那样参数类型是固定的，所以看着会有

些蛋疼。这里环境用的是python2.7。

MSG_ACCEPT = 4 # 接受

MSG_PROPOSE = 5 # 提议

MSG_EXT_PROPOSE = 6 # 额外提议

MSG_HEARTBEAT = 7 # 心跳，每隔一段时间同步消息

def __init__(self, command=None):

self.command = command

# 把收到的消息原原路返回，作为应答消息

def copyAsReply(self, message):

# 提议ID #当前的ID #发给谁 #谁发的

self.proposalID, self.instanceID, self.to, self.source = message.proposalID, message.instanceID, message.source, message.to

import queue

class MessagePump(threading.Thread):

# 收取消息线程

class MPHelper(threading.Thread):

#

def __init__(self, owner):

self.owner = owner

threading.Thread.__init__(self)

def run(self):

while not self.owner.abort: # 只要所有者线程没有结束,一直接受消息

pass

def __init__(self, owner, port, timeout=2):

threading.Thread.__init__(self)

self.owner = owner

self.abort = False

self.timeout = 2

self.port = port

self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # UDP通信

self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 200000) # 通信参数

self.socket.bind(("localhost", port)) # 通信地址，ip，端口