CN104320441B - 无线通信系统间信息共享方法 - Google Patents
无线通信系统间信息共享方法 Download PDFInfo
- Publication number
- CN104320441B CN104320441B CN201410527673.2A CN201410527673A CN104320441B CN 104320441 B CN104320441 B CN 104320441B CN 201410527673 A CN201410527673 A CN 201410527673A CN 104320441 B CN104320441 B CN 104320441B
- Authority
- CN
- China
- Prior art keywords
- message
- communication system
- information
- client
- return
- 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.)
- Active
Links
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/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/565—Conversion or adaptation of application format or content
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Mobile Radio Communication Systems (AREA)
- Information Transfer Between Computers (AREA)
Abstract
本发明提供了一种无线通信系统间信息共享方法,读入初始化配置文件后启动jms服务端,并为每一种通信系统都启动客户端,通过XML的应用将异构通信网络的不同格式消息统一成一种数据格式,采用JMS技术进行数据交互。本发明提使得各通信系统之间能够共享信息,设计了消息的转发机制,使得各系统的信息能够得到统一管理,使得各通信系统形成统一网络,从而大大扩展了各通信系统的感知范围和应用范围。
Description
技术领域
本发明涉及一种无线通信中不同通信系统间信息的分发和处理方法。
背景技术
纵观各国无线通信系统的建设,都是依据任务从首先解决有无链路的思想出发开始工作的。由于通信系统的逐年建设,使得目前的状况是各种不同的无线通信系统并存。各通信系统具有不同的系统结构,系统之间相互独立,数据结构、数据接口相异,各系统互操作困难,数据得不到高效共享,大大降低了系统的效能,对信息资源造成浪费。
目前美国主要是通过各种各样的网关和数据转发系统来实现各种通信系统之间的互联互通以及信息共享功能的。对于我国这样的发展中国家,尚不具备建设美国那样复杂数据链的能力,并且虽然当今电子技术的发展为研制开发高性能数据链终端提供了条件,但通常研制开发的周期相对较长。因此,改造现有通信装备,使其具有数据通信能力,能够在现有的基础上实现各无线通信系统的互联互通和信息共享,不失为一种我国信息系统建设的近期方案。
传统的数据转发网关随着通信网络的增加,网关的数量将成平方倍的增长,不仅实现方式复杂,而且网关的增加对原有的系统影响较大,因此需要一种新的网关实现方式,能够屏蔽不同通信系统的消息格式对于消息共享的影响,实现通用的数据访问接口。
发明内容
为了克服现有技术的不足,本发明提供一种无线通信系统间的信息共享方法,设计了一种异构消息的处理方式,使得各通信系统之间能够共享信息,设计了消息的转发机制,使得各系统的信息能够得到统一管理,使得各通信系统形成统一网络,从而大大扩展了各通信系统的感知范围和应用范围。
本方法涉及的无线通信系统间信息共享系统由若干个JMS客户端,JMS服务器,消息解析模块以及消息格式转换模块构成。
Java消息服务(Java Message Service,简称JMS)是用于访问企业消息系统的开发商中立的API。使用JMS的应用程序被称为JMS客户端,处理消息路由与传递的消息系统被称为JMS Provider,而JMS应用则是由多个JMS客户端和一个JMS Provider构成的业务系统。JMS支持2个标准异步消息传递方式:点对点(P2P)和发布/订阅(Pub/Sub)。
其中发布/订阅通信模式是基于主题(Topic)概念的。主题是消息的发布目标(受控对象),发布/订阅模式可以有多个发送消息和接收消息的客户机,每个主题可以有多个发布者和多个订阅者。jms客户端的发布流程和接收流程的前半部分过程是一样的,均为创建一个连接工厂(客户用来创建连接的对象),通过连接工厂建立和jms服务的连接,创建一个主题topic,通过连接创建会话。在后半部分,消息发布端根据会话和主题创建一个生产者发布消息,消息接收端根据会话和主题注册消费者,然后在这个主题上同步的接收消息或者异步的监听消息。其中的连接工厂和主题在jms服务器的JNDI(java命名和目录标准接口)中进行注册。
本发明解决其技术问题所采用的技术方案包括以下步骤:
1)读入初始化配置文件;初始化配置文件中包含每种通信系统需要发布的消息类型信息、通信系统与主题的对应关系信息、通信系统与连接工厂的对应关系信息、每种通信系统订阅的主题信息;
2)启动jms服务端,根据初始化文件中的参数配置好JNDI中的连接工厂和主题;
3)为每一种通信系统都启动客户端,根据初始化配置文件中的参数建立信息发布进程和信息接收进程,实现与服务器的通信;
4)客户端信息发布流程:
a.源通信系统客户端对源通信系统进行监听;
b.判断是否有消息到达,如有则进入步骤c,否则返回步骤a;
c.源通信系统客户端根据初始化文件判断该消息是否为需要共享的消息类型,如果是则进入步骤d,否则返回步骤a;
d.源通信系统客户端将消息转换成XML文件并连同它的消息类型一起存放在一个文件缓冲区中,进入步骤e;
e.源通信系统客户端的生产者对象将XML文件和消息类型打包发布到服务器源通信系统对应的发布主题上,返回步骤a;
5)客户端信息接收流程:
a.目的通信系统客户端对服务器进行监听;
b.判断是否有信息到达,如有则进入步骤c,否则返回步骤a;
c.目的通信系统客户端根据初始化文件判断该信息是否为自己订阅的主题,如果是则进入步骤d,否则返回步骤a;
d.目的通信系统客户端从服务器上获取XML文档,将XML文档转换为一个或多个目标XML文档,进入步骤e;
e.目的通信系统客户端将目标消息XML文档还原成目的通信系统的消息格式在目的通信系统进行发送,进入步骤a。
本发明的有益效果是:
在现有装备,标准未升级或更换的情况下,通过XML的应用将异构通信网络的不同格式消息统一成一种数据格式,使得各通信系统之间能够进行信息的交互和共享。使用统一的XML在各通信系统间进行传递降低了传统网关中不同通信系统之间的耦合程度,减小了通信系统的增加对网关的影响,减轻了网关的修改和增加对整个系统的影响。
在数据的交互方式上,采用JMS技术,将消息采用发布/订阅的方式进行共享,一个通信系统发布的信息可以有多个通信系统收到,减少了消息的转发次数,节约了网络带宽资源,使得需要共享到多个通信系统中的消息具有更高的传播效率。
附图说明
图1是本发明系统构造示意图;
图2是本发明处理方法流程图。
具体实施方式
下面结合附图和实施例对本发明进一步说明,本发明包括但不仅限于下述实施例。
本发明所设计实现的异构通信网络间共享信息的方法,通过JMS规范将各个不同的战术无线通信系统进行相连。对于需要在不同通信系统间共享的消息,利用XML技术将源通信系统中需要进行共享的消息转换成XML文件,该XML文件通过JMS服务器进行发布,对于订阅了此类消息的目的通信系统,可以从JMS服务器上获得此消息的XML文档。通过消息格式转换模块,目的通信系统将该XML文档转换成一个或多个对应的的XML文档。经过解析,这些转换后的XML文档变成目的通信系统内部格式的消息在目的通信系统中进行发送。
本发明包括以下步骤:
1)读入初始化配置文件。初始化配置文件中包含每种通信系统需要发布的消息类型信息、通信系统与主题的对应关系信息(一种通信系统对应一个主题)、通信系统与连接工厂的对应关系信息(一种通信系统对应一个连接工厂),每种通信系统订阅的主题信息(一个通信系统可以订阅多个主题)。
2)启动jms服务端,配置好JNDI中的连接工厂和主题。方法是采用开源消息系统ActiveMQ。下载并安装ActiveMQ,将相应软件拷入tomcat(开源的servlet容器,JNDI提供者)实现与tomcat的整合,实现对JNDI中连接工厂和主题的配置。
3)为每一种通信系统都启动客户端,根据初始化配置文件中的参数建立信息发布进程和信息接收进程,实现与服务器的通信。
信息发布进程建立:
读入初始化配置文件,根据自己的通信系统号获取自身对应的发布主题和连接工厂的JNDI名。根据获取的连接工厂JNDI名字向JNDI服务器查询对应的连接工厂对象。用找到的连接工厂对象来创建与JMS服务器的连接并建立会话。根据获取到的发布主题的JNDI名字向JNDI服务器查找对应的发布主题对象,为找到的发布主题对象创建生产者。生产者向发布主题对象发布信息。
信息接收进程建立:
读入初始化配置文件,根据自己的通信系统号获取自己订阅的主题和连接工厂的JNDI名。根据获取的连接工厂JNDI名字向JNDI服务器查询对应的连接工厂对象。用找到的连接工厂对象来创建与JMS服务器的连接并建立会话。根据获取到的订阅主题的JNDI名查找到订阅主题对象,为找到的订阅主题对象创建消费者,然后为消费者设立一个监听器。监听器在监听到服务器上有自己订阅的主题的内容后进入相应程序OnMessage()。
4)客户端信息发布流程:
a.源通信系统客户端对源通信系统进行监听;
b.判断是否有消息到达,如有则进入步骤c,否则返回步骤a;
c.源通信系统客户端根据初始化文件判断该消息是否为需要共享的消息类型,如果是则进入步骤d,否则返回步骤a;
d.源通信系统客户端调用消息解析模块对此消息进行处理,消息解析模块采用DOM作为解析器,将该业务消息在内存中的数据结构转换成一个XML文档并连同它的消息类型一起存放在一个文件缓冲区中,进入步骤e;
e.源通信系统客户端的生产者对象调用publish函数将XML文件和消息类型打包为一个TextMessage(简单文本)发布到服务器源通信系统对应的发布主题上,返回步骤a。
5)客户端信息接收流程:
a.目的通信系统客户端对服务器进行监听;
b.判断是否有信息到达,如有则进入步骤c,否则返回步骤a;
c.目的通信系统客户端根据初始化文件判断该信息是否为自己订阅的主题,如果是则进入步骤d,否则返回步骤a;
d.目的通信系统客户端从服务器上获取XML文档,然后进入响应函数OnMessage进行处理。在响应函数OnMessage中将XML文档传给消息格式转换模块。消息格式转换模块是根据不同通信系统消息之间的对应关系采用XPath(可扩展标记语言路径语言)进行编写的软件,一个通信系统的一条消息可以对应到另一个通信系统的一条或几条消息。消息格式转换模块将接收到的XML文档按照消息格式转换规则生成了一个或几个目标XML文档。进入步骤e;
e.目的通信系统客户端将目标消息XML文档发送到消息解析模块,仍然采用DOM作为解析器将XML文档还原成目的通信系统的消息格式在目的通信系统进行发送,进入步骤a。
下面结合实施例对本发明进一步说明。
异构通信网络间共享信息的方法,下面将对本发明的实施方式进行详细说明。
其中源消息格式如下,消息sys1.a1:
消息元素1 |
消息元素2 |
… |
位置信息(经度,纬度,高度) |
消息元素5 |
时间信息(时,分,秒) |
… |
表1 源消息格式sys1.a1
目的消息格式如下消息sys2.b6:
组1(消息元素1,消息元素5) |
组2(经度,纬度,高度,消息元素2) |
组3(时,分,秒) |
… |
表2 目的消息格式sys2.b6
其步骤如下:
步骤1:
读入初始化配置文件。初始化配置文件中包含每种通信系统需要发布的消息类型信息、通信系统与主题的对应关系信息(一种通信系统对应一个主题)、通信系统与连接工厂的对应关系信息(一种通信系统对应一个连接工厂),每种通信系统订阅的主题信息(一个通信系统可以订阅多个主题)。
表3 初始化配置文件
步骤2:
启动jms服务端,将表3中的连接工厂和主题在JNDI进行配置。
步骤3:
为System1和System2启动客户端。根据上表的初始化配置文件为客户端建立信息发布进程和信息接收进程。
步骤4:
客户端信息发布流程:
a.System1客户端监听System1;
b.判断网络有消息到达,进入步骤c;
c.System1客户端根据初始化文件判断该消息sys1.a1是需要共享的消息类型,进入步骤d;
d.System1客户端调用消息解析模块对sys.a1进行处理。消息解析模块采用DOM作为解析器将sys.a1转换成一个XML文档并连同它的消息类型sys1.a1一起存放在一个文件缓冲区中,然后进入步骤e;
e.System1客户端的生产者对象调用publish函数将XML文件和消息类型打包为一个TextMessage(简单文本)发布到服务器相应的主题Sys1Topic上,返回步骤a。
步骤5:
客户端信息接收流程:
a.System2客户端的消费者对象监听服务器;
b.有信息到达,进入步骤c;
c.System2客户端根据初始化文件判断该信息是自己订阅的主题Sys1Topic,进入步骤d;
d.System2客户端从服务器上获取XML文档,然后进入响应函数OnMessage进行处理。在响应函数OnMessage中将XML文档传给消息格式转换模块。消息格式转换模块首先解析出消息类型为sys1.a1,根据消息转换规则,一条sys1.a1将被转换成一条sys2.b6,采用XPath(可扩展标记语言路径语言)对sys1.a1对应的xml进行转换,例如,在xpath中“//位置信息”表示选择位置信息的所有子元素经度,纬度,高度。“/消息元素2”表示选择消息元素2这个根元素,则sys2.b6消息的xml可以用sys1.a1消息xml的目录信息描述为下表:
表4 消息xml文件转换对应表
经过转换后生成了一个sys2.b6对应的xml文件,进入步骤e;
e.b6消息的XML文档被发送到System2通信系统的消息解析模块,仍然采用DOM作为解析器将XML文档还原成System2的消息格式进行发送。
Claims (1)
1.一种无线通信系统间信息共享方法,其特征在于包括下述步骤:
1)读入初始化文件;初始化文件中包含每种通信系统需要发布的消息类型信息、通信系统与主题的对应关系信息、通信系统与连接工厂的对应关系信息、每种通信系统订阅的主题信息;
2)启动jms服务端,根据初始化文件中的参数配置好JNDI中的连接工厂和主题;
3)为每一种通信系统都启动客户端,根据初始化文件中的参数建立信息发布进程和信息接收进程,实现与服务器的通信;
4)客户端信息发布流程:
a.源通信系统客户端对源通信系统进行监听;
b.判断是否有消息到达,如有则进入步骤c,否则返回步骤a;
c.源通信系统客户端根据初始化文件判断该消息是否为需要共享的消息类型,如果是则进入步骤d,否则返回步骤a;
d.源通信系统客户端将消息转换成XML文件并连同它的消息类型一起存放在一个文件缓冲区中,进入步骤e;
e.源通信系统客户端的生产者对象将XML文件和消息类型打包发布到服务器源通信系统对应的发布主题上,返回步骤a;
5)客户端信息接收流程:
a.目的通信系统客户端对服务器进行监听;
b.判断是否有信息到达,如有则进入步骤c,否则返回步骤a;
c.目的通信系统客户端根据初始化文件判断该信息是否为自己订阅的主题,如果是则进入步骤d,否则返回步骤a;
d.目的通信系统客户端从服务器上获取XML文档,将XML文档转换为一个或多个目标XML文档,进入步骤e;
e.目的通信系统客户端将目标消息XML文档还原成目的通信系统的消息格式在目的通信系统进行发送,进入步骤a。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201410527673.2A CN104320441B (zh) | 2014-10-09 | 2014-10-09 | 无线通信系统间信息共享方法 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201410527673.2A CN104320441B (zh) | 2014-10-09 | 2014-10-09 | 无线通信系统间信息共享方法 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN104320441A CN104320441A (zh) | 2015-01-28 |
CN104320441B true CN104320441B (zh) | 2017-10-27 |
Family
ID=52375610
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201410527673.2A Active CN104320441B (zh) | 2014-10-09 | 2014-10-09 | 无线通信系统间信息共享方法 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN104320441B (zh) |
Families Citing this family (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN104717285A (zh) * | 2015-03-02 | 2015-06-17 | 国家电网公司 | 利用jms网络中间件实现异构系统之间的互操作 |
CN105407024B (zh) * | 2015-09-23 | 2019-04-09 | 中国电子科技集团公司第二十九研究所 | 一种基于发布订阅通信机制的异构数据互通方法及装置 |
CN106610985A (zh) * | 2015-10-23 | 2017-05-03 | 镇江金软计算机科技有限责任公司 | 一种信息发布系统 |
CN105607901B (zh) * | 2015-12-11 | 2019-12-13 | Tcl集团股份有限公司 | 系统内存的优化方法、装置及终端设备 |
CN106209468B (zh) * | 2016-07-21 | 2019-10-29 | 广东电网有限责任公司中山供电局 | 异构主备调度自动化系统之间操作信息同步的方法及系统 |
CN108197346B (zh) * | 2017-12-06 | 2021-11-09 | 中国南方电网有限责任公司 | 一种基于开放消息总线的主备异构系统通信模型同步方法 |
CN109889553B (zh) * | 2019-04-18 | 2021-07-13 | 中国电子科技集团公司第二十九研究所 | 一种结构化报文自适应转换方法及装置 |
Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1466062A (zh) * | 2002-06-28 | 2004-01-07 | 明日工作室股份有限公司 | 以无线平台共享信息的方法及系统 |
CN101151878A (zh) * | 2005-03-29 | 2008-03-26 | 索尼爱立信移动通讯股份有限公司 | 在手持通信装置之间共享信息的方法和手持通信装置 |
CN102484795A (zh) * | 2009-07-13 | 2012-05-30 | 独立行政法人情报通信研究机构 | 认知无线通信中的信息共享方法、认知无线通信装置以及认知无线通信系统 |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US8730923B2 (en) * | 2003-06-11 | 2014-05-20 | Alcatel Lucent | Method for controlling resource allocation in a wireless communication system |
-
2014
- 2014-10-09 CN CN201410527673.2A patent/CN104320441B/zh active Active
Patent Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1466062A (zh) * | 2002-06-28 | 2004-01-07 | 明日工作室股份有限公司 | 以无线平台共享信息的方法及系统 |
CN101151878A (zh) * | 2005-03-29 | 2008-03-26 | 索尼爱立信移动通讯股份有限公司 | 在手持通信装置之间共享信息的方法和手持通信装置 |
CN102484795A (zh) * | 2009-07-13 | 2012-05-30 | 独立行政法人情报通信研究机构 | 认知无线通信中的信息共享方法、认知无线通信装置以及认知无线通信系统 |
Non-Patent Citations (1)
Title |
---|
《异种战术无线通信系统信息的分发与共享》;吴金成;《军事通信技术》;20100925;第31卷(第3期);第39页-43页 * |
Also Published As
Publication number | Publication date |
---|---|
CN104320441A (zh) | 2015-01-28 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN104320441B (zh) | 无线通信系统间信息共享方法 | |
CN102255934B (zh) | 云服务发布方法及云服务中介 | |
US8938502B2 (en) | Subscriber device and subscription management that supports real-time communication | |
US8539097B2 (en) | Intelligent message processing | |
CN104156798B (zh) | 企业权威源系统数据实时推送方法 | |
CN101729491B (zh) | 一种增强基于脚本业务的应用可靠性的方法、装置和系统 | |
US20130036167A1 (en) | Automatic synchronization of clipboards | |
CN104580073B (zh) | 一种用于在异构系统之间实现消息传递的方法和装置 | |
CN102571550A (zh) | 一种通用的信息交互平台和方法 | |
CN104967650A (zh) | 第三方电商平台统一发布方法 | |
CN114024826B (zh) | 基于服务网格技术实现分布式esb场景下的应用多活系统 | |
CN102594695B (zh) | 一种企业服务总线的消息路由方法及系统 | |
CN1953463B (zh) | 多cad系统至pdm系统的信息集成系统及方法 | |
US7693972B2 (en) | Directory service in an automation system | |
CN101459609A (zh) | 企业服务总线实现方法 | |
CN103235813A (zh) | 用友财务核心系统与作业成本系统间的数据同步方法 | |
CN101339520B (zh) | 一种将ejb接入企业服务总线的方法 | |
CN106464728A (zh) | 处理通知信道断连的方法 | |
CN102196157A (zh) | 一种电视台节目的发布系统 | |
WO2014187397A1 (zh) | 多媒体消息的发布方法及装置 | |
US20100241716A1 (en) | System for interconnecting manifold entities across a real-time Meshed Information Exchange network | |
CN105515947B (zh) | 一种基于xmpp的异构终端消息互通的方法、服务器及系统 | |
US20150026307A1 (en) | Xmpp based upnp device architecture for cloud computing in a network environment | |
CN113312242A (zh) | 接口信息管理方法、装置、设备及存储介质 | |
CN114501347A (zh) | 异构系统间信息交互方法、装置及系统 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
C06 | Publication | ||
PB01 | Publication | ||
C10 | Entry into substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |