Lamport 全序组播(totally-ordered mulitcast)

背景

如何保证分布式系统中的各个子系统都按相同的顺序执行一组操作?一个等价的问题就是如何在分布式系统下实现全序组播(totally-ordered mulitcast)。这个可以利用Lamport提出的逻辑时钟实现。
但是规则的逻辑时钟是一个偏序,而非全序。

解决

使用Lamport的算法,但使用进程ID打破关系
L(e) = M * Li(e) + i
M = maximum number of processes
i = process ID

假设

Assume all messages sent by one sender are received in the order they were sent and that no messages are lost.

Lamport全序组播是在如下的假设下进行的:

  1. 发送者发送的顺序和接受者接收的顺序一致
  2. 消息不会丢失

实现

关键:每一个进程都维护一个本地请求队列(Request Queue),此队列里的消息按时间戳排序。

  1. 进程Pi给消息m加上时间戳Ti(m),并广播给所有进程(包括Pi);
  2. 进程Pj接收到消息m后,首先更新本地逻辑时钟,并把消息m加入请求队列,然后向所有进程(包括Pj)广播接收到消息m的确认信息ACK。
  3. 当进程的请求队列中的某个消息位于队列顶部,且已经收到所有进程关于此消息的确认信息ACK时,可以把此消息从队列顶部取走,并传给应用程序。

实例

更新操作顺序不一致,导致数据副本状态不一致

全局的逻辑时间
假设图左边为A,右边为B

B收到A之后,B才发送

图1

L(e) = M * Li(e) + i
计算例如:A->B(request),此时规则的逻辑时间为1,M(最大进程数)为2,i为pid 1,所以此时时间戳应该为1*2+1 = 3

  • queue:[{1,request,timestamps:3},{2,request,timestamps :10}]

AB同时发(1)

图2

这里ACK讨论的是在双方都未接收对方ACK前发送的。
队列里有两个请求,按时间戳从小到大排序

  • queue:[{1,request,timestamps:3},{2,request,timestamps :4}]

AB同时发(2)

图3
  • queue:[{1,request,timestamps:3},{2,request,timestamps :4}]

AB同时发(3)

图4
  • queue:[{1,request,timestamps:3},{2,request,timestamps :4}]

情况论述

没讨论的情况:B收到A的ACK穿插发生在B收到A和马上发回A一个ACK的间隙中。

不可能出现的情况:根据设定发送者发送的顺序和接受者接收的顺序一致,不可能出现B都已经收到了A发送的ACK,还没有收到A的请求消息的情况。

ACK分析

后面ACK接收情况的不同影响的是,执行消息的时机(只有当接收到所有其他进程对此消息的ACK,并且处在队列头部),执行顺序依旧是一样
(例如AB同时发的3种情况里的队列{1,request,timestamps:3}{2,request,timestamps :4})

关键

  1. 收到的ACK的时间戳是高于接收到的消息
    例如AB同时发的(图2)。B收到A的请求时间戳(3)小于收到A对于B请求回复的ACK(7)。
    Lamport全序组播是在发送者发送的顺序和接受者接收的顺序一致的假设下进行的,假设B的请求m,当B收到A对于消息m的ACK时,说明了以下两点:
  • 进程B知道了A进程成功收到了m消息
  • A发送ACK消息之前发送的请求消息N1、N2......,B进程也收到了,确保消息m不会提前执行,需要按照执行消息规则(时间戳顺序)来执行。
  1. 所有的进程的本地都有一份一致的请求队列副本
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,837评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,551评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,417评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,448评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,524评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,554评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,569评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,316评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,766评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,077评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,240评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,912评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,560评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,176评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,425评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,114评论 2 366
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,114评论 2 352

推荐阅读更多精彩内容