CN102137104A - 一种传输控制协议tcp长连接接入控制方法和装置 - Google Patents
一种传输控制协议tcp长连接接入控制方法和装置 Download PDFInfo
- Publication number
- CN102137104A CN102137104A CN2011100591385A CN201110059138A CN102137104A CN 102137104 A CN102137104 A CN 102137104A CN 2011100591385 A CN2011100591385 A CN 2011100591385A CN 201110059138 A CN201110059138 A CN 201110059138A CN 102137104 A CN102137104 A CN 102137104A
- Authority
- CN
- China
- Prior art keywords
- tcp
- long
- connects
- network element
- connection
- 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.)
- Granted
Links
- 238000000034 method Methods 0.000 title claims abstract description 43
- 230000005540 biological transmission Effects 0.000 title claims description 15
- 230000004044 response Effects 0.000 claims abstract description 110
- 238000004891 communication Methods 0.000 claims description 7
- 230000002085 persistent effect Effects 0.000 abstract description 195
- 230000001360 synchronised effect Effects 0.000 abstract description 19
- 230000007774 longterm Effects 0.000 description 11
- 238000010586 diagram Methods 0.000 description 5
- 230000005856 abnormality Effects 0.000 description 2
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000004590 computer program Methods 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 230000026676 system process Effects 0.000 description 1
Images
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
- Telephonic Communication Services (AREA)
Abstract
本发明公开了一种TCP长连接接入控制方法,包括:中央控制节点接收长连接前置机发送的包括TCP长连接接入或断开的信息的同步通知消息,统计当前TCP长连接个数;接收长连接前置机发送的TCP长连接申请请求消息;判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机。本发明还提供相应的中央控制节点、长连接前置机和电信设备。本发明技术方案中由中央控制节点判断当前TCP长连接个数是否小于设定值,从而决定是否允许再接入TCP长连接的技术方案,能够精确统计并控制接入的TCP长连接的个数,以使电信设备可靠运行。
Description
技术领域
本发明涉及通信技术领域,具体涉及一种传输控制协议TCP长连接接入控制方法和装置。
背景技术
传输控制协议(Transmission Control Protocol,TCP)长连接是一种先建立通讯连接,连接建立后不断开,然后可以重复进行报文发送和接收的连接方式,常用于点对点通讯。
随着电信数据业务量的激增,承载数据业务的电信设备例如网关设备通常会接入外部客户建立的大量TCP长连接。一方面,电信设备需要尽量保障外部网元TCP长连接的建立,来满足数据业务的开展;另一方面,为了保障电信设备系统运行的可靠性,需要控制TCP长连接的总数。
请参考图1,一种现有的电信设备包括一个长连接前置机和一个后台处理系统,其中长连接前置机用于接入外部网元建立的TCP长连接,并对接入的TCP长连接个数进行控制,后台处理系统则对接入的TCP长连接的数据业务进行处理。该种电信设备由于只包括一个长连接前置机,可扩展性差,能够接入的TCP长连接的个数有限,最大只能接入65535个并发TCP长连接。
请参考图2,另一种电信设备在前一种电信设备的基础上,将长连接前置机从一个增加到了多个,并增加了负载均衡器,由负载均衡器按照分发策略将外部网元发送的TCP长连接请求消息分发到各个长连接前置机。该种电信设备作为包括多个长连接前置机的集群系统,提升了接入TCP长连接的能力;但是,由于各个长连接前置机相互独立,不能协同控制接入的TCP长连接。
发明内容
本发明实施例提供一种TCP长连接接入控制方法和装置。
一种传输控制协议TCP长连接接入控制方法,包括:
中央控制节点接收长连接前置机发送的同步通知消息,所述同步通知消息包括TCP长连接接入或断开的信息;
根据所述同步通知消息统计当前TCP长连接个数;
接收所述长连接前置机发送的TCP长连接申请请求消息;
判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接。
一种传输控制协议TCP长连接接入控制方法,包括:
长连接前置机收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点;
接收所述中央控制节点返回的申请应答消息;
若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;
若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;
在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数。
一种中央控制节点,包括:
接收单元,用于接收长连接前置机发送的同步通知消息和TCP长连接申请请求消息,所述同步通知消息包括TCP长连接接入或断开的信息;
统计单元,用于根据所述同步通知消息统计当前TCP长连接个数;
判断单元,用于判断当前TCP长连接个数是否小于设定值;
发送单元,用于在所述判断单元判断当前TCP长连接个数小于设定值时,返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接。
一种长连接前置机,包括:
第一接收发送单元,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点,并接收所述中央控制节点返回的申请应答消息;
长连接处理单元,用于若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;
第二接收发送单元,用于在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数。
一种电信设备,包括:负载均衡器,与所述负载均衡器连接的多个长连接前置机,与所述多个长连接前置机连接的中央控制节点,以及与所述多个长连接前置机连接的后台处理系统;
所述负载均衡器,用于按照分发策略将外部网元的TCP长连接分发到各个长连接前置机;
所述长连接前置机,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点;接收所述中央控制节点返回的申请应答消息;若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数;
所述中央控制节点,用于接收所述长连接前置机发送的同步通知消息,所述同步通知消息包括TCP长连接接入或断开的信息;根据所述同步通知消息统计当前TCP长连接个数;接收所述长连接前置机发送的TCP长连接申请请求消息;判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接;
所述后台处理系统,用于对已接入的TCP长连接的数据业务进行处理。
本发明实施例采用由增加的中央控制节点统计并判断当前TCP长连接个数是否小于设定值,从而决定是否允许长连接前置机再接入TCP长连接的技术方案,能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
附图说明
图1是现有技术的一种电信设备的结构示意图;
图2是现有技术的另一种电信设备的结构示意图;
图3是本发明一个实施例提供的TCP长连接接入控制方法的流程图;
图4是本发明另一个实施例提供的TCP长连接接入控制方法的流程图;
图5是本发明又一个实施例提供的TCP长连接接入控制方法的流程图;
图6是本发明的方法用于一个应用场景的流程图;
图7是本发明的方法用于另一个应用场景的流程图;
图8是本发明的方法用于又一个应用场景的流程图;
图9是本发明实施例提供的中央控制节点的结构示意图;
图10是本发明实施例提供的长连接前置机的结构示意图;
图11是本发明实施例提供的电信设备的结构示意图。
具体实施方式
本发明实施例提供一种TCP长连接接入控制方法,采用由增加的中央控制节点统计并判断当前TCP长连接个数是否小于设定值,从而决定是否允许长连接前置机再接入TCP长连接的技术方案,能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。本发明实施例还提供相应的中央控制节点、长连接前置机和电信设备。以下分别进行详细说明。
如图2所示,电信设备包括:负载均衡器,与负载均衡器连接的多个长连接前置机,以及与多个长连接前置机连接的后台处理系统。实施本发明实施例提供的方法,还需在现有的电信设备中增加一个与多个长连接前置机连接的中央控制节点,或者以电信设备中已有的某个单元作为中央控制节点。
其中,负载均衡器用于按照分发策略将外部网元发送的用于建立连接到电信设备的TCP长连接的TCP长连接请求消息分发到各个长连接前置机;长连接前置机用于接收负载均衡器分发的外部网元发送的TCP长连接请求消息,并接收外部网元发送的登录消息,按照中央控制节点的判断结果拒绝外部网元发送的登录消息或者接入外部网元建立的TCP长连接,返回表示登录成功或失败的应答消息给长连接前置机;后台处理系统用于对已建立的TCP长连接的数据业务进行处理;中央控制节点则用于精确控制接入的TCP长连接的个数。
请参考图3,本发明一个实施例提供的TCP长连接接入控制方法包括以下步骤:
101、中央控制节点接收长连接前置机发送的同步通知消息,该同步通知消息包括TCP长连接接入或断开的信息。
长连接前置机每接入或者断开一个与外部网元的TCP长连接时,都将发送一个同步通知消息给中央控制节点,以便将TCP长连接接入或断开的信息通知中央控制节点。该同步通知消息至少包括长连接接入同步通知消息和长连接断开同步通知消息。
102、根据同步通知消息统计当前TCP长连接个数。
中央控制节点可以根据收到的同步通知消息统计当前TCP长连接的总个数,还可以分类统计TCP长连接的个数,例如可以特别统计某一个或某一类外部网元的TCP长连接的个数。
103、接收长连接前置机发送的TCP长连接申请请求消息。
长连接前置机收到外部网元发送的TCP长连接请求消息后,等待该外部网元发送登录消息,在收到该外部网元发送的登录消息后,发送一个TCP长连接申请请求消息给中央控制节点,以便中央控制节点根据策略判断是否允许该外部网元登录以接入该外部网元的TCP长连接。
104、判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接。
中央控制节点可以通过比较当前TCP长连接个数与设定值的大小以决定是否允许该外部网元登录长连接前置机以接入该外部网元的TCP长连接。其中,设定值是预先设定的允许接入的TCP长连接总个数。当前TCP长连接个数小于设定值时,返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机。
本发明实施例提供的方法,采用中央控制节点统计当前TCP长连接个数并判断当前TCP长连接个数是否小于设定值,从而决定是否允许长连接前置机再接入TCP长连接,从而能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
请参考图4,在另一个实施例中,本发明实施例提供的TCP长连接接入控制方法可以包括以下步骤:
101′、控制节点接收长连接前置机发送的同步通知消息,该同步通知消息包括指定外部网元的TCP长连接接入或断开的信息。
102′、根据该同步通知消息统计指定外部网元的TCP长连接的个数;
103′、接收长连接前置机发送的对应于指定外部网元的TCP长连接申请请求消息;
104′、判断指定外部网元的当前TCP长连接个数是否小于针对该指定外部网元的设定值,若是则返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机。
采用本实施例的方法,可以精确控制来自某个或者某一类指定外部网元的TCP连接,从而提高电信设备的控制能力。
请参考图5,本发明又一个实施例提供的TCP长连接接入控制方法包括以下步骤:
201、长连接前置机收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点。
外部网元发起建立TCP长连接到电信设备的流程,电信设备的负载均衡器会按照分发策略将外部网元发送的TCP长连接请求消息分发到各个长连接前置机,长连接前置机收到TCP长连接请求消息后,等待外部网元发送登录消息。
长连接前置机收在收到该外部网元发送的登录消息后,发送一个TCP长连接申请请求消息给中央控制节点,以便中央控制节点根据当前接入的TCP长连接个数决定是否允许再接入该外部网元的TCP长连接。
202、接收中央控制节点返回的申请应答消息。
中央控制节点比较当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息,否则返回不允许接入的申请应答消息。
203、若申请应答消息为不允许接入的申请应答消息,则拒绝外部网元的登录消息。
即,不允许接入该外部网元的TCP长连接,并返回登录失败应答消息给外部网元。
204、若申请应答消息为允许接入的申请应答消息,则接入外部网元建立的TCP长连接。
若为允许接入的申请应答消息,则长连接前置机放通该外部网元的登录消息,从而接入外部网元建立的TCP长连接,并返回登录成功应答消息给外部网元。
205、在TCP长连接接入或者断开时,发送同步通知消息给中央控制节点,同步通知消息包括TCP长连接接入或断开的信息,用于供中央控制节点统计当前TCP长连接个数。
长连接前置机在接入TCP长连接并返回登录成功应答消息给外部网元后,需要发送包括TCP长连接接入信息的同步通知消息给中央控制节点;同样的,在TCP长连接断开时,例如任务结束断开或者因各种异常而断开时,需要发送包括TCP长连接断开信息的同步通知消息给中央控制节点;以便中央控制节点统计当前TCP长连接个数。
本发明实施例提供的方法,长连接前置机可以按照中央控制节点返回的申请应答消息,决定是否允许再接入TCP长连接,从而能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
另一个实施例中,若长连接前置机收到外部网元发送的登录消息后,发送TCP长连接申请请求消息失败,则接入外部网元建立的TCP长连接。
又一个实施例中,长连接前置机在发送TCP长连接申请请求消息给中央控制节点之后,若预设时间内未收到中央控制节点返回的申请应答消息,则接入外部网元建立的TCP长连接。
采用上述两个实施例,即便长连接前置机因异常未能成功发送出TCP长连接申请请求,或者中央控制节点因宕机或者其它原因不能返回申请应答消息,也不影响该外部网元的TCP长连接接入,保障该外部网元数据业务的畅通。
下面,结合具体的应用场景里对本发明实施例的方法做进一步说明。
请参考图6,在一个应用场景里中,电信设备包括:负载均衡器,与负载均衡器连接的多个长连接前置机,以及与多个长连接前置机连接的后台处理系统,还包括一个与多个长连接前置机连接的中央控制节点。该电信设备是一个包括多个长连接前置机的集群系统。本发明实施例的方法包括以下步骤:
301、外部网元发起TCP长连接建立流程,发送TCP长连接请求消息给负载均衡器,以便建立连接到电信设备的TCP长连接;
302、电信设备的负载均衡器按照分发策略,将收到的TCP长连接请求消息分发到各个长连接前置机;
303、长连接前置机接收分发的TCP长连接请求消息,等待外部网元发送登录消息;
304、外部网元给长连接前置机发送登录消息;
305、当长连接前置机收到外部网元发送的登录消息后,向中央控制节点发送长连接申请请求消息(LongConnectReq);
306、中央控制节点收到长连接前置机发送的长连接申请请求消息后,根据当前的TCP长连接个数是否小于电信设备许可的长连接总个数进行判断,决定是否允许接入该TCP长连接;
307、如果当前TCP长连接个数<许可的长连接总个数,返回允许接入的长连接申请应答消息(LongConnectResp);如果当前TCP长连接个数>=系统许可的长连接总个数,返回不允许接入的长连接申请应答消息;
308、长连接前置机根据收到的长连接申请应答消息,决定是否接入该外部网元的TCP长连接;在收到不允许接入的长连接申请应答消息时,拒绝外部网元的登录消息;在收到允许接入的长连接申请应答消息时,放通外部网元的登录消息以接入该TCP长连接;
309、长连接前置机在放通登录消息后,返回登录成功应答消息给外部网元;或者,在拒绝登录消息后,返回登录失败应答消息给外部网元;
310、长连接前置机在放通登录消息并返回登录成功应答消息给外部网元后,需要发送包括长连接接入信息的同步通知消息(LongConnectNotify)给中央控制节点;
311、中央控制节点收到同步通知消息后,建立对TCP长连接个数的统计,用于后续是否允许接入TCP长连接的许可判断。
本应用场景中,中央控制节点根据当前TCP长连接个数是否小于系统许可的长连接总个数,返回是否允许接入的申请应答消息给长连接前置机,长连接前置机可以按照返回的申请应答消息,决定是否允许再接入TCP长连接,从而能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
请参考图7,在另一个应用场景里中,网元设备可以是服务提供商(Service Provider,SP)设备,电信设备可以是SAG(Service Access Gateway)网关,SAG网关包括作为长连接前置机的业务接入(Service Access,SA)模块,作为中央控制节点的中央管理服务器(Central Management Server,CM Server),以及后台处理(Service Orchestration,SO)系统。其中,SP可以采用3.3或3.4版本消息转换(short message peer to peer 3.3/3.4,SMPP3.3/3.4)协议,消息发布电脑接口(Computer Interface to Message Distribution 2,CIMD2)协议,或外部机器接口(External Machine Interface,EMI)协议等长连接协议接入SAG网关。本发明实施例的方法包括以下步骤:
401、SP发送用于建立TCP长连接的TCP长连接请求消息给SAG;
402、SAG的负载均衡器按照分发策略将收到的TCP长连接请求消息分发到各个SA;
403、SA接收分发的TCP长连接请求消息,等待SP发送登录消息;
404、SP向SA发送smpp3.3/3.4bind_transmitter登录消息;
405、当SA收到SP发送的smpp3.3/3.4bind_transmitter登录消息后,向CMServer发送长连接申请请求消息LongConnectReq;
406、CMServer收到长连接申请请求消息LongConnectReq后,根据当前长连接个数是否小于SAG许可的长连接总个数进行判断,决定是否允许接入该TCP长连接;
407、如果当前TCP长连接个数<许可的长连接总个数,返回允许接入的长连接申请应答消息LongConnectResp;如果当前TCP长连接个数>=系统许可的长连接总个数,返回不允许接入的长连接申请应答消息LongConnectResp;
408、SA根据收到的连接申请应答消息LongConnectResp,拒绝SP的登录消息,或者放通SP的登录消息以接入该TCP长连接;
409、如果放通,在放通登录消息后,SA返回登录成功应答消息smpp3.3/3.4bind_transmitter_resp给SP;如果失败,在拒绝登录消息后,SA返回登录失败应答消息smpp3.3/3.4bind_transmitter_resp给SP;
410、在放通登录消息并返回登录成功应答消息给SP后,SA需要发送包括长连接接入信息的同步通知消息LongConnectNotify给CMServer;
411、CMServer收到通知消息,建立对TCP长连接个数的统计,用于后续是否允许接入TCP长连接的许可判断。
请参考图8,在又一个应用场景里中,网元设备可以是服务提供商(Service Provider,SP)设备,电信设备可以是SAG(Service Access Gateway)网关,SAG网关包括作为长连接前置机的服务提供商代理(Service Provider Agent,SPAgent),作为中央控制节点的控制管理中心(Control Management Center,CMCenter),以及作为后台处理系统的短消息服务器(Short Message Server,SMServer)。其中,SP可以采用3.0版本中国移动点对点协议(China Mobile Peer to Peer 3.0,CMPP3.0)等长连接协议接入SAG网关。本发明实施例的方法包括以下步骤:
501、SP发送用于建立TCP长连接的TCP长连接请求消息给SAG;
502、SAG的负载均衡器按照分发策略将收到的TCP长连接请求消息分发到各SPAgent;
503、SPAgent接收分发的TCP长连接请求消息,等待SP发送登录消息;
504、SP向SPAgent发送CMPP3.0CMPP_CONNECT登录消息;
505、当SPAgent收到SP发送的CMPP3.0CMPP_CONNECT登录消息后,向CMCenter发送长连接申请请求消息LongConnectReq;
506、CMCenter收到长连接申请请求消息LongConnectReq后,根据当前长连接个数是否小于SAG许可的长连接总个数进行判断,决定是否允许接入该TCP长连接;
507、如果当前TCP长连接个数<许可的长连接总个数,返回允许接入的长连接申请应答消息LongConnectResp;如果当前TCP长连接个数>=系统许可的长连接总个数,返回不允许接入的长连接申请应答消息LongConnectResp;
508、SPAgent根据收到的连接申请应答消息LongConnectResp,拒绝SP的登录消息,或者放通SP的登录消息以接入该TCP长连接;
509、如果放通,在放通登录消息后,SPAgent返回登录成功应答消息CMPP3.0CMPP_CONNECT_RESP给SP;如果失败,在拒绝登录消息后,SPAgent返回登录失败应答消息CMPP3.0CMPP_CONNECT_RESP给SP;
510、在放通登录消息并返回登录成功应答消息给SP后,SPAgent需要发送包括长连接接入信息的同步通知消息LongConnectNotify给CMCenter;
511、CMCenter收到通知消息,建立对该长连接个数的统计,用于后续是否允许接入TCP长连接的许可判断。
请参考图9,本发明实施例还提供一种中央控制节点,包括:
接收单元601,用于接收长连接前置机发送的同步通知消息和TCP长连接申请请求消息,该同步通知消息包括TCP长连接接入或断开的信息;
统计单元602,用于根据同步通知消息统计当前TCP长连接个数;
判断单元603,用于判断当前TCP长连接个数是否小于设定值;
发送单元604,用于处理单元判断当前TCP长连接个数小于设定值时,返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机,以控制长连接前置机是否接入TCP长连接。
在另一实施例中:
接收单元601,还用于接收长连接前置机发送的包括指定外部网元的TCP长连接接入或断开信息的同步通知消息,和对应于指定外部网元的TCP长连接申请请求消息;
统计单元602,还用于根据同步通知消息统计指定外部网元的TCP长连接的个数,该同步通知消息包括指定外部网元的TCP长连接接入或断开的信息;
判断单元603,还用于判断指定外部网元的当前TCP长连接个数是否小于针对该指定外部网元的设定值;
发送单元604,还用于在判断单元判断指定外部网元的当前TCP长连接个数小于针对该指定外部网元的设定值时,返回允许接入的申请应答消息给长连接前置机,否则返回不允许接入的申请应答消息给长连接前置机。
本发明实施例提供的中央控制节点,能够通过与长连接前置机的交互统计当前TCP长连接个数,并判断当前TCP长连接个数是否小于设定值,从而决定是否允许长连接前置机再接入TCP长连接,在电信设备中采用该中央控制节点能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
请参考图10,本发明实施例还提供一种长连接前置机,包括:
第一接收发送单元701,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点,并接收中央控制节点返回的申请应答消息;
长连接处理单元702,用于若申请应答消息为不允许接入的申请应答消息,则拒绝外部网元的登录消息;若申请应答消息为允许接入的申请应答消息,则接入外部网元建立的TCP长连接;
第二接收发送单元703,用于在TCP长连接接入或者断开时,发送同步通知消息给中央控制节点,同步通知消息包括TCP长连接接入或断开的信息,用于供中央控制节点统计当前TCP长连接个数。
在另一个实施例中,长连接处理单元702,还用于若第一接收发送单元701发送TCP长连接申请请求消息给中央控制节点之后,预设时间内未收到中央控制节点返回的申请应答消息,则接入外部网元建立的TCP长连接。
在又一个实施例中,长连接处理单元702,还用于若第一接收发送单元701收到外部网元发送的登录消息后,发送TCP长连接申请请求消息失败,则接入外部网元建立的TCP长连接。
本发明实施例提供的长连接前置机,能够通过与上述实施例提供的中央控制节点进行交互,在中央控制节点控制下决定是否再接入TCP长连接,在电信设备中采用该长连接前置机与中央控制节点配合,能够精确控制接入的TCP长连接的个数,以提高电信设备运行的可靠性。
请参考图11,本发明实施例提供一种通信设备,包括:负载均衡器800,与负载均衡器800连接的多个长连接前置机700,与多个长连接前置机700连接的中央控制节点600,以及多个长连接前置机700连接的后台处理系统900;
负载均衡器800,用于按照分发策略将外部网元的TCP长连接分发到各个长连接前置机700;
长连接前置机700,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点600;接收中央控制节点600返回的申请应答消息;若申请应答消息为不允许接入的申请应答消息,则拒绝外部网元的登录消息;若申请应答消息为允许接入的申请应答消息,则接入外部网元建立的TCP长连接;在TCP长连接接入或者断开时,发送同步通知消息给中央控制节点600,同步通知消息包括TCP长连接接入或断开的信息,用于供中央控制节点600统计当前TCP长连接个数;
中央控制节点600,用于接收长连接前置机700发送的同步通知消息,同步通知消息包括TCP长连接接入或断开的信息;根据同步通知消息统计当前TCP长连接个数;接收长连接前置机700发送的TCP长连接申请请求消息;判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给长连接前置机700,否则返回不允许接入的申请应答消息给长连接前置机700,以控制长连接前置机700是否接入TCP长连接;
后台处理系统900,用于对已接入的TCP长连接的数据业务进行处理。
本发明实施例提供的通信设备,可以由中央控制节点统计并判断当前TCP长连接个数是否小于设定值,以决定是否允许长连接前置机再接入TCP长连接,从而能够精确控制接入的TCP长连接的个数,提高电信设备运行的可靠性。
本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程,是可以通过计算机程序来指令相关的硬件来完成,所述的程序可存储于一计算机可读取存储介质中,所述程序在执行时,可包括如上述各方法的实施例的流程。其中,所述的存储介质可为磁碟、光盘、只读存储记忆体(Read-Only Memory,ROM)或随机存储记忆体(Random Access Memory,RAM)等。
上述各实施例中所述的中央控制节点,长连接前置机,通信设备等,可以是具有处理器,输入输出接口、存储器等部件的物理实体,当然可以结合软件实现各实施例提及的功能。
以上对本发明实施例所提供的传输控制协议TCP长连接接入控制方法及相应的中央控制节点、长连接前置机和电信设备进行了详细介绍,本文中应用了具体个例对本发明的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本发明的方法及其核心思想,不应理解为对本发明的限制。
Claims (11)
1.一种传输控制协议TCP长连接接入控制方法,其特征在于,包括:
中央控制节点接收长连接前置机发送的同步通知消息,所述同步通知消息包括TCP长连接接入或断开的信息;
根据所述同步通知消息统计当前TCP长连接个数;
接收所述长连接前置机发送的TCP长连接申请请求消息;
判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接。
2.根据权利要求1所述的方法,其特征在于,所述同步通知消息包括指定外部网元的TCP长连接接入或断开的信息;
所述接收长连接前置机发送的同步通知消息之后还包括:
根据所述同步通知消息统计指定外部网元的TCP长连接的个数;
接收所述长连接前置机发送的对应于所述指定外部网元的TCP长连接申请请求消息;
判断指定外部网元的当前TCP长连接个数是否小于针对该指定外部网元的设定值,若是则返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机。
3.一种传输控制协议TCP长连接接入控制方法,其特征在于,包括:
长连接前置机收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点;
接收所述中央控制节点返回的申请应答消息;
若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;
若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;
在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数。
4.根据权利要求3所述的方法,其特征在于,所述发送TCP长连接申请请求消息给中央控制节点之后还包括:
若预设时间内未收到所述中央控制节点返回的申请应答消息,则接入所述外部网元建立的TCP长连接。
5.根据权利要求3所述的方法,其特征在于,
若所述长连接前置机收到外部网元发送的登录消息后,发送TCP长连接申请请求消息失败,则接入所述外部网元建立的TCP长连接。
6.一种中央控制节点,其特征在于,包括:
接收单元,用于接收长连接前置机发送的同步通知消息和TCP长连接申请请求消息,所述同步通知消息包括TCP长连接接入或断开的信息;
统计单元,用于根据所述同步通知消息统计当前TCP长连接个数;
判断单元,用于判断当前TCP长连接个数是否小于设定值;
发送单元,用于在所述判断单元判断当前TCP长连接个数小于设定值时,返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接。
7.根据权利要求6所述的中央控制节点,其特征在于:
所述接收单元,还用于接收所述长连接前置机发送的包括指定外部网元的TCP长连接接入或断开信息的同步通知消息,和对应于所述指定外部网元的TCP长连接申请请求消息;
所述统计单元,还用于根据所述同步通知消息统计指定外部网元的TCP长连接的个数,所述同步通知消息包括指定外部网元的TCP长连接接入或断开的信息;
所述判断单元,还用于判断指定外部网元的当前TCP长连接个数是否小于针对该指定外部网元的设定值;
所述发送单元,还用于在所述判断单元判断指定外部网元的当前TCP长连接个数小于针对该指定外部网元的设定值时,返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机。
8.一种长连接前置机,其特征在于,包括:
第一接收发送单元,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点,并接收所述中央控制节点返回的申请应答消息;
长连接处理单元,用于若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;
第二接收发送单元,用于在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数。
9.根据权利要求8所述的长连接前置机,其特征在于:
所述长连接处理单元,还用于若所述第一接收发送单元发送TCP长连接申请请求消息给中央控制节点之后,预设时间内未收到所述中央控制节点返回的申请应答消息,则接入所述外部网元建立的TCP长连接。
10.根据权利要求8所述的长连接前置机,其特征在于:
所述长连接处理单元,还用于若所述第一接收发送单元收到外部网元发送的登录消息后,发送TCP长连接申请请求消息失败,则接入所述外部网元建立的TCP长连接。
11.一种通信设备,其特征在于,包括:负载均衡器,与所述负载均衡器连接的多个长连接前置机,与所述多个长连接前置机连接的中央控制节点,以及与所述多个长连接前置机连接的后台处理系统;
所述负载均衡器,用于按照分发策略将外部网元的TCP长连接分发到各个长连接前置机;
所述长连接前置机,用于收到外部网元发送的登录消息后,发送TCP长连接申请请求消息给中央控制节点;接收所述中央控制节点返回的申请应答消息;若所述申请应答消息为不允许接入的申请应答消息,则拒绝所述外部网元的登录消息;若所述申请应答消息为允许接入的申请应答消息,则接入所述外部网元建立的TCP长连接;在所述TCP长连接接入或者断开时,发送同步通知消息给所述中央控制节点,所述同步通知消息包括TCP长连接接入或断开的信息,用于供所述中央控制节点统计当前TCP长连接个数;
所述中央控制节点,用于接收所述长连接前置机发送的同步通知消息,所述同步通知消息包括TCP长连接接入或断开的信息;根据所述同步通知消息统计当前TCP长连接个数;接收所述长连接前置机发送的TCP长连接申请请求消息;判断当前TCP长连接个数是否小于设定值,若是则返回允许接入的申请应答消息给所述长连接前置机,否则返回不允许接入的申请应答消息给所述长连接前置机,以控制所述长连接前置机是否接入所述TCP长连接;
所述后台处理系统,用于对已接入的TCP长连接的数据业务进行处理。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201110059138.5A CN102137104B (zh) | 2011-03-11 | 2011-03-11 | 一种传输控制协议tcp长连接接入控制方法和装置 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201110059138.5A CN102137104B (zh) | 2011-03-11 | 2011-03-11 | 一种传输控制协议tcp长连接接入控制方法和装置 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN102137104A true CN102137104A (zh) | 2011-07-27 |
CN102137104B CN102137104B (zh) | 2014-09-17 |
Family
ID=44296759
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201110059138.5A Expired - Fee Related CN102137104B (zh) | 2011-03-11 | 2011-03-11 | 一种传输控制协议tcp长连接接入控制方法和装置 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN102137104B (zh) |
Cited By (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN103973469A (zh) * | 2013-01-30 | 2014-08-06 | 阿里巴巴集团控股有限公司 | Comet连接的维护方法及装置 |
WO2014179925A1 (zh) * | 2013-05-06 | 2014-11-13 | 华为技术有限公司 | 控制规则的处理方法及装置 |
CN107070752A (zh) * | 2017-04-25 | 2017-08-18 | 上海斐讯数据通信技术有限公司 | 一种长连接容量的测试方法及测试系统 |
CN108965424A (zh) * | 2018-07-10 | 2018-12-07 | 中国银行股份有限公司 | 一种业务处理方法和装置 |
WO2019206296A1 (zh) * | 2018-04-28 | 2019-10-31 | 北京京东尚科信息技术有限公司 | 用于网关服务器的故障处理方法和装置 |
CN111064636A (zh) * | 2019-12-12 | 2020-04-24 | 南方电网数字电网研究院有限公司 | 前置机连接的控制方法、装置、系统、计算机设备 |
CN114598689A (zh) * | 2022-03-08 | 2022-06-07 | 深圳市火火兔智慧科技有限公司 | Iot设备的交互方法、装置、计算机设备及存储介质 |
Citations (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1561061A (zh) * | 2004-02-27 | 2005-01-05 | Ut斯达康通讯有限公司 | 通过nat进行双向访问的方法 |
US20070204060A1 (en) * | 2005-05-20 | 2007-08-30 | Hidemitsu Higuchi | Network control apparatus and network control method |
CN101827020A (zh) * | 2010-03-03 | 2010-09-08 | 深圳市深信服电子科技有限公司 | 一种对已经建立的长连接不断开进行加速的方法及系统 |
CN101938309A (zh) * | 2010-09-15 | 2011-01-05 | 重庆邮电大学 | 一种基于网络编码的wdm网络专有分段保护方法 |
-
2011
- 2011-03-11 CN CN201110059138.5A patent/CN102137104B/zh not_active Expired - Fee Related
Patent Citations (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1561061A (zh) * | 2004-02-27 | 2005-01-05 | Ut斯达康通讯有限公司 | 通过nat进行双向访问的方法 |
US20070204060A1 (en) * | 2005-05-20 | 2007-08-30 | Hidemitsu Higuchi | Network control apparatus and network control method |
CN101827020A (zh) * | 2010-03-03 | 2010-09-08 | 深圳市深信服电子科技有限公司 | 一种对已经建立的长连接不断开进行加速的方法及系统 |
CN101938309A (zh) * | 2010-09-15 | 2011-01-05 | 重庆邮电大学 | 一种基于网络编码的wdm网络专有分段保护方法 |
Cited By (12)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN103973469A (zh) * | 2013-01-30 | 2014-08-06 | 阿里巴巴集团控股有限公司 | Comet连接的维护方法及装置 |
CN103973469B (zh) * | 2013-01-30 | 2017-09-15 | 阿里巴巴集团控股有限公司 | Comet连接的维护方法及装置 |
WO2014179925A1 (zh) * | 2013-05-06 | 2014-11-13 | 华为技术有限公司 | 控制规则的处理方法及装置 |
CN107070752A (zh) * | 2017-04-25 | 2017-08-18 | 上海斐讯数据通信技术有限公司 | 一种长连接容量的测试方法及测试系统 |
CN107070752B (zh) * | 2017-04-25 | 2020-07-24 | 深圳市世纪福科技有限公司 | 一种长连接容量的测试方法及测试系统 |
WO2019206296A1 (zh) * | 2018-04-28 | 2019-10-31 | 北京京东尚科信息技术有限公司 | 用于网关服务器的故障处理方法和装置 |
US11632424B2 (en) | 2018-04-28 | 2023-04-18 | Beijing Jingdong Shangke Information Technology Co., Ltd. | Fault handling method and device for gateway server |
CN108965424A (zh) * | 2018-07-10 | 2018-12-07 | 中国银行股份有限公司 | 一种业务处理方法和装置 |
CN108965424B (zh) * | 2018-07-10 | 2021-02-26 | 中国银行股份有限公司 | 一种业务处理方法和装置 |
CN111064636A (zh) * | 2019-12-12 | 2020-04-24 | 南方电网数字电网研究院有限公司 | 前置机连接的控制方法、装置、系统、计算机设备 |
CN111064636B (zh) * | 2019-12-12 | 2022-03-08 | 南方电网数字电网研究院有限公司 | 前置机连接的控制方法、装置、系统、计算机设备 |
CN114598689A (zh) * | 2022-03-08 | 2022-06-07 | 深圳市火火兔智慧科技有限公司 | Iot设备的交互方法、装置、计算机设备及存储介质 |
Also Published As
Publication number | Publication date |
---|---|
CN102137104B (zh) | 2014-09-17 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN102137104B (zh) | 一种传输控制协议tcp长连接接入控制方法和装置 | |
US20190261159A1 (en) | Network Slice Selection Policy Updating Method and Apparatus | |
CN103685461B (zh) | 一种集群管理装置、管理系统以及管理方法 | |
US10389801B2 (en) | Service request processing method, related apparatus, and system | |
US11233694B2 (en) | Method and device for processing communication path | |
CN107528891B (zh) | 一种基于WebSocket的自动集群方法及其系统 | |
WO2015154350A1 (zh) | 上网流量分享处理方法、装置及终端 | |
US11051078B2 (en) | Video distribution method and device | |
EP4070529A1 (en) | User plane function load control | |
WO2020119328A1 (zh) | 数据传输方法、装置、设备及存储介质 | |
US9370032B2 (en) | Service processing method and apparatus based on android system | |
CN103312593B (zh) | 一种消息分发系统及方法 | |
WO2014176990A1 (zh) | 节点分配方法、装置及系统 | |
CN109151082A (zh) | 一种多连接建立方法、装置和系统 | |
CN103546528B (zh) | 分布式消息推送方法及系统 | |
WO2023035925A1 (zh) | 一种业务处理方法、装置和系统 | |
CN105681122B (zh) | 用于电信设备监视的方法和系统 | |
EP2944073A2 (en) | Method and system for the handling of redundant long poll | |
WO2013159492A1 (zh) | 信息上报与下载的方法及系统 | |
CN110391991B (zh) | 一种流量控制的方法及相关装置 | |
CN108574615A (zh) | 一种基于多路径mptcp的内容传输方法、设备及系统 | |
KR20120128031A (ko) | 망 부하 감소를 위한 푸시 서비스 제공 시스템 및 방법 | |
KR102168177B1 (ko) | 네트워크 장치 및 이를 이용한 패킷 처리 방법 | |
JP2012156800A (ja) | サーバ装置およびその通信方法 | |
CN112040513A (zh) | 一种数据传输方法、数据传输装置及数据传输系统 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
C06 | Publication | ||
PB01 | Publication | ||
C10 | Entry into substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
C14 | Grant of patent or utility model | ||
GR01 | Patent grant | ||
CF01 | Termination of patent right due to non-payment of annual fee | ||
CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20140917 Termination date: 20200311 |