[go: up one dir, main page]

GB2417160A - Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes - Google Patents

Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes Download PDF

Info

Publication number
GB2417160A
GB2417160A GB0517847A GB0517847A GB2417160A GB 2417160 A GB2417160 A GB 2417160A GB 0517847 A GB0517847 A GB 0517847A GB 0517847 A GB0517847 A GB 0517847A GB 2417160 A GB2417160 A GB 2417160A
Authority
GB
United Kingdom
Prior art keywords
topic
nodes
node
subscribing
publishing
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.)
Granted
Application number
GB0517847A
Other versions
GB2417160B (en
GB0517847D0 (en
Inventor
William Cullen
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.)
Progress Software Corp
Original Assignee
Progress Software Corp
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 Progress Software Corp filed Critical Progress Software Corp
Publication of GB0517847D0 publication Critical patent/GB0517847D0/en
Publication of GB2417160A publication Critical patent/GB2417160A/en
Application granted granted Critical
Publication of GB2417160B publication Critical patent/GB2417160B/en
Anticipated expiration legal-status Critical
Expired - Lifetime legal-status Critical Current

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q30/00—Commerce
    • G06Q30/02—Marketing; Price estimation or determination; Fundraising
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F15/00—Digital computers in general; Data processing equipment in general
    • G06F15/16—Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs
    • H04L12/58—
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
    • 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/563—Data redirection of data network streams
    • 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/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
    • H04L67/63—Routing a service request depending on the request content or context
    • 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/30—Definitions, standards or architectural aspects of layered protocol stacks
    • H04L69/32—Architecture of open systems interconnection [OSI] 7-layer type protocol stacks, e.g. the interfaces between the data link level and the physical level
    • H04L69/322—Intralayer communication protocols among peer entities or protocol data unit [PDU] definitions
    • H04L69/329—Intralayer communication protocols among peer entities or protocol data unit [PDU] definitions in the application layer [OSI layer 7]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00—Data switching networks
    • H04L12/02—Details
    • H04L12/16—Arrangements for providing special services to substations
    • H04L12/18—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast
    • H04L12/1859—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast adapted to provide push services, e.g. data channels
    • 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/2866—Architectures; Arrangements
    • H04L67/2885—Hierarchically arranged intermediate devices, e.g. for hierarchical caching

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Business, Economics & Management (AREA)
  • Theoretical Computer Science (AREA)
  • Strategic Management (AREA)
  • Finance (AREA)
  • Accounting & Taxation (AREA)
  • Development Economics (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Computer Hardware Design (AREA)
  • General Business, Economics & Management (AREA)
  • Marketing (AREA)
  • Economics (AREA)
  • Game Theory and Decision Science (AREA)
  • Computer Security & Cryptography (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Software Systems (AREA)
  • General Engineering & Computer Science (AREA)
  • Computer And Data Communications (AREA)
  • Information Transfer Between Computers (AREA)

Abstract

A system for dynamic message routing on a topic between publishing nodes (504a) and subscribing nodes (506a) includes a plurality of message queues, at least one topic/node table, a subscribing module, a publishing module, and other modules to send messages between one or more publisher and one or more subscribers. These modules are coupled together by a bus in a plurality of nodes and provide for the dynamic message routing on a topic between publishing nodes and subscribing nodes. The message queues store messages at each node for delivery to subscribers local to that node. The topic/node table lists which clients subscribe to which topics, and is used by the other modules to ensure proper distribution of messages. The subscribing module is use to establish a subscription to a topic for that node. The publishing module is used to identify subscribers to a topic and transmit messages to subscribers dynamically. The other modules include various devices to optimize message communication in a publish/subscribe architecture operating on a distributed computing system.

Description

GB 2417160 A continuation (74) Agent and/or Address for Service: Marks &
Clerk 19 Royal Exchange Square, GLASGOW, G1 3AE, United Kingdom
GB0517847A 2003-02-06 2004-02-06 Dynamic subscription and message routing on a topic between a publishig node and subscribing nodes Expired - Lifetime GB2417160B (en)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
US44554303P 2003-02-06 2003-02-06
PCT/US2004/003674 WO2004072800A2 (en) 2003-02-06 2004-02-06 Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes

Publications (3)

Publication Number Publication Date
GB0517847D0 GB0517847D0 (en) 2005-10-12
GB2417160A true GB2417160A (en) 2006-02-15
GB2417160B GB2417160B (en) 2006-12-20

Family

ID=32869378

Family Applications (1)

Application Number Title Priority Date Filing Date
GB0517847A Expired - Lifetime GB2417160B (en) 2003-02-06 2004-02-06 Dynamic subscription and message routing on a topic between a publishig node and subscribing nodes

Country Status (2)

Country Link
GB (1) GB2417160B (en)
WO (1) WO2004072800A2 (en)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11019115B2 (en) 2013-03-28 2021-05-25 Interdigital Ce Patent Holdings Object life cycle management in a publish-subscribe environment

Families Citing this family (22)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1327653C (en) * 2004-12-09 2007-07-18 中国科学院软件研究所 Routing method of pub/sub system on structural P2P network
WO2006073969A2 (en) 2005-01-06 2006-07-13 Tervela, Inc. Intelligent messaging application programming interface
US20060248181A1 (en) * 2005-05-02 2006-11-02 Polycentric Networks Corporation Formatted and/or tunable QOS data publication, subscription, and/or distribution servers and clients
WO2008101033A2 (en) * 2007-02-14 2008-08-21 Ripple Networks, Inc. Methods and systems for self-service programing of content and advertising in digital out-of-home networks
EP2223501B1 (en) 2007-12-19 2015-02-18 Telefonaktiebolaget LM Ericsson (publ) Publish/subscribe networks
WO2009109510A1 (en) * 2008-03-03 2009-09-11 International Business Machines Corporation Method and system for message delivery
GB2466289A (en) * 2008-12-18 2010-06-23 Veda Technology Ltd Executing a service application on a cluster by registering a class and storing subscription information of generated objects at an interconnect
CN105518695B (en) 2013-09-28 2019-01-18 迈克菲股份有限公司 Real-time policy distribution
US9712398B2 (en) 2015-01-29 2017-07-18 Blackrock Financial Management, Inc. Authenticating connections and program identity in a messaging system
US10609155B2 (en) 2015-02-20 2020-03-31 International Business Machines Corporation Scalable self-healing architecture for client-server operations in transient connectivity conditions
CN109391500B (en) * 2017-08-11 2021-08-31 华为技术有限公司 A configuration management method, device and device
CN111221659B (en) * 2018-11-23 2023-10-03 北京图森智途科技有限公司 Subscription performance tracking system of multi-robot operating system environment
CN111103570B (en) * 2019-11-04 2023-04-28 航天南湖电子信息技术股份有限公司 Radar real-time signal processing application software system
CN111163159B (en) * 2019-12-27 2023-07-14 中国平安人寿保险股份有限公司 Message subscription method, device, server and computer readable storage medium
US20220197728A1 (en) * 2020-12-22 2022-06-23 Nokia Solutions And Networks Oy Intent-based networking using partitioning for scalability
CN112540863B (en) * 2020-12-29 2025-11-28 深圳前海微众银行股份有限公司 Data processing method, device, equipment and computer storage medium
CN113162970B (en) * 2021-01-27 2023-08-22 中央财经大学 Message routing method, device, equipment and medium based on publish/subscribe model
CN115708368A (en) * 2021-08-20 2023-02-21 中移（杭州）信息技术有限公司 Message sending method, device and storage medium
EP4145287A1 (en) * 2021-09-03 2023-03-08 Siemens Aktiengesellschaft Embedded control device, method for updating a broker unit of the embedded device and computer program product
CN115190164B (en) * 2022-06-24 2023-11-03 弥费科技(上海)股份有限公司 Network communication method, device, computer equipment and storage medium
CN117527894A (en) * 2022-07-29 2024-02-06 中兴通讯股份有限公司 Network data plane system, data interaction method and storage medium
CN119583639B (en) * 2024-11-28 2025-11-18 武汉船舶通信研究所(中国船舶集团有限公司第七二二研究所) A publish-subscribe method, system, device, and storage medium for multiprocessors

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6154781A (en) * 1998-12-24 2000-11-28 International Business Machines Corporation Publish and subscribe data processing with subscriber option to request subscription propagation prior to acknowledgement
US6298455B1 (en) * 1998-12-29 2001-10-02 International Business Machines Corporation Publish and subscribe data processing with failover using cascaded sequence numbers
US6336119B1 (en) * 1997-11-20 2002-01-01 International Business Machines Corporation Method and system for applying cluster-based group multicast to content-based publish-subscribe system
US6643682B1 (en) * 1999-09-22 2003-11-04 International Business Machines Corporation Publish/subscribe data processing with subscription points for customized message processing
US6728715B1 (en) * 2000-03-30 2004-04-27 International Business Machines Corporation Method and system for matching consumers to events employing content-based multicast routing using approximate groups

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6336119B1 (en) * 1997-11-20 2002-01-01 International Business Machines Corporation Method and system for applying cluster-based group multicast to content-based publish-subscribe system
US6154781A (en) * 1998-12-24 2000-11-28 International Business Machines Corporation Publish and subscribe data processing with subscriber option to request subscription propagation prior to acknowledgement
US6298455B1 (en) * 1998-12-29 2001-10-02 International Business Machines Corporation Publish and subscribe data processing with failover using cascaded sequence numbers
US6643682B1 (en) * 1999-09-22 2003-11-04 International Business Machines Corporation Publish/subscribe data processing with subscription points for customized message processing
US6728715B1 (en) * 2000-03-30 2004-04-27 International Business Machines Corporation Method and system for matching consumers to events employing content-based multicast routing using approximate groups

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US11019115B2 (en) 2013-03-28 2021-05-25 Interdigital Ce Patent Holdings Object life cycle management in a publish-subscribe environment

Also Published As

Publication number Publication date
WO2004072800A3 (en) 2004-12-29
GB2417160B (en) 2006-12-20
GB0517847D0 (en) 2005-10-12
WO2004072800A2 (en) 2004-08-26

Similar Documents

Publication Publication Date Title
GB2417160A (en) Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes
CA2050130A1 (en) Communications network arranged to transport connection oriented and connectionless messages
EP0967756A4 (en) Atm repeater and network including the same
CA2310946A1 (en) Fast path forwarding of link state advertisements using multicast addressing
WO2004025913A3 (en) Communications systems and methods for exchanging messages between users
CA2329542A1 (en) System and method for scheduling message transmission and processing in a digital data network
CA2249841A1 (en) Pots/packet bridge
CA2329357A1 (en) System and method for regulating message flow in a digital data network
CA2220491A1 (en) Rules based electronic message management system
CA2432589A1 (en) Wireless router system and method
AU2003256199A1 (en) Distributing shared network access information in a shared network mobile communications system
DE60113370T2 (en) COMMUNICATION SYSTEM
BR0007079A (en) Local communication system and communications device
DE602006013128D1 (en) RECEIVING DATA ACCORDING TO A DATA TRANSFER PROTOCOL OF DATA FOCUSED ON ANY ONE MULTIPLE OF RECEIPT EQUIPMENT
CA2426143A1 (en) Recipient control over aspects of incoming messages
CN101072158A (en) Method for releasing and processing virtual circuit information and supplier edge device
WO2005048072A3 (en) Methods and systems for automatically populating network route table
CA2276577A1 (en) Method and apparatus for routing in a communication or data network, or a network comprising communication and data networks
GB2605028A8 (en) Internal message routing system and method
JP3654454B2 (en) Local area network
CN101383766A (en) Message forwarding method, device and equipment
CN116389484A (en) Cross-Kubernetes cluster network intercommunication system and method based on data distribution service
CN1937782B (en) Frame device and its message transmitting method
AU4296100A (en) Advanced service architecture for next generation network services and intelligent data network router
AU2002353302A1 (en) An efficient timeout message management in ieee 1394 bridged serial bus network

Legal Events

Date Code Title Description
PE20 Patent expired after termination of 20 years

Expiry date: 20240205