CN103684810B - 调整接口优先权的方法和枢纽系统 - Google Patents

Abstract

本发明公开了调整接口优先权的方法和枢纽系统。将发起方的消息转发给接收方；获取接收方的接口处理及时率；根据接口处理及时率获取动态优先权；根据获取的动态优先权调整接口优先权；按照调整后的接口优先权对消息进行转发。本发明降低与枢纽系统相连的系统或平台出现故障时对其他业务的接口造成影响。

Description

调整接口优先权的方法和枢纽系统

技术领域

本发明属于计算机互联技术，尤其涉及调整接口优先权的方法和枢纽系统。

背景技术

目前的接口系统中，一般根据业务的优先程度决定接口的优先权，枢纽系统（在各个交互之间设置的用于交互的系统）会优先处理优先级高的接口消息，保证重点业务的顺利开展。

当接口优先级高的落地方（是指相对于发起方的接收方）系统出现故障时，由于枢纽系统未能及时收到反馈，会重复发送消息，从而消耗大量的资源，影响枢纽系统的运行，并影响其他接口的正常运行以及业务的开展。

传统的做法是当某些系统的接口处理及时率低引起告警时，停掉此类的接口。

发明内容

鉴于以上，本发明提出调整接口优先权的方法和枢纽系统。

根据本发明一方面，提出调整接口优先权的方法，其中：

枢纽系统将发起方的消息转发给接收方；

枢纽系统获取接收方的接口处理及时率；

枢纽系统根据接口处理及时率获取动态优先权；

枢纽系统根据获取的动态优先权调整接口优先权；

枢纽系统按照调整后的接口优先权对消息进行转发。

进一步，所述调整接口优先权的方法，其中：

调整后的接口优先权为N2，N2=N1+动态优先权，N1为转发给接收方的消息的接口优先权，即所转发的消息在调整前的接口优先权。

进一步，所述调整接口优先权的方法，其中：

枢纽系统直接计算及时率，或者由其它系统计算及时率，并提供给枢纽系统，所述及时率指计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值。

进一步，所述调整接口优先权的方法，其中：

当由其它系统计算及时率时，在到达已设置的触发发送的条数时提供给枢纽系统，或者在到达设置的发送周期时提供给枢纽系统，发送周期与所述的规定时间一致，即到达规定时间，计算出及时率并发送给枢纽系统。

进一步，所述调整接口优先权的方法，其中：

由枢纽系统预先设置接口处理及时率与动态优先权的对应关系，或者由其它系统设置所述对应关系，并提供给枢纽系统。

根据本发明另一方面，还提出调整接口优先权的枢纽系统，包括接口监控模块和接口处理模块。其中：

接口监控模块获取接收方的接口处理及时率；

接口处理模块将发起方的消息转发给接收方；根据接口处理及时率获取动态优先权，根据获取的动态优先权调整接口优先权，按照调整后的接口优先权对消息进行转发。

进一步，所述调整接口优先权的枢纽系统，其中：

调整后的接口优先权为N2，N2=N1+动态优先权，N1为转发给接收方的消息的接口优先权，即所转发的消息在调整前的接口优先权。

进一步，所述调整接口优先权的枢纽系统，其中：

接口监控模块直接计算及时率，或者由其它系统计算及时率，并提供给接口监控模块，所述及时率指计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值。

进一步，所述调整接口优先权的枢纽系统，其中：

当由其它系统计算及时率时，在到达已设置的触发发送的条数时提供给接口监控模块，或者在到达设置的发送周期时提供给接口监控模块，发送周期与所述的规定时间一致，即到达规定时间，计算出及时率并发送给接口监控模块。

进一步，所述调整接口优先权的枢纽系统，其中：

接口处理模块预先设置接口处理及时率与动态优先权的对应关系，或者由其它系统设置所述对应关系，并提供给接口处理模块。

本发明在枢纽系统中，将接口消息落地方的系统（或平台）的接口处理及时率与接口的优先权进行关联，并进行动态调整。使得接口处理及时率高的系统（或平台）的接口优先权提高，从而提高该系统（或平台）的利用率；接口处理及时率低的系统（或平台）的接口优先权降低，从而接口处理及时率低的系统（或平台）收到的消息减少，降低该系统（或平台）的性能压力，避免消耗大量的资源，影响该枢纽系统的运行，也降低与枢纽系统相连的系统（或平台）出现故障时对其他业务的接口造成影响。

附图说明

此处所说明的附图用来提供对本发明的进一步理解，构成本发明的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：

图1为本发明调整接口优先权的方法流程示意图。

图2示出了本发明调整接口优先权的枢纽系统结构示意图。

具体实施方式

现在将参照附图来详细描述本发明的各种示例性实施例。应注意到：除非另外具体说明，否则在这些实施例中阐述的部件和步骤的相对布置和数值不限制本发明的范围。

同时，应当明白，为了便于描述，附图中所示出的各个部分的尺寸并不是按照实际的比例关系绘制的。

以下对至少一个示例性实施例的描述实际上仅仅是说明性的，决不作为对本发明及其应用或使用的任何限制。

对于相关领域普通技术人员已知的技术、方法和设备可能不作详细讨论，但在适当情况下，所述技术、方法和设备应当被视为授权说明书的一部分。

在这里示出和讨论的所有示例中，任何具体值应被解释为仅仅是示例性的，而不是作为限制。因此，示例性实施例的其它示例可以具有不同的值。

应注意到：相似的标号和字母在下面的附图中表示类似项，因此，一旦某一项在一个附图中被定义，则在随后的附图中不需要对其进行进一步讨论。

本发明在需要接口交互的各系统间设置枢纽系统，不同的接口可设置不同的优先权，将落地方系统（或平台）的接口处理及时率作为该接口的优先权的参数，对接口优先权进行动态管理。

下面参照附图对本发明进行更全面的描述，其中说明本发明的示例性实施例。

图1为本发明调整接口优先权的方法流程示意图。包括以下步骤：

S101、消息的发起方系统A，该消息的接口优先权为N1，消息的落地方为系统B（或平台B），该消息经过枢纽系统进行转发。

S102、枢纽系统获取落地方，即系统B（或平台B）的接口处理及时率。

及时率指在规定时间内，及时处理消息的能力。即计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值。这里所说的规定时间，可以根据具体情况进行设置。对于不同的枢纽系统，可以设置不同的规定时间。

在一实施例中，枢纽系统可以直接计算及时率。

在另一实施例中，由其它系统计算及时率，并提供给枢纽系统。可以由枢纽系统在需要时主动获取，也可以由计算出及时率的系统主动提供给枢纽系统。

例如，在到达设置的发送周期时进行提供。该发送周期可以与上述的规定时间一致，即在到达规定时间，计算出及时率并发送给枢纽系统。

又例如，在到达已设置的触发发送的条数时，向枢纽系统提供所计算的至少一个及时率。即所发送的及时率多于一个时，可以节省对相关资源的占用，例如，当需要网络传送时，可以减少对网络资源的占用。当然，也减少对枢纽系统中用于获取及时率的相关接口的占用。

S103、枢纽系统根据接口处理及时率获取动态优先权。

在一实施例中，由枢纽系统预先设置接口处理及时率与动态优先权的对应关系。

在另一实施例中，由其它系统设置该对应关系，并提供给枢纽系统。可以由枢纽系统在需要时主动获取，也可以由设置该对应关系的系统主动提供给枢纽系统。

对于不同的枢纽系统，接口处理及时率与动态优先权的对应关系可能不同。在这里，假设接口处理及时率与动态优先权之间的对应关系保存在列表中，称为动态优先权列表。则枢纽系统与该动态优先权列表之间的对应关系，例如：

枢纽系统1，对应动态优先权列表1；

枢纽系统2，对应动态优先权列表2；

枢纽系统N，对应动态优先权列表N；N为大于等于1的整数。

根据枢纽系统的编号查找对应的动态优先权列表，并将已查到的优先权列表提供给枢纽系统。

接口处理及时率与动态优先权的对应关系，例如：

接口处理及时率低于10%，动态优先权=8；

10%<接口及时率<50%，动态优先权=5。

本例中接口优先级数字愈大优先权愈低。当然，也可以设置接口优先级数字愈大优先权愈高。

S104、枢纽系统根据获取的动态优先权调整接口优先权。

例如，调整后的接口优先权为N2，N2=N1+动态优先权。

S105、枢纽系统按照调整后的接口优先权对消息进行转发。

当枢纽系统有多个需要转发的消息时，枢纽系统按接口优先权将接收的消息进行排队并转发。

如果接口处理及时率与动态优先权的对应关系是由枢纽系统设置的，则在获取该动态优先权后，枢纽系统修改已保存的接口处理及时率与动态优先权的对应关系，即保存调整后的接口优先权与接口处理及时率的对应关系。并且，在执行本次消息转发之后，下次再获取动态优先权时，则获取该调整后的动态优先权。

如果接口处理及时率与动态优先权的对应关系是由其它系统设置的，则枢纽系统将调整后的接口优先权与接口处理及时率的对应关系返回给设置该对应关系的其它系统，由其它系统进行保存。并且，在执行本次消息转发之后，下次再向枢纽系统提供动态优先权时，则提供该调整后的动态优先权。

S106、落地方即系统B（或平台B）接收系统A发起的消息，并对消息进行处理。

图2示出了本发明调整接口优先权的枢纽系统结构示意图。该枢纽系统包括接口监控模块21和接口处理模块22。

接口监控模块21获取接收方的接口处理及时率。

及时率指在规定时间内，及时处理消息的能力。即计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值。这里所说的规定时间，可以根据具体情况进行设置。对应不同的枢纽系统，可以设置不同的规定时间。

在一实施例中，枢纽系统可以直接计算及时率。

在另一实施例中，由其它系统计算及时率，并提供给枢纽系统。可以由枢纽系统在需要时主动获取，也可以由计算出及时率的系统主动提供给枢纽系统。

例如，在到达设置的发送周期时进行提供。该发送周期可以与上述的规定时间一致，即在到达规定时间，计算出及时率并发送给枢纽系统。

又例如，在到达已设置的触发发送的条数时，向枢纽系统提供所计算的至少一个及时率。即所发送的及时率多于一个时，可以节省对相关资源的占用，例如，当需要网络传送时，可以减少对网络资源的占用。当然，也减少对枢纽系统中用于获取及时率的相关接口的占用。

接口处理模块22将发起方的消息转发给接收方。根据接口处理及时率获取动态优先权，根据获取的动态优先权调整接口优先权，按照调整后的接口优先权对消息进行转发。

其中，接口处理模块22可以预先设置接口优先权，根据接口处理及时率所处的范围分别设置动态优先权。

在一实施例中，由枢纽系统预先设置接口处理及时率与动态优先权的对应关系。

在另一实施例中，由其它系统设置该对应关系，并提供给枢纽系统。可以由枢纽系统在需要时主动获取，也可以由设置该对应关系的系统主动提供给枢纽系统。

对于不同的枢纽系统，接口处理及时率与动态优先权的对应关系可能不同。在这里，假设接口处理及时率与动态优先权之间的对应关系保存在列表中，称为动态优先权列表。则枢纽系统与该动态优先权列表之间的对应关系，例如：

枢纽系统1，对应动态优先权列表1；

枢纽系统2，对应动态优先权列表2；

枢纽系统N，对应动态优先权列表N；N为大于等于1的整数。

根据枢纽系统的编号查找对应的动态优先权列表，并将已查到的优先权列表提供给枢纽系统。

接口处理及时率与动态优先权的对应关系，例如：

接口处理及时率低于10%，动态优先权=8；

10%<接口及时率<50%，动态优先权=5。

本例中接口优先级数字愈大优先权愈低。当然，也可以设置接口优先级数字愈大优先权愈高。

接口处理模块22调整后的接口优先权为N2，N2=N1+动态优先权，N1为转发给接收方的消息的接口优先权，即所转发的消息在调整前的接口优先权。

当枢纽系统有多个需要转发的消息时，枢纽系统按接口优先权将接收的消息进行排队并转发。

如果接口处理及时率与动态优先权的对应关系是由枢纽系统设置的，则在获取该动态优先权后，枢纽系统修改已保存的接口处理及时率与动态优先权的对应关系，即保存调整后的接口优先权与接口处理及时率的对应关系。并且，在执行本次消息转发之后，下次再获取动态优先权时，则获取该调整后的动态优先权。

如果接口处理及时率与动态优先权的对应关系是由其它系统设置的，则枢纽系统将调整后的接口优先权与接口处理及时率的对应关系返回给设置该对应关系的其它系统，由其它系统进行保存。并且，在执行本次消息转发之后，下次再向枢纽系统提供动态优先权时，则提供该调整后的动态优先权。

本发明在枢纽系统中，将接口消息落地方的系统（或平台）的接口处理及时率与接口优先权进行关联，并进行动态调整。使得接口处理及时率高的系统（或平台）的接口优先权提高，从而提高该系统（或平台）的利用率；接口处理及时率低的系统（或平台）的接口优先权降低，从而接口处理及时率低的系统（或平台）收到的消息减少，降低该系统（或平台）的性能压力，避免消耗大量的资源，影响该枢纽系统的运行，也降低与枢纽系统相连的系统（或平台）出现故障时对其他业务的接口造成影响。例如，与枢纽系统相连的业务平台1出现故障，由于业务平台1出错太多，导致枢纽系统处理的业务平台1的错误增多，会影响业务平台2的运行效率。

至此，已经详细描述了本发明。为了避免遮蔽本发明的构思，没有描述本领域所公知的一些细节。本领域技术人员根据上面的描述，完全可以明白如何实施这里公开的技术方案。

可能以许多方式来实现本发明的方法以及装置。例如，可通过软件、硬件、固件或者软件、硬件、固件的任何组合来实现本发明的方法以及装置。用于所述方法的步骤的上述顺序仅是为了进行说明，本发明的方法的步骤不限于以上具体描述的顺序，除非以其它方式特别说明。此外，在一些实施例中，还可将本发明实施为记录在记录介质中的程序，这些程序包括用于实现根据本发明的方法的机器可读指令。因而，本发明还覆盖存储用于执行根据本发明的方法的程序的记录介质。

虽然已经通过示例对本发明的一些特定实施例进行了详细说明，但是本领域的技术人员应该理解，以上示例仅是为了进行说明，而不是为了限制本发明的范围。本领域的技术人员应该理解，可在不脱离本发明的范围和精神的情况下，对以上实施例进行修改。本发明的范围由所附权利要求来限定。

Claims (10)

1.调整接口优先权的方法，其特征在于：

枢纽系统将发起方的消息转发给接收方；

枢纽系统获取接收方的接口处理及时率，其中，所述及时率指计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值；

枢纽系统根据接口处理及时率获取动态优先权；

枢纽系统根据获取的动态优先权调整接口优先权；

枢纽系统按照调整后的接口优先权对消息进行转发。

2.如权利要求1所述调整接口优先权的方法，其特征在于：

调整后的接口优先权为N2，N2＝N1+动态优先权，N1为转发给接收方的消息的接口优先权，即所转发的消息在调整前的接口优先权。

3.如权利要求1或2所述调整接口优先权的方法，其特征在于：

枢纽系统直接计算及时率，或者由其它系统计算及时率，并提供给枢纽系统。

4.如权利要求3所述调整接口优先权的方法，其特征在于：

当由其它系统计算及时率时，在到达已设置的触发发送的条数时提供给枢纽系统，或者在到达设置的发送周期时提供给枢纽系统，发送周期与所述的规定时间一致，即到达规定时间，计算出及时率并发送给枢纽系统。

5.如权利要求1或2所述调整接口优先权的方法，其特征在于：

由枢纽系统预先设置接口处理及时率与动态优先权的对应关系，或者由其它系统设置所述对应关系，并提供给枢纽系统。

6.调整接口优先权的枢纽系统，其特征在于，包括接口监控模块和接口处理模块：

接口监控模块获取接收方的接口处理及时率，其中，所述及时率指计算规定时间内，处理的消息的条数除以接收到的总消息条数所得到的比值；

接口处理模块将发起方的消息转发给接收方；根据接口处理及时率获取动态优先权，根据获取的动态优先权调整接口优先权，按照调整后的接口优先权对消息进行转发。

7.如权利要求6所述调整接口优先权的枢纽系统，其特征在于：

调整后的接口优先权为N2，N2＝N1+动态优先权，N1为转发给接收方的消息的接口优先权，即所转发的消息在调整前的接口优先权。

8.如权利要求6或7所述调整接口优先权的枢纽系统，其特征在于：

接口监控模块直接计算及时率，或者由其它系统计算及时率，并提供给接口监控模块。

9.如权利要求8所述调整接口优先权的枢纽系统，其特征在于：

当由其它系统计算及时率时，在到达已设置的触发发送的条数时提供给接口监控模块，或者在到达设置的发送周期时提供给接口监控模块，发送周期与所述的规定时间一致，即到达规定时间，计算出及时率并发送给接口监控模块。

10.如权利要求6或7所述调整接口优先权的枢纽系统，其特征在于：

接口处理模块预先设置接口处理及时率与动态优先权的对应关系，或者由其它系统设置所述对应关系，并提供给接口处理模块。