-
公开(公告)号：CN115103011B
公开(公告)日：2024-02-09
申请号：CN202210724076.3
申请日：2022-06-24
Applicant: 北京奥星贝斯科技有限公司 , 中国人民大学
IPC: H04L67/51 , H04L67/1097 , G06F13/28 , G06F9/46 , H04L67/56 , H04L69/166
Abstract: 本说明书实施例公开了跨数据中心的业务处理方法、装置以及设备。包括：第一数据中心内的协调者节点，接收并解析客户端发送的事务请求，得到分别对应于数据中心的子事务，确定子事务涉及的数据分片，以及确定其主副本所在的数据中心，作为第二数据中心，在第二数据中心内确定代理协调者节点，将子事务发送给代理协调者节点，以便其通过远程直接内存访问处理子事务；若协调者节点不可用，则确定协调者节点上是否有数据分片的主副本，若是，则选择数据分片的一个从副本，作为主副本，并回滚涉及数据分片的未完成事务；在子事务发送给代理协调者节点之后，代理协调者节点，若与协调者节点之间涉及子事务的通信失败，则回滚未完成的子事务。
-
公开(公告)号：CN115033350A
公开(公告)日：2022-09-09
申请号：CN202210641911.7
申请日：2022-06-07
Applicant: 北京奥星贝斯科技有限公司 , 中国人民大学
Abstract: 本说明书公开了一种分布式事务的执行方法及装置，通过先接收包含若干数据操作的事务请求，然后根据数据中心将该事务划分为若干子事务，在本地数据中心内，采用远程直接内存访问方式，执行本地子事务包含的数据操作并确定第一操作结果，以及将各远程子事务采用网络通信方式，发送至对应的其他数据中心，使得各其他数据中心采用远程直接内存访问方式执行接收到的远程子事务包含的数据操作，并接收各其他数据中心返回的第二操作结果，最后根据第一操作结果以及第二操作结果确定事务的执行结果。通过数据中心之间采用网络通信方式执行访问，每个数据中心内采用远程直接内存访问方式执行访问，提高了大范围的分布式事务的执行效率。
-
公开(公告)号：CN115982190A
公开(公告)日：2023-04-18
申请号：CN202211739339.4
申请日：2022-12-31
Applicant: 中国人民大学 , 北京奥星贝斯科技有限公司
Abstract: 本说明书公开了一种日志提交方法、装置、存储介质及电子设备，本说明书实施例中第一节点确定第二节点写入的针对同一数据的各操作日志中接收到提交时刻的第一日志，并从各第一日志对应的提交时刻中确定最迟的提交时刻。从除各第一日志之外的其他操作日志中筛选出写入操作日志的时刻早于最迟的提交时刻的第二日志。等到所有第二日志接收到提交时刻后，依次提交各操作日志。第一节点和第二节点位于不同的数据中心。在此方法中，在未接收到提示信息的操作日志均接收到指示消息后，才按照提交时刻对各操作日志进行提交并依次回放，可以避免位于不同数据中心内的节点针对同一数据的日志回放顺序不一致的问题，以保证分布式数据库系统的数据一致性。
-
公开(公告)号：CN115103011A
公开(公告)日：2022-09-23
申请号：CN202210724076.3
申请日：2022-06-24
Applicant: 北京奥星贝斯科技有限公司 , 中国人民大学
IPC: H04L67/51 , H04L67/1097 , G06F13/28 , G06F9/46 , H04L67/56 , H04L69/166
Abstract: 本说明书实施例公开了跨数据中心的业务处理方法、装置以及设备。包括：第一数据中心内的协调者节点，接收并解析客户端发送的事务请求，得到分别对应于数据中心的子事务，确定子事务涉及的数据分片，以及确定其主副本所在的数据中心，作为第二数据中心，在第二数据中心内确定代理协调者节点，将子事务发送给代理协调者节点，以便其通过远程直接内存访问处理子事务；若协调者节点不可用，则确定协调者节点上是否有数据分片的主副本，若是，则选择数据分片的一个从副本，作为主副本，并回滚涉及数据分片的未完成事务；在子事务发送给代理协调者节点之后，代理协调者节点，若与协调者节点之间涉及子事务的通信失败，则回滚未完成的子事务。
-
公开(公告)号：CN115098231A
公开(公告)日：2022-09-23
申请号：CN202210722852.6
申请日：2022-06-24
Applicant: 北京奥星贝斯科技有限公司 , 中国人民大学
IPC: G06F9/46 , G06F13/28 , H04L67/1097 , H04L69/16
Abstract: 本说明书实施例公开了跨数据中心的事务处理方法、装置以及设备。应用于由多个数据中心构成的分布式系统，方案包括：第一数据中心内的协调者节点，接收并解析客户端发送的事务请求，得到一个或者多个分别对应于一个数据中心的子事务；协调者节点，确定子事务对应的数据中心，作为第二数据中心，若第二数据中心不为第一数据中心，则在第二数据中心内确定代理协调者节点，将子事务发送给代理协调者节点；代理协调者节点，确定子事务涉及的数据分片的副本在第二数据中心内所在的数据节点，通过对数据节点进行远程直接内存访问，执行子事务，根据执行结果响应协调者节点；所述协调者节点，根据各代理协调者节点的响应，继续处理事务请求。
-
Patent Agency Ranking
公开(公告)号：CN119357210A
公开(公告)日：2025-01-24
申请号：CN202411944388.0
申请日：2024-12-26
Applicant: 北京奥星贝斯科技有限公司
Abstract: 本说明书提供一种分布式集群的管理方法及装置、锁服务集群及分布式集群，该方法包括：向锁服务集群的每个锁服务节点发送锁申请消息，其中，所述锁服务节点用于在接收到至少一个数据节点发送的锁申请消息后向所述至少一个数据节点中一个数据节点发送锁确认消息；若接收到所述锁服务集群内不小于预设比例的锁服务节点发送的锁确认消息，则在所述分布式集群内加锁成功，若未接收到所述锁服务集群内不小于预设比例的锁服务节点发送的锁确认消息，则在所述分布式集群内加锁失败。
-
公开(公告)号：CN115905402B
公开(公告)日：2023-07-18
申请号：CN202211172899.6
申请日：2022-09-26
Applicant: 北京奥星贝斯科技有限公司
IPC: G06F16/27 , G06F16/242 , G06F16/23
Abstract: 本说明书实施例提供了一种处理事务日志的方法及装置。该方法包括：针对分布式数据库执行一个事务，其中，该事务中包括第一操作及第二操作；确定第一序号，以及第二序号；其中，第一序号及第二序号之间的先后顺序与第一操作及第二操作之间的执行先后顺序相同；生成第一操作对应的第一日志以及第二操作对应的第二日志；在第一日志中携带第一序号，在第二日志中携带第二序号；将第一日志及第二日志分别写入该分布式数据库中的两个日志流中。通过本申请能够根据日志流中的日志得到事务中的各个操作之间的先后顺序，从而能够正确地得到事务的事务数据。
-
公开(公告)号：CN116069792A
公开(公告)日：2023-05-05
申请号：CN202211559350.2
申请日：2022-12-06
Applicant: 北京奥星贝斯科技有限公司
Abstract: 本说明书公开了一种数据库容灾系统、方法、装置、存储介质及电子设备，在本说明书提供的数据库容灾系统中，在本说明书提供的数据库容灾系统中，所述系统包括第一数据库，第一数据库中的数据处理节点将数据库操作生成的日志基于分布式一致性协议至少同步在一个数据保护节点中，所述数据保护节点接收并存储日志，当所述第一数据库中的部分数据处理节点异常时，第一数据库中未出现异常的数据处理节点基于所述数据保护节点中存储的日志提供数据库服务，实现了对所述第一数据库的容灾，从上述系统中可以看出，本系统可以基于分布式一致性协议，通过与所述数据处理节点独立的数据保护节点对所述第一数据库实现不损失数据的容灾。
-
公开(公告)号：CN115658245B
公开(公告)日：2023-03-10
申请号：CN202211654866.5
申请日：2022-12-22
Applicant: 北京奥星贝斯科技有限公司
Abstract: 本说明书提供一种分布式数据库系统，包括：目标事务的事务协调者和事务参与者，每一事务参与者记录有分界位置，其中：所述事务协调者，用于向所述事务参与者发起针对所述目标事务的准备请求，以使所述事务参与者生成并持久化对应的准备日志；以及，根据所有事务参与者返回的针对所述准备日志的持久化结果，向所述事务参与者发起对应的事务执行请求；所述事务参与者，用于响应于所述准备请求生成对应的准备日志，将所述准备日志持久化，并将持久化结果返回至所述事务协调者；以及，响应于所述事务执行请求，执行对应所述事务执行请求的事务操作，并在执行完成后将所述目标事务由未决状态切换为已决状态。
-
公开(公告)号：CN115576969B
公开(公告)日：2023-03-10
申请号：CN202211567893.9
申请日：2022-12-07
Applicant: 北京奥星贝斯科技有限公司
Abstract: 本说明书公开了一种并行执行数据库任务的方法、装置、介质及设备，通过接收若干数据库操作任务，并调用至少一个线程，并行执行数据库操作任务。针对每个数据操作任务，记录执行该数据操作任务的线程的线程标识，以及确定线程执行该数据操作任务的时间戳，进而确定各数据库操作任务的先后顺序。当存在异常线程时，根据异常线程的线程标识以及记录的执行数据操作任务的线程的线程标识，确定异常线程执行的数据操作任务。将确定出的数据操作任务所操作的数据，作为回滚数据进行回滚，以及根据对回滚数据操作的先后顺序，将其他线程对回滚数据的操作进行回滚。该方法可实现数据库任务的并行执行，并且大大的提高了并行执行数据库任务的效率。
-
-
-
-
-
-
-
-
-
Search Results
71
records
(took 0.055 seconds)
