CN111726400A - 反向连接的方法、装置和服务端系统 - Google Patents
反向连接的方法、装置和服务端系统 Download PDFInfo
- Publication number
- CN111726400A CN111726400A CN202010514640.XA CN202010514640A CN111726400A CN 111726400 A CN111726400 A CN 111726400A CN 202010514640 A CN202010514640 A CN 202010514640A CN 111726400 A CN111726400 A CN 111726400A
- Authority
- CN
- China
- Prior art keywords
- gateway
- equipment
- target
- reverse proxy
- reverse
- 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.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 46
- 238000013507 mapping Methods 0.000 claims abstract description 20
- 230000004044 response Effects 0.000 claims description 33
- 238000004590 computer program Methods 0.000 claims description 10
- 238000004891 communication Methods 0.000 abstract description 16
- 238000010586 diagram Methods 0.000 description 12
- 230000006870 function Effects 0.000 description 8
- 230000003287 optical effect Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 238000012545 processing Methods 0.000 description 3
- 230000008901 benefit Effects 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 238000012546 transfer Methods 0.000 description 2
- 230000008859 change Effects 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000010276 construction Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 239000000835 fiber Substances 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000013519 translation Methods 0.000 description 1
Images
Classifications
-
- 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/14—Session management
-
- 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
-
- 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/50—Network services
- H04L67/56—Provisioning of proxy services
-
- 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/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
-
- 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/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明公开了反向连接的方法、装置和服务端系统，涉及计算机技术领域。该方法的一具体实施方式包括：根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。该实施方式能够通过长连接和重定向服务实现服务节点主动向网关内设备发送请求，且不用重新设计服务节点的通信方式，易于实现。
Description
技术领域
本发明涉及计算机技术领域，尤其涉及一种反向连接的方法、装置和服务端系统。
背景技术
在设备与设备管理服务器的通信方式中，不仅有设备主动向管理服务器发起请求，也有管理服务器主动向设备发起请求的情况存在，例如管理服务器主动向设备推送执行策略或一些工作时必须的信息。
当把管理服务器部署在网关外而设备部署在网关内部时，内部设备知道服务器的公网IP地址，可以发起主动访问，但是服务器不知道网关内设备的IP地址，或者说即使知道，这也是一个局域网内部的IP地址，服务器是无法访问到的，只能被动等待网关内设备主动访问自己。
如何实现服务器主动向网关内设备发送请求，这是目前急需解决的问题。
发明内容
有鉴于此，本发明实施例提供一种反向连接的方法、装置和服务端系统，能够通过长连接和重定向服务实现服务节点主动向网关内设备发送请求，且不用重新设计服务节点的通信方式，易于实现。
为实现上述目的，根据本发明实施例的一个方面，提供了一种反向连接的方法，包括：
根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
可选地，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，还包括：
利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；
建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
可选地，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
可选地，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，还包括：
将所述目标反向代理节点的IP地址发送至所述服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
可选地，利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，还包括：从所述请求信息中解析请求标识和所述服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，还包括：利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述服务节点标识，根据第二对应关系确定与所述服务节点标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
可选地，利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
根据本发明实施例的第二方面，提供一种反向连接的装置，包括：
重定向模块，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
反向代理模块，利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
可选地，所述反向代理模块还用于：在所述重定向模块根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
可选地，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
可选地，所述重定向模块还用于：根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，将所述目标反向代理节点的IP地址发送至所述服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
可选地，所述反向代理模块还用于：
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，从所述请求信息中解析请求标识和所述服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述服务节点标识，根据第二对应关系确定与所述服务节点标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
可选地，所述反向代理模块还用于：利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
根据本发明实施例的第三方面，提供一种服务端系统，包括：反向连接装置和服务节点；其中，
所述服务节点生成待发送至目标网关内设备的请求消息，并发送至所述反向连接装置，所述请求消息包括目标网关内设备的设备标识；
所述反向连接装置根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
可选地，所述反向连接装置还用于：根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
可选地，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
可选地，所述反向连接装置还用于：根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，将所述目标反向代理节点的IP地址发送至所述服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
可选地，所述反向连接装置还用于：
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，从所述请求信息中解析请求标识和所述服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述服务节点标识，根据第二对应关系确定与所述服务节点标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
可选地，所述反向代理装置还用于：利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
根据本发明实施例的第四方面，提供一种反向连接的电子设备，包括：
一个或多个处理器；
存储装置，用于存储一个或多个程序，
当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现本发明实施例第一方面提供的方法。
根据本发明实施例的第五方面，提供一种计算机可读介质，其上存储有计算机程序，所述程序被处理器执行时实现本发明实施例第一方面提供的方法。
上述发明中的一个实施例具有如下优点或有益效果：能够通过长连接和重定向服务实现服务节点主动向网关内设备发送请求，且不用重新设计服务节点的通信方式，易于实现。
上述的非惯用的可选方式所具有的进一步效果将在下文中结合具体实施方式加以说明。
附图说明
附图用于更好地理解本发明，不构成对本发明的不当限定。其中：
图1是本发明实施例的反向连接的方法的主要流程的示意图；
图2是本发明可选实施例的反向连接的方法的主要流程的示意图；
图3是本发明实施例的反向连接的装置的主要模块的示意图；
图4是本发明实施例可以应用于其中的示例性系统架构图；
图5是适于用来实现本发明实施例的终端设备或服务器的计算机系统的结构示意图。
具体实施方式
以下结合附图对本发明的示范性实施例做出说明，其中包括本发明实施例的各种细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识到，可以对这里描述的实施例做出各种改变和修改，而不会背离本发明的范围和精神。同样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。
根据本发明实施例的一个方面，提供了一种反向连接的方法。
图1是本发明实施例的反向连接的方法的主要流程的示意图，如图1所示，反向连接的方法包括：
步骤S101、根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
步骤S102、利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
网关(Gateway)又称网间连接器、协议转换器。网关在网络层以上实现网络互连，是复杂的网络互连设备，是一种充当转换重任的计算机系统或设备。使用在不同的通信协议、数据格式或语言，甚至体系结构完全不同的两种网络之间，网关是一个翻译器。网关对收到的信息要重新打包，以适应目的系统的需求。
NAT(Network Address Translation，网络地址转换)是指将收到的IP(InternetProtocol，网络之间互连的协议)数据包的源IP地址和目的IP地址进行修改后，再将数据包发送出去。NAT网关即实现了NAT功能的网关，通常部署在局域网和互联网的连接处。局域网内部(即网关内)的设备拥有局域网IP，这个IP只在局域网内部可以正常寻址。而NAT网关同时拥有局域网IP和互联网可寻址的公网IP。当局域网内部的设备想要访问互联网时，发送的IP数据包的源IP是自己在局域网内部的IP，而目的IP是要访问的互联网上的IP。当数据包发出后，NAT网关收到这个数据包，将源IP修改为NAT网关的互联网公网IP，并将数据包转发出去，这样这个数据包的应答包就会发送给自己的公网IP。当数据包的应答包返回时，NAT网关再将应答包的目的IP修改为局域网中真实发送设备的IP地址，并将应答包转发到局域网中。NAT网关可以实现局域网内部的多个设备通过一个互联网公网IP访问互联网服务，同时又可以实现对局域网内设备的保护，但是互联网上的服务节点无法直接访问局域网里的设备。
如果在NAT网关上配置转发规则，让服务节点可以主动访问NAT网关内部的设备，这种暴露访问内部地址的方式会增加网络的风险。若网关内设备通过轮询方式定期访问服务节点已查询服务节点是否有待发送至网关内设备的信息，如果时间间隔过小，网关内设备会频繁访问服务节点，以服务节点部署在云端为例，云端服务节点通常是多租户设计，每个租户又会管理多台设备，如此会导致访问数据量会成指数倍上升，占据带宽，增加流量使用费用。而如果时间间隔过大，信息的实时性又无法得到保证，例如时间间隔为10分钟，新增加的策略有可能在10分钟后网关内设备才主动发起请求进行获取并执行，实时性差。
设备标识是指网关内设备的唯一标识，用于唯一代表一个网关内设备。重定向节点和反向代理节点是部署在网关外的节点。本申请在步骤S101和S102中，先通过重定向操作确定与目标网关内设备保持长连接的反向代理节点，然后在步骤S103中采用反向代理的方式，通过该反向代理节点将服务节点拟转发至目标网关内设备的请求消息转发至目标网关内设备，能够通过长连接和重定向服务实现服务节点主动向网关内设备发送请求，避免上述各种不足之处，且不用重新设计服务节点的通信方式，易于实现。
第一对应关系可以是人为设定并预先保存的，也可以是在网关内设备向反向代理节点注册之后确定的。例如，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，利用至少一个反向代理节点接收各个网关内设备发送的注册请求，注册请求包括网关内设备的设备标识；建立网关内设备和接收网关内设备的注册请求的反向代理节点之间的长连接，并保存网关内设备的设备标识和接收网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。一个反向代理节点可以仅与一个网关内设备保存长连接。为了实现高可用和负载均衡，每个网关内设备与一个反向代理保持长连接，反向代理包括多个反向代理节点，通过部署多个反向代理节点的实例将访问服务节点的请求负载均衡到其中一个反向代理节点上。这样，只要不是所有反向代理节点都发生异常，保持连接的功能就一直是可用的。当网关内设备发现与某个反向代理节点之间的长连接不可用时可以发起重注册，然后更新第一对应关系。
实际应用过程中，在根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，可以直接将服务节点的请求消息转发至目标反向代理节点。在可选的实施例中，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，还包括：将目标反向代理节点的IP地址发送至服务节点，以使服务节点根据目标反向代理节点的IP地址向目标反向代理节点发送该请求消息。如此，能够降低重定向操作的复杂度，便于开发。
利用目标反向代理节点，将请求消息转发至目标网关内设备之前，还可以包括：从请求信息中解析请求标识和服务节点的服务节点标识，保存请求标识和服务节点标识之间的第二对应关系。利用目标反向代理节点，将请求消息转发至目标网关内设备之后，还包括：利用反向代理节点接收网关内设备发送的应答消息，从应答消息中解析服务节点标识，根据第二对应关系确定与该服务节点标识对应的目标服务节点，将应答消息转发至目标服务节点。
请求标识是指请求消息的唯一标识，用于唯一代表一个请求消息。服务节点标识是指服务节点的唯一标识，用于唯一代表一个服务节点。请求标识的内容请求消息和对应的应答消息中保持不变，以便服务节点或客户端将请求和应答关联起来。通过保存各个请求消息的请求标识和发生该请求消息的服务节点的服务节点标识之间的第二对应关系，能够在接收到网关内设备的应答消息之后快速确定与之对应的服务节点，进而将应答消息转发至该对应的服务节点。
可选地，利用反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。示例性地，网关内设备定期向与其保持长连接的反向代理节点发送心跳包，以保持该长连接，若连接中断则尝试重连。通过发送心跳包能够在连接中断时及时发现并重连，避免由于网关内设备与对应反向代理节点之间的长连接中断而导致服务节点无法向该网关内设备主动发生请求消息的情况发生。
图2是本发明可选实施例的反向连接的方法的主要流程的示意图。本实施例中，服务节点部署在云上。在云端部署Socket-server(反向代理节点)，Socket-server(例如，图2中的Socket-server-1或Socket-server-2)主要负责维持与网关内设备(例如，图2中的设备-A、设备-B或设备-C)和云上服务节点(例如，图2中的Server-1、Server-2或Server-3)的连接，在中间进行数据包的转发。为了实现高可用和负载均衡，部署多个Socket-server实例(反向代理节点)，将来自公网IP的请求负载均衡到其中一个Socket-server上。NAT网关内的设备(例如，图2中的设备-A、设备-B或设备-C)主动向Socket-server进行注册，注册内容为其设备标识(deviceID)。Socket-server接收到设备的注册请求后，将deviceID和Socket-server实例的IP的第一对应关系保存，并维持与设备之间的长连接。NAT网关内的设备定期向Socket-server发送心跳包以保持长链接，若连接中断则尝试重连。
云上服务节点需要向NAT网关内的设备发送请求消息时，先将请求消息发送到云端的redirect-server(重定向节点，例如，图2中的redirect-server-1或redirect-server-2)，redirect-server从请求消息中获取到deviceID，根据deviceID查询已保存的deviceID和Socket-server实例的IP的第一对应关系，从而获取到与目标网关内设备(例如，图2中的设备-A、设备-B或设备-C)保持长连接的目标Socket-server的IP地址。redirect-server向云上服务节点返回HTTP 307(HTTP的英文全称为HyperText TransferProtocol，中文含义为超文本传输协议。在HTTP协议中，307是表示重定向的响应状态码)重定向应答报文，让云上服务节点向保持与目标网关内设备长连接的目标Socket-server实例发送这个请求消息。如果只有一个Socket-server实例，云上服务节点可以直接向Socket-server发送请求消息，如果有多个Socket-server实例，云上服务节点不知道自己想通信的目标网关内设备和哪一个Socket-server保持连接，所以需要通过redirect-server进行重定向。重定向时使用HTTP重定向协议，对于云上服务节点来说不需要额外修改程序增加查询Socket-server地址的操作，易于实现和扩展。
Socket-server收到云上服务节点发来的请求消息，获取请求消息的HTTP header(消息头)中的X-Request-ID(请求标识，例如其为云上服务节点为此次HTTP连接创建的随机ID)，保存X-Request-ID和云上服务节点的服务节点标识之间的第二对应关系，再将请求消息通过负载均衡与NAT网关之间的长连接转发给NAT网关内的设备。因为服务器往往有多个服务节点，需要根据应答报文中的X-Request-ID确定要将该应答报文转发给哪个云上服务节点。
网关内设备将应答报文通过长连接返回至与其保持长连接的Socket-server，Socket-server接收到应答报文后，通过HTTP header中的X-Request-ID，找到对应的和云上服务节点之间的连接，并将返回的应答报文转发给云上服务节点。
本实施例中，需要主动连接NAT网关内部设备的服务节点在上云之后，不用重新设计通信方式，即可将原来被动接收请求的通信方式改为交互式的通信方式，实现了云上服务节点主动向位于NAT网关内部的设备发送请求。采用本发明实施例的方法，NAT网关内部的服务器可以实现无缝上云，NAT网关内部的服务器在NAT网关内部是向设备发起请求，在上云之后是向redirect-server发起请求，除了目的地址发生改变之外不需要其它的改动。由于部署多个Socket-server实例，能够实现云上服务器系统的高可用。
根据本发明实施例的第二方面，提供一种实现上述方法的装置。
图3是本发明实施例的反向连接的装置的主要模块的示意图，如图3所示，反向连接的装置300包括：
重定向模块301，在根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
反向代理模块302，利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
可选地，所述反向代理模块还用于：在所述重定向模块根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
可选地，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
可选地，所述重定向模块还用于：在根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，将所述目标反向代理节点的IP地址发送至所述服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
可选地，所述反向代理模块还用于：
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，从所述请求信息中解析请求标识和所述服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述服务节点标识，根据第二对应关系确定与所述服务节点标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
可选地，所述反向代理模块还用于：利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
根据本发明实施例的第三方面，提供一种服务端系统，包括：反向连接装置和服务节点；其中，
所述服务节点生成待发送至目标网关内设备的请求消息，并发送至所述反向连接装置，所述请求消息包括目标网关内设备的设备标识；
所述反向连接装置根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
可选地，所述反向连接装置还用于：在根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
可选地，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
可选地，所述反向连接装置还用于：在根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，将所述目标反向代理节点的IP地址发送至所述服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
可选地，所述反向连接装置还用于：
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，从所述请求信息中解析请求标识和所述服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述服务节点标识，根据第二对应关系确定与所述服务节点标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
可选地，所述反向代理装置还用于：利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
根据本发明实施例的第四方面，提供一种反向连接的电子设备，包括：
一个或多个处理器；
存储装置，用于存储一个或多个程序，
当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现本发明实施例第一方面提供的方法。
根据本发明实施例的第五方面，提供一种计算机可读介质，其上存储有计算机程序，所述程序被处理器执行时实现本发明实施例第一方面提供的方法。
图4示出了可以应用本发明实施例的反向连接的方法或反向连接的装置的示例性系统架构400。
如图4所示，系统架构400可以包括终端设备401、402、403，网关404和服务器405。
用户可以使用终端设备401、402、403通过网关404与服务器405交互，以接收或发送消息等。终端设备401、402、403上可以安装有各种通讯客户端应用，例如购物类应用、网页浏览器应用、搜索类应用、即时通信工具、邮箱客户端、社交平台软件等(仅为示例)。
终端设备401、402、403可以是具有显示屏并且支持网页浏览的各种电子设备，包括但不限于智能手机、平板电脑、膝上型便携计算机和台式计算机等等。
服务器405可以是提供各种服务的服务器，例如对用户利用终端设备401、402、403所浏览的购物类网站提供支持的后台管理服务器(仅为示例)。后台管理服务器可以主动向终端设备推送执行策略或一些工作时必须的信息。
需要说明的是，本发明实施例所提供的反向连接的方法一般由服务器405执行，相应地，反向连接的装置一般设置于服务器405中。
应该理解，图4中的终端设备、网络和服务器的数目仅仅是示意性的。根据实现需要，可以具有任意数目的终端设备、网络和服务器。
下面参考图5，其示出了适于用来实现本发明实施例的终端设备的计算机系统500的结构示意图。图5示出的终端设备仅仅是一个示例，不应对本发明实施例的功能和使用范围带来任何限制。
如图5所示，计算机系统500包括中央处理单元(CPU)501，其可以根据存储在只读存储器(ROM)502中的程序或者从存储部分508加载到随机访问存储器(RAM)503中的程序而执行各种适当的动作和处理。在RAM 503中，还存储有系统500操作所需的各种程序和数据。CPU 501、ROM 502以及RAM 503通过总线504彼此相连。输入/输出(I/O)接口505也连接至总线504。
以下部件连接至I/O接口505：包括键盘、鼠标等的输入部分506；包括诸如阴极射线管(CRT)、液晶显示器(LCD)等以及扬声器等的输出部分507；包括硬盘等的存储部分508；以及包括诸如LAN卡、调制解调器等的网络接口卡的通信部分509。通信部分509经由诸如因特网的网络执行通信处理。驱动器510也根据需要连接至I/O接口505。可拆卸介质511，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器510上，以便于从其上读出的计算机程序根据需要被安装入存储部分508。
特别地，根据本发明公开的实施例，上文参考流程图描述的过程可以被实现为计算机软件程序。例如，本发明公开的实施例包括一种计算机程序产品，其包括承载在计算机可读介质上的计算机程序，该计算机程序包含用于执行流程图所示的方法的程序代码。在这样的实施例中，该计算机程序可以通过通信部分509从网络上被下载和安装，和/或从可拆卸介质511被安装。在该计算机程序被中央处理单元(CPU)501执行时，执行本发明的系统中限定的上述功能。
需要说明的是，本发明所示的计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质或者是上述两者的任意组合。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储介质的更具体的例子可以包括但不限于：具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机访问存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本发明中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。而在本发明中，计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括但不限于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括但不限于：无线、电线、光缆、RF等等，或者上述的任意合适的组合。
附图中的流程图和框图，图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图或流程图中的每个方框、以及框图或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。
描述于本发明实施例中所涉及到的模块可以通过软件的方式实现，也可以通过硬件的方式来实现。所描述的模块也可以设置在处理器中，例如，可以描述为：一种处理器包括：重定向模块和反向代理模块。其中，这些模块的名称在某种情况下并不构成对该模块本身的限定，例如，重定向模块还可以被描述为“将所述请求消息转发至所述目标网关内设备的模块”。
作为另一方面，本发明还提供了一种计算机可读介质，该计算机可读介质可以是上述实施例中描述的设备中所包含的；也可以是单独存在，而未装配入该设备中。上述计算机可读介质承载有一个或者多个程序，当上述一个或者多个程序被一个该设备执行时，使得该设备包括：根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
根据本发明实施例的技术方案，能够通过长连接和重定向服务实现服务节点主动向网关内设备发送请求，且不用重新设计服务节点的通信方式，易于实现。
上述具体实施方式，并不构成对本发明保护范围的限制。本领域技术人员应该明白的是，取决于设计要求和其他因素，可以发生各种各样的修改、组合、子组合和替代。任何在本发明的精神和原则之内所作的修改、等同替换和改进等，均应包含在本发明保护范围之内。
Claims (10)
1.一种反向连接的方法，其特征在于，包括：
根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
2.如权利要求1所述的方法，其特征在于，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之前，还包括：
利用至少一个反向代理节点接收各个网关内设备发送的注册请求，所述注册请求包括所述网关内设备的设备标识；
建立所述网关内设备和接收所述网关内设备的注册请求的反向代理节点之间的长连接，并保存所述网关内设备的设备标识和接收所述网关内设备的注册请求的反向代理节点的IP地址之间的映射关系，得到第一对应关系。
3.如权利要求1或2所述的方法，其特征在于，每个网关内设备与一个反向代理保持长连接，所述反向代理包括多个反向代理节点。
4.如权利要求1所述的方法，其特征在于，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点之后，还包括：
将所述目标反向代理节点的IP地址发送至服务节点，以使所述服务节点根据所述目标反向代理节点的IP地址向所述目标反向代理节点发送所述请求消息。
5.如权利要求1所述的方法，其特征在于，利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之前，还包括：从所述请求信息中解析请求标识和服务节点的服务节点标识，保存所述请求标识和所述服务节点标识之间的第二对应关系；
利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备之后，还包括：利用所述反向代理节点接收所述网关内设备发送的应答消息，从所述应答消息中解析所述请求标识，根据第二对应关系确定与所述请求标识对应的目标服务节点，将所述应答消息转发至所述目标服务节点。
6.如权利要求1所述的方法，其特征在于，利用所述反向代理节点接收与其保持长连接的网关内设备定期发送的心跳包，以保持与对应的网关内设备之间的长连接。
7.一种反向连接的装置，其特征在于，包括：
重定向模块，根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点，所述请求消息包括目标网关内设备的设备标识；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；
反向代理模块，利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
8.一种服务端系统，其特征在于，包括：反向连接装置和服务节点；其中，
所述服务节点生成待发送至目标网关内设备的请求消息，并发送至所述反向连接装置，所述请求消息包括目标网关内设备的设备标识；
所述反向连接装置根据缓存的第一对应关系确定待发送至目标网关内设备的请求消息对应的目标反向代理节点；第一对应关系为每个网关内设备的设备标识和与所述网关内设备保持长连接的反向代理节点之间的映射关系；利用所述目标反向代理节点，将所述请求消息转发至所述目标网关内设备。
9.一种反向连接的电子设备，其特征在于，包括：
一个或多个处理器；
存储装置，用于存储一个或多个程序，
当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求1-6中任一所述的方法。
10.一种计算机可读介质，其上存储有计算机程序，其特征在于，所述程序被处理器执行时实现如权利要求1-6中任一所述的方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010514640.XA CN111726400A (zh) | 2020-06-08 | 2020-06-08 | 反向连接的方法、装置和服务端系统 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010514640.XA CN111726400A (zh) | 2020-06-08 | 2020-06-08 | 反向连接的方法、装置和服务端系统 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111726400A true CN111726400A (zh) | 2020-09-29 |
Family
ID=72567328
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010514640.XA Pending CN111726400A (zh) | 2020-06-08 | 2020-06-08 | 反向连接的方法、装置和服务端系统 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111726400A (zh) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113271260A (zh) * | 2021-05-12 | 2021-08-17 | 康键信息技术（深圳）有限公司 | 负载均衡处理方法、装置、设备及存储介质 |
| CN114143315A (zh) * | 2021-11-30 | 2022-03-04 | 阿里巴巴（中国）有限公司 | 边缘云系统、主机访问方法及设备 |
| CN115225715A (zh) * | 2022-06-30 | 2022-10-21 | 深圳市云洲创新科技有限公司 | 一种数据交互方法及数据交互系统 |
| CN118018604A (zh) * | 2024-04-09 | 2024-05-10 | 创意信息技术股份有限公司 | 一种云边一体化的反向代理方法及装置 |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104168302A (zh) * | 2013-05-20 | 2014-11-26 | 中国电信股份有限公司 | 设备操控实现方法、系统和代理网关 |
| CN104980528A (zh) * | 2015-06-26 | 2015-10-14 | 广州华多网络科技有限公司 | 实现节点间通信的方法、系统及装置 |
| CN108600204A (zh) * | 2018-04-11 | 2018-09-28 | 浙江大学 | 一种基于反向连接和应用层隧道的企业内网访问方法 |
| CN109729115A (zh) * | 2017-10-30 | 2019-05-07 | 北京临风云科技有限公司 | 实现分布式计算的方法、装置、代理服务器、终端设备 |
-
2020
- 2020-06-08 CN CN202010514640.XA patent/CN111726400A/zh active Pending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104168302A (zh) * | 2013-05-20 | 2014-11-26 | 中国电信股份有限公司 | 设备操控实现方法、系统和代理网关 |
| CN104980528A (zh) * | 2015-06-26 | 2015-10-14 | 广州华多网络科技有限公司 | 实现节点间通信的方法、系统及装置 |
| CN109729115A (zh) * | 2017-10-30 | 2019-05-07 | 北京临风云科技有限公司 | 实现分布式计算的方法、装置、代理服务器、终端设备 |
| CN108600204A (zh) * | 2018-04-11 | 2018-09-28 | 浙江大学 | 一种基于反向连接和应用层隧道的企业内网访问方法 |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113271260A (zh) * | 2021-05-12 | 2021-08-17 | 康键信息技术（深圳）有限公司 | 负载均衡处理方法、装置、设备及存储介质 |
| CN114143315A (zh) * | 2021-11-30 | 2022-03-04 | 阿里巴巴（中国）有限公司 | 边缘云系统、主机访问方法及设备 |
| CN115225715A (zh) * | 2022-06-30 | 2022-10-21 | 深圳市云洲创新科技有限公司 | 一种数据交互方法及数据交互系统 |
| CN115225715B (zh) * | 2022-06-30 | 2024-01-26 | 深圳市云洲创新科技有限公司 | 一种数据交互方法及数据交互系统 |
| CN118018604A (zh) * | 2024-04-09 | 2024-05-10 | 创意信息技术股份有限公司 | 一种云边一体化的反向代理方法及装置 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11431673B2 (en) | Method, apparatus, and system for selecting MEC node | |
| EP3886404B1 (en) | Domain name server allocation method and device | |
| CN109889621B (zh) | 虚拟私有云服务的配置方法和装置 | |
| CN111726400A (zh) | 反向连接的方法、装置和服务端系统 | |
| CN109729040B (zh) | 协议的选择的方法、设备以及计算机可读介质 | |
| KR20000057718A (ko) | 자각-개시 푸시를 제공하기 위한 방법 및 장치 | |
| KR20080026161A (ko) | 원격 네트워크 액세스를 위한 통일된 아키텍쳐 | |
| US8935377B2 (en) | Dynamic registration of listener resources for cloud services | |
| CN114398176A (zh) | 服务访问方法、装置、电子设备及存储介质 | |
| CN112104640B (zh) | 网关的数据处理方法、装置、设备及可读存储介质 | |
| CN112003945A (zh) | 服务请求响应方法及装置 | |
| CN113364741A (zh) | 一种应用访问方法及代理服务器 | |
| CN115883655A (zh) | 服务请求处理方法、装置、电子设备及存储介质 | |
| CN112968965A (zh) | Nfv网络节点的元数据服务方法、服务器及存储介质 | |
| US10243920B1 (en) | Internet protocol address reassignment between virtual machine instances | |
| CN107222365B (zh) | 数据处理方法、装置及服务器 | |
| CN113079098B (zh) | 路由更新的方法、装置、设备和计算机可读介质 | |
| CN107872538B (zh) | 解耦tcp长连接的业务处理方法、反向代理和业务服务器 | |
| CN116633993A (zh) | 跨网络调用微服务方法、装置、设备及存储介质 | |
| CN112055083B (zh) | 请求处理方法、装置、电子设备和介质 | |
| CN109600452B (zh) | 服务器集群、消息推送方法及相关服务器 | |
| US9634987B2 (en) | Obtaining a MAC address from an external source | |
| CN114466011A (zh) | 一种元数据服务请求方法、装置、设备及介质 | |
| CN115516842A (zh) | 编排代理服务 | |
| CN113824808A (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 | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20200929 |