CN114490100B - 一种消息队列遥测传输负载均衡方法、装置及服务器 - Google Patents
一种消息队列遥测传输负载均衡方法、装置及服务器 Download PDFInfo
- Publication number
- CN114490100B CN114490100B CN202011163725.4A CN202011163725A CN114490100B CN 114490100 B CN114490100 B CN 114490100B CN 202011163725 A CN202011163725 A CN 202011163725A CN 114490100 B CN114490100 B CN 114490100B
- Authority
- CN
- China
- Prior art keywords
- message queue
- queue telemetry
- telemetry transmission
- server
- cluster
- 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
Links
- 230000005540 biological transmission Effects 0.000 title claims abstract description 489
- 238000000034 method Methods 0.000 title claims abstract description 47
- 238000013507 mapping Methods 0.000 claims abstract description 62
- 238000012545 processing Methods 0.000 claims abstract description 29
- 238000012163 sequencing technique Methods 0.000 claims description 8
- 238000012790 confirmation Methods 0.000 claims description 7
- 238000010606 normalization Methods 0.000 claims description 7
- 230000001360 synchronised effect Effects 0.000 description 18
- 238000010586 diagram Methods 0.000 description 7
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000002085 persistent effect Effects 0.000 description 1
- 238000000926 separation method Methods 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/505—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the load
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5083—Techniques for rebalancing the load in a distributed system
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/547—Messaging middleware
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/548—Queue
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Computer And Data Communications (AREA)
Abstract
本发明提供了一种消息队列遥测传输负载均衡方法、装置及服务器，涉及物联网技术领域，该方法包括，接收第二服务器发送的服务请求；确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器。本发明实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上提供会话处理服务，打破了现有消息队列遥测传输服务器水平扩展的瓶颈。
Description
技术领域
本发明涉及物联网领域，特别涉及一种消息队列遥测传输负载均衡方法、装置及终端。
背景技术
在可支持水平扩展的消息队列遥测传输（Message Queuing TelemetryTransport，MQTT）协议服务器实现方案中，负载均衡方案是必不可少的，通过负载均衡技术可以把用户的访问压力分配到多台服务器上，是可水平扩展服务中的关键技术。
目前，在支持分布式部署方案的实现中通常仅仅使用常规的硬负载均衡器F5或代理服务器Nginx对MQTT设备的长连接进行无差别的负载均衡。这样无差别的负载均衡将会使得一个群组的MQTT设备可能分布在多个不同的消息队列遥测传输服务器（MQTT Borker）会话处理服务上。使得一个可水平扩展MQTT服务器实现中跨MQTT Borker连接的MQTT设备发布订阅关系信息同步。部分技术通过将订阅关系持久化在分布式数据库中，但是对于订阅关系发生变化、发布消息时，跨MQTT Borker的订阅关系信息以及消息的同步是水平扩展的一个瓶颈。
发明内容
本发明实施例提供一种消息队列遥测传输负载均衡方法、装置及终端，用以解决相关技术中对中消息队列遥测传输设备的长连接进行无差别的负载均衡时，引入消息队列遥测传输设备跨消息队列遥测传输服务器发布订阅消息同步，影响消息队列遥测传输服务器的性能以及水平扩展能力的问题。
本发明的实施例提供一种消息队列遥测传输负载均衡方法，应用于第一服务器，包括：
接收第二服务器发送的服务请求；
确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
可选地，所述方法还包括：
获取所述第一集群的消息队列遥测传输服务器的负载信息；
对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
根据所述负载状态，对所述第一集群中的消息队列遥测传输服务器进行负载排序，得到排序结果。
可选地，确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中一个存在映射关系，包括：
将所述第一身份信息与所述第一集群的消息队列遥测传输服务器的第二身份信息进行对比；
若所述第一身份信息与所述第二身份信息匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
若所述第一身份信息与所述第二身份信息不匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系。
可选地，所述根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器，包括：
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将所述与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，根据所述排序结果，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器。
可选地，所述将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器，包括：
将所述第一消息队列遥测传输服务器的身份标识发送给所述第二服务器；或者，
建立所述消息队列遥测传输设备与所述第二消息队列遥测传输服务器之间的第一映射关系，并保存所述第一映射关系。
可选地，所述负载信息，包括以下信息中的至少一项：
消息队列遥测传输服务器的在线设备数量、消息队列遥测传输服务器的中央处理器CPU使用率以及消息队列遥测传输服务器的内存使用率。
本发明实施例还提供一种消息队列遥测传输负载均衡方法，应用于第二服务器，包括：
接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
可选地，所述接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，包括：
接收消息队列遥测传输设备的连接报文；所述连接报文包括所述消息队列遥测传输设备的第一身份信息；
根据所述消息队列遥测传输设备的身份信息，得到服务请求；
将所述服务请求发送给第一服务器。
本发明实施例还提供一种消息队列遥测传输负载均衡装置，包括：
第一接收模块，用于接收第二服务器发送的服务请求；
第一确认模块，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
第二确认模块，用于根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
第一发送模块，用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
可选地，所述的消息队列遥测传输负载均衡装置，还包括：
第一获取模块，用于获取所述第一集群的消息队列遥测传输服务器的负载信息；
处理模块，用于对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
排序模块，用于根据所述负载状态，对所述第一集群中的消息队列遥测传输服务器进行负载排序，得到排序结果。
本发明实施例还提供一种消息队列遥测传输负载均衡装置，包括：
第二接收模块，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
第三接收模块，用于接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
第二发送模块，用于根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
本发明实施例还提供一种服务器，所述服务器为第一服务器，包括：第一处理器和第一收发器；
所述第一收发器，用于接收第二服务器发送的服务请求；
所述第一处理器，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
所述第一收发器，还用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
本发明实施例还提供一种服务器，所述服务器为第二服务器，包括：第二处理器和第二收发器；
所述第二收发器，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
所述第二处理器，用于根据所述身份标识，获取所述消息队列遥测传输设备的数据报文；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
本发明实施例还提供一种服务器，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的程序；所述处理器执行所述程序时实现如上所述的消息队列遥测传输负载均衡方法。
本发明实施例还提供一种可读存储介质，其上存储有程序，该程序被处理器执行时实现如上所述的消息队列遥测传输负载均衡方法。
本发明的有益效果是：
本发明实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
附图说明
图1表示本发明实施例的消息队列遥测传输负载均衡方法的步骤示意图；
图2表示本发明实施例的另一消息队列遥测传输负载均衡方法的步骤示意图；
图3表示本发明实施例的消息队列遥测传输负载均衡装置的模块示意图；
图4表示本发明实施例的另一消息队列遥测传输负载均衡装置的模块示意图；
图5表示本发明实施例的消息队列遥测传输负载均衡方法的实现示意图；
图6表示本发明实施例的服务器的结构示意图；
图7表示本发明实施例的另一服务器的结构示意图。
具体实施方式
为使本发明的目的、技术方案和优点更加清楚，下面将结合附图及具体实施例对本发明进行详细描述。
为解决现有技术对中消息队列遥测传输设备的长连接进行无差别的负载均衡时，引入消息队列遥测传输设备跨消息队列遥测传输服务器发布订阅消息同步，影响消息队列遥测传输服务器的性能以及水平扩展能力的问题。提供一种消息队列遥测传输负载均衡方法、装置及服务器。
如图1所示，本发明的实施例提供一种消息队列遥测传输负载均衡方法，应用于第一服务器，包括：
步骤101，接收第二服务器发送的服务请求；
步骤102，确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
步骤103，根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
步骤104，将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
这里，还包括消息队列遥测传输设备连接硬负载均衡器F5后，通过硬负载均衡器对消息队列遥测传输设备进行无差别的负载均衡到连接管理服务集群的各个服务器上。
本发明的实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
可选地，所述方法还包括：
获取所述第一集群的消息队列遥测传输服务器的负载信息；
对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
根据所述负载状态，对所述第一集群的消息队列遥测传输服务器进行负载排序，得到排序结果。
在本发明的一实施例中，设备调度服务周期性的获取属于同一集群的消息队列遥测传输服务器的负载信息，对所述负载信息归一化处理后，对消息队列遥测传输服务器根据负载的高低进行排序。
举例说明，每个一分钟获取依次第一集群的消息队列遥测传输服务器的第一负载信息，对第一负载信息归一化处理后，将第一集群的消息队列遥测传输服务器按照负载由低到高或者由高到低进行排序。
对同一群组的消息队列遥测传输服务器进行排序，可以使选择消息队列遥测传输服务器时优先选择负载较低的服务器，保证了各个消息队列遥测传输服务器的压力处于相对均衡的状态。
可选地，确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系，包括：
将所述第一身份信息与所述第一集群的消息队列遥测传输服务器的第二身份信息进行对比；
若所述第一身份信息与所述第二身份信息匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
若所述第一身份信息与所述第二身份信息不匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系。
所述第一身份信息包括同一群组内所有消息队列遥测传输设备所有身份信息以及连接信息，所述第二身份信息包括同一集群内所有消息队列遥测传输服务器的所有身份信息以及连接信息。
将第一身份信息和第二身份信息进行对比，可以判断出消息队列遥测传输设备是否连接过同一集群中的消息队列遥测传输服务器。如果存在与第二身份信息匹配的第一身份信息，则消息队列遥测传输设备连接过同一集群中的消息队列遥测传输服务器；如果不存在与第二身份信息匹配的第一身份信息，消息队列遥测传输设备没有连接过同一集群中消息队列遥测传输服务器的任意一个。
根据历史连接数据判断是否存在已有的连接映射关系，若存在则无需建立心的映射关系；若不存在，则建立新的连接映射关系。节约了时间成本。
可选地，所述根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器，包括：
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将所述与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，根据所述排序结果，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器。
如果消息队列遥测传输设备连接过同一集群中消息队列遥测传输服务器的一个，则该消息队列遥测传输设备与同其连接过的消息队列遥测传输服务器之间存在映射关系；若消息队列遥测传输设备不曾连接过所述同一集群的任一消息队列遥测传输服务器，则需建立与该集群中的消息队列遥测传输服务器的新的连接关系，且可以选择负载最低的消息队列遥测传输服务器。
根据历史连接数据判断是否存在已有的连接映射关系，若存在则无需建立心的映射关系；若不存在，则与集群中负载最低的消息队列遥测传输服务器建立连接映射关系。节约时间成本的同时，保证了各个消息队列遥测传输服务器的压力处于相对均衡的状态。将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。
所述将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器，包括：
将所述第一消息队列遥测传输服务器的身份标识发送给所述第二服务器；或者，
建立所述消息队列遥测传输设备与所述第二消息队列遥测传输服务器之间的第一映射关系，并在保存所述第一映射关系之后，将所述第二消息队列遥测传输服务器的身份标识发送给所述第二服务器。
与集群中负载最低的消息队列遥测传输服务器建立连接映射关系，保证了各个消息队列遥测传输服务器的压力处于相对均衡的状态，并将新建立的映射关系持久化，保存到数据库，以及时更新和补充数据库中的映射关系数据。
可选地，所述负载信息，包括以下信息中的至少一项：
消息队列遥测传输服务器的在线设备数量、消息队列遥测传输服务器的中央处理器CPU使用率以及消息队列遥测传输服务器的内存使用率。
根据对消息队列遥测传输服务器的在线设备数量、消息队列遥测传输服务器的中央处理器CPU使用率以及消息队列遥测传输服务器的内存使用率添加权重进行计算，得到不同权重下消息队列遥测传输服务器的负载状态。根据不同的需求，对同一集群中的消息队列遥测传输服务器的状态信息进行排序，以能够快速确定所需要的消息队列遥测传输服务器。
本发明实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
如图2所示，本发明实施例还提供一种消息队列遥测传输负载均衡方法，应用于第二服务器，包括：
步骤201，接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
步骤202，接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
步骤203，根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
举例说明，第一消息队列遥测传输服务器为目标消息队列遥测传输服务器，则将第一群组的所有消息队列遥测传输服设备的报文均转发至第一消息队列遥测传输服务器上。
本发明实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
可选地，所述接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，包括：
接收消息队列遥测传输设备的连接报文；所述连接报文包括所述消息队列遥测传输设备的第一身份信息；
根据所述消息队列遥测传输设备的身份信息，得到服务请求；
将所述服务请求发送给第一服务器。
举例说明，获取第一群组中消息队列遥测传输设备的连接报文，连接报文包括消息队列遥测传输设备的身份信息和连接信息。根据连接报文生成服务请求，服务请求中包含第一群组中所有消息队列遥测传输设备的身份信息和连接信息。
确定目标消息队列遥测传输服务器之后，将第一群组内每个消息队列遥测传输设备均与目标消息队列遥测传输服务器建立映射关系，并将第一群组内每个消息队列遥测传输设备的报文发送至目标消息队列遥测传输服务器上，实现了将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上来提供会话处理服务，避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。
本发明实施例的消息队列遥测传输负载均衡方法，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
如图3所示，本发明实施例还提供一种消息队列遥测传输负载均衡装置300，包括：
第一接收模块301，用于接收第二服务器发送的服务请求；
第一确认模块302，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
第二确认模块303，用于根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
第一发送模块304，用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
本发明实施例的消息队列遥测传输负载均衡装置，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
可选地，所述的消息队列遥测传输负载均衡装置，还包括：
第一获取模块，用于获取所述第一集群的消息队列遥测传输服务器的负载信息；
处理模块，用于对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
排序模块，用于根据所述负载状态，对所述第一集群的消息队列遥测传输服务器进行负载排序，得到排序结果。
对同一群组的消息队列遥测传输服务器进行排序，可以使选择消息队列遥测传输服务器时优先选择负载较低的服务器，保证了各个消息队列遥测传输服务器的压力处于相对均衡的状态。
如图4所示，本发明实施例还提供一种消息队列遥测传输负载均衡装置400，包括：
第二接收模块401，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
第三接收模块402，用于接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
第二发送模块403，用于根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
本发明实施例的消息队列遥测传输负载均衡装置，基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
如图5所示，硬负载均衡器主要负责对消息队列遥测传输设备的无差别负载均衡，让消息队列遥测传输设备平均连接到连接管理服务集群的每个节点上。
连接管理服务模块主要负责与消息队列遥测传输设备保持的传输控制协议（Transmission Control Protocol，TCP）长连接，维护设备与消息队列遥测传输服务器之间的映射关系。实现了设备的会话处理服务与TCP长连接的分离。通过设备调度服务为每个消息队列遥测传输设备指定实际提供服务的消息队列遥测传输服务器，实现消息队列遥测传输设备长连接与会话处理服务的分离。
设备调度模块主要负责应该由哪个消息队列遥测传输服务器来为消息队列遥测传输设备来提供会话处理服务。同时也负责定时收集各个消息队列遥测传输服务器负载信息。综合消息队列遥测传输设备的用户信息元数据以及当前消息队列遥测传输服务器的负载信息进行负载均衡，保证各个消息队列遥测传输服务器的压力处于相对均衡的状态。
消息队列遥测传输服务器模块主要负责对设备的会话处理服务，消息队列遥测传输协议报文的解析，发布消息的匹配，以及订阅取消订阅等消息队列遥测传输协议规定的逻辑处理工作。
连接管理服务模块接收消息队列遥测传输设备的第一身份信息，向设备调度模块发送服务请求；
接收所述设备调度模块根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备至少有一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
设备调度模块接收连接管理模块发送的服务请求；
确定所述服务请求对应的消息队列遥测传输设备是否与同一集群消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
将所述目标消息队列遥测传输服务器的身份标识发送给所述连接管理模块；
其中，所述服务请求中包括消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
如图6所示，本发明实施例还提供一种服务器600，所述服务器为第一服务器，包括：第一处理器601和第一收发器602；
所述第一收发器602，用于接收第二服务器发送的服务请求；
所述第一处理器601，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
所述第一收发器602，还用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组。
基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
如图7所示，本发明实施例还提供一种服务器700，所述服务器为第二服务器，包括：第二处理器701和第二收发器702；
所述第二收发器702，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求；
接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
所述第二处理器701，用于根据所述身份标识，获取所述消息队列遥测传输设备的数据报文；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
基于用户信息元数据和消息队列遥测传输服务器的负载两方面因素，将同一群组的消息队列遥测传输设备负载均衡到同一消息队列遥测传输服务器上，来提供会话处理服务。避免了跨消息队列遥测传输服务器必须要同步发布订阅树，同步发布消息等问题。解决了消息队列遥测传输服务器之间的同步发布消息需要中转的延迟问题，以及各个消息队列遥测传输服务器的订阅树同步延迟以及实现复杂度的问题，打破了现有消息队列遥测传输服务器的水平扩展的瓶颈。
本发明实施例还提供一种服务器，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的程序；所述处理器执行所述程序时实现如上所述的消息队列遥测传输负载均衡方法。
本发明实施例还提供一种可读存储介质，其上存储有程序，该程序被处理器执行时实现如上所述的消息队列遥测传输负载均衡方法。
以上所述的是本发明的优选实施方式，应当指出对于本技术领域的普通人员来说，在不脱离本发明所述的原理前提下还可以作出若干改进和润饰，这些改进和润饰也在本发明的保护范围内。
Claims (14)
1.一种消息队列遥测传输负载均衡方法，应用于第一服务器，其特征在于，包括：
接收第二服务器发送的服务请求；
确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器，包括：
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器。
2.根据权利要求1所述的消息队列遥测传输负载均衡方法，其特征在于，所述方法还包括：
获取所述第一集群的消息队列遥测传输服务器的负载信息；
对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
根据所述负载状态，对所述第一集群中的消息队列遥测传输服务器进行负载排序，得到排序结果。
3.根据权利要求1所述的消息队列遥测传输负载均衡方法，其特征在于，确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中一个存在映射关系，包括：
将所述第一身份信息与所述第一集群的消息队列遥测传输服务器的第二身份信息进行对比；
若所述第一身份信息与所述第二身份信息匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
若所述第一身份信息与所述第二身份信息不匹配，则所述服务请求对应的消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系。
4.根据权利要求1所述的消息队列遥测传输负载均衡方法，其特征在于，所述将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器，包括：
将所述第一消息队列遥测传输服务器的身份标识发送给所述第二服务器；或者，
建立所述消息队列遥测传输设备与所述第二消息队列遥测传输服务器之间的第一映射关系，并在保存所述第一映射关系之后，将所述第二消息队列遥测传输服务器的身份标识发送给所述第二服务器。
5.根据权利要求2所述的消息队列遥测传输负载均衡方法，其特征在于，所述负载信息，包括以下信息中的至少一项：
消息队列遥测传输服务器的在线设备数量、消息队列遥测传输服务器的中央处理器CPU使用率以及消息队列遥测传输服务器的内存使用率。
6.一种消息队列遥测传输负载均衡方法，应用于第二服务器，其特征在于，包括：
接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，以使得所述第一服务器在所述消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器，在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
7.根据权利要求6所述的消息队列遥测传输负载均衡方法，其特征在于，所述接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，包括：
接收消息队列遥测传输设备的连接报文；所述连接报文包括所述消息队列遥测传输设备的第一身份信息；
根据所述消息队列遥测传输设备的身份信息，得到服务请求；
将所述服务请求发送给第一服务器。
8.一种消息队列遥测传输负载均衡装置，其特征在于，包括：
第一接收模块，用于接收第二服务器发送的服务请求；
第一确认模块，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
第二确认模块，用于根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
第一发送模块，用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述第二确认模块，具体用于：
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器。
9.根据权利要求8所述的消息队列遥测传输负载均衡装置，其特征在于，还包括：
第一获取模块，用于获取所述第一集群的消息队列遥测传输服务器的负载信息；
处理模块，用于对所述负载信息进行归一化处理，得到各个所述消息队列遥测传输服务器的负载状态；
排序模块，用于根据所述负载状态，对所述第一集群的消息队列遥测传输服务器进行负载排序，得到排序结果。
10.一种消息队列遥测传输负载均衡装置，其特征在于，包括：
第二接收模块，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，以使得所述第一服务器在所述消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器，在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
第三接收模块，用于接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
第二发送模块，用于根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
11.一种服务器，所述服务器为第一服务器，其特征在于，包括：第一处理器和第一收发器；
所述第一收发器，用于接收第二服务器发送的服务请求；
所述第一处理器，用于确定所述服务请求对应的消息队列遥测传输设备是否与第一集群的消息队列遥测传输服务器中的一个存在映射关系；
根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器；
所述第一收发器，还用于将所述目标消息队列遥测传输服务器的身份标识发送给所述第二服务器；
其中，所述服务请求中包括所述消息队列遥测传输设备的第一身份信息；
所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述根据确定结果，从所述第一集群的消息队列遥测传输服务器中确定目标消息队列遥测传输服务器，包括：
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器。
12.一种服务器，所述服务器为第二服务器，其特征在于，包括：第二处理器和第二收发器；
所述第二收发器，用于接收消息队列遥测传输设备的第一身份信息，向第一服务器发送服务请求，以使得所述第一服务器在所述消息队列遥测传输设备与第一集群的消息队列遥测传输服务器中的一个存在映射关系的情况下，将与所述消息队列遥测传输设备存在映射关系的第一消息队列遥测传输服务器作为目标消息队列遥测传输服务器，在所述消息队列遥测传输设备与所述第一集群的消息队列遥测传输服务器中的任一个都不存在映射关系的情况下，将所述第一集群的消息队列遥测传输服务器中负载最低的第二消息队列遥测传输服务器作为目标消息队列遥测传输服务器；
接收所述第一服务器根据所述服务请求反馈的目标消息队列遥测传输服务器的身份标识；
根据所述身份标识，将所述消息队列遥测传输设备的数据报文发送给所述目标消息队列遥测传输服务器；
所述第二处理器，用于根据所述身份标识，获取所述消息队列遥测传输设备的数据报文；
其中，所述消息队列遥测传输设备的数量为至少一个，且均属于第一群组；
所述服务请求中包括所述第一身份信息，或者所述第一身份信息以及对应的消息队列遥测传输服务器的第二身份信息。
13.一种服务器，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的程序；其特征在于，所述处理器执行所述程序时实现如权利要求1至5中任一项所述的消息队列遥测传输负载均衡方法，或者实现如权利要求6至7中任一项所述的消息队列遥测传输负载均衡方法。
14.一种可读存储介质，其上存储有程序，其特征在于，该程序被处理器执行时实现如权利要求1至5中任一项所述的消息队列遥测传输负载均衡方法中的步骤，或者实现如权利要求6至7中任一项所述的消息队列遥测传输负载均衡方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011163725.4A CN114490100B (zh) | 2020-10-27 | 2020-10-27 | 一种消息队列遥测传输负载均衡方法、装置及服务器 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011163725.4A CN114490100B (zh) | 2020-10-27 | 2020-10-27 | 一种消息队列遥测传输负载均衡方法、装置及服务器 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114490100A CN114490100A (zh) | 2022-05-13 |
| CN114490100B true CN114490100B (zh) | 2024-06-04 |
Family
ID=81470241
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011163725.4A Active CN114490100B (zh) | 2020-10-27 | 2020-10-27 | 一种消息队列遥测传输负载均衡方法、装置及服务器 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114490100B (zh) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115277698B (zh) * | 2022-07-20 | 2024-01-16 | 福州大学 | 基于可靠性的遥测收集方案部署方法 |
| CN115426392B (zh) * | 2022-11-02 | 2023-03-24 | 苏州万店掌网络科技有限公司 | 一种设备网络管理方法、装置、设备及存储介质 |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104935482A (zh) * | 2015-06-26 | 2015-09-23 | 曙光信息产业(北京)有限公司 | 分布式监控系统及方法 |
| CN108776934A (zh) * | 2018-05-15 | 2018-11-09 | 中国平安人寿保险股份有限公司 | 分布式数据计算方法、装置、计算机设备及可读存储介质 |
| CN109660607A (zh) * | 2018-12-05 | 2019-04-19 | 北京金山云网络技术有限公司 | 一种业务请求分发方法、接收方法、装置及服务器集群 |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9519518B2 (en) * | 2013-05-15 | 2016-12-13 | Citrix Systems, Inc. | Systems and methods for deploying a spotted virtual server in a cluster system |
| US9538345B2 (en) * | 2015-01-28 | 2017-01-03 | Citrix Systems, Inc. | Systems and methods for performing load balancing and message routing for short message peer to peer protocol |
-
2020
- 2020-10-27 CN CN202011163725.4A patent/CN114490100B/zh active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104935482A (zh) * | 2015-06-26 | 2015-09-23 | 曙光信息产业(北京)有限公司 | 分布式监控系统及方法 |
| CN108776934A (zh) * | 2018-05-15 | 2018-11-09 | 中国平安人寿保险股份有限公司 | 分布式数据计算方法、装置、计算机设备及可读存储介质 |
| CN109660607A (zh) * | 2018-12-05 | 2019-04-19 | 北京金山云网络技术有限公司 | 一种业务请求分发方法、接收方法、装置及服务器集群 |
Non-Patent Citations (2)
| Title |
|---|
| Dynamic Adaptation for Elastic System Services Using Virtual Servers;Abhishek Kulkarni等;《2015 IEEE 22nd International Conference on High Performance Computing (HiPC)》;20160204;第125-134页 * |
| 基于运维监控业务的微服务架构设计模式研究与应用;张亚东;《中国优秀硕士学位论文全文数据库 信息科技辑》;20200415;第I138-104页 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114490100A (zh) | 2022-05-13 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108009028B (zh) | 消息处理方法、装置、设备及计算机可读存储介质 | |
| CN108696374B (zh) | 更新客户端配置的方法和装置 | |
| CN101938502B (zh) | 一种服务器集群系统及负载均衡方法 | |
| CN109309698B (zh) | 数据处理系统、方法和装置 | |
| JP2000276432A (ja) | トランザクション・メッセージの動的負荷分散方式 | |
| CN112866394B (zh) | 一种负载均衡方法、装置、系统、计算机设备和存储介质 | |
| US20220318071A1 (en) | Load balancing method and related device | |
| CN111447185A (zh) | 一种推送信息的处理方法及相关设备 | |
| CN102281190A (zh) | 负载均衡装置组网方法以及服务器、客户端接入方法 | |
| CN114490100B (zh) | 一种消息队列遥测传输负载均衡方法、装置及服务器 | |
| CN107968797B (zh) | 一种视频传输方法、装置及系统 | |
| CN113391979A (zh) | 监控数据展示的处理方法、设备、系统及存储介质 | |
| US8606908B2 (en) | Wake-up server | |
| CN114024972A (zh) | 一种长连接通信方法、系统、装置、设备及存储介质 | |
| US20160065660A1 (en) | Computer system, computer, and load balancing method | |
| CN101317407B (zh) | 用于在通信系统中传送消息的方法和系统 | |
| CN112839067A (zh) | 一种数据同步方法及装置 | |
| CN115633039A (zh) | 通信建立方法、负载均衡装置、设备及存储介质 | |
| CN103248636A (zh) | 离线下载的系统及方法 | |
| CN108696549B (zh) | 负载均衡方法、装置和系统 | |
| CN115665173B (zh) | 一种基于MQ的WebSocket通信方法、系统和存储介质 | |
| EP2690560A2 (en) | Method of benchmarking the behaviour of a replacement information system with the old system | |
| CN116743836A (zh) | 长连接通信链路建立方法及其装置、电子设备及存储介质 | |
| CN111092952A (zh) | 一种数据交互方法及相关产品 | |
| CN111049751A (zh) | 数据传输优化方法、装置、设备及可读存储介质 |
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 |