CN111538588B 分布式数据处理方法及相关装置 （中国平安人寿保险股份有限公司）

本申请实施例公开了一种分布式数据处理定所述消费消息为满足执行条件的待执行消费行结果通知第一服务器修改待执行消费消息的2从第一服务器获取消费消息以及所述消费消息对应的从第二服务器获取所述待执行消费消息对应的分布式锁，其中所述待执根据获取到的分布式锁执行所述待执行消费消根据所述业务过程的执行结果通知所述第一服务器修改所述待执行消费消息的执行其中，在从第二服务器获取所述待执行消费消息对应的获取与所述唯一标识对应的业务ID，每一个唯一标识对应生获取所述消费消息对应的执行时间，所述执行时间包括根据计时确定所述到达执行时间的消费消息为满足执行按照所述等候时长的大小关系进行排序，并将排序最前的所述等候时长对于提示所述第一服务器将所述消费消息的执3从第一服务器获取执行状态为未执行的消费消息以及所述消费消息对应的唯第一获取单元，用于从第一服务器获取消费消息以及所述消费消息对应的唯一标识，第二获取单元，从第二服务器获取所述待执行消费消息对应通知单元，用于根据所述业务过程的执行结果通知所述第一服务器修括用于执行如权利要求1-5任一项所述的方法中的步4[0001]本申请涉及分布式处理技术领域，具体涉及一种分布式数据处理方法及相关装[0009]根据所述业务过程的执行结果通知所述第一服务器修改所述待执行消费消息的5[0023]若所述业务过程的执行结果为执行失败，则延后所述消[0028]若所述业务过程的执行结果为执行失败，则向所述第一服务器发送第一提示消[0029]若所述业务过程的执行结果为执行成功，则向所述第一服务器发送第二提示消[0031]从第一服务器获取执行状态为未执行的消费消息以及所述消费消息对应的唯一[0035]执行单元，用于根据获取到的分布式锁执行所述待执行消费消息对应的业务过6[0049]若所述业务过程的执行结果为执行失败，则延后所述消[0054]若所述业务过程的执行结果为执行失败，则向所述第一服务器发送第一提示消[0055]若所述业务过程的执行结果为执行成功，则向所述第一服务器发送第二提示消[0057]从第一服务器获取执行状态为未执行的消费消息以及所述消费消息对应的唯一7[0076]请参阅图1B，图1B是本申请实施例提供的一种分布式数8询浏览和抽奖预约这6中业务进行1～6的编号，抽奖活动的消息请求发生时间对应的时间地址为B0-25-AA-21-75-5E，根据业务类型编号+时间戳+MAC地址生成的唯一标识为：2-在多个需要执行消费消息的业务过程的情况，为了公平分配消费端获取分布式锁的机会，与当前时间的差值小于第一预设时间阈值，则确定消费消息为到达执行时间的消费消息；确定到达执行时间的消费消息为满足执行条件9[0098]消费端获取到消费消息以及消费消息对应的唯一标识并确定其为待执行消费消[0101]105、消费端根据所述业务过程的执行结果通知所述第一服务器修改所述待执行服务器获取执行状态为未执行的消费消息以及消费消息对应[0108]请参阅图2，图2是本申请实施例提供的另一种分布式数[0117]请参阅图3，图3是本申请实施例提供的另一种分布式数[0130]请参阅图4，图4是本申请实施例提供的另一种分布式数[0131]401、消费端从第一服务器获取执行状态为未执行的消费消息以及所述消费消息[0136]消费端从第一服务器获取执行状态为未执行的消费消息以及消费消息对应的唯一服务器将消费消息的执行状态修改为已执行，已执行的消费消息不能再被消费端获取；取该消费消息时，能够根据新的唯一标识从第二服务器获取到该消费消息对应的分布式[0143]根据所述业务过程的执行结果通知所述第一服务器修改所述待执行消费消息的[0158]若所述业务过程的执行结果为执行失败，则延后所述消[0163]若所述业务过程的执行结果为执行失败，则向所述第一服务器发送第一提示消[0164]若所述业务过程的执行结果为执行成功，则向所述第一服务器发送第二提示消[0166]从第一服务器获取执行状态为未执行的消费消息以及所述消费消息对应的唯一[0168]第一获取单元601，用于从第一服务器获取消费消息以及所述消费消息对应的唯所述待执行消费消息对应的唯一标识未被所述第[0170]执行单元603，用于根据获取到的分布式锁执行所述待执行消费消息对应的业务[0171]通知单元604，用于根据所述业务过程的执行结果通知所述第一服务器修改所述费消息对应的唯一标识；再从第二服务器获取满足执行条件的消费消息对应的分布式锁，[0186]若所述业务过程的执行结果为执行失败，则延后所述消[0191]若所述业务过程的执行结果为执行失败，则向所述第一服务器发送第一提示消[0192]若所述业务过程的执行结果为执行成功，则向所述第一服务器发送第二提示消[0194]从第一服务器获取执行状态为未执行的消费消息以及所述消费消息对应的唯一法实施例中记载的任一方法的部分或全部步骤。该计算机程序产品可以为一个软件安装的耦合或直接耦合或通信连接可以是通过一些接口，装置或单元的间接耦合或通信连接，[0202]上述集成的单元若以软件功能单元的形式实现并作为独说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现为个人计算机、服务器或者网络设备等)执行本申请各个实施例上述方法的全部或部分步骤。而前述的存储器包括：U盘、只读存储器(Read-OnlyMemory,ROM)、随机存取[0203]本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可实施方式进行了阐述，以上实施例的说明只是用于帮助理解本申请的方法及其核心思想；