[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN109962963B - 消息处理方法及装置 - Google Patents

消息处理方法及装置 Download PDF

Info

Publication number
CN109962963B
CN109962963B CN201711436020.3A CN201711436020A CN109962963B CN 109962963 B CN109962963 B CN 109962963B CN 201711436020 A CN201711436020 A CN 201711436020A CN 109962963 B CN109962963 B CN 109962963B
Authority
CN
China
Prior art keywords
quota
host
linked list
message
resource
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Active
Application number
CN201711436020.3A
Other languages
English (en)
Other versions
CN109962963A (zh
Inventor
王琪
屈立学
骆艳中
刘宇宏
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Mobile Communications Group Co Ltd
China Mobile Group Inner Mongolia Co Ltd
Original Assignee
China Mobile Communications Group Co Ltd
China Mobile Group Inner Mongolia Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Mobile Communications Group Co Ltd, China Mobile Group Inner Mongolia Co Ltd filed Critical China Mobile Communications Group Co Ltd
Priority to CN201711436020.3A priority Critical patent/CN109962963B/zh
Publication of CN109962963A publication Critical patent/CN109962963A/zh
Application granted granted Critical
Publication of CN109962963B publication Critical patent/CN109962963B/zh
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
    • H04L51/58—Message adaptation for wireless communication
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer And Data Communications (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

本发明实施例提供一种消息处理方法及装置，该方法包括：获取待处理消息的业务类型；根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。

Description

消息处理方法及装置
技术领域
本发明实施例涉及移动通信技术领域，尤其涉及一种消息处理方法及装置。
背景技术
在IT技术不断发展的今天，应用的分布式部署越来越多的被应用到不同的领域，而分布式系统处理高并发业务的能力是系统最重要的技术指标之一。为了提高分布式系统处理高并发消息，各个设备厂商提供了不同的负载均衡策略，目前大多数厂家采用轮询或者最小连接数策略实现系统的负载均衡。
轮询法是将请求按顺序轮流地分配到后端服务器上，它均衡地对待后端的每一台服务器，而不关心服务器实际的连接数和当前的系统负载；最小连接数法比较灵活和智能，由于后端服务器的配置不尽相同，对于请求的处理有快有慢，它是根据后端服务器当前的连接情况，动态地选取其中当前积压连接数最少的一台服务器来处理当前的请求，尽可能地提高后端服务的利用效率，将负责合理地分流到每一台服务器。但不论是轮询法或者最小连接数法都无法保障多业务场景下分布式系统消息合理分配，在实际应用中，仍会出现某台服务器或某一个进程超负荷运行的情况。
发明内容
本发明提供一种消息处理方法及装置，用于解决现有技术中无法保障多业务场景下分布式系统消息合理分配的问题。
第一方面，本发明实施例提供一种消息处理方法，包括：
获取待处理消息的业务类型；
根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；
将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
对所述资源配额链表矩阵进行更新。
第二方面，本发明实施例提供一种消息处理装置，包括：
消息管理模块，用于获取待处理消息的业务类型；
配额管理模块，用于根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；
执行模块，用于将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
更新模块，用于对所述资源配额链表矩阵进行更新。
第三方面，本发明实施例提供一种电子设备，包括：处理器、存储器、总线及存储在存储器上并可在处理器上运行的计算机程序；
其中，所述处理器，存储器通过所述总线完成相互间的通信；
所述处理器执行所述计算机程序时实现如上述的方法。
第四方面，本发明实施例提供一种非暂态计算机可读存储介质，所述非暂态计算机可读存储介质上存储有计算机程序，该计算机程序被处理器执行时实现如上述的方法。
由上述技术方案可知，本发明实施例提供的一种消息处理方法及装置，通过获取待处理消息的业务类型，根据业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，将待处理消息发送给对应所述主机IP的主机，使主机上对应端口ID的应用程序对待处理消息进行处理，最后对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。
附图说明
图1为本发明一实施例提供的消息处理方法的流程示意图；
图2为本发明一实施例提供的初始化的资源配额链表矩阵的示意图；
图3为本发明一实施例提供的获取主机IP以及端口ID的流程示意图；
图4为本发明一实施例提供的消息处理方法的应用部署示意图；
图5为本发明一实施例提供的负载均衡系统生成的链表矩阵的示意图；
图6为图5链表矩阵更新后的示意图；
图7为本发明一实施例提供的获取主机IP以及端口ID的流程示意图；
图8为本发明一实施例提供的负载均衡系统生成的链表矩阵的示意图；
图9为图8链表矩阵更新后的示意图；
图10为本发明一实施例提供的消息处理装置的结构示意图；
图11为本发明一实施例提供的电子设备的结构示意图。
具体实施方式
下面结合附图和实施例，对本发明的具体实施方式作进一步详细描述。以下实施例用于说明本发明，但不用来限制本发明的范围。
图1示出了本发明一实施例提供一种消息处理方法，包括：
S11、获取待处理消息的业务类型。
在本步骤中，需要说明的是，在本发明实施例中，负载均衡系统会接收到外部外围系统发送的待处理消息，此时负载均衡系统会按照预设的解析准则对待处理消息进行解析，获得其具有的识别字段，然后根据所述识别字段和预设的识别字段与业务类型的对应关系获得所述待处理消息的业务类型。该识别字段和业务类型的对应关系为负载均衡系统对能够处理的各自业务消息预先设置的对应关系，用于在接收到消息后确认该消息的业务类型。
S12、根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID。
在本步骤中，需要说明的是，在本发明实施例中，负载均衡系统在启动后，会接收部署在各个主机上的负载均衡代理程序的上报信息，该上报信息包括业务类型、主机IP、端口号、配额等。负载均衡系统会根据上报信息生成资源配额链表矩阵。
该资源配额链表矩阵包括对应于每一个业务类型的横向链表。
每个横向链表的头节点数据结构为：业务类型，复杂系数。
每个横向链表的中间节点(即：配额节点)数据结构为：主机IP、端口号、最大配额、已用配额。
每个横向链表的尾节点的数据结构为：主机IP、端口号、最大配额、已用配额，结束符(一般为0)。即：在最后一个配额节点的数据结构中增加结束符。
同时需要将每台主机的主机性能因子作为单独项进行存储，用于计算配额剩余量。主机性能因子根据CUP和内存等指标综合评定。
例如，接入负载均衡系统的业务类型有m个，分别用A1……Am表示，后端系统有K台主机，主机IP分别用IP1……IPk表示，每台主机针对不同的应用部署的进程个数分别为N1……Nm、M1……Mm，……，P1……Pm。那么业务A1在主机1上端口号分别为B111、B112……B11N1，配额总量分别为C111、C112……C11N1；业务A1在主机2上端口号(端口ID)分别为B211、B212……B21M1，配额总量分别为C211、C212……C21M1；……；业务A1在主机K上端口号分别为BK11、BK12……BK1P1，配额总量分别为CK11、CK12……CK1P1；依据业务A的描述说明，结合其他业务A2……Am在不同主机上端口号及配额量分配，可得出所需的初始化的资源配额链表矩阵参见图2。
初始化的资源配额链表矩阵的已用配额量为0。当将一个业务消息发送给某一个主机，使该主机上的某一端口的应用程序进行处理时，则该端口所在的配额节点上的已用配额量会1。依次类推，其他配额节点上也会由于处理业务消息使已用配额量大于1。此时，资源配额链表矩阵为正在使用的矩阵。
负载均衡系统会根据待处理消息的业务类型，会根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，如图3所示，具体可为：
S121、根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
S122、根据所述横向链表中所有配额节点的配额剩余量确定能够处理所述待处理消息的多个主机IP；
S123、根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
S124、根据各个主机IP对应的资源剩余量确定唯一主机IP；
S125、从所述横向链表中获得匹配有唯一主机IP的配额节点，根据配额节点的配额剩余量确定端口ID。
针对步骤S121-步骤S125，需要说明的是，在本发明实施例中，在资源配额链表矩阵中匹配以该业务类型为头节点的横向链表，再计算各个配额节点的配额剩余量(配额总量－已用配额量)。若配额剩余量不为零，则获取对应配额节点记录的主机IP。
负载均衡系统再根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量。此时计算的各个主机IP对应的资源剩余量仅是能够继续处理业务消息的主机对应的资源剩余量。
例如，若后端系统的主机一共10台，通过上述配额剩余量获取到4台主机的IP，则只计算这四台主机的资源剩余量。
需要说明的是，在本发明实施例中，资源剩余量计算公式可为：
资源剩余量＝主机性能因子－(A1业务的已用配额量×U1+A2业务的已用配额量×U2+，……，+Am业务的已用配额量×Um)。
负载均衡系统再选取最大资源剩余量对应的主机IP作为唯一主机IP。其中，若存在多个相同最大资源剩余量，则任选其一主机IP作为唯一主机IP。
负载均衡系统再从匹配有唯一主机IP的配额节点中选取最大配额剩余量的配额节点，从而获取该配额节点中的端口ID。其中，若存在多个相同最大配额剩余量，则任选其一配额节点，从而获取该配额节点中的端口ID。
S13、将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理。
在本步骤中，需要说明的是，在本发明实施例中，负载均衡系统会将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理。
S14、对所述资源配额链表矩阵进行更新。
在本步骤中，需要说明的是，在本发明实施例中，由于所选取的配额节点中的已用配额量被使用一次，则负载均衡系统会对资源配额链表矩阵进行更新。
下面以具体实例对上述步骤进行解释说明：
例如当前后端系统有3台主机，主机性能因子分别为200、300、400，该后端系统需要处理的业务类型为3类，分别为A1、A2、A3，每类业务对应的业务复杂系数为1、2、3，在三台主机都负责处理上述三类业务，每台主机上处理每类业务的应用部署参见图4示例。按图4进行部署，可知：
主机1中应用A1的处理配额分为：3、4，已用配额为1，2；应用A2的处理配额分别为：4、6、8，已用配额为2，3，6；应用A3的处理配额分别为：3、5，已用配额为0，3；
主机2中应用A1的处理配额分为：2、3、8，已用配额为1，2，4；应用A2的处理配额分别为：5、7，已用配额为3，3；应用A3的处理配额分别为：9，已用配额为5；
主机3中应用A1的处理配额分为：5，已用配额为3；应用A2的处理配额分别为：3、7，已用配额为3，4；应用A3的处理配额分别为：10、6、8，已用配额为6，3，5。
根据以上应用部署，负载均衡系统生成的链表矩阵参见图5。
当负载均衡系统接收到待处理消息时，对消息进行解析，获取该消息的业务类型为A2，则在链表矩阵中选取可以处理该业务的主机，最终得到的结果时三台主机都可以处理类型为A2的消息。然后根据资源剩余量计算公式进行计算：
主机1的配额剩余量＝200－(3×1+11×2+3×3)＝166。
主机2的配额剩余量＝300－(7×1+6×2+5×3)＝266。
主机3的配额剩余量＝400－(3×1+7×2+14×3)＝341。
根据上述的选取方式，可选择主机3，端口为B323端口对应的应用程序对待处理消息进行处理，并更新链表矩阵，更新后参见图6。
本发明实施例提供的一种消息处理方法，通过获取待处理消息的业务类型，根据业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，将待处理消息发送给对应所述主机IP的主机，使主机上对应端口ID的应用程序对待处理消息进行处理，最后对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。
本发明一实施例提供的一种消息处理方法，包括：
S21、获取待处理消息的业务类型；
S22、根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；
S23、将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
S24、对所述资源配额链表矩阵进行更新。
针对本实施例，需要说明的是，本实施例的步骤S21、步骤S23-步骤S24与上述实施例步骤S11、步骤S13-步骤S14在原理上相同，在此不再赘述。
需要说明的是，本发明实施例步骤S22与上述实施例步骤S12获取主机IP和端口ID的情况不同。
如图7所示，本实施例步骤S22具体可为：
S221、根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
S222、根据所述横向链表中所有配额节点的配额剩余量确定不存在能够处理所述待处理消息的主机IP；
S223、根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
S224、根据各个主机IP对应的资源剩余量确定待分配主机IP；
S225、根据所述业务类型在所述横向链表的表尾插入匹配所述待分配主机IP的新配额节点；
S226、从所述新配额节点中获取端口ID。
针对步骤S221-步骤S226，需要说明的是，在发明实施例中，在资源配额链表矩阵中匹配以该业务类型为头节点的横向链表，再计算各个配额节点的配额剩余量(配额总量－已用配额量)。若该横向链表中的所有配额节点上的配额剩余量均为零，则需要在该横向链表上配置新配额节点，配置新配额节点需要获取待分配主机IP。
此时，负载均衡系统根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量。
需要说明的是，在本发明实施例中，资源剩余量计算公式可为：
资源剩余量＝主机性能因子－(A1业务的已用配额量×U1+A2业务的已用配额量×U2+，……，+Am业务的已用配额量×Um)。
负载均衡系统再选取最大资源剩余量对应的主机IP作为待分配主机IP。其中，若存在多个相同最大资源剩余量，则任选其一主机IP作为待分配主机IP。
负载均衡系统根据所述业务类型在所述横向链表的表尾插入匹配所述待分配主机IP的新配额节点，从所述新配额节点中获取端口ID。
继续以上述实施例的三台主机对本实施例步骤进行解释说明：
根据以上应用部署，负载均衡系统生成的链表矩阵参见图8。
负载均衡系统监控到A1的可用配额<＝0，则根据当前链表矩阵的情况计算可分配的主机配额：
主机1的配额剩余量＝200－(7×1+13×2+5×3)＝152。
主机2的配额剩余量＝300－(7×1+6×2+5×3)＝266。
主机3的配额剩余量＝400－(3×1+7×2+14×3)＝341。
此时，可选取主机3作为新申请配额的主机。负载均衡系统会根据主机IP和业务类型在A1业务对应的链表尾端插入新应用的节点信息，IP地址为IP3，端口为B312，配额量为10，已处理配额为0，新链表矩阵参见图9。
另外，在消息处理过程中，若所述资源配额链表矩阵中任一配额节点的配额剩余量为0，则将所述配额节点从其对应的横向链表中删除，并更新所述资源配额链表矩阵，可减少资源空间。
本发明实施例提供的一种消息处理方法，通过获取待处理消息的业务类型，根据业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的主机IP以及端口ID，将待处理消息发送给对应所述主机IP的主机，使主机上对应端口ID的应用程序对待处理消息进行处理，最后对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。
图10示出了本发明实施例提供的一种消息处理装置，包括消息管理模块31、配额管理模块32、执行模块33和更新模块34，其中：
消息管理模块31，用于获取待处理消息的业务类型；
配额管理模块32，用于根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，具体用于：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定能够处理所述待处理消息的多个主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定唯一主机IP；
从所述横向链表中获得匹配有唯一主机IP的配额节点，根据配额节点的配额剩余量确定端口ID。
执行模块33，用于将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
更新模块34，用于对所述资源配额链表矩阵进行更新。
由于本发明实施例所述装置与上述实施例所述方法的原理相同，对于更加详细的解释内容在此不再赘述。
需要说明的是，本发明实施例中可以通过硬件处理器(hardware processor)来实现相关功能模块。
本发明实施例提供的一种消息处理装置，通过获取待处理消息的业务类型，根据业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，将待处理消息发送给对应所述主机IP的主机，使主机上对应端口ID的应用程序对待处理消息进行处理，最后对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。
本发明实施例提供的一种消息处理装置，包括消息管理模块、配额管理模块、执行模块和更新模块，其中：
消息管理模块，用于获取待处理消息的业务类型；
配额管理模块，用于根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID，具体用于：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定不存在能够处理所述待处理消息的主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定待分配主机IP；
根据所述业务类型在所述横向链表的表尾插入匹配所述待分配主机IP的新配额节点；
从所述新配额节点中获取端口ID。
执行模块，用于将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
更新模块，用于对所述资源配额链表矩阵进行更新。
另外，还包括删除模块，用于若所述资源配额链表矩阵中任一配额节点的配额剩余量为0，则将所述配额节点从其对应的横向链表中删除，并更新所述资源配额链表矩阵。
由于本发明实施例所述装置与上述实施例所述方法的原理相同，对于更加详细的解释内容在此不再赘述。
需要说明的是，本发明实施例中可以通过硬件处理器(hardware processor)来实现相关功能模块。
本发明实施例提供的一种消息处理装置，通过获取待处理消息的业务类型，根据业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的主机IP以及端口ID，将待处理消息发送给对应所述主机IP的主机，使主机上对应端口ID的应用程序对待处理消息进行处理，最后对所述资源配额链表矩阵进行更新，在实现负载均衡的基础上增加了系统动态扩容能力，大大提高了高并发消息处理的及时性，降低了由于系统性能导致消息处理失败的情况。
图11示出了本发明一实施例提供的一种电子设备，包括：处理器401、存储器402、总线403及存储在存储器上并可在处理器上运行的计算机程序；
其中，所述处理器，存储器通过所述总线完成相互间的通信；
所述处理器执行所述计算机程序时实现如上述的方法，例如包括：获取待处理消息的业务类型；根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；对所述资源配额链表矩阵进行更新。
本发明实施例提供一种非暂态计算机可读存储介质，所述非暂态计算机可读存储介质上存储有计算机程序，该计算机程序被处理器执行时实现如上述的方法，例如包括：获取待处理消息的业务类型；根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；对所述资源配额链表矩阵进行更新。
此外，本领域的技术人员能够理解，尽管在此所述的一些实施例包括其它实施例中所包括的某些特征而不是其它特征，但是不同实施例的特征的组合意味着处于本发明的范围之内并且形成不同的实施例。例如，在下面的权利要求书中，所要求保护的实施例的任意之一都可以以任意的组合方式来使用。
应该注意的是上述实施例对本发明进行说明而不是对本发明进行限制，并且本领域技术人员在不脱离所附权利要求的范围的情况下可设计出替换实施例。在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本发明可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。
本领域普通技术人员可以理解：以上各实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述各实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分或者全部技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明权利要求所限定的范围。

Claims (10)

1.一种消息处理方法，其特征在于，包括：
获取待处理消息的业务类型；
根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；
将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
对所述资源配额链表矩阵进行更新；
其中，所述根据所述业务类型和预生成的资源配额链表矩阵确定主机IP以及端口ID，包括：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定能够处理所述待处理消息的多个主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定唯一主机IP；
从所述横向链表中获得匹配有唯一主机IP的配额节点，根据配额节点的配额剩余量确定端口ID。
2.根据权利要求1所述的方法，其特征在于，所述根据所述业务类型和预生成的资源配额链表矩阵确定主机IP以及端口ID，包括：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定不存在能够处理所述待处理消息的主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定待分配主机IP；
根据所述业务类型在所述横向链表的表尾插入匹配所述待分配主机IP的新配额节点；
从所述新配额节点中获取端口ID。
3.根据权利要求1所述的方法，其特征在于，还包括：
若所述资源配额链表矩阵中任一配额节点的配额剩余量为0，则将所述配额节点从其对应的横向链表中删除，并更新所述资源配额链表矩阵。
4.根据权利要求1所述的方法，其特征在于，所述获取待处理消息的业务类型，包括：
对所述待处理消息进行解析获得对应的识别字段；
根据所述识别字段和预设的识别字段与业务类型的对应关系获得所述待处理消息的业务类型。
5.一种消息处理装置，其特征在于，包括：
消息管理模块，用于获取待处理消息的业务类型；
配额管理模块，用于根据所述业务类型和预生成的资源配额链表矩阵确定能够处理所述待处理消息的唯一主机IP以及端口ID；
执行模块，用于将所述待处理消息发送给对应所述主机IP的主机，使所述主机上对应端口ID的应用程序对所述待处理消息进行处理；
更新模块，用于对所述资源配额链表矩阵进行更新；
其中，所述配额管理模块具体用于：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定能够处理所述待处理消息的多个主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定唯一主机IP；
从所述横向链表中获得匹配有唯一主机IP的配额节点，根据配额节点的配额剩余量确定端口ID。
6.根据权利要求5所述的装置，其特征在于，所述配额管理模块具体用于：
根据所述业务类型从所述资源配额链表矩阵中获取对应所述业务类型的横向链表；
根据所述横向链表中所有配额节点的配额剩余量确定不存在能够处理所述待处理消息的主机IP；
根据所述资源配额链表矩阵和预设的资源剩余量计算公式获得所述各个主机IP对应的资源剩余量；
根据各个主机IP对应的资源剩余量确定待分配主机IP；
根据所述业务类型在所述横向链表的表尾插入匹配所述待分配主机IP的新配额节点；
从所述新配额节点中获取端口ID。
7.根据权利要求5所述的装置，其特征在于，还包括删除模块，用于：若所述资源配额链表矩阵中任一配额节点的配额剩余量为0，则将所述配额节点从其对应的横向链表中删除，并更新所述资源配额链表矩阵。
8.根据权利要求5所述的装置，其特征在于，所述消息管理模块具体用于：
对所述待处理消息进行解析获得对应的识别字段；
根据所述识别字段和预设的识别字段与业务类型的对应关系获得所述待处理消息的业务类型。
9.一种电子设备，其特征在于，包括：处理器、存储器、总线及存储在存储器上并可在处理器上运行的计算机程序；
其中，所述处理器，存储器通过所述总线完成相互间的通信；
所述处理器执行所述计算机程序时实现如权利要求1-4中任一项所述的方法。
10.一种非暂态计算机可读存储介质，其特征在于，所述非暂态计算机可读存储介质上存储有计算机程序，该计算机程序被处理器执行时实现如权利要求1-4中任一项所述的方法。
CN201711436020.3A 2017-12-26 2017-12-26 消息处理方法及装置 Active CN109962963B (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201711436020.3A CN109962963B (zh) 2017-12-26 2017-12-26 消息处理方法及装置

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201711436020.3A CN109962963B (zh) 2017-12-26 2017-12-26 消息处理方法及装置

Publications (2)

Publication Number Publication Date
CN109962963A CN109962963A (zh) 2019-07-02
CN109962963B true CN109962963B (zh) 2020-08-18

Family

ID=67022475

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201711436020.3A Active CN109962963B (zh) 2017-12-26 2017-12-26 消息处理方法及装置

Country Status (1)

Country Link
CN (1) CN109962963B (zh)

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113055427B (zh) * 2019-12-28 2022-12-23 浙江宇视科技有限公司 一种基于业务的服务器集群接入方法及装置

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
FR3003115A1 (fr) * 2013-03-06 2014-09-12 France Telecom Procede d'allocation de ressources pour la mise en oeuvre de reseaux virtuels dans un reseau de telecommunication
CN104581219A (zh) * 2014-12-22 2015-04-29 浙江工业大学 一种流媒体转发服务器的控制方法
WO2015180648A1 (zh) * 2014-05-30 2015-12-03 华为技术有限公司 一种资源分配的方法及装置
CN105872082A (zh) * 2016-05-18 2016-08-17 上海交通大学 基于容器集群负载均衡算法的细粒度资源响应系统
CN105978744A (zh) * 2016-07-26 2016-09-28 浪潮电子信息产业股份有限公司 一种资源分配方法、装置及系统
CN106302565A (zh) * 2015-05-12 2017-01-04 浙江格林蓝德信息技术有限公司 业务服务器的调度方法及系统

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
FR3003115A1 (fr) * 2013-03-06 2014-09-12 France Telecom Procede d'allocation de ressources pour la mise en oeuvre de reseaux virtuels dans un reseau de telecommunication
WO2015180648A1 (zh) * 2014-05-30 2015-12-03 华为技术有限公司 一种资源分配的方法及装置
CN104581219A (zh) * 2014-12-22 2015-04-29 浙江工业大学 一种流媒体转发服务器的控制方法
CN106302565A (zh) * 2015-05-12 2017-01-04 浙江格林蓝德信息技术有限公司 业务服务器的调度方法及系统
CN105872082A (zh) * 2016-05-18 2016-08-17 上海交通大学 基于容器集群负载均衡算法的细粒度资源响应系统
CN105978744A (zh) * 2016-07-26 2016-09-28 浪潮电子信息产业股份有限公司 一种资源分配方法、装置及系统

Also Published As

Publication number Publication date
CN109962963A (zh) 2019-07-02

Similar Documents

Publication Publication Date Title
US10225145B2 (en) Method and device for updating client
US8069224B2 (en) Method, equipment and system for resource acquisition
EP3905589B1 (en) Slice resource deployment method and apparatus, and slice manager and computer storage medium
CN110365748B (zh) 业务数据的处理方法和装置、存储介质及电子装置
KR102513998B1 (ko) 통신 방법 및 장치, 엔티티 및 컴퓨터 판독가능 저장 매체
CN107210924B (zh) 用于配置通信系统的方法和设备
CN107911470A (zh) 分布式动态负载均衡方法、计算设备及计算机存储介质
CN109451088A (zh) 一种数据访问方法及装置
CN107105050B (zh) 一种业务对象的存储、下载方法及系统
CN108989430B (zh) 负载均衡方法、装置及存储介质
CN109104368B (zh) 一种请求连接方法、装置、服务器及计算机可读存储介质
CN107105013B (zh) 文件的处理方法、服务器、终端和系统
CN103731448A (zh) 一种压缩图片的方法和系统
WO2019170011A1 (zh) 任务分配方法及装置、分布式存储系统
CN109151025B (zh) 基于url的负载均衡方法、装置、计算机存储介质及设备
US9390156B2 (en) Distributed directory environment using clustered LDAP servers
CN103414657A (zh) 一种跨数据中心的资源调度方法、超级调度中心和系统
CN102724105B (zh) 一种负载均衡方法和装置
CN107172214B (zh) 一种具有负载均衡的服务节点发现方法及装置
US11025490B2 (en) Method for dynamically managing a network service in a communication network
CN110515728B (zh) 服务器调度方法、装置、电子设备及机器可读存储介质
CN109962963B (zh) 消息处理方法及装置
CN108259605B (zh) 一种基于多数据中心的数据调用系统及方法
CN106790354B (zh) 一种防数据拥堵的通信方法及其装置
US10353741B2 (en) Load distribution of workflow execution request among distributed servers

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant