WO2020098040A1 - Procédé de communication entre segments de réseau à base de dds - Google Patents

Procédé de communication entre segments de réseau à base de dds Download PDF

Info

Publication number
WO2020098040A1
WO2020098040A1 PCT/CN2018/121108 CN2018121108W WO2020098040A1 WO 2020098040 A1 WO2020098040 A1 WO 2020098040A1 CN 2018121108 W CN2018121108 W CN 2018121108W WO 2020098040 A1 WO2020098040 A1 WO 2020098040A1
Authority
WO
WIPO (PCT)
Prior art keywords
host
data
create
input
domain
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.)
Ceased
Application number
PCT/CN2018/121108
Other languages
English (en)
Chinese (zh)
Inventor
浦勇
吴俊�
李敏敏
李俊
王啸
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Communication Technology (nanjing) Co Ltd
Original Assignee
China Communication Technology (nanjing) Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by China Communication Technology (nanjing) Co Ltd filed Critical China Communication Technology (nanjing) Co Ltd
Publication of WO2020098040A1 publication Critical patent/WO2020098040A1/fr
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Images

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/04—Network management architectures or arrangements
    • H04L41/046—Network management architectures or arrangements comprising network management agents or mobile agents therefor
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/02—Standardisation; Integration
    • H04L41/0246—Exchanging or transporting network management information using the Internet; Embedding network management web servers in network elements; Web-services-based protocols
    • H04L41/0266—Exchanging or transporting network management information using the Internet; Embedding network management web servers in network elements; Web-services-based protocols using meta-data, objects or commands for formatting management information, e.g. using eXtensible markup language [XML]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/08—Configuration management of networks or network elements
    • H04L41/0803—Configuration setting
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/50—Network service management, e.g. ensuring proper service fulfilment according to agreements
    • H04L41/5003—Managing SLA; Interaction between SLA and QoS
    • H04L41/5019—Ensuring fulfilment of SLA
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L61/00—Network arrangements, protocols or services for addressing or naming
    • H04L61/50—Address allocation
    • H04L61/5007—Internet protocol [IP] addresses

Definitions

  • the invention relates to a cross-network segment communication method, in particular to a cross-network segment communication method based on DDS.
  • Data Distribution Service is a software design standard and specification issued by the Object Management Group (OMG) that implements the publish / subscribe communication model and meets real-time requirements after the CORBA specification is launched.
  • OMG Object Management Group
  • the interface and behavior of data publishing, transmitting and receiving in the real-time system are standardized.
  • DDS uses pure data as the center for data distribution, and describes the status of resources, expectations of resources, network status, etc. with the parameters of Quality of Service (QoS), which greatly enhances the real-time and Flexibility simplifies the effective publishing of data in distributed systems and provides efficient and useful communication services for data-centric distributed applications in real-time environments.
  • QoS Quality of Service
  • DDS defines a data-centric publish / subscribe communication mechanism.
  • the data-centric publish / subscribe model is based on the concept of global data space (Global Data Space), as shown in Figure 1.
  • DDS specifications include domain participants, publishers, subscribers, data types, data writers, data readers, topics, built-in topics, and QoS.
  • DDS is above the operating system and under the user application program, which can well shield the details of the underlying system and the heterogeneity of the bus, and provide a unified API interface to the application data, as shown in Figure 2 .
  • DDS uses domains to divide data communication subspaces. Participants belonging to the same domain can communicate with each other. Each domain participant can have one or more publishers or subscribers. ), Each publisher can have one or more data writers (Data Writer), each subscriber can also have one or more data readers (DataReader). The data writer sends the data to the corresponding data reader through the data channel. The data reader obtains the data of interest from the data channel. The data writer and the data reader pass the topic and QoS matches and establishes contacts. Generally, each data writer or data reader writes or reads only one type of data.
  • the present invention provides a method for realizing mutual communication between hosts on different network segments.
  • DDS middleware real-time and effective implementation is achieved by creating a proxy data reader datareader and a proxy data writer datawriter The transmission of information improves the system interconnectivity.
  • a DDS-based cross-network segment communication method includes the following steps:
  • IP addresses of the dual network cards of the computer C are on the same network segment as the IP addresses of the host A and the IP address of the host B;
  • the xml configuration file contains domain ID information, subject information, and QoS configuration information of hosts A and B;
  • step (6) In the callback function in step (6), set the proxy datareader and datawriter according to the configuration binding information saved in step (5);
  • proxy datareader callback function first obtain the data published by host A, then obtain the proxy datawriter pointer in the user_data strategy, and send the obtained data to host B through the proxy datawriter.
  • Figure 1 is a DDS architecture diagram
  • Figure 2 is a schematic diagram of the location of DDS middleware
  • Figure 3 is a flow chart of obtaining a datareader with a built-in theme of DCPSPublication according to a configuration file and setting a callback function;
  • Figure 4 is a flow chart of creating proxy datareader and datawriter to achieve cross-network segment communication
  • FIG. 6 (a) is a schematic diagram of communication to be crossed across network segments in an embodiment
  • FIG. 6 (b) is a diagram of determining publishers and subscribers
  • FIG. 6 (c) is a schematic diagram of data transmission principles.
  • a method for cross-network segment communication based on DDS includes the following steps:
  • Host A uses DDS middleware to publish data, create the domain domain1 with ID 1; create a publisher (Publisher), register the data type for publishing and defined in step (1), such as: StringMsg; create Published topics (Topic), such as "hello Topic”; create a data writer (Data Writer), write data (write); publish data in the form of multicast;
  • DDS middleware uses DDS middleware to publish data, create the domain domain1 with ID 1; create a publisher (Publisher), register the data type for publishing and defined in step (1), such as: StringMsg; create Published topics (Topic), such as "hello Topic”; create a data writer (Data Writer), write data (write); publish data in the form of multicast;
  • IP addresses of the dual network cards of the computer C are on the same network segment as the IP addresses of the host A and the IP address of the host B;
  • the xml configuration file contains domain ID information, subject information, and QoS configuration information of hosts A and B;
  • step (6) In the callback function in step (6), set the proxy datareader and datawriter according to the saved configuration binding information; as shown in Figure 4;
  • step (7.1) When the datawriter of host A starts to write data, it starts to publish data.
  • step (6.3) obtain the domain participant dp, ie input_dp, according to the built-in datareader;
  • step (7.2) According to input_dp in step (7.1), find the corresponding topic information and QoS configuration information in input_map, namely input_info;
  • step (7.3) Match the theme, match the theme information in input_info obtained in step (7.2) with the theme of the data published by the host A read through the built-in datareader;
  • step (7.5) According to the QoS configuration judgment in step (7.5), set the QoS of proxy datareader and proxy datawriter respectively;
  • step (7.8) According to the sub information in input_info, the subject created in step (7.4) and the QoS of the proxy datareader set in step (7.6), create the proxy datareader and set the callback function.
  • hosts A IP: 192.168.1.2
  • B IP: 192.168.2.2
  • A is the publisher pub
  • B is the subscriber sub, to realize the cross-network segment communication of A and B, as shown in Figure 6 (b).
  • the DDS-based cross-network segment communication method proposed by the present invention adopts the agent idea, using a computer C with dual network cards, the network card IPs are 192.168.1.3/24 and 192.168.2.3/24, running a domain1 sub and a domain0 pub, sub is used to receive the data published from the pub of 192.168.1.2/24, and then publish the received data to the sub of 192.168.2.2/24 through pub.
  • the principle is shown in Figure 6 (c).
  • DDS communication is in the form of multicast
  • a and B hosts need to create when using DDS middleware to communicate Different domain IDs, such as A is domain1, B is domain0.

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Information Transfer Between Computers (AREA)

Abstract

La présente invention concerne un procédé de communication entre segments de réseau à base de DDS, comprenant les étapes suivantes : établir respectivement un domaine a et un domaine b avec des ID différents sur deux hôtes A et B dans différents segments de réseau, créer un diffuseur sur l'hôte A, créer un abonné sur l'hôte B, enregistrer le même type de données, créer le même thème, créer un système d'écriture de données par l'hôte A pour écrire des données, et créer un lecteur de données par l'hôte B pour lire des données ; exécuter un abonné du domaine a et un diffuseur du domaine b sur un ordinateur C avec deux cartes de réseau ; l'abonné reçoit des données publiées par le diffuseur de l'hôte A, et envoie les données reçues à l'abonné de l'hôte B au moyen du diffuseur pour mettre en œuvre la communication. Le procédé peut réaliser une communication entre segments de réseau d'hôtes dans différents segments de réseau en temps réel et de manière fiable, et facilite une meilleure extension d'un réseau de système.
PCT/CN2018/121108 2018-11-16 2018-12-14 Procédé de communication entre segments de réseau à base de dds Ceased WO2020098040A1 (fr)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201811366255.4A CN109547243B (zh) 2018-11-16 2018-11-16 一种基于dds的跨网段通信方法
CN201811366255.4 2018-11-16

Publications (1)

Publication Number Publication Date
WO2020098040A1 true WO2020098040A1 (fr) 2020-05-22

Family

ID=65847713

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2018/121108 Ceased WO2020098040A1 (fr) 2018-11-16 2018-12-14 Procédé de communication entre segments de réseau à base de dds

Country Status (2)

Country Link
CN (1) CN109547243B (fr)
WO (1) WO2020098040A1 (fr)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114006824A (zh) * 2021-10-22 2022-02-01 南京芯传汇电子科技有限公司 一种基于分布式通信的反射内存卡仿真的通讯方法
CN114443422A (zh) * 2021-12-29 2022-05-06 中国航空工业集团公司西安航空计算技术研究所 一种分布式资源监控方法和系统
CN115250287A (zh) * 2022-06-23 2022-10-28 重庆长安汽车股份有限公司 一种基于dds多端口的自动适配方法及系统
CN115580660A (zh) * 2022-10-12 2023-01-06 北京华玉通软科技有限公司 一种基于dds协议的周期性数据通信方法及装置
CN116527744A (zh) * 2023-04-27 2023-08-01 中国直升机设计研究所 一种用于ima系统的a664网络数据订阅发布方法

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111930499A (zh) * 2020-07-06 2020-11-13 中国电子科技集团公司电子科学研究院 Dds中间件应用识别符的生成方法、配置方法及装置
CN112492039B (zh) * 2020-12-02 2022-09-02 广东博智林机器人有限公司 运行于多内核的数据分发服务方法、及装置
CN115549963B (zh) * 2022-08-23 2026-03-17 优跑汽车技术(上海)有限公司 基于dds的上下车体跨域通信安全系统及汽车

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1538316A (zh) * 2003-04-17 2004-10-20 联想(北京)有限公司 具有层次拓扑结构的消息中间件系统及消息传递方法
EP1892893A1 (fr) * 2006-08-24 2008-02-27 NTT DoCoMo, Inc. Procédé et dispositif pour mappage de la qualité de service
CN101795222A (zh) * 2009-11-13 2010-08-04 深圳市科陆电子科技股份有限公司 多级转发服务系统及方法

Family Cites Families (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2015059128A1 (fr) * 2013-10-24 2015-04-30 Thomson Licensing Protocole de sélection d'élément de réacheminement pour un réseau et dispositif cpe correspondant
CN105119950B (zh) * 2014-01-16 2016-08-17 国网山东省电力公司青岛供电公司 一种配电网通信方法
CN105138339A (zh) * 2015-09-10 2015-12-09 中国航空无线电电子研究所 一种基于dds规范的分布式通信中间件开发方法
CN107665237B (zh) * 2017-08-18 2020-11-27 北京海兰信数据科技股份有限公司 数据结构分类装置、非结构化数据的发布订阅系统及方法
CN107563075B (zh) * 2017-09-08 2020-09-18 中国航空工业集团公司沈阳飞机设计研究所 一种实现CosiMate网络和DDS网络互联的方法
CN108199865A (zh) * 2017-12-07 2018-06-22 中国航空工业集团公司西安航空计算技术研究所 一种基于发布订阅的路由服务实现方法

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1538316A (zh) * 2003-04-17 2004-10-20 联想(北京)有限公司 具有层次拓扑结构的消息中间件系统及消息传递方法
EP1892893A1 (fr) * 2006-08-24 2008-02-27 NTT DoCoMo, Inc. Procédé et dispositif pour mappage de la qualité de service
CN101795222A (zh) * 2009-11-13 2010-08-04 深圳市科陆电子科技股份有限公司 多级转发服务系统及方法

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
SHI, WANGYANG: "Discussion on a Method for Implementing Cross Network Segment Service with a Single DHCP Server", SILICON VALLEY, 12 August 2009 (2009-08-12) *
ZHU, HUAYONG ET AL.: "Z3V (Non-official translation: Chapter 3 How to Write a Simple Application Program", REAL-TIME PUBLISH/SUBSCRIBE DATA DISTRIBUTION FOR DISTRIBUTED SYSTEMS, 31 August 2013 (2013-08-31) *

Cited By (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114006824A (zh) * 2021-10-22 2022-02-01 南京芯传汇电子科技有限公司 一种基于分布式通信的反射内存卡仿真的通讯方法
CN114443422A (zh) * 2021-12-29 2022-05-06 中国航空工业集团公司西安航空计算技术研究所 一种分布式资源监控方法和系统
CN115250287A (zh) * 2022-06-23 2022-10-28 重庆长安汽车股份有限公司 一种基于dds多端口的自动适配方法及系统
CN115250287B (zh) * 2022-06-23 2023-08-04 重庆长安汽车股份有限公司 一种基于dds多端口的自动适配方法
CN115580660A (zh) * 2022-10-12 2023-01-06 北京华玉通软科技有限公司 一种基于dds协议的周期性数据通信方法及装置
CN116527744A (zh) * 2023-04-27 2023-08-01 中国直升机设计研究所 一种用于ima系统的a664网络数据订阅发布方法

Also Published As

Publication number Publication date
CN109547243B (zh) 2021-12-03
CN109547243A (zh) 2019-03-29

Similar Documents

Publication Publication Date Title
WO2020098040A1 (fr) Procédé de communication entre segments de réseau à base de dds
US11728992B2 (en) Cryptlet binding key graph
US10728181B2 (en) Advanced message queuing protocol (AMQP) message broker and messaging client interactions via dynamic programming commands using message properties
CN105205183A (zh) 一种基于xml的dds分布式系统自动构建方法
US11418342B2 (en) System and methods for data exchange using a distributed ledger
CN110413418A (zh) 缓存同步装置及方法，缓存同步系统、电子设备
CN108512814B (zh) 媒体数据处理方法、装置和系统
CN112448969A (zh) 链路追踪方法、装置、系统、设备及可读存储介质
KR20120048742A (ko) 확장성과 적응성을 가지는 ｄｄｓ 구조 및 ｄｄｓ를 구성하는 노드
CN113220432A (zh) 多云互联方法、装置、设备、存储介质及产品
Chang et al. Future Classroom with the Internet of Things-A Service-Oriented Framework.
CN108566412B (zh) 一种数据服务方法及数据服务装置
US20070118842A1 (en) DDS-assisted CORBA discovery
CN110708390A (zh) 基于节点间数据共享的数据处理方法、设备、装置、介质
US7506334B2 (en) Common, multi-version interface that allows a distributed sybsystem to communicate with multiple versions of the distributed subsystem
CN112312061B (zh) 一种视频会议方法、装置、电子设备及存储介质
US7814482B2 (en) System and method for grid MPI job allocation using file-based MPI initialization in grid computing system
CN115023931B (zh) 用于服务api发布的方法和网络实体
CN113301088B (zh) 消息处理方法、装置、系统、电子设备及可读存储介质
US20140354765A1 (en) Multipoint control unit and service providing method thereof
CN108055594A (zh) 边缘切片的实现方法、装置、计算机设备及存储介质
CN114116258B (zh) 队列管理器热备方法、系统、终端及存储介质
CN111478932B (zh) 智能合约数据的处理方法、区块链网络及存储介质
JP3569114B2 (ja) 要求応答型無限長データ通信方法
CN115883560A (zh) 一种基于消息中间件aop的集群负载均衡方法

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 18939970

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 18939970

Country of ref document: EP

Kind code of ref document: A1