一种分布式系统中的数据同步方法和分布式系统

摘要

本申请实施例公开了一种分布式系统中的数据同步方法和分布式系统。分布式系统包括至少两个子系统，每个子系统分别位于不同的数据中心上，其中，每个子系统包括消费者模块、生产者模块、消费者存储模块和生产者存储模块，在位于任意一个数据中心的子系统中，生产者模块生产数据，将生产的数据写入到本地子系统的消费者存储模块和生产者存储模块；消费者模块从本地子系统的消费者存储模块中读取数据，对读取的数据进行处理；生产者存储模块存储本地子系统的生产者模块写入的数据，向位于除本地子系统所在的数据中心之外的其它数据中心的子系统中的消费者存储模块同步所存储的数据；消费者存储模块存储本地子系统的生产者模块写入的数据和位于除本地子系统所在的数据中心之外的其它数据中心的子系统的生产者存储模块同步的数据。根据本申请实施例，能够支持本地的消费者对远程的生产者生产的数据进行处理。