技术领域 本发明涉及内容分发网络（ Content Delivery Network , CDN )的数据同 步技术， 尤其涉及 CDN中分布式服务端主动同步的方法及系统。

背景技术 在通信技术领域， 互联网协议电视 ( Internet Protocol TV或 Interactive Personal TV, 简称为 IPTV )也称交互式网络电视， 是一种基于互联网的多媒 体通信技术。 IPTV利用宽带网的基础设施， 以家用电视机或计算机作为主要 终端设备， 通过互联网协议 ( Internet Protocol, IP )传送电视信号， 向家庭 用户提供包括电视在内的多种交互式数字媒体 服务。

CDN是一种新的网络架构， 将业务的内容发布到最接近用户的网络 "边 缘" ， 使用户可以就近取得其所需的内容， 从而提高系统的运行效率。 CDN 在技术上可以全面解决由于用户访问量大， 服务器分布不均对骨干网带来的 拥塞问题， 同时可以提高用户访问流媒体服务器的速度以 及缩短对用户的服 务请求的响应时间。

CDN为了确保分布在不同地点的内容数据的一 致性，需要在内容数据进 行更新后针对不同地点进行同步处理。 在 CDN上有一个数据同步处理管理 器应用模块， 部署在 CDN的业务处理机上， 用于执行 IPTV系统管理侧下发 的任务以及为数据同步客户端分配可服务的同 步处理代理器等。 从业务处理 机分离出来的数据同步处理代理器， 是用于分担业务处理机部分功能的一台 物理设备， 主要执行的操作是保持与数据同步客户端之间 的心跳关系， 并与 数据同步客户端进行数据同步处理等。 目前， 在 IPTV系统的内容分发网络中， 数据同步处理管理器和数据同 步处理代理器虽然已经釆用了分布式部署， 但是由于只有数据同步处理管理 器可以获得管理侧的任务， 所以对于数据同步服务端 （包括同步处理管理器 和同步处理代理器）主动向数据同步客户端发 起的同步的数据传输， 依然只 能在数据同步处理管理器上进行。

随着业务量的提高， 数据同步客户端设备及其需要获取的同步的消 息的 数据量也相应地增大， 使得原有的所有主动接口只能由数据同步管理 器进行 数据同步触发的系统架构遭遇性能危机。

发明内容 本发明所要解决的技术问题是提供一种内容分 发网络中数据同步的系 统及方法， 能够在内容分发网络的分布式服务端的主动同 步过程中均衡系统 压力， 从而提高系统工作的稳定性。 为了解决上述技术问题， 本发明提供了一种内容分发网络中数据同步的 方法，该方法包括： 数据同步客户端从数据同步处理管理器请求获 取归属的数据同步处理代 理器， 建立与归属的同步处理代理器的心跳联系， 以获知归属的数据同步代 理处理器的运行状态； 数据同步处理管理器扫描所述管理侧数据库， 若扫描到管理侧数据库有 需通知到数据同步客户端的同步任务， 则在能力侧数据库中为相应数据同步 处理代理器生成同步任务。 若扫描到有需通知到数据同步客户端的同步任 务， 则在所述能力侧数据 库中为相应数据同步处理代理器生成所述同步 任务的步骤包括： 若扫描到有需通知到所有的数据同步客户端的 同步任务， 则在所述能力 侧数据库中为每一数据同步处理代理器生成所 述同步任务；

若扫描到只需通知到个别的数据同步客户端的 同步任务， 且查询到这些 数据同步客户端所属的同步处理代理器， 则在能力侧数据库中为查询到的同 步处理代理器生成同步任务。 管理侧数据库中的同步任务，是管理侧管理平 台在需要进行数据更新时， 将要更新的业务数据写入管理侧数据库的同时 生成的。 在所述能力侧数据库中为相应同步处理代理器 生成所述同步任务的步骤 之后， 该方法还包括: 数据同步处理代理器扫描能力侧数据库， 若扫描到存在需要执行的同步 任务及其要更新的业务数据， 则将要更新的业务数据保存到本地， 同时主动 向所服务的数据同步客户端发送同步数据通知 。 主动向所服务的数据同步客户端发送同步数据 通知的步骤之后， 该方法 还包括： 数据同步客户端接收到数据同步处理代理器发 送的同步数据通知后， 向 同步处理代理器发送同步数据请求； 通过数据同步处理代理器返回的同步数 据响应接收及保存本次同步任务要更新的业务 数据。

为了解决上述技术问题， 本发明提供了一种内容分发网络中数据同步的 系统， 包括： 管理侧数据库、 数据同步处理管理器、 能力侧数据库、 数据同 步处理代理器以及数据同步客户端， 其中： 管理侧数据库设置为： 生成及保存同步任务及其更新的业务数据； 数据同步客户端设置为： 从数据同步处理管理器请求获取到归属的数据 同步处理代理器， 建立与归属的同步处理代理器的心跳联系， 以获知该归属 的数据同步代理处理器的运行状态； 数据同步处理管理器设置为： 根据数据同步客户端的请求为数据同步客 户端分配所归属的数据同步处理代理器； 扫描管理侧数据库， 若扫描到有需 通知到数据同步客户端的同步任务， 则在能力侧数据库中为相应数据同步处 理代理器生成同步任务； 能力侧数据库设置为： 保存同步任务及其要更新的业务数据。 所述数据同步处理管理器是设置为按如下方式 在所述能力侧数据库中为 相应数据同步处理代理器生成所述同步任务： 若扫描到有需通知到所有的数据同步客户端的 同步任务， 则在所述能力 侧数据库中为每一数据同步处理代理器生成所 述同步任务； 若扫描到只需通知到个别的数据同步客户端的 同步任务， 且查询到这些 数据同步客户端所属的同步处理代理器， 则在能力侧数据库中为查询到的同 步处理代理器生成同步任务。 管理侧数据库中的同步任务，是管理侧管理平 台在需要进行数据更新时， 将要更新的业务数据写入的同时生成及保存的 。 数据同步处理代理器还设置为： 扫描能力侧数据库， 若扫描到存在需要 执行的同步任务及其要更新的业务数据，则将 要更新的业务数据保存到本地， 同时主动向所服务的数据同步客户端发送同步 数据通知。 数据同步客户端还设置为： 接收到数据同步处理代理器发送的同步数据 通知后， 向同步处理代理器发送同步数据请求， 通过数据同步处理代理器返 回的同步数据响应收到及保存本次同步任务要 更新的业务数据。

为了解决上述技术问题， 本发明提供了一种数据同步处理管理器， 其包 括： 分配模块， 其设置为： 接收数据同步客户端发送的获取归属的数据同 步 处理代理器的请求， 并根据所述获取归属的数据同步处理代理器的 请求为所 述数据同步客户端分配所归属的数据同步处理 代理器； 扫描模块， 其设置为： 扫描生成并保存有同步任务及其更新的业务数 据 的管理侧数据库， 若扫描到有需通知到数据同步客户端的同步任 务， 则触发 同步任务生成模块； 以及 同步任务生成模块， 其设置为： 若扫描到有需通知到数据同步客户端的 同步任务， 则在保存所述同步任务及其要更新的业务数据 的能力侧数据库中 为相应数据同步处理代理器生成所述同步任务 。 所述同步任务生成模块是设置为按如下方式在 所述能力侧数据库中为相 应数据同步处理代理器生成所述同步任务： 若扫描到有需通知到所有的数据同步客户端的 同步任务， 则在所述能力 侧数据库中为每一数据同步处理代理器生成所 述同步任务； 若扫描到只需通知到个别的数据同步客户端的 同步任务， 且查询到这些 数据同步客户端所属的同步处理代理器， 则在所述能力侧数据库中为查询到 的所述同步处理代理器生成所述同步任务。

为了解决上述技术问题， 本发明提供了一种数据同步处理代理器， 其包 括： 连接建立模块， 其设置为： 当数据同步处理管理器根据数据同步客户端 的请求为所述数据同步客户端分配本数据同步 代理器为数据同步客户端所归 属的数据同步处理代理器时， 与归属于本数据同步代理器的数据同步客户端 建立心跳联系， 以使所述数据同步客户端获知所述数据同步代 理处理器的运 行状态； 扫描模块， 其设置为： 扫描能力侧数据库， 若扫描到存在需要执行的同 步任务及其要更新的业务数据， 触发发送模块； 其中， 所述能力侧数据库保 存有数据同步处理管理器扫描到管理侧数据库 中有需通知到数据同步客户端 的同步任务时， 在所述能力侧数据库中为相应数据同步处理代 理器生成的同 步任务； 以及 发送模块， 其设置为： 若扫描到存在需要执行的同步任务及其要更新 的 业务数据， 将所述要更新的业务数据保存到本地， 同时主动向所服务的数据 同步客户端发送同步数据通知。 所述数据同步处理代理器还包括： 接收模块， 其设置为： 接收所述数据同步客户端在接收到所述同步数 据 通知后， 向所述同步处理代理器发送的同步数据请求； 所述发送模块还设置为： 向所述数据同步客户端返回同步数据响应， 所 述同步数据响应携带有本次同步任务要更新的 业务数据。

本发明通过釆用数据同步处理代理器配合数 据同步处理管理器进行数据 同步处理，来减轻以往同步处理管理器过重的 负担，使得系统压力得到均衡， 从而提高了系统的性能。

附图概述 图 1 是本发明的在 IPTV系统中内容分发网络数据同步处理系统实� �例 的框架结构图； 图 2 是本发明的在 IPTV系统中内容分发网络数据同步方法实施例� �程 时序图； 图 3是本发明的方法实施例中数据同步处理管理� �为数据同步客户端生 成数据同步任务的流程图； 图 4是本发明的方法实施例中数据同步处理代理� �通知数据同步客户端 进行数据同步的流程图； 图 5是本发明的方法实施例中数据同步处理代理� �根据数据同步客户端 的数据同步请求返回同步数据的流程图。

本发明的较佳实施方式 以下结合附图和优选实施例对本发明的技术方 案进行详细地阐述。 以下 例举的实施例仅仅用于说明和解释本发明， 而不构成对本发明技术方案的限 制。

图 1是本发明以 IPTV系统为实施例给出的内容分发网络数据同� �处理 系统的框架结构， 主要包括一个数据同步处理管理器和多个数据 同步处理代 理器， 以及隶属各个数据同步处理代理器的多个数据 同步客户端； 其中： 数据同步处理管理器设置为： 为数据同步客户端分配可服务的同步处理 代理器； 若扫描到管理侧数据库有同步任务， 则在能力侧数据库为每一同步 处理代理器生成同步任务， 或为请求数据同步的数据同步客户端相应的同 步 处理代理器生成同步任务； 数据同步处理管理器在数据同步客户端请求数 据同步处理代理器时， 根 据负载均衡策略为其分配数据同步处理代理器 ， 同时更新该数据同步处理代 理器的数据同步客户端连接数。 数据同步处理代理器设置为： 在为其服务的数据同步客户端扫描到能力 侧数据库有同步任务时， 将查获的同步数据保存在其内存数据库中， 并通知 该数据同步客户端； 在收到数据同步客户端的数据同步请求时， 将从内存数 据库中查获的同步数据返回给该数据同步客户 端； 数据同步客户端设置为： 向数据同步处理管理器请求数据同步处理代理 器， 并建立与分配到的同步处理代理器的心跳联系 ； 在收到同步处理代理器 的数据同步通知后， 向该同步处理代理器发出数据同步请求， 并通过该同步 处理代理器返回的数据同步响应获取相应的同 步数据。 本实施例还提供了一种数据同步处理管理器， 其包括： 分配模块， 其设置为： 接收数据同步客户端发送的获取归属的数据同 步 处理代理器的请求， 并根据该获取归属的数据同步处理代理器的请 求为所述 数据同步客户端分配所归属的数据同步处理代 理器； 扫描模块， 其设置为： 扫描生成并保存有同步任务及其更新的业务数 据 的管理侧数据库， 若扫描到有需通知到数据同步客户端的同步任 务， 则触发 同步任务生成模块； 以及 同步任务生成模块， 其设置为： 若扫描到有需通知到数据同步客户端的 同步任务， 则在保存所述同步任务及其要更新的业务数据 的能力侧数据库中 为相应数据同步处理代理器生成所述同步任务 。 所述同步任务生成模块是设置为按如下方式在 所述能力侧数据库中为相 应数据同步处理代理器生成所述同步任务： 若扫描到有需通知到所有的数据同步客户端的 同步任务， 则在所述能力 侧数据库中为每一数据同步处理代理器生成所 述同步任务； 若扫描到只需通知到个别的数据同步客户端的 同步任务， 且查询到这些 数据同步客户端所属的同步处理代理器， 则在所述能力侧数据库中为查询到 的所述同步处理代理器生成所述同步任务。 本实施例还提供了一种数据同步处理代理器， 其包括： 连接建立模块， 其设置为： 当数据同步处理管理器根据数据同步客户端 的请求为所述数据同步客户端分配本数据同步 代理器为数据同步客户端所归 属的数据同步处理代理器时， 与归属于本数据同步代理器的数据同步客户端 建立心跳联系， 以使所述数据同步客户端获知所述数据同步代 理处理器的运 行状态； 扫描模块， 其设置为： 扫描能力侧数据库， 若扫描到存在需要执行的同 步任务及其要更新的业务数据， 触发发送模块； 其中， 所述能力侧数据库保 存有数据同步处理管理器扫描到管理侧数据库 中有需通知到数据同步客户端 的同步任务时， 在所述能力侧数据库中为相应数据同步处理代 理器生成的同 步任务； 以及 发送模块， 其设置为： 若扫描到存在需要执行的同步任务及其要更新 的 业务数据， 将所述要更新的业务数据保存到本地， 同时主动向所服务的数据 同步客户端发送同步数据通知。 该数据同步处理代理器还包括： 接收模块， 其设置为： 接收所述数据同步客户端在接收到所述同步数 据 通知后， 向所述同步处理代理器发送的同步数据请求； 所述发送模块还设置为： 向所述数据同步客户端返回同步数据响应， 所 述同步数据响应携带有本次同步任务要更新的 业务数据。

如图 2所示， 本发明以 IPTV系统为实施例， 给出内容分发网络中数据 同步方法流程， 包括如下步骤： 步骤 1 : 数据同步客户端向数据同步处理管理器请求数 据同步处理代理 器， 并得到数据同步处理管理器返回的其归属的同 步处理代理器； 数据同步客户端请求数据同步处理代理器的时 机为： 本设备启动时， 服 务获取请求周期到达时， 或在检测到当前业务处理代理器异常时。 步骤 2: 数据同步客户端建立与其归属的数据同步处理 代理器的心跳联 系， 以获知为其服务的数据同步代理处理器是否处 于正常运行状态； 步骤 3、 4: 数据同步处理管理器扫描管理侧数据库， 检查是否存在要执 行的同步任务， 如果存在（即管理侧数据库返回要执行的同步 任务） ， 且要 求通知到所有数据同步客户端， 则在能力侧数据库中为每一数据同步处理代 理器生成 (即插入）一条对应的任务， 并得到能力侧数据库返回的操作结果； 管理侧管理平台在需要进行数据更新时， 将要更新的业务数据写入管理 侧数据库， 同时向管理侧数据库中的任务表中插入对应的 同步任务。 在另一实施例里， 如果数据同步处理管理器检查存在只针对个别 的数据 同步客户端的同步任务， 且查询到这些数据同步客户端它们所属的数据 同步 处理代理器， 则在能力侧数据库中为这些数据同步处理代理 器——生成对应 的同步任务， 并得到能力侧数据库返回的操作结果。 步骤 5、 6: 数据同步处理代理器定时扫描能力侧数据库， 检查是否存在 需要执行的同步任务， 如果存在 (即能力侧数据库返回要执行的同步任务）， 则将需要更新的数据保存到本地内存数据库中 ， 同时主动向所服务的数据同 步客户端 （譬如电子节目指南 （ Electronic Program Guide, EPG )服务设备 ) 发送同步数据通知； 数据同步处理代理器根据能力侧数据库中查获 的数据同步任务的任务标 识、任务类型、 需要进行数据同步的客户端标识等参数， 查询能力侧数据库， 将需要同步的数据保存在内存数据库中， 然后主动向需要进行数据同步的客 户端发送该任务类型的数据同步通知。 步骤 7: 数据同步客户端接收到数据同步处理代理器发 来的同步数据通 知， 向对应的数据同步处理代理器发送同步数据请 求， 数据同步处理代理器 将本次同步任务要更新的业务数据通过同步数 据响应返回给数据同步客户 端； 数据同步客户端在接收到数据同步通知后， 在下一个空闲周期， 按照接 收到的消息类型调用相应的接口向该数据同步 处理代理器发送该任务类型的 数据同步请求。 数据同步处理代理器接收到数据同步请求后， 根据请求中的任务类型， 从内存数据库中解析需要进行数据同步的数据 ， 发送给数据同步客户端。 步骤 8: 数据同步处理代理器更新数据库中本任务的状 态为同步成功。 图 3是本发明上述方法实施例中数据同步处理管� �器为数据同步客户端 生成数据同步任务的方法流程， 是在查询到管理侧数据库中存在数据同步任 务后执行的， 包括如下步骤： 301 : 判断查询到的任务是否要求通知到所有数据同 步客户端，是则执行 步骤 302 , 否则执行步骤 303 ;

302: 在能力侧数据库中为每一个数据同步处理代理 器生成数据同步任 务， 执行步骤 306;

303：查询内存数据库中该任务相应的数据同步 客户端与数据同步处理代 理器之间的对应关系；

304:该客户端是否存在对应的数据同步处理� �理器，是则执行步骤 305 , 否则执行步骤 307;

305:根据该对应关系在能力侧数据库中为需要� �行数据同步处理的数据 同步代理器生成数据同步任务； 306: 更新管理侧数据库中任务状态为已生成同步任 务， 结束流程；

307: 更新管理侧数据库中任务状态为生成同步任务 失败， 结束流程。

图 4是本发明上述方法实施例中数据同步处理代� �器通知数据同步客户 端进行数据同步的流程， 是在查询到能力侧数据库中存在本代理器的数 据同 步任务后执行， 包括如下步骤：

401 :根据该数据同步任务的任务标识、任务类型� �能力侧数据库查询到 需同步的数据， 并将其保存在本地内存数据库中；

402: 向要进行数据同步的数据同步客户端发送数据 同步通知；

403 : 判断通知发送是否成功， 是则执行步骤 404 , 否则执行步骤 406; 数据同步处理代理器经过一段时间延迟后若收 到数据同步客户端的回 复， 则判断通知发送成功； 如果未收到回复， 则判断通知发送失败。

404: 更新能力侧数据库中该任务的状态为已通知； 405: 等待数据同步客户端请求获取同步数据， 结束流程；

406: 判断重复通知次数是否超过阀值， 是则执行步骤 407 , 否则执行步 骤 408;

407: 更新能力侧数据库中该任务的状态为通知失败 ， 结束流程； 408: 在下一周期重复发送数据同步通知， 返回步骤 403执行。

图 5是本发明上述方法实施例中数据同步处理代� �器根据数据同步客户 端的数据同步请求返回同步数据的流程， 是在接收到数据同步客户端的数据 同步请求通知后执行， 包括如下步骤：

501 : 检查该数据同步客户端是否合法， 是则执行步骤 502 , 否则结束流 程；

502:根据数据同步请求通知中的任务类型、客� �端标识将同步数据返回 给数据同步客户端；

503 : 判断返回是否成功， 是则执行步骤 504 , 否则执行步骤 505; 数据同步处理代理器经过一段时间延迟后若收 到数据同步客户端的回 复， 则判断返回成功； 否则， 则判断返回失败。

504: 更新能力侧数据库中该任务状态为同步成功， 结束流程；

505: 判断重复返回次数是否超过阀值， 是则执行步骤 506 , 否则执行步 骤 507;

506: 更新能力侧数据库中该任务状态为同步失败， 结束流程；

507: 在下一周期重复返回同步数据， 返回步骤 503执行。

本领域普通技术人员可以理解上述方法中的 全部或部分步骤可通过程序 来指令相关硬件完成， 所述程序可以存储于计算机可读存储介质中， 如只读 存储器、 磁盘或光盘等。 可选地， 上述实施例的全部或部分步骤也可以使用 一个或多个集成电路来实现。 相应地， 上述实施例中的各模块 /单元可以釆用 硬件的形式实现， 也可以釆用软件功能模块的形式实现。 本发明不限制于任 何特定形式的硬件和软件的结合。

以上内容是结合具体的优选实施方式对本发 明所作的进一步详细说明， 但这只是为便于理解而举的实例， 不应认为本发明的具体实施只局限于这些 说明。 对于本发明所属技术领域的普通技术人员来说 ， 在不脱离本发明构思 的前提下， 可以做出各种可能的等同改变或替换， 这些改变或替换都应属于 本发明的保护范围。

工业实用性 本发明针对 IPTV系统的内容分发网络中的数据同步系统， 釆用数据同 步处理代理器配合数据同步处理管理器，来减 轻数据同步处理管理器的负担， 使得系统压力得到均衡， 从而可以提高系统的性能。 本发明除了应用在交互式网络电视商用系统中 ， 还可以应用在视频监控 等其它基于内容分发网络的系统中。