CN104320441B - Information sharing method between wireless communication system - Google Patents

Abstract

The invention provides a method for information sharing among wireless communication systems. After reading the initialization configuration file, the jms server is started, and the client is started for each communication system, and the messages of different formats in the heterogeneous communication network are transferred to each other through the application of XML. Unify into one data format, and use JMS technology for data interaction. The present invention enables communication systems to share information, and designs a message forwarding mechanism, so that the information of each system can be managed in a unified manner, so that each communication system forms a unified network, thereby greatly expanding the perception range and application of each communication system scope.

Description

Information sharing method among wireless communication systems

technical field

The invention relates to a method for distributing and processing information between different communication systems in wireless communication.

Background technique

Throughout the construction of wireless communication systems in various countries, they all start from the idea of whether there is a link or not based on the task. Due to the year-by-year construction of communication systems, the current situation is that various wireless communication systems coexist. Each communication system has a different system structure, the systems are independent of each other, the data structure and data interface are different, the interoperability of each system is difficult, and the data cannot be shared efficiently, which greatly reduces the efficiency of the system and causes a waste of information resources.

At present, the United States mainly realizes the interconnection and information sharing functions between various communication systems through various gateways and data forwarding systems. For a developing country like my country, it does not yet have the ability to build a complex data link like the United States, and although the development of electronic technology today provides conditions for the development of high-performance data link terminals, the development cycle is usually relatively long. Therefore, it is a short-term plan for the construction of information systems in my country to transform the existing communication equipment so that it has data communication capabilities and can realize the interconnection and information sharing of various wireless communication systems on the existing basis.

With the increase of the communication network, the number of traditional data forwarding gateways will increase quadratically. Not only the implementation method is complicated, but also the increase of gateways has a great impact on the original system. Therefore, a new gateway implementation method is needed, which can Shield the impact of message formats of different communication systems on message sharing, and realize a common data access interface.

Contents of the invention

In order to overcome the deficiencies of the prior art, the present invention provides an information sharing method among wireless communication systems, designs a heterogeneous message processing method, enables information sharing between communication systems, and designs a message forwarding mechanism, The information of each system can be managed in a unified manner, and each communication system can form a unified network, thereby greatly expanding the range of perception and application of each communication system.

The information sharing system among wireless communication systems involved in the method is composed of several JMS clients, JMS servers, a message parsing module and a message format conversion module.

Java Message Service (Java Message Service, JMS for short) is a developer-neutral API for accessing enterprise messaging systems. An application using JMS is called a JMS client, and a message system that handles message routing and delivery is called a JMS Provider, while a JMS application is a business system composed of multiple JMS clients and a JMS Provider. JMS supports two standard asynchronous messaging methods: point-to-point (P2P) and publish/subscribe (Pub/Sub).

The publish/subscribe communication mode is based on the topic (Topic) concept. A topic is the publishing target (controlled object) of the message. The publish/subscribe mode can have multiple clients sending and receiving messages, and each topic can have multiple publishers and multiple subscribers. The publishing process of the jms client is the same as the first half of the receiving process. They both create a connection factory (the object used by the customer to create a connection), establish a connection with the jms service through the connection factory, create a topic topic, and create a connection through the connection. session. In the second half, the message publisher creates a producer to publish messages according to the session and topic, and the message receiver registers consumers according to the session and topic, and then receives messages synchronously or listens to messages asynchronously on this topic. The connection factories and topics are registered in the JNDI (java naming and directory standard interface) of the jms server.

The technical solution adopted by the present invention to solve its technical problems comprises the following steps:

1) Read in the initialization configuration file; the initialization configuration file contains the message type information that each communication system needs to publish, the correspondence between the communication system and the topic, the correspondence between the communication system and the connection factory, and the topics subscribed by each communication system information;

2) Start the jms server, and configure the connection factory and theme in JNDI according to the parameters in the initialization file;

3) start the client for each communication system, establish the information publishing process and the information receiving process according to the parameters in the initialization configuration file, and realize the communication with the server;

4) Client information publishing process:

a. The source communication system client monitors the source communication system;

b. Determine whether there is a message arriving, if so, go to step c, otherwise return to step a;

c. The source communication system client judges whether the message is a message type that needs to be shared according to the initialization file, and if so, enters step d, otherwise returns to step a;

d. The source communication system client converts the message into an XML file and stores it together with its message type in a file buffer, and enters step e;

e. The producer object of the source communication system client packs and publishes the XML file and the message type to the corresponding publication topic of the server source communication system, and returns to step a;

5) Client information receiving process:

a. The client of the destination communication system monitors the server;

b. Determine whether there is any information arriving, if so, go to step c, otherwise return to step a;

c. The client of the destination communication system judges whether the information is the subject it subscribes to according to the initialization file, and if so, proceeds to step d, otherwise returns to step a;

d. The target communication system client obtains the XML document from the server, converts the XML document into one or more target XML documents, and proceeds to step e;

e. The target communication system client restores the target message XML document to the message format of the target communication system and sends it to the target communication system, and enters step a.

The beneficial effects of the present invention are:

In the case of existing equipment and standards that have not been upgraded or replaced, through the application of XML, messages of different formats in heterogeneous communication networks can be unified into one data format, so that information can be exchanged and shared between communication systems. The use of unified XML to transfer between communication systems reduces the coupling degree between different communication systems in traditional gateways, reduces the impact of the addition of communication systems on gateways, and reduces the impact of modification and addition of gateways on the entire system.

In terms of data interaction, JMS technology is used to share messages in a publish/subscribe manner. The information published by one communication system can be received by multiple communication systems, which reduces the number of message forwarding and saves network bandwidth resources. The message that needs to be shared in multiple communication systems has higher propagation efficiency.

Description of drawings

Fig. 1 is a schematic diagram of the system structure of the present invention;

Fig. 2 is a flow chart of the processing method of the present invention.

detailed description

The present invention will be further described below in conjunction with the accompanying drawings and embodiments, and the present invention includes but not limited to the following embodiments.

The method for sharing information among heterogeneous communication networks designed and realized by the present invention connects different tactical wireless communication systems through the JMS specification. For messages that need to be shared between different communication systems, use XML technology to convert the messages that need to be shared in the source communication system into XML files, and the XML files are published through the JMS server. For the destination communication systems that subscribe to such messages, you can Get the XML document of this message from the JMS server. Through the message format conversion module, the destination communication system converts the XML document into one or more corresponding XML documents. After parsing, these transformed XML documents become messages in the internal format of the destination communication system and are sent in the destination communication system.

The present invention comprises the following steps:

1) Read in the initialization configuration file. The initialization configuration file contains information about the types of messages that each communication system needs to publish, information about the correspondence between communication systems and topics (one communication system corresponds to one topic), and information about the correspondence between communication systems and connection factories (one communication system corresponds to one connection factory), topic information subscribed by each communication system (a communication system can subscribe to multiple topics).

2) Start the jms server and configure the connection factory and theme in JNDI. The method is to use the open source messaging system ActiveMQ. Download and install ActiveMQ, copy the corresponding software into tomcat (an open source servlet container, JNDI provider) to realize the integration with tomcat, and realize the configuration of connection factories and topics in JNDI.

3) Start the client for each communication system, establish the information publishing process and information receiving process according to the parameters in the initialization configuration file, and realize the communication with the server.

The information release process is established:

Read in the initialization configuration file, and obtain the corresponding publishing topic and the JNDI name of the connection factory according to your own communication system number. Query the corresponding connection factory object from the JNDI server according to the obtained JNDI name of the connection factory. Use the found connection factory object to create a connection to the JMS server and establish a session. According to the obtained JNDI name of the published topic, search the JNDI server for the corresponding published topic object, and create a producer for the found published topic object. Producers publish information to publish topic objects.

The information receiving process is established:

Read in the initialization configuration file, and obtain the topics you subscribe to and the JNDI name of the connection factory according to your own communication system number. Query the corresponding connection factory object from the JNDI server according to the obtained JNDI name of the connection factory. Use the found connection factory object to create a connection to the JMS server and establish a session. Find the subscription topic object according to the obtained JNDI name of the subscription topic, create a consumer for the found subscription topic object, and then set up a listener for the consumer. The listener enters the corresponding program OnMessage() after listening to the content of the topic it subscribes to on the server.

4) Client information publishing process:

a. The source communication system client monitors the source communication system;

b. Determine whether there is a message arriving, if so, go to step c, otherwise return to step a;

c. The source communication system client judges whether the message is a message type that needs to be shared according to the initialization file, and if so, enters step d, otherwise returns to step a;

d. The source communication system client invokes the message parsing module to process the message. The message parsing module uses DOM as a parser to convert the data structure of the business message in memory into an XML document and store it together with its message type in In a file buffer, enter step e;

e. The producer object of the source communication system client calls the publish function to package the XML file and message type into a TextMessage (simple text) and publish it to the corresponding publishing topic of the server source communication system, and return to step a.

5) Client information receiving process:

a. The client of the destination communication system monitors the server;

b. Determine whether there is any information arriving, if so, go to step c, otherwise return to step a;

c. The client of the destination communication system judges whether the information is the subject it subscribes to according to the initialization file, and if so, proceeds to step d, otherwise returns to step a;

d. The client of the destination communication system obtains the XML document from the server, and then enters the response function OnMessage for processing. In the response function OnMessage, pass the XML document to the message format conversion module. The message format conversion module is software written by using XPath (Extensible Markup Language Path Language) according to the corresponding relationship between messages of different communication systems. One message of one communication system can correspond to one or several messages of another communication system. The message format conversion module generates one or several target XML documents according to the message format conversion rules from the received XML document. Go to step e;

e. The target communication system client sends the target message XML document to the message parsing module, still uses DOM as the parser to restore the XML document to the message format of the target communication system and sends it to the target communication system, and enters step a.

Below in conjunction with embodiment the present invention is further described.

The method for sharing information between heterogeneous communication networks will be described in detail below in the implementation manner of the present invention.

The source message format is as follows, message sys1.a1:

message element 1 message element 2 … Location information (longitude, latitude, altitude) message element 5 Time information (hour, minute, second) …

Table 1 Source message format sys1.a1

The destination message format is as follows message sys2.b6:

Group 1 (message element 1, message element 5) Group 2 (longitude, latitude, altitude, message element 2) Group 3 (hour, minute, second) …

Table 2 Purpose message format sys2.b6

The steps are as follows:

step 1:

Read in the initialization configuration file. The initialization configuration file contains information about the types of messages that each communication system needs to publish, information about the correspondence between communication systems and topics (one communication system corresponds to one topic), and information about the correspondence between communication systems and connection factories (one communication system corresponds to one connection factory), topic information subscribed by each communication system (a communication system can subscribe to multiple topics).

Table 3 Initialization configuration file

Step 2:

Start the jms server, and configure the connection factory and topic in Table 3 in JNDI.

Step 3:

Start the client for System1 and System2. According to the initialization configuration file in the above table, establish an information publishing process and an information receiving process for the client.

Step 4:

Client information release process:

a. The System1 client monitors System1;

b. Judging that there is a message arriving on the network, go to step c;

c. The System1 client judges that the message sys1.a1 is a message type that needs to be shared according to the initialization file, and proceeds to step d;

d. The System1 client calls the message parsing module to process sys.a1. The message parsing module uses DOM as a parser to convert sys.a1 into an XML document and store it together with its message type sys1.a1 in a file buffer, and then enter step e;

e. The producer object of the System1 client calls the publish function to pack the XML file and the message type into a TextMessage (simple text) and publish it to the corresponding topic Sys1Topic of the server, and return to step a.

Step 5:

Client information receiving process:

a. The consumer object of the System2 client listens to the server;

b. When information arrives, go to step c;

c. The System2 client judges that the information is the topic Sys1Topic subscribed by itself according to the initialization file, and enters step d;

d. The System2 client gets the XML document from the server, and then enters the response function OnMessage for processing. In the response function OnMessage, pass the XML document to the message format conversion module. The message format conversion module first parses out that the message type is sys1.a1, and according to the message conversion rules, a sys1.a1 will be converted into a sys2.b6, and XPath (Extensible Markup Language Path Language) is used to process the xml corresponding to sys1.a1 Transformation, for example, "//location information" in xpath means to select all child elements of location information longitude, latitude, altitude. "/message element 2" means to select the root element of message element 2, then the xml of the sys2.b6 message can be described as the following table by using the directory information of the sys1.a1 message xml:

Table 4 Message xml file conversion correspondence table

After conversion, an xml file corresponding to sys2.b6 is generated, and enter step e;

The XML document of the e.b6 message is sent to the message parsing module of the System2 communication system, and DOM is still used as the parser to restore the XML document to the message format of System2 for sending.

Claims (1)

1. A method for sharing information between wireless communication systems, characterized in that it comprises the following steps: 1) Read in the initialization file; the initialization file contains the message type information that each communication system needs to publish, the correspondence relationship information between the communication system and the topic, the correspondence relationship information between the communication system and the connection factory, and the topic information subscribed by each communication system; 2) Start the jms server, and configure the connection factory and theme in JNDI according to the parameters in the initialization file; 3) Start the client for each communication system, establish the information publishing process and the information receiving process according to the parameters in the initialization file, and realize the communication with the server; 4) Client information publishing process: a. The source communication system client monitors the source communication system; b. Determine whether there is a message arriving, if so, go to step c, otherwise return to step a; c. The source communication system client judges whether the message is a message type that needs to be shared according to the initialization file, and if so, enters step d, otherwise returns to step a; d. The source communication system client converts the message into an XML file and stores it together with its message type in a file buffer, and enters step e; e. The producer object of the source communication system client packs and publishes the XML file and the message type to the corresponding publication topic of the server source communication system, and returns to step a; 5) Client information receiving process: a. The client of the destination communication system monitors the server; b. Determine whether there is any information arriving, if so, go to step c, otherwise return to step a; c. The client of the destination communication system judges whether the information is the subject it subscribes to according to the initialization file, and if so, proceeds to step d, otherwise returns to step a; d. The target communication system client obtains the XML document from the server, converts the XML document into one or more target XML documents, and proceeds to step e; e. The target communication system client restores the target message XML document to the message format of the target communication system and sends it to the target communication system, and enters step a.