基于基于python的的Paxos算法实现算法实现
主要介绍了基于python的Paxos算法实现，理解一个算法最快，最深刻的做法，我觉着可能是自己手动实现，虽
然项目中不用自己实现，有已经封装好的算法库，供我们调用，我觉着还是有必要自己亲自实践一下,需要的朋
友可以参考下
理解一个算法最快，最深刻的做法，我觉着可能是自己手动实现，虽然项目中不用自己实现，有已经封装好的算法库，供我们
调用，我觉着还是有必要自己亲自实践一下。
这里首先说明一下，python这种动态语言，对不熟悉的人可能看着比较别扭，不像java那样参数类型是固定的，所以看着会有
些蛋疼。这里环境用的是python2.7。
class Message:
# command
MSG_ACCEPTOR_AGREE = 0 # 追随者约定
MSG_ACCEPTOR_ACCEPT = 1 # 追随者接受
MSG_ACCEPTOR_REJECT = 2 # 追随者拒绝-网络不通
MSG_ACCEPTOR_UNACCEPT = 3 # 追随者网络通-不同意
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
self.value = message.value # 发的信息
然后是利用然后是利用socket,线程和队列实现的消息处理器：线程和队列实现的消息处理器：
# 基于socket传递消息，封装网络传递消息
import threading
import pickle
import socket
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: # 只要所有者线程没有结束,一直接受消息
try:
(bytes, addr) = self.owner.socket.recvfrom(2048) # 收取消息
msg = pickle.loads(bytes) # 读取二进制数据转化为消息
msg.source = addr[1]
self.owner.queue.put(msg) # 队列存入消息
except Exception as e:
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，端口
剩余7页未读，继续阅读
评论0
最新资源