[go: up one dir, main page]

WO2004072800A3 - 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
WO2004072800A3
WO2004072800A3 PCT/US2004/003674 US2004003674W WO2004072800A3 WO 2004072800 A3 WO2004072800 A3 WO 2004072800A3 US 2004003674 W US2004003674 W US 2004003674W WO 2004072800 A3 WO2004072800 A3 WO 2004072800A3
Authority
WO
WIPO (PCT)
Prior art keywords
topic
nodes
node
subscribing
publishing
Prior art date
Application number
PCT/US2004/003674
Other languages
French (fr)
Other versions
WO2004072800A2 (en
Inventor
William Cullen
Original Assignee
Progress Software Corp
William Cullen
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, William Cullen filed Critical Progress Software Corp
Priority to GB0517847A priority Critical patent/GB2417160B/en
Publication of WO2004072800A2 publication Critical patent/WO2004072800A2/en
Publication of WO2004072800A3 publication Critical patent/WO2004072800A3/en

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
    • 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.
PCT/US2004/003674 2003-02-06 2004-02-06 Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes WO2004072800A2 (en)

Priority Applications (1)

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

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
US44554303P 2003-02-06 2003-02-06
US60/445,543 2003-02-06

Publications (2)

Publication Number Publication Date
WO2004072800A2 WO2004072800A2 (en) 2004-08-26
WO2004072800A3 true WO2004072800A3 (en) 2004-12-29

Family

ID=32869378

Family Applications (1)

Application Number Title Priority Date Filing Date
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

Country Status (2)

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

Families Citing this family (21)

* 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
CA2594036A1 (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
JP2016514870A (en) * 2013-03-28 2016-05-23 トムソン ライセンシングＴｈｏｍｓｏｎ Ｌｉｃｅｎｓｉｎｇ Object lifecycle management in a publish-subscribe environment
CN105518695B (en) * 2013-09-28 2019-01-18 迈克菲股份有限公司 Real-time policy distribution
US9705752B2 (en) 2015-01-29 2017-07-11 Blackrock Financial Management, Inc. Reliably updating 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
CN112540863A (en) * 2020-12-29 2021-03-23 深圳前海微众银行股份有限公司 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
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 surface system, data interaction method and storage medium

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

Also Published As

Publication number Publication date
GB0517847D0 (en) 2005-10-12
GB2417160B (en) 2006-12-20
GB2417160A (en) 2006-02-15
WO2004072800A2 (en) 2004-08-26

Similar Documents

Publication Publication Date Title
WO2004072800A3 (en) Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes
EP0967756A4 (en) Atm repeater and network including the same
EP1429489A3 (en) Method and device for multicast group management
WO2004025913A3 (en) Communications systems and methods for exchanging messages between users
AU2002220653A1 (en) Subgroup multicasting in a communications network
WO1996007257A3 (en) Scalable distributed computing environment
CA2050130A1 (en) Communications network arranged to transport connection oriented and connectionless messages
DE60113370D1 (en) COMMUNICATION SYSTEM
WO2009112411A3 (en) Method and filter arrangement for filtering messages that are received via a serial data bus by a user node of a communications network
IL146348A0 (en) Method and apparatus in a communication network
GB2429371B (en) System and method for routing messages
WO2001043359A3 (en) Multicasting in virtual private networks
WO2005048072A3 (en) Methods and systems for automatically populating network route table
PL1712063T3 (en) A method and system for optimizing data transfer between network devices
GB2605028A8 (en) Internal message routing system and method
CN109818883B (en) Distributed publishing and subscribing transmission method based on appointed source multicast
WO2001024029A3 (en) Network topology for a scalable multiprocessor system
WO2006130266A3 (en) System and method for routing messages within a messaging system
WO2004092968A3 (en) Multi-node system with global access states
CN103051744A (en) Method and device for converting multicast address
AU2001252371A1 (en) Communications system
Kitahara et al. An Opportunistic Communication Protocol to Reduce Energy Consumption of Nodes
CN103200470A (en) Issuing device and method of Gb passive optical network system multicasting service
WO2025188705A8 (en) Network-on-chip multicasting with packet specific exclusion encoding
AU2188701A (en) Domestic communication and entertainment system

Legal Events

Date Code Title Description
AK Designated states

Kind code of ref document: A2

Designated state(s): AE AG AL AM AT AU AZ BA BB BG BR BW BY BZ CA CH CN CO CR CU CZ DE DK DM DZ EC EE EG ES FI GB GD GE GH GM HR HU ID IL IN IS JP KE KG KP KR KZ LC LK LR LS LT LU LV MA MD MG MK MN MW MX MZ NA NI NO NZ OM PG PH PL PT RO RU SC SD SE SG SK SL SY TJ TM TN TR TT TZ UA UG US UZ VC VN YU ZA ZM ZW

AL Designated countries for regional patents

Kind code of ref document: A2

Designated state(s): BW GH GM KE LS MW MZ SD SL SZ TZ UG ZM ZW AM AZ BY KG KZ MD RU TJ TM AT BE BG CH CY CZ DE DK EE ES FI FR GB GR HU IE IT LU MC NL PT RO SE SI SK TR BF BJ CF CG CI CM GA GN GQ GW ML MR NE SN TD TG

121 Ep: the epo has been informed by wipo that ep was designated in this application
WWE Wipo information: entry into national phase

Ref document number: 0517847

Country of ref document: GB

122 Ep: pct application non-entry in european phase