1、提出者向leader發(fā)出詢問消息
2、leader向所有的QuorumPeer發(fā)出投票請(qǐng)求
3、QuorumPeer對(duì)該請(qǐng)求進(jìn)行投票，如果消息的txid大于QuorumPeer的txid則通過該投票，否則反對(duì)該投票
4、leader根據(jù)所有的QuorumPeer投票結(jié)果進(jìn)行計(jì)算，如果有一半以上的QuorumPeer通過則接受提出者的請(qǐng)求，否則拒絕提出者的請(qǐng)求
switch (message.getType())
{
case QuorumCode.ask://詢問類型
//詢問該事務(wù)是否可操作
Ask task=new Ask(message,sc);
My.executor.execute(task);
m.setCode(JuiceCode.OK);
break;
case QuorumCode.vote://投票類型
if(My.txid>=message.getTxid())
//拒絕
m.setCode(JuiceCode.ERROR);
else
{
//通過
m.setCode(JuiceCode.OK);
My.updateMyTxid(message.getTxid());
}
break;
case QuorumCode.ping://ping
m.setCode(JuiceCode.OK);
m.setMyid(message.getMyid());
break;
}
public static boolean sendAndVote(Message m) throws IOException
{
m.setType(QuorumCode.vote);
Map<Integer,Response> mp=new TreeMap<Integer,Response>();
for(Map.Entry<Integer,NIOClient> entry:voteClientMap.entrySet())
{
NIOClient client=entry.getValue();
Response response=client.send(ByteUtil.getBytes(m));
mp.put(entry.getKey(), response);
}
Map<Integer,Message> vote=new TreeMap<Integer,Message>();
for(Map.Entry<Integer,Response> entry:mp.entrySet())
vote.put(entry.getKey(), (Message)ByteUtil.getObject(entry.getValue().getData()));
int ok=0;
for(Map.Entry<Integer,Message> entry:vote.entrySet())
{
Message f=entry.getValue();
if(f.getCode()==JuiceCode.OK)
ok++;
}
if(ok/(vote.size()*1.0)>1/2.0)
return true;
return false;
}posted on 2013-04-23 13:19
nianzai 閱讀(1762)
評(píng)論(0) 編輯 收藏 所屬分類:
分布式