CN101515889B - 一种组播报文的复制处理方法和装置 - Google Patents

Abstract

本发明实施例提供一种组播报文的复制处理方法和装置，其中，一种组播报文的复制处理方法，包括：用于接收组播报文，根据所述组播报文的组播组地址确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数；所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文。当组播组的接收端个数相当多，需要大量复制的情况下，用户可以预设组播报文的复制处理次数，减小了组播报文复制的延时。

Description

一种组播报文的复制处理方法和装置

技术领域

本发明涉及通信技术领域，尤其涉及一种组播报文的复制处理方法和装置。

背景技术

采用IP组播技术(Multicast)能够明显降低对网络的带宽要求，降低了网络负载，提高了网络的传输效率。IP组播应用大概可以分为三类：点对多点，多点对点，多点对多点。点对多点应用是指一个发送端对应着多个接收端，比如：网络电视；多点对点应用是指多个发送端对应一个接收端，比如：网络竞拍；多点对多点应用是指多个发送端对应多个接收端，比如：网络会议。

具体而言，在IP组播技术中，发送端发送多个组播报文信息，由接收端接收组播报文信息，若干个接收端构成一个组播组(Multicast Group，MG)，同时可以有多个组播组，每个组播组具有唯一对应的组播组地址(MGID，Multicast Group Identity)。发送端发送多个组播报文信息，一个组播报文被复制到组播组的所有接收端之后再复制下一个组播报文，也就是，一个组播报文在一个组播组被复制接收端个数次，再复制下一个组播报文。

在实现本发明过程中，发明人发现现有技术中至少存在如下问题：

当一个组播组的接收端个数相当的多时(如大于等于10000个)，还采用一个组播报文复制完之后再去复制下一个组播报文时，就会导致下一个组播报文复制后发送的时延过大，在接收该组播报文的组播组一端来看，会出现数据不连续的现象，影响IP组播的能力。

发明内容

本发明的实施例提供了一种组播报文的复制处理方法和装置，减小了组播报文复制的延时。

一种组播报文的复制处理方法，包括：

接收组播报文，根据所述组播报文的组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数，所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数；

所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，将所述组播报文的组播组地址添加到查找表，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文，所述查找表用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址。

一种组播报文的复制处理装置，包括：

复制确认单元：用于接收组播报文，根据所述组播报文组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数，所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数；

复制处理单元：用于所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文；

查找表存储单元：用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以预设组播报文的复制处理次数，减小了组播报文复制的延时。

附图说明

为了更清楚地说明本发明实施例的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动性的前提下，还可以根据这些附图获得其他的附图。

图1为本发明实施例组播报文的复制处理方法的流程图；

图2为本发明实施例组播报文的复制处理方法的流程图；

图3为本发明实施例组播报文的复制处理方法的流程图；

图4为本发明实施例组播报文的复制处理装置的构成框图；

图5为本发明实施例组播报文的复制处理装置的构成框图；

图6为本发明实施例组播报文的复制处理装置的构成框图。

具体实施方式

下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

如图1所示，本发明实施例提供一种组播报文的复制处理方法，包括：

步骤1：接收组播报文，根据所述组播报文的组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数；

步骤2：所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文。

所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数。

可以看出来，当需要大量复制的情况下，用户可以根据时延要求预设组播报文的复制处理次数，减小了组播报文复制的延时；而且，用户可以根据时延要求，在组播报文复制过程中动态调整复制处理次数。

其中，步骤2，还可以是：

所述组播报文全部复制需要的次数小于等于所述预设的组播报文复制处 理次数，对所述组播报文进行所述全部复制需要的次数的复制并发送复制的组播报文。

这样，组播报文只进行预设的复制处理次数的复制就发送，满足了组播报文复制的延时要求，而未完全复制完成的组播报文可以被存储起来，分若干次复制处理实现全部复制。而且，需要将未完全复制完成的所述组播报文的组播组地址添加到查找表，所述查找表用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址。

查找表可以是事先就建立好的，也可以在首个组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，建立查找表，这样，采用查找表可以避免未完全复制完成的组播报文在存储之后可能产生的乱序。

可以知道，不断调度得到新的组播报文信息，接收端接收组播报文信息。

所以，所述方法还包括，步骤3：接收新的组播报文，确定所述新的组播报文与所述存储的组播报文(即未完全复制完成的组播报文)中进行复制处理的组播报文的步骤，具体而言，

步骤3可以是：新的组播报文的组播组地址与所述查找表内的组播组地址匹配时，所述新的组播报文为所述匹配的组播组地址对应的组播报文的后续报文，所述新的组播报文被对应存储在所述组播报文后。

之所以将所述新的组播报文对应存储在所述组播报文后，是为了保证报文顺序不会乱序，以实现全部复制。

进一步，所述存储的组播报文进行复制之后，所述存储的组播报文的复制次数未达到其全部复制需要的次数时，回写所述存储的组播报文，使得其等待后续被调度，实现所述存储的组播报文全部复制；所述存储的组播报文的复制次数已经达到其全部复制需要的次数时，所述存储的组播报文完成了全部复制。

或者，步骤3可以是，新的组播报文的组播组地址与所述查找表内的组播 组地址不匹配时，根据预设的新的组播报文与存储的组播报文的优先级，调度得到进行复制处理的组播报文。

具体而言，根据调度得到进行复制处理的组播报文的不同，包括如下2种情形：

当调度得到进行复制处理的组播报文为所述新的组播报文时：

当所述新的组播报文全部复制需要的次数小于等于所述预设的组播报文复制处理次数时，对所述新的组播报文进行全部复制需要的次数的复制并被发送复制的组播报文；

或者，当所述新的组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述新的组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，并且存储所述新的组播报文以及将所述新的组播报文的组播组地址添加到所述查找表内。

当调度得到进行复制处理的组播报文为所述存储的组播报文时：

对所述存储的组播报文进行复制处理，所述存储的组播报文的复制次数未达到其全部复制需要的次数时，回写所述存储的组播报文；所述存储的组播报文的复制次数已经达到其全部复制需要的次数时，所述存储的组播报文完成了全部复制。

在另外一个实施例中，当调度得到进行复制处理的组播报文为所述存储的组播报文时，需要对所述存储的组播报文进行复制处理，这是可以先判断，全部复制需要的次数，减去经过预设的组播报文复制处理次数的复制次数后，剩余的复制需要的次数是否还大于预设的组播报文复制处理次数，若大于则对所述报文进行预设的组播报文复制处理次数的复制，回写所述存储的组播报文；若小于，则进行剩余的复制需要的次数复制，这样，所述存储的组播报文的复制次数已经达到其全部复制需要的次数时，所述存储的组播报文完成了全部复制。

而且，步骤3中预设的新的组播报文与存储的组播报文的优先级，用户可 以在组播报文复制过程中动态调整。

所述调度可以采用加杈公平队列调度(WFQ，Weighted FairQueuing)，也可以采用加权轮循(Weighted Round Robin，WRR)调度或者轮转(Round Robin)调度。

而且，所述方法中，可以根据多个组播报文的优先级调度确认接收各所述组播报文的顺序。

值得注意的是，新的组播报文的组播组地址与所述查找表内的组播组地址不匹配时，若所述存储或回写的组播报文为两个以上时，可以先对所述存储或回写的组播报文之间进行调度，以得到与所述新的组播报文进行调度的组播报文，最后再得到进行复制处理的组播报文。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以根据不同的时延要求预设组播报文的复制处理次数，根据实际的报文全部需要复制的次数与与预设的组播报文的复制处理次数，对组播报文进行复制，减小了组播报文复制的延时；而且，用户可以任意配置该时延，方便灵活、适用范围广。

如图4所示，对应于上述组播报文的复制处理方法，本发明实施例还提供一种组播报文的复制处理装置，包括：

复制确认单元10：用于接收组播报文，根据所述组播报文组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数；

复制处理单元20：用于所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文。

同样，所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数。

组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数 时，进行预设的组播报文复制处理次数的复制并不能实现对所述组播报文的完全复制，所以，可以存储未完全复制完成的组播报文，分若干次复制处理实现全部复制。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以根据不同的时延要求预设组播报文的复制处理次数，根据实际的报文全部需要复制的次数与与预设的组播报文的复制处理次数，对组播报文进行复制，减小了组播报文复制的延时；而且，用户可以任意配置该时延，方便灵活、适用范围广。并且采用了组播报文的回写机制，使组播报文的复制次数达到了全部需要复制的次数；引入了查找表单元，减小了未完全复制完成的组播报文在存储之后可能产生乱序的情况。

所以，如图5所示，所述组播报文的复制处理装置，还可以包括：

查找表存储单元30：用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址；

回写确认单元40：用于确认组播报文的组播组地址是否与所述查找表存储单元内的组播组地址匹配，用于确认组播报文是否需要存储或回写，以及用于管理所述查找表存储单元。

回写缓存50：其可以包括至少一个回写寄存器501以及对应的至少一个回写先进先出存储器502，其中，

至少一个回写寄存器501，用于按照组播组地址存储所述全部复制需要的次数大于所述预设的组播报文复制处理次数并且与查找表存储单元30内的组播组地址不匹配的组播报文，以及回写所述组播报文；

至少一个回写先进先出存储器502，用于存储所述回写寄存器501内组播报文的后续报文，所述后续报文为组播组地址与所述回写寄存器501内组播报文的组播组地址匹配的组播报文。

这里，所述回写缓存50中回写寄存器501的个数由需要存储的组播报文的 个数决定。所述回写缓存50中回写先进先出存储器502的存储深度根据所述存储的组播报文的后续报文的个数决定。

而且，回写先进先出存储器502的后续组播报文输出进入回写寄存器501内，避免组播报文可能产生的乱序。

回写可以解释为，回写寄存器501内组播报文进行复制之后，其复制次数未达到其全部复制需要的次数时，需要回写所述组播报文，等待后续再次被调度进行复制处理，以实现全部复制；所述组播报文的复制次数已经达到其全部复制需要的次数时，所述组播报文完成了全部复制。

而且，所述组播报文的复制处理装置，还可以包括：

复制调度单元60，用于确认组播报文与回写寄存器501内的组播报文中进行复制处理的组播报文。

这里，与回写寄存器501内的组播报文进行调度的组播报文是与查找表存储单元30内的组播组地址不匹配的组播报文，由于与查找表存储单元30内的组播组地址不匹配，其不是回写寄存器501内组播报文的后续报文，所以，要调度得出一个进入复制处理单元的组播报文。

具体而言，所述复制调度单元60可以包括：

第一调度模块601，用于对两个以上回写寄存器501内的组播报文进行调度；

第二调度模块602，用于从第一调度模块601的调度结果及所述组播报文中调度得到进入所述复制处理单元20的组播报文；

所述调度方式为加权公平队列调度、加权轮循调度或轮转调度。

所述组播报文的复制处理装置，还可以包括：

入口先进先出缓存70：用于接收多个组播报文并根据其优先级存储所述多个组播报文；

入口调度单元80：用于根据多个组播报文的优先级，调度得到入口先进先出缓存70中各组播报文发送给复制确认单元10的顺序。

入口先进先出缓存70可以由至少两个高低优先级的FIFO(先进先出，First-in First-out)存储器组成，根据多个组播报文的优先级，将多个组播报文映射到对应的两个不同高低优先级的FIFO存储器中。采用优先级映射，可以保证高优先级的报文不被低优先级的报文抢占带宽。

入口调度单元80可以采用加权公平队列调度、加权轮循调度或轮转调度，以确认入口先进先出缓存70中哪一个组播报文离开队列被读取。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以根据不同的时延要求预设组播报文的复制处理次数，根据实际的报文全部需要复制的次数与预设的组播报文的复制处理次数，对组播报文进行复制，减小了组播报文复制的延时；而且，用户可以任意配置该时延，方便灵活、适用范围广。并且采用了组播报文的回写机制，使组播报文的复制次数达到了全部需要复制的次数；引入了查找表单元，减小了未完全复制完成的组播报文在存储之后可能产生乱序的情况。

下面结合具体的组播组、组播报文，来说明本发明的实施例提供的技术方案。

实施例一

参见图3所示，以n个组播组，组播组地址为MGID0-MGIDn-1例，说明组播报文的复制处理方法，包括：

步骤1、从缓存的多个组播报文中调度得到一个组播报文

接收多个组播报文并可以按照优先级先存到入口先进先出缓存中，可以以组播报文的优先级为权重，采用加权公平队列WFQ调度得到第一组播报文，组播组地址MGID0。当然在另一个实施例中也可以采用加权轮循WRR调度或者轮转RR调度。

步骤2、接收调度得到的组播报文

接收第一组播报文，可以通过其组播组地址MGID0得知目标组播组，以及进一步得知目标组播组所包含的接收端的个数，以及确认出第一组播报文被全部复制需要的次数K。而且，还获得用户根据延时需要预设的复制处理次数N。

第一组播报文被全部复制需要的次数K大于用户根据延时需要预设的复制处理次数N，所以，第一组播报文可以只复制N次就发送，满足复制组播报文之后发送复制的组播报文之间的延时较小。

步骤3、判断组播报文的组播组地址是否与查找表内组播组地址匹配

查找表用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址，由于第一组播报文为首个接收的组播报文，所以，查找表目前为空，第一组播报文的组播组地址与查找表内组播组地址不匹配，进入步骤4。

如果后续步骤中，接收到的组播报文的组播组地址与查找表内组播组地址匹配时，组播报文为查找表内匹配的组播组地址对应的组播报文的后续报文，所以，进入步骤7，将后续组播报文存储起来，具体可以见后文叙述。

步骤4、调度得到进行复制处理组播报文

由于第一组播报文为首个接收的组播报文，可知进行复制处理组播报文为第一组播报文。

步骤5、复制处理并发送复制的组播报文

第一组播报文只进行预设的复制处理次数N次的复制即发送复制的组播报文。但第一组播报文未实现全部复制的次数K，所以，可以进入步骤6。

步骤6、判断是否存储或回写组播报文

第一组播报文只进行预设的复制处理次数N次的复制即发送，第一组播报文未完全复制完成，所以进入步骤7存储第一组播报文，留待后续步骤中分若干次进行复制处理实现全部复制。

步骤7、存储或回写组播报文以及管理查找表

存储第一组播报文，以及将第一组播报文的组播组地址MGID0添加到查找表内，避免组播报文在存储之后可能产生的乱序。

可以知道，步骤1中不断有新的组播报文被调度出来，等待复制处理，下面以4个例子说明可能存在的情形。这里及下文的“新的组播报文”仅是对应于之前调度得到的组播报文而言，不是对报文本身的限定。

再参见图3所示，可以是，步骤1中又调度得到第二组播报文，其组播组地址MGID0。

步骤2、接收调度得到的组播报文

接收第二组播报文，确认出第二组播报文被全部复制需要的次数K′，以及已知用户根据延时需要预设的复制处理次数N。

步骤3、判断组播报文的组播组地址是否与查找表内组播组地址匹配

查找表内组播组地址为MGID0，第二组播报文的组播组地址MGID0与查找表内组播组地址MGID0匹配，进入步骤7。

步骤7、存储或回写组播报文以及管理查找表

第二组播报文为第一组播报文的后续报文，将第二组播报文存储在第一组播报文之后，保证属于同一组播组地址的报文不乱序。

再参见图3所示，还可以是，步骤1中又调度得到第二组播报文，其组播组地址MGID1，那么第二组播报文循环上述步骤，如下：

步骤2、接收调度得到的组播报文

接收第二组播报文，确认出第二组播报文被全部复制需要的次数K′，以及已知用户根据延时需要预设的复制处理次数N。

步骤3、判断组播报文的组播组地址是否与查找表内组播组地址匹配

查找表内组播组地址为MGID0，第二组播报文的组播组地址MGID1与查找表内组播组地址MGID0不匹配，进入步骤4。

步骤4、调度得到进行复制处理组播报文

在存储的第一组播报文与第二组播报文中，根据预设的新的组播报文与 存储或回写的组播报文的优先级为权重，采用加杈公平队列调度得到存储的第一组播报文进行复制处理。当然在另一个实施例中也可以采用加杈轮循WRR调度或者轮转RR调度。

步骤5、复制处理并发送复制的组播报文

存储的第一组播报文再次只进行预设的复制处理次数N次的复制即发送复制的组播报文。

步骤6、判断是否存储或回写组播报文

若存储的第一组播报文未实现全部复制的次数K，进入步骤7，如果存储的第一组播报文实现全部复制的次数K，则结束。

步骤7、存储或回写组播报文以及管理查找表

存储的第一组播报文进行回写，留待后续步骤中被调度进行复制处理实现全部复制。

再参见图3所示，还可以是，步骤1中又调度得到第二组播报文，其组播组地址MGID1，那么第二组播报文循环上述步骤，如下：

步骤2、接收调度得到的组播报文

接收第二组播报文，确认出第二组播报文被全部复制需要的次数K′，以及已知用户根据延时需要预设的复制处理次数N。

步骤3、判断组播报文的组播组地址是否与查找表内组播组地址匹配

查找表内组播组地址为MGID0，第二组播报文的组播组地址MGID1与查找表内组播组地址MGID0不匹配，进入步骤4。

步骤4、调度得到进行复制处理组播报文

在存储的第一组播报文与第二组播报文中，根据预设的新的组播报文与存储或回写的组播报文的优先级为权重，采用加权公平队列WFQ调度得到存储的第二组播报文进行复制处理。当然在另一个实施例中也可以采用加权轮循WRR调度或者轮转RR调度。

步骤5、复制处理并发送复制的组播报文

第二组播报文被全部复制需要的次数K′大于预设的复制处理次数N，第二组播报文只进行预设的复制处理次数N次的复制即发送复制的组播报文。

步骤6、判断是否存储或回写组播报文

第二组播报文只进行预设的复制处理次数N次的复制，第二组播报文未实现全部复制的次数K′，所以进入步骤7。

步骤7、存储或回写组播报文以及管理查找表

存储第二组播报文，留待后续步骤中被调度进行复制处理实现全部复制。

再参见图3所示，如果上述步骤5中第二组播报文被全部复制需要的次数K′小于等于预设的复制处理次数N，第二组播报文进行K′次复制处理，即实现全部复制并可以满足预设的时延要求。

综上所述，每次调度得到一个新的组播报文，就要判断该新的组播报文的组播组地址是否与查找表内的组播组地址匹配。如果匹配，则参照上述步骤7进行后续流程；如果不匹配，则参照上述步骤4、5、6进行后续流程，从而实现对所有组播报文的完全复制。

上述步骤6中，存在回写处理方式，以实现组播报文全部复制。具体是，已经存储的组播报文，又再次被调度进行复制处理，如果复制次数满足了全部复制的次数，则组播报文完成了全部复制；如果复制次数未到达全部复制的次数，那么还需要回写组播报文，使得组播报文被回写保留，等待后续被调度，实现组播报文全部复制。

这里，可以在调度得到组播报文之时，就得到组播报文全部复制需要的次数是否大于用户根据延时预设的复制处理次数N，来确认组播报文是否需要存储以及是否需要回写，进一步，为组播报文标记回写标记。

而且，上述步骤6中，如果存储或回写的组播报文为两个以上，则两个以上的组播报文之间可以进行调度，将调度得到的结果与新的组播报文进行调度，进而得到进行复制处理步骤5的那一个组播报文，而且，需要根据预设的 新的组播报文与存储或回写的组播报文的优先级为权重，对新的组播报文与存储或回写的组播报文进行调度。所述调度可以采用加权公平队列调度(WFQ，Weighted Fair Queuing)，也可以采用加权轮循(WeightedRound Robin，WRR)调度或者轮转(Round Robin)调度。

上述步骤7中，当属于同一个组播组的所有报文全部被复制完成后，即一个组播组地址对应的所有组播报文均实现全部复制，将该组播组地址从查找表内删除。

还可以知道，可以在步骤4复制处理并发送复制的组播报文的同时，就进行步骤6。可以在步骤4复制处理并发送复制的组播报文的同时，就进行步骤1，调度得到新的组播报文。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以根据不同的时延要求预设组播报文的复制处理次数，根据实际的报文全部需要复制的次数与预设的组播报文的复制处理次数，对组播报文进行复制，减小了组播报文复制的延时；而且，用户可以任意配置该时延，方便灵活、适用范围广。并且采用了组播报文的回写机制，使组播报文的复制次数达到了全部需要复制的次数；引入了查找表，减小了未完全复制完成的组播报文在存储之后可能产生乱序的情况。

实施例二

参见图6所示，一种对应于实施例一中组播报文的复制处理方法的组播报文的复制处理装置，仍以n个组播组，组播组地址为MGID0-MGIDn-1例。

组播报文的复制处理装置，包括：

复制确认单元10：用于接收组播报文，根据所述组播报文的组播组地址确认组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数；

复制处理单元20：用于所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文。

复制确认单元10获得的预设的组播报文复制处理次数为用户根据时延要求预设的复制处理次数。而且，用户可以根据时延要求在组播报文复制过程中动态调整组播报文复制处理次数。

当组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，进行预设的组播报文复制处理次数的复制并不能实现对所述组播报文的完全复制。

所以，组播报文的复制处理装置，还包括查找表存储单元30、回写确认单元40、回写缓存50、复制调度单元60。

查找表存储单元30：查找表存储单元：用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址；

回写确认单元40：用于确认组播报文的组播组地址是否与查找表存储单元30内的组播组地址匹配，用于确认组播报文是否需要存储或回写，以及用于管理所述查找表存储单元30。

具体而言，用于确认组播报文的组播组地址是否与查找表存储单元30内的组播组地址匹配是指，根据查找表存储单元30内的组播组地址，可以判断接收到的组播报文是否是查找表存储单元30内匹配的组播组地址对应的组播报文的后续报文，如果是，则为了避免报文乱序，把属于同一组播组地址的组播报文顺序存储。

用于确认组播报文是否需要存储是指，当接收到的组播报文需要复制的次数大于所述预设的组播报文复制处理次数时，将组播报文存储在回写缓存50内，等后续被调度，实现组播报文全部复制；后续接收到的新的组播报文需要复制的次数大于所述预设的组播报文复制处理次数，且与查找表存储单元30内的组播组地址匹配时，将组新的播报文存储在回写缓存50内，等后续 被调度，实现组播报文全部复制。

确认所述存储的组播报文是否需要回写是指，已经存储在回写缓存50内的组播报文，后续又再次被调度进行复制处理，如果仍没有实现全部复制，那么还需要将存储的组播报文回写在回写缓存50内，使得其等待后续被调度，实现组播报文全部复制。

管理查找表存储单元30是指，当接收到的组播报文需要复制的次数大于所述预设的组播报文复制处理次数时，将组播报文的组播组地址添加到查找表存储单元30内；不断接收新的组播报文，当新的组播报文与查找表存储单元30内的组播组地址不匹配，并且新的组播报文需要存储在回写缓存50内时，添加新的组播报文的组播组地址到查找表存储单元30内，不断丰富查找表存储单元30的记录；当查找表存储单元30任一组播组地址的所有组播报文全部被复制完成后，将该组播组地址从查找表存储单元30内删除。可以知道，采用查找表机制可以避免报文在组播回写之后可能会产生的乱序。

这里及下文的“新的组播报文”仅是对应于之前调度得到的组播报文而言，不是对报文本身的限定。

回写缓存50：其包括至少一个回写寄存器501以及对应的至少一个回写先进先出存储器502，其中，

至少一个回写寄存器501，用于按照组播组地址存储所述全部复制需要的次数大于所述预设的组播报文复制处理次数并且与查找表存储单元30内的组播组地址不匹配的组播报文，以及回写所述组播报文。按照组播组地址存储所述组播报文，以便进行后续的调度，分若干次复制处理实现全部复制。图4中示意出16个回写寄存器501(reg_0-reg_15)。

至少一个回写先进先出(First-in First-out，FIFO)存储器502，用于存储所述回写寄存器501内组播报文的后续报文，所述后续报文为组播组地址与所述回写寄存器501内组播报文的组播组地址匹配的组播报文。先进先出(FIFO)的存储方式保证组播报文以及其后续报文在复制过程中，不乱序。 图4中示意出16个回写先进先出存储器502(fifo_0-fifo_15)，其存储深度由存储的组播报文的后续报文的个数决定。

由于回写寄存器501按不同的组播组地址MGID区分，而回写先进先出存储器502用于储存回写寄存器501内组播报文的后续保文，所以，相应的回写先进先出存储器502内存储的组播报文的组播组地址MGID必然不同。

而且，回写缓存50的个数与入口的多播流量突发有关系，突发越小，回写缓存50相应减少，突发越大，回写缓存50相应需要增加。

复制调度单元60，用于确认新的组播报文与所述回写寄存器501内的回写组播报文中进行复制处理的组播报文。所述新的组播报文为与所述查找表存储单元30内的组播组地址不匹配的组播报文。

具体而言，复制调度单元60包括：

第一调度模块601，用于对两个以上回写寄存器501内的组播报文进行调度，这里，采用轮转调度。当然也可以采用加权公平队列调度(WFQ，Weighted Fair Queuing)，或者加权轮循(Weighted Round Robin，WRR)调度。

第二调度模块602，用于从第一调度模块601的调度结果及所述新的组播报文中调度得到进入所述复制处理单元20的组播报文。

第二调度模决602根据预设的新的组播报文与存储或回写的组播报文的优先级为权重，从第一调度模块601的调度结果及与具有与查找表存储单元30内的组播组地址不匹配的新的组播报文中得到进入复制处理单元20的组播报文。而且，用户可以在组播报文复制过程中动态调整配置新的组播报文与回写的组播报文的优先级。

组播报文的复制处理装置，还包括：入口先进先出缓存70以及入口调度单元80。

入口先进先出(FIFO)缓存70：用于接收多个组播报文并根据其优先级存储所述多个组播报文。

入口先进先出缓存70可以由至少两个高低优先级的先进先出(FIFO)存储器组成，根据多个组播报文的各报文头携带的优先级，将多个组播报文映射到对应的两个不同高低优先级的先进先出存储器中。采用优先级映射，可以保证高优先级的报文不被低优先级的报文抢占带宽。

入口调度单元80：用于根据多个组播报文的优先级，调度得到入口先进先出缓存70中各组播报文发送给复制确认单元10的顺序。这里，入口调度单元80以多个组播报文的优先级为权重，采用加权公平队列调度方式得到发送给复制确认单元10的组播报文。

参见图5所示，具体应用本实施例的组播报文的复制处理装置时，以第一组播报文，其组播组地址MGID0，其复制需要的次数K大于预设的复制处理次数N，以及第二组播报文，其组播组地址为MGID1，其复制需要的次数K′大于预设的复制处理次数N为例，包括：

1：入口调度单元80根据多个组播报文的优先级为权重采用加权公平队列调度，从入口先进先出缓存70中得到组播报文，如第一组播报文，其组播组地址MGID0。

2：复制确认单元10接收第一组播报文，并确认第一组播报文的全部复制需要的次数K以及获得用户根据延时预设的复制处理次数N，以及确认第一组播报文的全部复制需要的次数K大于用户根据延时预设的复制处理次数N。

3：回写确认单元40将第一组播报文的组播组地址MGID0添加到查找表存储单元30内，第一组播报文在复制处理单元20内复制处理N次后，回写确认单元40将其存储在回写寄存器501(reg_0-reg_15)内的一个未被占用的寄存器内，如reg_0，等后续被调度，实现组播报文全部复制。

4：接收入口调度单元80从入口先进先出缓存70中调度得到新的组播报文，如第二组播报文，组播组地址为MGID1，第二组播报文的组播组地址MGID1与查找表存储单元30内的组播组地址MGID0不相匹配。

5：根据用户预设的新的组播报文与回写的组播报文的优先级为权重，调 度单元60的第二调度模块602对第二组播报文与第一组播报文进行加权公平队列调度，确认进入复制处理单元20进行复制并发送的组播报文为第二组播报文。

6：根据第二组播报文的组播组地址MGID1，复制确认单元10确认第二组播报文的复制需要的次数K′大于预设的复制处理次数N，所以，第二组播报文进入复制处理单元20进行预设的组播报文复制处理次数N的复制并发送复制的组播报文，同样，也需要存储第二组播报文，如将第二组播报文存储在回写寄存器501(reg_0-reg_15)内的一个未被占用的寄存器内，如reg_1，等后续被调度，实现组播报文全部复制。

而且，回写确认单元40还将第二组播报文的组播组地址MGID1添加到查找表存储单元30内，目的是，根据查找表存储单元30判断后续新调度的组播报文是否为第二组播报文的后续报文，如果后续调度的新组播报文的组播组地址与查找表存储单元30内存储的第二组播报文的组播组地址匹配，则可以将后续调度的新组播报文存储到与reg_1对应的回写先进先出存储器(fifo_0-fifo_15)中的fifo_1内，保证不会乱序。

这样，不断调度得到所有组播报文并实现对所有组播报文的复制。

上述步骤5中，如果回写寄存器501存储的组播报文为两个以上，则第一调度模块601对两个以上的组播报文进行轮转调度，将轮转调度得到的结果输入第二调度模块602内，第二调度模块602从轮转调度结果与新的组播报文进行加权公平队列调度，进而得到进行复制处理的那一个组播报文。

而且上述步骤5之后，上述步骤6中，如果复制确认单元10确认第二组播报文全部复制需要的次数K′小于等于预设的组播报文复制处理次数N，则第二组播报文进入复制处理单元20进行全部复制需要的次数K′的复制并被发送，实现报文全部复制。

上述步骤5中，如果第二调度模块602确认进入复制处理单元20进行复制的组播报文为第一组播报文，则第一组播报文进入复制处理单元20进行预设 的组播报文复制处理次数N的复制并发送复制的组播报文，进一步地，此时，如果复制次数满足了K次，则第一组播报文完成了全部复制；如果复制次数未到达K次，那么回写确认单元40还需要将第一组播报文回写，即回写保存在回写寄存器501的reg_0内，等后续被调度，实现组播报文全部复制。

再以第一组播报文，其组播组地址MGID0，其复制需要的次数K大于预设的复制处理次数N，以及第二组播报文，其组播组地址为MGID0，其复制需要的次数K′大于预设的复制处理次数N为例，具体应用本实施例的组播报文的复制处理装置时，包括：

1：入口调度单元80根据多个组播报文的优先级为权重采用加权公平队列调度，从入口先进先出缓存70中得到组播报文，如第一组播报文，其组播组地址MGID0。

2：复制确认单元10接收第一组播报文，并确认第一组播报文的全部复制需要的次数K以及获得用户根据延时预设的复制处理次数N，以及确认第一组播报文的全部复制需要的次数K大于用户根据延时预设的复制处理次数N。

3：回写确认单元40建立查找表存储单元30，并将第一组播报文的组播组地址MGID0添加到查找表存储单元30内，以及第一组播报文在复制处理单元20内复制处理N次后，回写确认单元40将其存储在回写寄存器501(reg_0-reg_15)内的一个未被占用的寄存器内，如reg_0，等后续被调度，实现组播报文全部复制。

4：接收入口调度单元80从入口先进先出缓存70中调度得到新的组播报文，如第二组播报文，组播组地址为MGID0，第二组播报文的组播组地址为MGID0与查找表存储单元30内的组播组地址MGID0相匹配，则说明第二组播报文是与第一组播报文具有相同组播组地址的后续报文。

5：回写确认单元40将第二组播报文存储到与reg_0对应的回写先进先出存储器502(fifo_0-fifo_15)中的fifo_0内，实现属于同一个组播组的后续报文存储在一起，而且第二组播报文存储在第一组播报文之后，仍然可以保证 第二组播报文为第一组播报文的后续报文，不会乱序，以实现全部复制。

也就是本应用例与上应用例不同之处仅在于第二组播报文的组播组地址为MGID0，第二组播报文是与第一组播报文具有相同组播组地址的后续报文，需要将第二组播报文存储在第一组播报文之后，保证不会乱序。

通过上面的叙述应当知道，本实施例的组播报文的复制处理装置，在前一个组播报文进行复制处理的同时，入口调度单元80就可以从入口先进先出缓存70中调度得到下一个组播报文。

需要注意的是，入口调度单元80从入口先进先出缓存70中调度得到组播报文，与查找表存储单元30内的组播组地址MGID有匹配，但对应的回写先进先出存储器502满时，则将该组播报文丢弃，防止入口先进先出缓存70中的后续报文比没有复制完成的有相同组播组地址的组播报文先发送出去，导致乱序。

并且，从入口先进先出缓存70中读取组播报文时，需要满足入口先进先出缓存70中至少两个先进先出存储器中任一个非空，同时回写寄存器501没有被完全占满，也可以说是查找表存储单元30没有被完全占满。

由上述本发明的实施例提供的技术方案可以看出，当组播组的接收端个数相当多，需要大量复制的情况下，用户可以根据不同的时延要求预设组播报文的复制处理次数，根据实际的报文全部需要复制的次数与与预设的组播报文的复制处理次数，对组播报文进行复制，减小了组播报文复制的延时；而且，用户可以任意配置该时延，方便灵活、适用范围广。并且采用了组播报文的回写机制，使组播报文的复制次数达到了全部需要复制的次数；引入了查找表单元，减小了未完全复制完成的组播报文在存储之后可能产生乱序的情况。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到本发明可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，或者二者的结合来实施。基于这样的理解，本发明的技术方案本质上或者说 对现有技术做出贡献的部分可以以软件产品的形式体现出来，该软件模块或计算机软件产品可以存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述的方法。存储介质可以是随机存储器(RAM)、内存、只读存储器(ROM)、电可编程ROM、电可擦除可编程ROM、寄存器、硬盘、可移动磁盘、CD-ROM、或技术领域内所公知的任意其它形式的存储介质。

以上所述，仅为本发明较佳的具体实施方式，但本发明的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本发明揭露的技术范围内，可轻易想到的变化或替换，都应涵盖在本发明的保护范围之内。因此，本发明的保护范围应该以权利要求的保护范围为准。

Claims (11)

1.一种组播报文的复制处理方法，其特征在于，包括：

接收组播报文，根据所述组播报文的组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数，所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数；

所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，将所述组播报文的组播组地址添加到查找表，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文，所述查找表用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址。

2.根据权利要求1所述的组播报文的复制处理方法，其特征在于，所述方法还包括：接收新的组播报文，确定所述新的组播报文与所述存储的组播报文中进行复制处理的组播报文的步骤：

新的组播报文的组播组地址与所述查找表内的组播组地址匹配时，所述新的组播报文为所述匹配的组播组地址对应的组播报文的后续报文，所述新的组播报文被对应存储在所述匹配的组播组地址对应的组播报文后；

或者，新的组播报文的组播组地址与所述查找表内的组播组地址不匹配时，根据预设的新的组播报文与存储的组播报文的优先级，调度得到进行复制处理的组播报文。

3.根据权利要求2所述的组播报文的复制处理方法，其特征在于，新的组播报文的组播组地址与所述查找表内的组播组地址不匹配：

调度得到所述新的组播报文进行复制处理，当所述新的组播报文全部复制需要的次数小于等于所述预设的组播报文复制处理次数时，对所述新的组播报文进行全部复制需要的次数的复制，并发送复制的组播报文，

或者，当所述新的组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述新的组播报文进行所述预设的组播报文复制处理次数的复制，并发送复制的组播报文，存储所述新的组播报文以及将所述新的组播报文的组播组地址添加到所述查找表内；

或者，调度得到所述存储的组播报文进行复制处理，对所述存储的组播报文进行复制处理，所述存储的组播报文的复制次数未达到其全部复制需要的次数时，回写所述存储的组播报文。

4.根据权利要求1所述的组播报文的复制处理方法，其特征在于，根据多个组播报文的优先级调度得到接收各所述组播报文的顺序。

5.根据权利要求2或3或4所述的组播报文的复制处理方法，其特征在于，所述调度采用加权公平队列调度、加权轮循调度或轮转调度。

6.一种组播报文的复制处理装置，其特征在于，包括：

复制确认单元：用于接收组播报文，根据所述组播报文组播组地址，确认所述组播报文全部复制需要的次数，以及获得预设的组播报文复制处理次数，所述预设的组播报文复制处理次数为根据时延要求预设的复制处理次数；

复制处理单元：用于所述组播报文全部复制需要的次数大于所述预设的组播报文复制处理次数时，对所述组播报文进行所述预设的组播报文复制处理次数的复制并发送复制的组播报文，以及存储所述组播报文；

查找表存储单元：用于存储全部复制需要的次数大于所述预设的组播报文复制处理次数的组播报文的组播组地址。

7.根据权利要求6所述的组播报文的复制处理装置，其特征在于，所述装置，还包括：

回写确认单元：用于确认组播报文的组播组地址是否与所述查找表存储单元内的组播组地址匹配，用于确认组播报文是否需要存储或回写，以及用于管理所述查找表存储单元。

8.根据权利要求7所述的组播报文的复制处理装置，其特征在于，所述装置，还包括：

回写缓存：其包括至少一个回写寄存器以及对应的至少一个回写先进先出存储器，其中，

所述至少一个回写寄存器，用于按照组播组地址存储所述全部复制需要的次数大于所述预设的组播报文复制处理次数，并且与所述查找表存储单元内的组播组地址不匹配的组播报文，以及回写所述组播报文；

所述至少一个回写先进先出存储器，用于存储所述回写寄存器内组播报文的后续报文，所述后续报文为组播组地址与所述回写寄存器内组播报文的组播组地址匹配的组播报文。

9.根据权利要求8所述的组播报文的复制处理装置，其特征在于，所述装置，还包括：

复制调度单元，用于确认组播报文与所述回写寄存器内的组播报文中进行复制处理的组播报文。

10.根据权利要求9所述的组播报文的复制处理装置，其特征在于，所述复制调度单元包括：

第一调度模块，用于对两个以上所述回写寄存器内的组播报文进行调度；

第二调度模块，用于从所述第一调度模块的调度结果及所述组播报文中调度得到进入所述复制处理单元的组播报文；

所述调度方式为加权公平队列调度、加权轮循调度或轮转调度。

11.根据权利要求6所述的组播报文的复制处理装置，其特征在于，所述装置，还包括：

入口先进先出缓存：用于接收多个组播报文并根据其优先级存储所述多个组播报文；

入口调度单元：用于根据多个组播报文的优先级，采用加权公平队列调度、加权轮循调度或轮转调度得到入口先进先出缓存中各组播报文发送给复制确认单元的顺序。

Images