CN-122027688-A - Multi-domain system interconnection method and equipment

CN122027688ACN 122027688 ACN122027688 ACN 122027688ACN-122027688-A

Abstract

The embodiment of the application provides a multi-domain system interconnection method and equipment, and relates to the technical fields of finance and technology, communication and computers. The method is applied to a control node in a multi-domain system, the control node comprises a global coordinator, service metadata of a first service sent by a first federal agency is received through the global coordinator, the first service is registered in the global coordinator and a first response is sent to the first federal agency based on the service metadata of the first service, the first response indicates success or failure of registration of the first service, a call request for the first service sent by a second federal agency is received, the first federal agency providing the first service is inquired in the global coordinator, and access strategy, address information and route information of the first federal agency are sent to the second federal agency. The method is used for improving the interconnection efficiency of the multi-domain system.

Inventors

LI TONGLIANG

Assignees

中国工商银行股份有限公司
工银科技有限公司

Dates

Publication Date: 20260512
Application Date: 20260209

Claims (16)

1. A method of interconnecting a multi-domain system, the method being applied to a control node in the multi-domain system, the control node comprising a global coordinator, the method comprising: receiving service metadata of a first service sent by a first federal agent through the global coordinator; registering the first service in the global coordinator and sending a first response to the first federal agent based on service metadata of the first service, the first response indicating success or failure of registration of the first service; Receiving a call request for a first service sent by a second contact proxy; querying the global coordinator for a first federal agent providing the first service; And sending the access policy, address information and routing information of the first federal agent to the second federal agent.
2. The method according to claim 1, wherein the method further comprises: subscribing to the appointed business process and receiving the event chain log of the appointed business process reported by the federation agency.
3. The method according to claim 1, wherein the method further comprises: And receiving heartbeat data of the first federal agent, wherein the heartbeat data of the first federal agent is used for adjusting an access policy of the first federal agent.
4. A method according to any one of claims 1-3, characterized in that the method further comprises: receiving a query request sent by a first federation proxy, wherein the query request is used for requesting to query the routing information of a first message; and inquiring the routing information of the first message according to the inquiry request and sending an inquiry response to the first federal agency, wherein the inquiry response comprises the routing information of the first message.
5. A method of multi-domain system interconnection, characterized by a first federal agent applied to a first executing node, the method comprising: Registering service metadata of a first service with a global coordinator of a control node in response to publishing the first service; And receiving a first response sent by the global coordinator, wherein the first response represents success or failure of first service registration.
6. The method of claim 5, wherein the method further comprises: and sending heartbeat data to the global coordinator periodically.
7. The method of claim 5, wherein the method further comprises: Receiving a request message of a first service sent by a second contact proxy; Analyzing the request message of the first service to obtain a semantic tag bitmap and a semantic tag; comparing a semantic tag bitmap generated by the semantic tag through a hash algorithm with a semantic tag bitmap obtained by analyzing a request message to verify the integrity of the semantic tag; under the condition that the semantic tag is complete, comparing the semantic tag with a local business data dictionary of the first federal agency to obtain a comparison result; And under the condition that the comparison result indicates that the semantic tags are not matched, converting the key fields with the unmatched semantic tags, generating a response message of the first request by utilizing the data of the converted key fields, and sending the response message of the first request to the second contact proxy.
8. The method of claim 7, wherein the first federal agent operates a first system, the method further comprising: identifying, by a plurality of federal agents, different from the first federal agent, of the first service call, a cross-domain transaction if the first system call the first service and the first service is a cross-domain transaction; generating a global transaction identifier of the cross-domain transaction; invoking a plurality of federation agents and receiving processing results of a plurality of sub-transactions of the cross-domain transaction, the plurality of federation agents being operable to execute the plurality of sub-transactions of the cross-domain transaction; And summarizing the processing results of the plurality of federation agents to obtain the processing results of the cross-domain transaction and feeding back the processing results of the cross-domain transaction to the first system through the first service.
9. The method of claim 7, wherein each federal agent of the first service call, after executing the corresponding sub-transaction, records a transaction log for the sub-transaction and completes the atomization of the sub-transaction at the local database.
10. The method of claim 7, wherein the method further comprises: Recording information of a first business event into a local first event chain log in response to the generation of a preset first business event, wherein the information of the first business event comprises at least one of identification, type, occurrence time, occurrence system, hash value, event load and hash value of the last business event of the business event; Broadcasting the information of the first business event to all federation agents related to a first business process where the first business event is located, and reporting the first event chain log to the global coordinator under the condition that the global coordinator subscribes to the first business process, wherein all federation agents related to the first business process are used for recording the information of the first business event in a local event chain log after hash verification; and according to the first business flow query request, locally querying the first event chain log.
11. The method of any of claims 5-7, wherein the first federal agent comprises a first federal message bridge, the method further comprising: responsive to publishing a first message to a first topic of a local message cluster of the first federal agent, sending a query request to the global coordinator through the first federal message bridge, the first federal message bridge subscribing to the first topic, the query request for requesting to query routing information of the first message; Receiving a query response sent by the global coordinator, wherein the query response comprises the routing information of the first message; Determining that the first message needs to be forwarded to a second federation proxy according to the routing information of the first message and encapsulating the first message into a target notification in a unified format through the first federation message bridge; And sending the target notification to a second federation message bridge through a communication link between the first federation message bridge and the second federation message bridge, wherein the second federation proxy comprises the second federation message bridge.
12. A method of multi-domain system interconnection, the method comprising, applied to a second federation proxy of a second execution node: Sending a call request for a first service to a global coordinator of a control node; receiving an access strategy, address information and route information of a first federal agent sent by the global coordinator; And when the access policy indicates that the second federation proxy has the calling right of the first service, the first service is called to the first federation proxy according to the address information and the routing information of the first federation proxy.
13. The method of claim 12, wherein the invoking the first service comprises: generating a semantic tag for each key field in the request message of the first service according to the local business data dictionary of the second contact agent; Generating a semantic tag bitmap by using semantic tags of all key fields in the request message of the first service through a hash algorithm; Carrying the semantic tag and the semantic tag bitmap in a request message of the first service and sending the request message of the first service to the first federal agency; and receiving a response message of the first service sent by the first federal agency.
14. The method according to claim 12, wherein the method further comprises: Recording information of a second business event into a local second event chain log in response to the generation of a preset second business event, wherein the information of the second business event comprises at least one of identification, type, occurrence time, occurrence system, hash value, event load and hash value of the last business event of the second business event; broadcasting the information of the second business event to all federation agents related to a second business process where the second business event is located, and reporting the second event chain log to the global coordinator under the condition that the global coordinator subscribes to the second business process, wherein all federation agents related to the second business process are used for recording the information of the second business event in the local event chain log after hash verification; And according to a second business flow query request, locally querying the second event chain log.
15. The method of any of claims 12-14, wherein the second federation proxy includes a second federation message bridge, the method further comprising: Receiving, by a communication link between a first federation message bridge and a second federation message bridge, a target notification sent by a first federation agent, the first federation agent comprising the first federation message bridge; Analyzing and converting the target notification through the second peer message bridge to obtain a second message conforming to a local message cluster format of the second peer agent, and sending the second message to a second topic, wherein the second peer message bridge subscribes to the second topic; The second contact message bridge consumes the second message locally.
16. An electronic device comprising a processor and a memory communicatively coupled to the processor; The memory stores computer-executable instructions; The processor executes computer-executable instructions stored in the memory to implement the method of any one of claims 1 to 4, or the method of any one of claims 5 to 11, or the method of any one of claims 12 to 15.

Description

Multi-domain system interconnection method and equipment Technical Field The application relates to the technical fields of finance and technology, communication and computer, in particular to a multi-domain system interconnection method and equipment. Background In a large enterprise clustered architecture, a group subordinate branch or subsidiary usually independently builds a heterogeneous information system based on own business requirements. These systems have significant differences in technology stacks, data models, and communication protocols, resulting in the formation of "data islands" and "flow breaks" between systems. The related art employs a single API gateway or the like as a hub for all interactions. However, when the group is large in scale and frequent in interaction, the central node is very easy to become a performance bottleneck and a single point of failure source, and is difficult to adapt to the requirement of rapid iteration of the technical stack of each branch company. And, each branch company system adopts different technical stacks, and the central gateway is difficult to unify and convert the protocol, and an adapter needs to be customized, so that the maintenance cost is high. Disclosure of Invention The application provides a multi-domain system interconnection method and equipment, which are used for improving the multi-domain system interconnection efficiency. In a first aspect, the application provides a multi-domain system interconnection method, which is applied to a control node in a multi-domain system, wherein the control node comprises a global coordinator, the method comprises the steps of receiving service metadata of a first service sent by a first federation agent through the global coordinator, registering the first service in the global coordinator based on the service metadata of the first service and sending a first response to the first federation agent, wherein the first response indicates success or failure of registration of the first service, receiving a call request for the first service sent by a second federation agent, querying the first federation agent providing the first service in the global coordinator, and sending access strategy, address information and routing information of the first federation agent to the second federation agent. In one possible embodiment, the method further comprises subscribing to a specified business process and receiving an event chain log of the specified business process reported by the federal agent. In one possible embodiment, the method further comprises receiving heartbeat data of the first federal agent, the heartbeat data of the first federal agent being used to adjust an access policy of the first federal agent. In one possible embodiment, the method further comprises receiving a query request sent by the first federal agent, the query request requesting to query for routing information of the first message, querying the routing information of the first message according to the query request and sending a query response to the first federal agent, the query response including the routing information of the first message. In a second aspect, an embodiment of the present application provides a multi-domain system interconnection method, applied to a first federation proxy of a first execution node, where the method includes registering service metadata of a first service with a global coordinator of a control node in response to issuing the first service, and receiving a first response sent by the global coordinator, where the first response indicates success or failure of registration of the first service. In one possible embodiment, the method further comprises periodically sending heartbeat data to the global coordinator. In a possible embodiment, the method further comprises the steps of receiving a request message of a first service sent by a second federation agent, analyzing the request message of the first service to obtain a semantic label bitmap and a semantic label, comparing the semantic label bitmap generated by the semantic label through a hash algorithm with the semantic label bitmap obtained by analyzing the request message to verify the integrity of the semantic label, comparing the semantic label with a local service data dictionary of the first federation agent to obtain a comparison result under the condition that the semantic label is complete, converting key fields which are not matched with the semantic label under the condition that the comparison result indicates that the semantic label is not matched, generating a response message of the first request by utilizing data of the key fields after conversion, and sending the response message of the first request to the second federation agent. In one possible embodiment, the first federal agent runs the first system, and the method further comprises, in the case where the first system invokes the first service and the first service is a cro