CN106936701A - A kind of cloud gateway, cloud connection system and the method using cloud gateway communication - Google Patents
A kind of cloud gateway, cloud connection system and the method using cloud gateway communication Download PDFInfo
- Publication number
- CN106936701A CN106936701A CN201511007794.5A CN201511007794A CN106936701A CN 106936701 A CN106936701 A CN 106936701A CN 201511007794 A CN201511007794 A CN 201511007794A CN 106936701 A CN106936701 A CN 106936701A
- Authority
- CN
- China
- Prior art keywords
- cloud
- session
- information
- account
- session information
- 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
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/66—Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
-
- 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
- H04L67/1004—Server selection for load balancing
- H04L67/1008—Server selection for load balancing based on parameters of servers, e.g. available memory or workload
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/08—Protocols for interworking; Protocol conversion
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Computer Hardware Design (AREA)
- General Engineering & Computer Science (AREA)
- Computer And Data Communications (AREA)
Abstract
本发明提供一种云网关及利用云网关通信的方法,包括:账号映射单元,其配置为记录用户在不同云中的账号信息及其映射关系;多个业务会话处理单元,每个所述业务会话处理单元转换收到的会话信息;接入门户单元,分配进入所述云网关的第一云的会话信息到一个所述业务会话处理单元中,并把所述业务会话处理单元转换后的会话信息发送到第二云中;其中,收到会话信息的所述业务会话处理单元从所述账号映射单元取得会话信息发送方和接收方在第一云和第二云的账号信息的映射关系;并把会话信息中发送方和接收方的账号信息转换成发送方和接收方在第二云的账号信息、把会话信息转换成适应第二云协议的会话信息。采用一个独立于不同云的云网关,对云网关进行任何配置,均不影响两侧的云系统,避免了不同厂家为实现互联互通而对云做的修改。
The present invention provides a cloud gateway and a communication method using the cloud gateway, including: an account mapping unit configured to record user account information in different clouds and its mapping relationship; multiple business session processing units, each of the business The session processing unit converts the received session information; the access portal unit assigns the session information of the first cloud entering the cloud gateway to one of the business session processing units, and converts the session information converted by the business session processing unit The information is sent to the second cloud; wherein, the business session processing unit that receives the session information obtains the mapping relationship between the account information of the session information sender and the receiver in the first cloud and the second cloud from the account mapping unit; And the account information of the sender and the receiver in the session information is converted into the account information of the sender and the receiver in the second cloud, and the session information is converted into session information adapted to the second cloud protocol. Using a cloud gateway independent of different clouds, any configuration of the cloud gateway will not affect the cloud systems on both sides, avoiding the modification of the cloud by different manufacturers to achieve interconnection.
Description
技术领域technical field
本发明涉及一种云网关、云连接系统及利用云网关通信的方法。The invention relates to a cloud gateway, a cloud connection system and a communication method using the cloud gateway.
背景技术Background technique
随着物联网、云计算技术的飞速发展,智能产品伴随着智能云如雨后春笋般出现了,智能云可以提供可用的、便捷的、按需的网络访问,云中可配置包括网络,服务器,存储,应用软件,服务的资源共享池。由于缺乏统一的技术标准,业界的智能控制协议的不统一,各厂商在开发各自产品和服务的过程中各自为政,各厂家的智能产品一般只能直接连接自己的智能云,而这种云又称私有云,云基础设施是被一个厂家拥有并由该厂家管理,一般而言,一个厂家的私有云并不能和其他厂家的私有云进行互通,局限性很大。这样对于用户来说,买了哪家的智能产品,就只能用该厂家的APP应用接入其私有云而不能接入其它厂商的私有云,智能产品应用很受限制,因此急需解决不同厂家智能云之间互联互通的问题。With the rapid development of the Internet of Things and cloud computing technology, smart products have sprung up along with the smart cloud. The smart cloud can provide available, convenient, and on-demand network access. The cloud can be configured including network, server, storage, Application software, service resource sharing pool. Due to the lack of unified technical standards and the inconsistency of intelligent control protocols in the industry, each manufacturer works independently in the process of developing their own products and services. Generally, the intelligent products of each manufacturer can only be directly connected to their own intelligent cloud, and this cloud is also called In private cloud, the cloud infrastructure is owned and managed by a manufacturer. Generally speaking, a private cloud of a manufacturer cannot communicate with private clouds of other manufacturers, which has great limitations. In this way, for users, no matter which smart product they buy, they can only use the manufacturer's APP to access its private cloud and cannot access other manufacturers' private clouds. The application of smart products is very limited, so it is urgent to solve the problem of different manufacturers. Interconnection between intelligent clouds.
发明内容Contents of the invention
针对上述技术问题, 本发明提供了一种云网关、云连接系统及利用云网关进行通信的方法。In view of the above technical problems, the present invention provides a cloud gateway, a cloud connection system and a communication method using the cloud gateway.
本发明提供了一种云网关包括:多个业务会话处理单元,每个业务会话处理单元转换收到的会话信息;接入门户单元,分配进入所述云网关的第一云的会话信息到一个所述业务会话处理单元中,并把所述业务会话处理单元转换后的会话信息发送到第二云中;账号映射单元,其配置为记录用户在不同云中的账号信息及其映射关系;其中,收到会话信息的所述业务会话处理单元从所述账号映射单元取得会话信息发送方和接收方在第一云和第二云的账号信息的映射关系;并把会话信息中发送方和接收方的账号信息转换成发送方和接收方在第二云的账号信息、把会话信息转换成适应第二云协议的会话信息。The present invention provides a cloud gateway comprising: a plurality of business session processing units, each of which converts the received session information; an access portal unit, which distributes the session information of the first cloud entering the cloud gateway to a In the business session processing unit, the session information converted by the business session processing unit is sent to the second cloud; the account mapping unit is configured to record the account information and the mapping relationship of the user in different clouds; wherein The business session processing unit that receives the session information obtains the mapping relationship between the account information of the session information sender and the receiver in the first cloud and the second cloud from the account mapping unit; and puts the session information in the sender and receiver The account information of the party is converted into the account information of the sender and the receiver in the second cloud, and the session information is converted into session information adapted to the second cloud protocol.
优选地,所述接入门户单元包括 负载均衡转发器,其查询所述业务会话处理单元的负载状态,分配进入云网关的会话信息到负载较轻的所述业务会话处理单元中。Preferably, the access portal unit includes a load balancing forwarder, which queries the load status of the service session processing unit, and distributes session information entering the cloud gateway to the service session processing unit with a lighter load.
优选地,接入门户单元还包括业务选择转发器,其根据所述业务会话处理单元转换后的会话信息选择对应的连接云网关的第二云,并把转换后的会话信息发送到第二云。Preferably, the access portal unit further includes a service selection transponder, which selects the corresponding second cloud connected to the cloud gateway according to the session information converted by the service session processing unit, and sends the converted session information to the second cloud .
优选地,账号映射单元中用户在不同云的账号信息的映射关系为一一对应关系或一对多对应关系。Preferably, the mapping relationship of user account information in different clouds in the account mapping unit is a one-to-one correspondence or a one-to-many correspondence.
优选地,会话数据库单元,用于存储所述业务会话处理单元生成的会话记录。Preferably, the session database unit is configured to store the session records generated by the business session processing unit.
优选地,收到会话信息的所述业务会话处理单元根据会话信息的内容创建一个新的会话记录并保存到所述会话数据库单元中或从所述会话数据库单元读取已有的会话记录。Preferably, the business session processing unit that receives the session information creates a new session record according to the content of the session information and saves it in the session database unit or reads an existing session record from the session database unit.
本发明还提供了一种云连接系统,包括多个云服务器;及连接在多个云服务器之间的上述云网关。The present invention also provides a cloud connection system, including a plurality of cloud servers; and the above-mentioned cloud gateway connected between the plurality of cloud servers.
本发明还提供一种利用云网关通信的方法,包括接入门户单元把进入云网关的第一云的会话信息分配到一个业务会话处理单元中;查询账号映射单元获得发送方和接收方各自在第一云的账号和第二云的账号的映射信息;业务会话处理单元把会话信息中发送方和接收方在第一云的账号信息转换成发送方和接收方在第二云的账号信息,并把会话信息转换成适应于第二云协议的会话信息;业务会话处理单元把转换后的会话信息发送到接入门户单元中;接入门户单元把收到的转换后的会话信息发送到第二云中。The present invention also provides a method for communicating with the cloud gateway, including the access portal unit distributing the session information of the first cloud entering the cloud gateway to a business session processing unit; querying the account mapping unit to obtain the respective addresses of the sender and the receiver The mapping information of the account number of the first cloud and the account number of the second cloud; the business session processing unit converts the account information of the sender and the receiver in the first cloud in the session information into the account information of the sender and the receiver in the second cloud, And convert the session information into session information adapted to the second cloud protocol; the service session processing unit sends the converted session information to the access portal unit; the access portal unit sends the received converted session information to the second cloud protocol Two clouds.
优选地,接入门户单元分配进入云网关的第一云的会话信息到一个业务会话处理单元中包括:负载均衡转发器查询多个业务会话处理单元的负载状态,并分配会话信息到负载较轻的一个所述业务会话处理单元中。Preferably, the access portal unit distributes the session information of the first cloud entering the cloud gateway to a service session processing unit comprising: the load balancing forwarder queries the load status of multiple service session processing units, and distributes the session information to a service session processing unit with a lighter load In one of the business session processing units.
优选地,接入门户单元把收到的转换后的会话信息发送到第二云中还包括:业务选择转发器根据转换后的会话信息选择对应的连接云网关的第二云。Preferably, the access portal unit sending the received converted session information to the second cloud further includes: the service selection forwarder selects the corresponding second cloud connected to the cloud gateway according to the converted session information.
优选地,账号映射单元中发送方在第一云的账号和第二云的账号的映射为一一对应或一对多映射,接收方在第一云的账号和第二云的账号的映射为一一对应或一对多映射。Preferably, in the account mapping unit, the mapping between the account number of the sender in the first cloud and the account number of the second cloud is one-to-one correspondence or one-to-many mapping, and the mapping between the account number of the receiver in the first cloud and the account number of the second cloud is One-to-one or one-to-many mapping.
优选地,账号映射单元包括设备或APP应用在连接云网关的不同云中的账号信息映射表。Preferably, the account mapping unit includes an account information mapping table of the device or APP application in different clouds connected to the cloud gateway.
优选地, 务会话处理单元查询账号映射单元后,还包括以下步骤Preferably, after the service session processing unit queries the account mapping unit, it also includes the following steps
业务会话处理单元根据会话信息判断是否是新的会话;The business session processing unit judges whether it is a new session according to the session information;
如果是,则在会话数据库单元里分配一个新的会话记录;If so, allocate a new session record in the session database unit;
如果不是,则从所述会话数据库单元里取出对应的会话记录。If not, the corresponding session record is taken out from the session database unit.
通过云网关实现了各厂家云的互联互通,实现方式很方便,采用一个独立于不同云的云网关,对云网关可以进行任何配置,均不影响两侧的云系统,不仅避免了不同厂家为实现互联互通而对云做的修改,减少了工作量,同时也克服了各个厂家由于商业地位不同导致的对云的修改难度。Through the cloud gateway, the interconnection and intercommunication of each manufacturer's cloud is realized. The implementation method is very convenient. Using a cloud gateway independent of different clouds, any configuration can be performed on the cloud gateway without affecting the cloud systems on both sides, which not only avoids different manufacturers. The modification of the cloud to achieve interconnection reduces the workload, and at the same time overcomes the difficulty of modifying the cloud due to the different commercial status of various manufacturers.
另一方面,通过上述云网关实现了智能产品通过云端对接其它厂家,让智能产品可以被包括自己APP在内的应用,以及任何其它云平台的APP操作,最大程度方便用户使用自己的智能产品。On the other hand, through the above-mentioned cloud gateway, smart products can be connected to other manufacturers through the cloud, so that smart products can be operated by applications including their own APP, as well as any other cloud platform APP, making it more convenient for users to use their own smart products.
该云网关,可以适应两端云的连接协议和要求,并支持负荷分担、负载均衡,任意地方部署,可以满足合适的对接业务流量。除此之外,独立的云网关实现的程度可以自己定义,灵活实现,比如让智能产品或APP,接入云网关不同的云,还是只接入相同的云。The cloud gateway can adapt to the connection protocol and requirements of the clouds at both ends, and supports load sharing and load balancing. It can be deployed anywhere to meet the appropriate docking business traffic. In addition, the degree of realization of an independent cloud gateway can be defined by oneself and implemented flexibly, such as allowing smart products or apps to connect to different clouds of the cloud gateway or only to the same cloud.
附图说明Description of drawings
图1是本发明实施例的不同云之间通过云网关连接的结构示意图;Fig. 1 is a schematic structural diagram of connecting different clouds through a cloud gateway according to an embodiment of the present invention;
图2 是本发明实施例的云网关的结构示意图;Fig. 2 is a schematic structural diagram of a cloud gateway according to an embodiment of the present invention;
图3 是本发明实施例的利用云网关进行通信的方法的流程图。Fig. 3 is a flowchart of a method for communicating using a cloud gateway according to an embodiment of the present invention.
具体实施方式detailed description
为了使本技术领域的人员更好地理解本发明中的技术方案,下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本发明保护的范围。In order to enable those skilled in the art to better understand the technical solutions in the present invention, the technical solutions in the embodiments of the present invention will be clearly and completely described below in conjunction with the drawings in the embodiments of the present invention. Obviously, the described The embodiments are only some of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts shall fall within the protection scope of the present invention.
图1为本发明实施例不同云之间通过云网关连接的示意图。参照图1,A、B、C分别代表不同厂家的私有云,设备A1、A2表示可以接入私有云A的智能设备,设备B1、B2、B3和B4是可以接入私有云B的智能设备,设备C1、C2是可以接入私有云C的智能设备。不同的云A、B和C之间通过云网关10进行连接,这样云A中的各种设备可以通过接入云A,然后通过云网关10,和其它云如云B中的各种设备进行通信。Fig. 1 is a schematic diagram of connecting different clouds through a cloud gateway according to an embodiment of the present invention. Referring to Figure 1, A, B, and C represent private clouds of different manufacturers, devices A1 and A2 represent smart devices that can access private cloud A, and devices B1, B2, B3, and B4 are smart devices that can access private cloud B , the devices C1 and C2 are smart devices that can access the private cloud C. Different clouds A, B, and C are connected through cloud gateway 10, so that various devices in cloud A can access cloud A, and then through cloud gateway 10, and other clouds such as various devices in cloud B communication.
图2是本发明实施例的云网关的结构示意图。参照图2, 云网关10包括,一个接入门户单元101、接入门户单元通过云网关10的网络接口与多个云进行通信;Fig. 2 is a schematic structural diagram of a cloud gateway according to an embodiment of the present invention. Referring to FIG. 2, the cloud gateway 10 includes an access portal unit 101, and the access portal unit communicates with multiple clouds through the network interface of the cloud gateway 10;
多个业务会话处理单元104,每个业务会话处理单元与所述接入门户单元101进行通信连接,对所述接入门户单元101分配的会话信息进行转换,使会话信息在不同云之间进行通信。接入门户单元101接收到连接云网关第一云的会话信息后,把此会话信息分配到一个业务会话处理单元104中,收到会话信息的业务会话处理单元104从账号映射单元取得会话信息发送方和接收方在第一云A和第二云B的账号信息的映射关系;把会话信息中发送方和接收方在第一云A的账号信息C1A和C1B转换成发送方和接收方在第二云B的账号信息C2A和C2B,并把会话信息转换成适应第二云协议的会话信息,然后把转换后的会话信息发送到接入门户单元101中,使其适应连接云网关的第二云B。A plurality of service session processing units 104, each service session processing unit communicates with the access portal unit 101, and converts the session information allocated by the access portal unit 101, so that the session information is transferred between different clouds communication. After the access portal unit 101 receives the session information for connecting to the first cloud of the cloud gateway, it distributes the session information to a business session processing unit 104, and the business session processing unit 104 that receives the session information obtains the session information from the account mapping unit and sends it to The mapping relationship between the account information of the sender and the receiver in the first cloud A and the second cloud B; convert the account information C1A and C1B of the sender and receiver in the first cloud A in the session information into the account information C1A and C1B of the sender and receiver in the second cloud The account information C2A and C2B of cloud B, and convert the session information into session information adapted to the second cloud protocol, and then send the converted session information to the access portal unit 101 to adapt to the second cloud gateway connection Cloud B.
云网关10还包括会话数据库单元103、账号映射单元102,每个业务会话处理单元104分别与所述账号映射单元102与会话数据库单元103连接。 会话数据库单元103包括第一存储器,用于存储会话记录数据,记录会话上下文信息。会话记录数据包括会话标识字段、发送方和接收方的账号信息、会话状态标志。如果是一个新的会话,业务会话处理单元104会在会话数据库单元103中分配一个会话信息记录,如果是一个已有的会话,则业务会话处理单元104会从会话数据库单元103中调取已有的会话记录信息到内存中;账号映射单元104具有第二存储器,用于存储用户在不同云的账号信息的映射表,如设备和/或APP应用在连接云网关10的不同云中的账号信息,以及这些账号信息在不同云间的映射关系。一个云中的设备或APP应用程序,可以注册成为其它云的一个账号,或者一个云中多个设备或多个APP应用注册成为对方云的一个账号。比如:第一云跟第二云对接时,根据第二云的要求,第一云中的设备必须要先向第二云注册一个独立的账号,这样第二云对接的协议才支持操作该设备。又比如:第一云跟微信对接时,第一云的设备不必每一个都注册成为微信账号,第一云的多个账号可以对应一个微信账号。反之,微信APP用户账号,也可以不必注册为第一云的账号,因为也可以不关心是哪个用户的操作智能设备。 这种映射关系可以通过不同云账号映射表为一一对应、一对多对应来实现,映射表保存映射单元中的存储设备中。The cloud gateway 10 also includes a session database unit 103 and an account mapping unit 102 , and each service session processing unit 104 is connected to the account mapping unit 102 and the session database unit 103 respectively. The session database unit 103 includes a first memory for storing session record data and recording session context information. The session record data includes a session identification field, account information of the sender and receiver, and a session status flag. If it is a new session, the business session processing unit 104 will allocate a session information record in the session database unit 103, if it is an existing session, the business session processing unit 104 will retrieve the existing session from the session database unit 103 The account mapping unit 104 has a second memory for storing the mapping table of the user's account information in different clouds, such as the account information of the device and/or APP application in different clouds connected to the cloud gateway 10 , and the mapping relationship of these account information among different clouds. A device or APP in one cloud can be registered as an account of another cloud, or multiple devices or APPs in one cloud can be registered as an account of the other cloud. For example: when the first cloud is connected with the second cloud, according to the requirements of the second cloud, the device in the first cloud must first register an independent account with the second cloud, so that the protocol for the connection of the second cloud can support the operation of the device . Another example: when First Cloud connects with WeChat, each of First Cloud's devices does not need to be registered as a WeChat account, and multiple accounts of First Cloud can correspond to one WeChat account. Conversely, the WeChat APP user account does not need to be registered as an account of First Cloud, because it does not need to care which user is operating the smart device. This mapping relationship can be realized through one-to-one correspondence and one-to-many correspondence between different cloud account mapping tables, and the mapping table is stored in the storage device in the mapping unit.
接入门户单元101还包括负载均衡转发器,其连接每个业务会话处理单元104;对于进入云网关10的会话信息,负载均衡转发器查询多个业务会话处理单元中的待处理的会话信息队列的负载状态,将会话信息处理分配到一个当前负载较轻的业务会话处理单元104,从而实现了均衡业务会话处理单元的会话信息队列,让会话信息可以得到及时处理。负载均衡转发器可以选择会话消息队列最短的会话业务处理单元, 也可以选择会话消息队列的长度值小于预设值的几个会话业务处理单元,然后随机分配会话信息给这几个会话业务处理单元。The access portal unit 101 also includes a load balancing transponder, which is connected to each service session processing unit 104; for the session information entering the cloud gateway 10, the load balancing transponder queries the pending session information queue in a plurality of service session processing units The load status of the session information is allocated to a service session processing unit 104 with a current light load, so that the session information queue of the service session processing unit is balanced, so that the session information can be processed in time. The load balancing forwarder can select the session service processing unit with the shortest session message queue, or select several session service processing units whose length value of the session message queue is less than the preset value, and then randomly distribute session information to these session service processing units .
特别地,一个完整的业务的多次会话信息处理可能由不同的业务会话处理单元进行处理,通过会话数据库单元取得会话信息记录,可以了解会话标识、目前的状态等会话记录信息,使得会话信息能及时得到处理,业务转发的均衡性不影响完整事务的处理。In particular, the multiple session information processing of a complete business may be processed by different business session processing units. The session information records can be obtained through the session database unit, and session record information such as session identification and current status can be known, so that session information can be It is processed in time, and the balance of business forwarding does not affect the processing of complete transactions.
接入门户单元还包括业务选择转发器,对于业务会话处理单元处理完成的会话信息,根据转换后的会话内容选择接收方对应的第二云,并转发到会话信息到第二云。The access portal unit also includes a service selection forwarder, for the session information processed by the service session processing unit, selects the second cloud corresponding to the recipient according to the converted session content, and forwards the session information to the second cloud.
图3是本发明利用云网关进行通信的方法的流程图。 本实施例中,第一云中的一个设备A,其账号为C1A,向第二云的一个设备B,其账号C2B,发送一条会话信息,比如控制信息或沟通信息;C1A在第二云中的账号为C2A,C2B在第一云的账号为C1B。参照图3,设备A发出的该条会话信息包括信息发送方为A,接收方为B的字段,该信息从第一云发出,使用第一云的对应协议发到云网关。该消息到达云网关后,Fig. 3 is a flow chart of the communication method using the cloud gateway in the present invention. In this embodiment, a device A in the first cloud, whose account is C1A, sends a piece of session information, such as control information or communication information, to a device B in the second cloud, whose account is C2B; C1A is in the second cloud The account number of C2B is C2A, and the account number of C2B in First Cloud is C1B. Referring to FIG. 3 , the piece of session information sent by device A includes a field that the sender is A and the receiver is B. The information is sent from the first cloud and sent to the cloud gateway using the corresponding protocol of the first cloud. After the message reaches the cloud gateway,
S1:接入门户单元把进入云网关的第一云的会话信息分配到一个业务会话处理单元中;S1: The access portal unit distributes the session information of the first cloud entering the cloud gateway to a business session processing unit;
S2:业务会话处理单元查询账号映射单元获得发送方和接收方各自在第一云的账号C1A和C1B和第二云的账号的映射信息C2A和C2B;S2: The business session processing unit queries the account mapping unit to obtain the mapping information C2A and C2B of the accounts C1A and C1B of the sender and the receiver in the first cloud and the accounts of the second cloud respectively;
S3:业务会话处理单元把会话信息中发送方和接收方在第一云的账号信息C1A和C1B转换成发送方和接收方在第二云的账号信息C2A和C2B,并把会话信息转换成适应于第二云协议的会话信息;S3: The business session processing unit converts the account information C1A and C1B of the sender and receiver in the first cloud in the session information into account information C2A and C2B of the sender and receiver in the second cloud, and converts the session information into Session information on the second cloud agreement;
S4:业务会话处理单元把转换后的会话信息发送到接入门户单元中;S4: The business session processing unit sends the converted session information to the access portal unit;
S5:接入门户单元把收到的转换后的会话信息发送到第二云中。S5: The access portal unit sends the received converted session information to the second cloud.
在步骤S1 的接入门户单元分配进入云网关的会话信息中还包括:The session information assigned to the cloud gateway by the access portal unit in step S1 also includes:
负载均衡转发器查询多个业务会话处理单元的当前的信息队列的负载状态;The load balancing forwarder queries the load status of the current message queues of multiple business session processing units;
负载均衡转发器根据业务会话处理单元的状态,分配会话信息到一个负载较轻的业务会话处理单元中。其中,负载均衡转发器可1011以选择会话消息队列最短的会话业务处理单元, 也可以选择会话消息队列的长度值小于预设值的几个会话业务处理单元,然后随机分配会话信息给这几个会话业务处理单元。The load balancing forwarder distributes session information to a service session processing unit with a lighter load according to the state of the service session processing unit. Wherein, the load balancing forwarder can select 1011 the session service processing unit with the shortest session message queue, or select several session service processing units whose length value of the session message queue is less than a preset value, and then randomly distribute session information to these several session service processing units. Session business processing unit.
步骤2中业务会话处理单元查询得到的信息包括 发送方的账户映射信息及接收方的账号映射信息,其中发送方的账号映射信息包括发送方A在第一云的账号C1A和第二云的账号C2A的映射信息,接收方的账号映射信息包括接收方在第一云的账号C1B和第二云的账号C2B的映射信息。The information queried by the business session processing unit in step 2 includes the account mapping information of the sender and the account mapping information of the receiver, wherein the account mapping information of the sender includes the account C1A of the sender A in the first cloud and the account of the second cloud The mapping information of C2A and the account mapping information of the receiver include the mapping information of the receiver's account C1B in the first cloud and the account C2B of the second cloud.
业务会话处理单元对信息内容进行变换包括:The transformation of information content by the business session processing unit includes:
根据所述账号映射信息转换接会话信息中发送方的账号信息C1A为第二云的账号信息C2A,接收方的第一云的账号C1B为第二云的账号C2B,并转换第一云的通信协议为第二云的通信协议;According to the account mapping information, convert the account information C1A of the sender in the session information to the account information C2A of the second cloud, the account C1B of the first cloud of the receiver to the account C2B of the second cloud, and convert the communication of the first cloud The protocol is the communication protocol of the second cloud;
步骤S5中,接入门户单元把接收到的转换后的会话信息发送到第二云中还包括以下步骤In step S5, the access portal unit sending the received converted session information to the second cloud also includes the following steps
业务选择转发器接收转换的会话信息;The service selection transponder receives the converted session information;
然后根据转换后的会话信息,业务选择转发器选择对应的第二云。将信息发送方为C2A,接收方为C2B的会话信息发给第二云,该会话信息经第二云到达C2B。Then, according to the converted session information, the service selection transponder selects the corresponding second cloud. The session information that the sender is C2A and the receiver is C2B is sent to the second cloud, and the session information reaches C2B through the second cloud.
在步骤2,业务会话处理单元查询账号映射单元后,在会话处理单元对会话信息处理前(或同时),还包括:In step 2, after the business session processing unit queries the account mapping unit, before (or at the same time) the session processing unit processes the session information, it also includes:
业务会话处理单元根据会话信息里的会话号标识字段判断是否是新的会话,如果会话标识字段为空(如NULL)或会话业务处理单元在数据库单元中没有找到相应的会话标识,则判断为新的会话记录,则在会话数据库单元里分配一个新的会话;否则,则根据查到的会话数据库单元的已有会话记录,将会话信息从所述会话数据库单元调入内存进行处理。The business session processing unit judges whether it is a new session according to the session number identification field in the session information. If the session identification field is empty (such as NULL) or the session business processing unit does not find the corresponding session identification in the database unit, it is judged as a new session. If there is no session record, a new session is allocated in the session database unit; otherwise, the session information is transferred from the session database unit into memory for processing according to the found session record of the session database unit.
本发明还提供了一种云连接系统,包括多个云服务器及上述实施例中的云网关,云网关连接在所述多个云服务器之间。The present invention also provides a cloud connection system, including a plurality of cloud servers and the cloud gateway in the above embodiment, and the cloud gateway is connected between the plurality of cloud servers.
以上仅为本发明的实施例而已,并不用于限制本发明。对于本领域技术人员来说,本发明可以有各种更改和变化。凡在本发明的精神和原理之内所作的任何修改、等同替换、改进等,均应包含在本发明的权利要求范围之内。The above are only examples of the present invention, and are not intended to limit the present invention. Various modifications and variations of the present invention will occur to those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present invention shall be included within the scope of the claims of the present invention.
Claims (13)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201511007794.5A CN106936701A (en) | 2015-12-30 | 2015-12-30 | A kind of cloud gateway, cloud connection system and the method using cloud gateway communication |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201511007794.5A CN106936701A (en) | 2015-12-30 | 2015-12-30 | A kind of cloud gateway, cloud connection system and the method using cloud gateway communication |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN106936701A true CN106936701A (en) | 2017-07-07 |
Family
ID=59458465
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201511007794.5A Pending CN106936701A (en) | 2015-12-30 | 2015-12-30 | A kind of cloud gateway, cloud connection system and the method using cloud gateway communication |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN106936701A (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110942372A (en) * | 2019-11-21 | 2020-03-31 | 杭州涂鸦信息技术有限公司 | Method for butting service end and ERP system and gateway |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101072191A (en) * | 2007-03-30 | 2007-11-14 | 腾讯科技(深圳)有限公司 | Instant messaging user account converting method and device |
| CN101374118A (en) * | 2007-08-23 | 2009-02-25 | 华为技术有限公司 | Method, system and device for message interconnection |
| CN103248661A (en) * | 2012-02-13 | 2013-08-14 | 宇龙计算机通信科技(深圳)有限公司 | Account number binding method and system |
| CN103986741A (en) * | 2013-02-08 | 2014-08-13 | 株式会社日立制作所 | Cloud data system, cloud data center and resource management method thereof |
| WO2015085962A1 (en) * | 2013-12-09 | 2015-06-18 | 腾讯科技(深圳)有限公司 | Method, device and system for processing account information of web application in joint operation |
-
2015
- 2015-12-30 CN CN201511007794.5A patent/CN106936701A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101072191A (en) * | 2007-03-30 | 2007-11-14 | 腾讯科技(深圳)有限公司 | Instant messaging user account converting method and device |
| CN101374118A (en) * | 2007-08-23 | 2009-02-25 | 华为技术有限公司 | Method, system and device for message interconnection |
| CN103248661A (en) * | 2012-02-13 | 2013-08-14 | 宇龙计算机通信科技(深圳)有限公司 | Account number binding method and system |
| CN103986741A (en) * | 2013-02-08 | 2014-08-13 | 株式会社日立制作所 | Cloud data system, cloud data center and resource management method thereof |
| WO2015085962A1 (en) * | 2013-12-09 | 2015-06-18 | 腾讯科技(深圳)有限公司 | Method, device and system for processing account information of web application in joint operation |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110942372A (en) * | 2019-11-21 | 2020-03-31 | 杭州涂鸦信息技术有限公司 | Method for butting service end and ERP system and gateway |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN102893556B (en) | Method, system and apparatus for capacity-based Diameter load sharing among source peers | |
| CN103312605B (en) | A kind of gateway device identity setting method and management gateway equipment | |
| US9503957B2 (en) | Low cost mesh network capability | |
| CN108449418A (en) | A hybrid cloud platform management system and method | |
| WO2024082990A1 (en) | Network system, service mesh configuration method, storage medium, and electronic device | |
| US11095716B2 (en) | Data replication for a virtual networking system | |
| CN104125208A (en) | Data transmission method and data transmission device | |
| US9319449B2 (en) | Method, apparatus, and computer program product for processing data requests | |
| CN102404229A (en) | Load balancing system, device and method | |
| CN114338063B (en) | Message queue system, business processing method and computer-readable storage medium | |
| US20140003449A1 (en) | Bandwidth Virtualization | |
| CN114549264A (en) | Management method and management server for utilizing multiple SIM cards | |
| CN110012118B (en) | Method and controller for providing Network Address Translation (NAT) service | |
| CN105450585A (en) | Information transmission method and device | |
| CN110557289A (en) | Network architecture supporting configuration and service response method | |
| CN103636173A (en) | Relay server and relay communication system | |
| CN112583655A (en) | Data transmission method and device, electronic equipment and readable storage medium | |
| CN107846365A (en) | A kind of load balancing based on SDN realizes system and method | |
| CN109474713B (en) | Message forwarding method and device | |
| CN116418724A (en) | Service access method, device and load balancing system | |
| KR20130130295A (en) | System and method for assigining server to terminal and efficiently delivering messages to the terminal | |
| CN111679918B (en) | A message transmission method and device | |
| CN102244687A (en) | Method, device and system for acquiring multi-address message | |
| CN115086425A (en) | Message transmission method, device, program product, medium and electronic equipment | |
| CN107682396B (en) | IM server deployment method and system |
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 | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20170707 |
|
| WD01 | Invention patent application deemed withdrawn after publication |