[go: up one dir, main page]

CN1905535A - 发布/预订消息传递方法和系统 - Google Patents

发布/预订消息传递方法和系统 Download PDF

Info

Publication number
CN1905535A
CN1905535A CN200610071449.2A CN200610071449A CN1905535A CN 1905535 A CN1905535 A CN 1905535A CN 200610071449 A CN200610071449 A CN 200610071449A CN 1905535 A CN1905535 A CN 1905535A
Authority
CN
China
Prior art keywords
send
message
reservation request
intermediary device
subject information
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
CN200610071449.2A
Other languages
English (en)
Other versions
CN1905535B (zh
Inventor
巴莱特·V·贝迪
安德鲁·J·斯坦福-克拉克
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.)
International Business Machines Corp
Original Assignee
International Business Machines 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 International Business Machines Corp filed Critical International Business Machines Corp
Publication of CN1905535A publication Critical patent/CN1905535A/zh
Application granted granted Critical
Publication of CN1905535B publication Critical patent/CN1905535B/zh
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • 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/55—Push-based network services
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F17/00—Digital computing or data processing equipment or methods, specially adapted for specific functions
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F17/00—Digital computing or data processing equipment or methods, specially adapted for specific functions
    • G06F17/40—Data acquisition and logging
    • 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
    • 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/03—Protocol definition or specification 

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • Signal Processing (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Data Mining & Analysis (AREA)
  • Databases & Information Systems (AREA)
  • General Physics & Mathematics (AREA)
  • Mathematical Physics (AREA)
  • Software Systems (AREA)
  • Computer Security & Cryptography (AREA)
  • Computer Hardware Design (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Computer And Data Communications (AREA)

Abstract

本发明涉及一种在发布/预订消息传递系统中管理预订请求的方法。客户可经由一个协议在消息中介器注册预订，并且接收匹配有关另一个协议的预订的消息。

Description

发布/预订消息传递方法和系统
技术领域
本发明一般来说涉及数据处理网络中的消息通信领域，尤其涉及网络上的发布/预订(pub/sub)消息传递(messaging)。
背景技术
消息传递系统通过提供路由和格式化服务的服务器(“中介器”)网络传递消息。若干消息中介器支持发布/预订模式作为散发消息的途径。这涉及一组一个或多个发布者发送通信给已经注册了他们对接收某种类型的通信的兴趣的一组一个或多个订户。订户通知中介器有关他们希望接收的消息类型，并且将该信息存储在中介器端。发布者发送他们的消息到中介器，其比较消息类型(例如，检查消息头主题字段或检查消息内容)与它所存储的订户信息，以便确定该消息应该被转发给哪个订户。订户通常不关心消息被发送到哪里，而且，订户通常对他们已经收到的消息是从哪里发送的不感兴趣。消息中介器还可以在将他们传送到订户之前，执行附加的功能，如对接收的消息进行滤除、格式化或其它不同的处理。
发布/预订消息允许预订用户接收有关感兴趣主题的最近信息(例如，股票价格、最后新闻、购物特价或天气)。在典型的发布/预订环境中，若干发布者应用发送若干消息给可能遍布网络地处偏远的订户应用。计算机利用这样的消息传递通信的网络包括：因特网、内联网或任何计算机网络。
消息中介器按照向中介器注册的有效预订管理消息的发布。发布者和订户还可与中介器的网络互动，每一个中介器传播预订并且转发发布给网络内的其他中介器。这样的网络通常包括，位于通信集线器的一个或多个消息中介器，通过该集线器发布者和订户通信。在此所使用的术语“中介器”应该理解为包含单个中介器或作为网络一起工作以便提供中介服务的多个中介器。
消息中介器通常利用单个通信协议或传输机制彼此通信并且和订户通信。这样的协议或传输机制将具有用来确定中介器处理消息的方式的相关联的“服务质量”。已知的服务质量特征包括以下因素：诸如网络带宽要求、吞吐量、延迟、差错率、压缩、加密或数据流所要求的存储器量或缓冲器空间。服务质量可能不对所有消息或所有订户适合。应用不适合的协议可导致许多消息不以最有效率的方式处理。中介器软件可以实现比由通信协议自身提供的更高的服务质量，但是这导致难以管理复杂的系统。还可能使用支持最高服务质量的通信协议，但是当处理仅仅要求较低服务质量的消息时，这招致日常开支，并且许多消息不以最有效率的方式处理。
美国公开第2003/0115317 A1公开了一种发布/订户环境中的通信方法，用于通过确定足以对有关某个主题在消息之间交换的最低服务质量，主要在中介器之间经济地传递消息。这减少了关联于对中介器之间的通信不必要地使用更高服务质量的日常开支。在任何时候，它依赖于中介器能够接受有关一组不同协议的通信量(traffic)，这允许发送中介器基于服务质量要求选择它认为合适的任何协议。该方法与中介器之间的通信有关，并且没有解决中介器-订户通信的问题。
订户可以利用通信协议与中介器连接并预订，他们还可以为其它交易使用该通信协议。然而，订户可能想要这种其它交易优先于发布消息，并且订户可被堵塞他的网络的发布的消息阻碍。存在对改善的中介器-订户通信的需要。
美国专利第6,101,545公开了一种消息处理系统，其中，发送器可指定消息交付类型以便指定消息是交付重要还是时间重要。接着消息交付选择器基于消息交付类型选择协议(例如，传输控制协议(TCP)或用户数据报协议(UDP))。消息的发送器可以指定消息交付类型，其被分析并被用来控制消息传输协议的选择，但该选择中没有涉及关于消息的预定接受者的信息。在消息中介器环境中，实现基于美国6,101,545的方案的企图会导致许多消息被无效率地处理，因为由发送器指定的高服务质量即使接受者不要求也被兑现。在此系统中，预定的接受者可被堵塞他的网络的消息阻碍。
存在对消息中介器网络的更有效的方案的需求，其致力于中介器和订户之间的通信。
发明内容
因此，本发明提供了一种在发布/预订消息传递系统中通信的方法，所述消息传递系统包含：向中介器发布信息的多个发布者和预订经由中介器从一个或多个发布者接收的信息的多个订户，所述方法包括以下步骤：经由第一通信协议接收预订请求，指示请求订户感兴趣的主题信息；确定所述预订请求是否包括请求要经由第二通信协议发送的发布的信息的指示符；以及响应于所述确定步骤，如果所述预订请求包括所述指示符，则经由所述第二通信协议发送主题信息，否则经由所述第一协议发送主题信息。
根据另一个方面，提供了一种消息中介器，用于管理在发布/预订消息传递系统中的通信，该消息传递系统包含向中介器发布信息的多个发布者和预订经由所述中介器从一个或多个发布者接收的信息的多个订户，所述中介器包含：接收装置，用于经由第一通信协议接收预订请求，指示请求订户感兴趣的主题信息；确定装置，用于确定所述预订请求是否包括请求要经由第二通信协议发送的发布的信息的指示符；以及发送装置，响应于所述确定装置，如果所述预订请求包括所述指示符，则经由所述第二通信协议发送主题信息，否则经由所述第一协议发送主题信息。
根据另一个方面，本发明提供了一种计算机程序，用于管理在发布/预订消息系统中的通信。
附图说明
现在参照下面的附图，仅仅通过举例描述本发明的优选实施例，附图中：
图1是消息系统的示意性表示，其中发布者和订户应用经由消息中介器通信；
图2示出了主题树的例子；
图3是图示根据优选实施例的预订概略的注册的流程图；以及
图4图示了根据优选实施例的消息中介器的有关组件。
具体实施方式
IBM公司的WebSphereMQ族消息产品是支持分布式异质环境中不同系统上运行的应用程序之间的互操作的已知产品。(WebSphere是国际商业机器公司的商标)。计算机利用消息队列经由网络通信，该网络可以是因特网、内联网或任何其他的计算机网络。WebSphere MQ产品使得应用程序能够发送消息到其他应用程序的输入队列，由此实现可穿过计算机网络传播的应用程序之间的消息传递，而不要求在应用程序之间的专门的端对端连接。然而，在应用程序之间可能相互的连接的映射可能相当复杂。
代替在系统之间具有直接连接，网络架构包括与其他系统连接的通信集线器，由此简化所述复杂性。消息中介能力在通信集线器提供，以便提供智能消息路由和应用的集成。消息中介功能包括：利用包括在消息头中的消息“主题”信息，按照不同应用程序的信息要求的规则和知识来智能地路由消息的能力。另一个消息中介功能是利用目标应用或目标系统的消息格式要求变换消息格式，从而调和在系统和应用之间的差异的能力。
通过提供用于应用程序之间交换的消息的智能路由和变换服务，来提供这种消息中介能力的产品的例子，是IBM公司的WebSphere业务集成消息中介器。这样的消息中介能力可被集成在数据处理系统的其他组件内，例如，在操作系统软件内。
多中介器布局可以被用来跨越过程、机器和地理位置分配负荷。当存在大量的客户时，其有益于跨越几个中介器分配这些客户，从而减少中介器的资源要求并减少若特定服务器故障的影响。
图1示出了其中一个或者多个发布者应用10、20、30发送消息到消息中介器70的网络例子。消息中介器可以包含一个或多个订户应用40、50、60，其已经注册了他们对从发布者接收指定的消息类型的兴趣。在典型的发布/预订消息中介器环境中，发布者不明确地标识目标订户，并且可能不知道订户是谁。发布者和订户应用不包含专门的端对端连接，并且有时可能不并发地连接到中介器网络。例如，订户应用可位于遥远的地理位置，而且经由仅仅在某些时间可用的通信卫星连接到中介器。
发布者对他们正在发布的消息指定主题名称，而订户对他们感兴趣接收的消息指定主题名称。消息中介器70比较进入的消息和订户的预订概略，以便标识匹配，并传递匹配消息给用于转发到相关订户的输出组件(未示出)。例如，订户40可对伦敦的天气感兴趣，而且可发送预订请求给诸如“天气/伦敦”之类的中介器。中介器对照在主题树中的适合的主题存储该预定信息，接着，如果消息从发布者到达中介器，并且消息头包括主题标识符“天气/伦敦”，则中介器比较该消息与它的预订列表，并且标识出，所述消息匹配用于订户40的预订概略。中介器接着路由消息到订户40。中介器70可以是过程、一组过程或其他执行组件，或可以被包括在其他应用代码内。然而，中介器的逻辑功能将在网络中的某处存在。
图2示出了示例主题树。主题树通常基于在中介器处接收的订户请求创建。在此例子中可看到，主要主题是“马”，关于该主要主题的信息被发布。可将该主题划分为三类：颜色；饲料和装备。每类接着可被细分为例如颜色-杂色-草莓色。当在中介器处接收发布时，对照树结构解析以便匹配已经向中介器注册的预订请求。例如，订户可提交下面的预订给中介器：“马/颜色/栗色/暗”。
传统的消息中介器方案对所有用于发送发布到相关的订户的消息使用了相同的传输机制或协议。例如，在IBM的WebSphere业务集成消息中介器产品里面的消息中介器可被配置为：在IBM的WebSphere消息传递软件控制下，总是利用交易有保证的交付发送消息。在此例子中，消息传输机制能够满足用于交易消息交付的发布者指定的要求。然而，存在各种消息或订户，对于它们交易消息交付是不必要的，并且对于这样的情况，可以采用为效率而优化的低日常开支交付机制而不是交付保证，例如，股价更新。
本发明实现了：在某些情况下，订户可能期望利用一个协议连接中介器，注册预订，但是使随后的发布在不同的协议上发送。这按照优选实施例通过添加预订请求来指定协议名称和协议特定的标识符是能够做到的。例如，为了接收SMS消息，协议名称将会是SMS，并且ID将会是电话号码(例如，目的地)。
参照图3，现在描述向中介器注册预订概略的优选方法。在步骤305，中介器(见图1的参考标号70)接收预订请求。预订请求包括显式主题层次字符串(例如，天气/汉普郡(hampshire)/hursley)。根据本发明的一个实施例，预订请求包括两个附加的字段：一个表示交付协议(如果这由订户请求从而与请求协议不同的话)和交付地址(如果这由订户请求从而不同于请求地址的话)。这样的预订请求例子是“天气/汉普郡(hampshire)/hursley”“MQTelemetry(MQ遥感勘测)”，“fred”。MQTelemetry是由订户请求的交付协议，而fred是由订户请求的交付地址。交付地址可与请求人的地址不同。
在步骤310，中介器将预订请求解析为主题字符串、输出协议和输出地址。
接着在步骤315进行检查，以便确定当收到预订时是否要经由相同的协议发送发布的消息。如果将不采用第二协议，则在步骤320，将订户与输入协议相关联。接着在步骤325，将订户与返回地址相关联。返回地址可与预订地址相同或者不同，并且可在预订请求中指示。接着，在步骤330，将订户与主题相关联。在返回地址上监听的订户将会接收所期望的发布。
如果发布的消息将经由不同协议发送，则如由点线指示的那样，在步骤315之后执行步骤340。在步骤340，将订户在步骤325与返回地址相关联之前，与指定的输出协议相关联。
根据本发明的另一个实施例，订户可指定他想要在预定时间帧期间将发布发送给他。例如，在正常业务时间期间对于在线信用卡验证，可利用ISDN将超级市场连接到网络，并且使用在该连接上适合于应用的协议，向中介器预订与条形码目录更新相关的发布。然而，超级市场不想接收经由与会堵塞网络并且干扰客户交易的协议相同的协议发送的发布。根据该实施例，超级市场可利用一个协议向中介器预订，并且在业务时间期间经由在卫星广播网络上的第二协议，或当超级市场对业务关闭时经由预订协议，接收发布。
根据本发明的该实施例，如果在步骤315，确定输出协议可能与预订协议不同，则在步骤335进行检查，以便确定预订请求是否包括时间标准。如果该请求没有指定时间标准，则在步骤340将订户与输出协议相关联，接着在步骤325与返回地址相关联。
然而，如果在步骤335，确定预订请求不包括时间标准，则在步骤345，在中介器中将订户与时间标准相关联，并且接着在步骤340与输出协议相关联。
可以由订户请求时间标准，使得在某些时间之间，即在超级市场的开门时间期间，发布不被发送到返回地址。在此情形中，中介器检查在发布被发送到订户之前已经满足时间标准。可以经由第一或第二协议发送发布，并且将由中介器保持，直到时间标准已经被满足。
根据本发明的另一个实施例，可以由订户请求时间标准，使得依赖于什么时候发送发布，经由输入协议或输出协议将发布发送到返回地址。要理解到，本发明可以是伸缩的，使得发布可在不同的时间帧内经由更大数量的协议发送并且到任何数量的订户返回地址。
图4示出了根据本发明的实施例的消息中介器的组件。消息中介器70包含匹配引擎100，其经由第一通信协议从订户接收预订请求(步骤305)。(验证的适合于在本发明中应用的已知协议包括HTTP、WebSphere MQ、WebSphere MQ移动、WebSphere MQ Telemetry Transport(遥感勘测传输)和WebSphere MQ实时。然而，可以想见，本发明能够利用其它的通信协议)。
经由输入节点80在中介器接收预订请求，并且向中介器注册。匹配引擎使用解析器组件105将每个预订请求解析为主题字符串、输出协议和输出地址。将主题字符串存储在主题空间110。地址分配器120分配输出地址(见图3的步骤325)，而协议分配器130分配输出协议或多个输出协议(图3的步骤320和340)。时间分配器140在预订请求包括时间标准时被使用(如在步骤335所确定的)。经由输出节点85将发布发送到订户。
发布的消息从发布者(10、20、30)发送到中介器70。当消息在中介器处接收时，对照主题空间110中的树结构对它解析，以便匹配向中介器注册的预订请求。预订请求可在主题空间110向树结构存储，或可存储在从主题空间可访问的分开的查找表(未示出)中。服从包括在预订请求(协议、时间、返回地址)中的条件，发布的消息接着从中介器发送到订户。
通过智能中间件产品的应用到应用消息传送提供了对在不同数据处理技术之间的互操作的问题的解决方案。通过利用由订户有效地选择的通信协议，使得消息中介器能够发送每个消息，来提供可靠的消息交付和有效率的消息发送性能，本发明提供了相对已知的发布/预订环境的优点。

Claims (12)

1.一种在发布/预订消息传递系统中通信的方法，所述消息传递系统包含：向中介器发布信息的多个发布者和预订经由中介器从一个或多个发布者接收的信息的多个订户，所述方法包括以下步骤：
经由第一通信协议接收预订请求，指示请求订户感兴趣的主题信息；
确定所述预订请求是否包括请求要经由第二通信协议发送的发布的信息的指示符；以及
响应于所述确定步骤，如果所述预订请求包括所述指示符，则经由所述第二通信协议发送主题信息。
2.如权利要求1所述的方法，还包括以下步骤：如果所述预订请求不包括所述指示符，则经由所述第一通信协议发送主题信息。
3.如权利要求1所述的方法，其中所述预订请求还包括与所述第二通信协议相关联的时间标准，并且所述确定步骤包括以下步骤：响应于确定所述主题信息将在所述时间标准内一次发送，如果满足所述时间标准，则经由所述第二通信协议发送所述主题信息。
4.如权利要求3所述的方法，还包括以下步骤：如果不满足所述时间标准，则经由所述第一通信协议发送主题信息。
5.如权利要求3所述的方法，还包括以下步骤：延迟发布的发送直到时间出现在所述时间标准内。
6.如前面的权利要求中的任何一个所述的方法，还包括以下步骤：
确定所述预订请求是否指定交付地址；以及
如果指定，则发送主题信息给交付地址，否则发送主题信息给请求地址。
7.一种消息中介器，用于管理在发布/预订消息传递系统中的通信，该消息传递系统包含向中介器发布信息的多个发布者和预订经由所述中介器从一个或多个发布者接收的信息的多个订户，所述中介器包含：
接收装置，用于经由第一通信协议接收预订请求，指示请求订户感兴趣的主题信息；
确定装置，用于确定所述预订请求是否包括请求要经由第二通信协议发送的发布的信息的指示符；以及
发送装置，用于响应于所述确定装置，如果所述预订请求包括所述指示符，则经由所述第二通信协议发送主题信息。
8.如权利要求7所述的消息中介器，还包括：如果所述预订请求不包括所述指示符，则经由所述第一通信协议发送主题信息的装置。
9.如权利要求7所述的消息中介器，其中所述确定装置还包括用于确定所述预订请求是否包含与所述第二通信协议相关联的时间标准的装置。
10.如权利要求9所述的消息中介器，还包括用于延迟发布的发送直到时间出现在所述时间标准内的装置。
11.如权利要求7所述的消息中介器，还包括：
用于确定所述预订请求是否指定交付地址的装置；以及
如果指定，则发送主题信息给交付地址，否则发送主题信息给请求地址的装置。
12.一种计算机程序，包括当所述程序在计算机上运行时适合于执行权利要求1至6的所有步骤的程序代码装置。
CN200610071449.2A 2005-07-30 2006-03-28 发布/预订消息传递方法和系统 Expired - Fee Related CN1905535B (zh)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
GB0515713.6 2005-07-30
GB0515713A GB2428828A (en) 2005-07-30 2005-07-30 Publish/subscribe messaging system

Publications (2)

Publication Number Publication Date
CN1905535A true CN1905535A (zh) 2007-01-31
CN1905535B CN1905535B (zh) 2010-06-23

Family

ID=34983800

Family Applications (1)

Application Number Title Priority Date Filing Date
CN200610071449.2A Expired - Fee Related CN1905535B (zh) 2005-07-30 2006-03-28 发布/预订消息传递方法和系统

Country Status (3)

Country Link
US (1) US20070067389A1 (zh)
CN (1) CN1905535B (zh)
GB (1) GB2428828A (zh)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102843306A (zh) * 2011-06-21 2012-12-26 腾讯科技（深圳）有限公司 微博信息发布方法及系统

Families Citing this family (22)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
GB0521355D0 (en) * 2005-10-19 2005-11-30 Ibm Publish/subscribe system and method for managing subscriptions
US9756114B2 (en) * 2007-11-23 2017-09-05 International Business Machines Corporation Asynchronous response processing in a web based request-response computing system
US20100299140A1 (en) * 2009-05-22 2010-11-25 Cycorp, Inc. Identifying and routing of documents of potential interest to subscribers using interest determination rules
US9047589B2 (en) * 2009-10-30 2015-06-02 Verisign, Inc. Hierarchical publish and subscribe system
US10552239B2 (en) * 2009-12-01 2020-02-04 International Business Machines Corporation Message recall
US8671306B2 (en) 2010-12-21 2014-03-11 Microsoft Corporation Scaling out a messaging system
US10002033B2 (en) 2012-02-07 2018-06-19 Microsoft Technology Licensing, Llc Efficiently receiving messages across a large number of messaging entities
US9344391B2 (en) 2012-03-14 2016-05-17 Microsoft Technology Licensing, Llc High density hosting for messaging service
US9882950B2 (en) 2012-06-13 2018-01-30 All Purpose Networks LLC Methods and systems of an all purpose broadband network
US9084143B2 (en) 2012-06-13 2015-07-14 All Purpose Networks LLC Network migration queuing service in a wireless network
US8565689B1 (en) 2012-06-13 2013-10-22 All Purpose Networks LLC Optimized broadband wireless network performance through base station application server
US9219541B2 (en) 2012-06-13 2015-12-22 All Purpose Networks LLC Baseband data transmission and reception in an LTE wireless base station employing periodically scanning RF beam forming techniques
US9503927B2 (en) 2012-06-13 2016-11-22 All Purpose Networks LLC Multiple-use wireless network
WO2015020575A1 (en) * 2013-08-09 2015-02-12 Telefonaktiebolaget L M Ericsson (Publ) Communication network node
US9912619B1 (en) * 2014-06-03 2018-03-06 Juniper Networks, Inc. Publish-subscribe based exchange for network services
CN109428922B (zh) * 2017-08-29 2020-09-08 华为技术有限公司 一种订阅发布方法及服务器
US11026090B2 (en) 2018-01-08 2021-06-01 All Purpose Networks, Inc. Internet of things system with efficient and secure communications network
WO2020101747A1 (en) 2018-01-08 2020-05-22 All Purpose Networks, Inc. Publish-subscribe broker network overlay system
GB2588107B (en) * 2019-10-07 2022-11-02 British Telecomm Secure publish-subscribe communication methods and apparatus
CN111970363B (zh) * 2020-08-17 2022-08-16 北京金山云网络技术有限公司 基于物联网的数据处理方法及装置
US11683400B1 (en) 2022-03-03 2023-06-20 Red Hat, Inc. Communication protocol for Knative Eventing's Kafka components
CN114866504B (zh) * 2022-03-25 2024-02-23 安徽南瑞中天电力电子有限公司 一种基于mqtt消息协议的能源控制器进程间的通信方法

Family Cites Families (15)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
KR100325961B1 (ko) * 1999-07-16 2002-03-07 통신시스템에서의 착신응답 대기시간을 이용한정보제공방법 및 그 장치
GB2354913B (en) * 1999-09-28 2003-10-08 Ibm Publish/subscribe data processing with publication points for customised message processing
US6801936B1 (en) * 2000-04-07 2004-10-05 Arif Diwan Systems and methods for generating customized bundles of information
US20020019812A1 (en) * 2000-06-16 2002-02-14 Board Karen Eleanor System and service for receiving, customizing, and re-broadcasting high-speed financial data to users operating wireless network-capable devices
CN1337811A (zh) * 2000-08-03 2002-02-27 北京新太利通信技术有限责任公司 通过无线网和互联网实现用户自定制手机功能菜单的方法
US20020024536A1 (en) * 2000-08-25 2002-02-28 Michal Kahan Method and apparatus for information aggregation and personalized display of the aggregated information
CA2361861A1 (en) * 2001-11-13 2003-05-13 Ibm Canada Limited-Ibm Canada Limitee Wireless messaging services using publish/subscribe systems
US7549096B2 (en) * 2001-11-16 2009-06-16 At&T Mobility Ii Llc Methods and systems for tracking and playing back errors in a communications network
US8122118B2 (en) * 2001-12-14 2012-02-21 International Business Machines Corporation Selection of communication protocol for message transfer based on quality of service requirements
GB0212820D0 (en) * 2002-06-01 2002-07-10 Ibm Method and system for information enrichment using distributed computer systems
US9124447B2 (en) * 2002-07-26 2015-09-01 International Business Machines Corporation Interactive client computer communication
US7366760B2 (en) * 2003-01-03 2008-04-29 Microsoft Corporation System and method for improved client server communications of email messages
US7349980B1 (en) * 2003-01-24 2008-03-25 Blue Titan Software, Inc. Network publish/subscribe system incorporating Web services network routing architecture
US20060090003A1 (en) * 2004-10-22 2006-04-27 Microsoft Corporation Rendezvousing resource requests with corresponding resources
US8060640B2 (en) * 2005-05-27 2011-11-15 Microsoft Corporation Combining SIP requests with SIP responses

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102843306A (zh) * 2011-06-21 2012-12-26 腾讯科技（深圳）有限公司 微博信息发布方法及系统
CN102843306B (zh) * 2011-06-21 2016-06-22 腾讯科技（深圳）有限公司 微博信息发布方法及系统

Also Published As

Publication number Publication date
GB2428828A (en) 2007-02-07
GB0515713D0 (en) 2005-09-07
US20070067389A1 (en) 2007-03-22
CN1905535B (zh) 2010-06-23

Similar Documents

Publication Publication Date Title
CN1905535B (zh) 发布/预订消息传递方法和系统
US7809813B2 (en) System and method for providing content-oriented services to content providers and content consumers
EP2122997B1 (en) Method and arrangement for mediating web services using uddi
US8566423B2 (en) Scalable publish/subscribe messaging systems and methods
CA2406262C (en) Method and system for content deployment and activation
US8639848B2 (en) Data communication efficiency
JP3980596B2 (ja) サーバを遠隔かつ動的に構成する方法およびシステム
US20070061282A1 (en) Data network information distribution
US7051073B1 (en) Method, system and program for efficiently distributing serial electronic publications
US20100093441A1 (en) Integration gateway
US8488448B2 (en) System and method for message sequencing in a broadband gateway
US8549122B2 (en) System and method for communication agent within a fully distributed network
US20080133646A1 (en) System and method for fully distributed network with agents
US6718369B1 (en) Method, system and program for efficiently distributing serial electronic publications
CN101193077A (zh) 用于订阅匹配的方法和系统
CN101326508A (zh) 智能消息传递应用编程接口
CN100407627C (zh) 一种实现端到端文件共享的系统及方法
CN106846115A (zh) 用于数字视听场所线下资源自助预订的方法、系统以及数字娱乐点播系统
US20090113024A1 (en) Multicase Downloading Using Path Information
EP1285522A1 (en) System for delivery and exchange of electronic data
US20090177753A1 (en) Retained publish/subscribe system
US20080141280A1 (en) Method for handling communication without centralized component within a fully distributed network
EP1119135A2 (en) Apparatus and method for a push service
GB2441627A (en) Information processing system with collaborating devices
US20110167171A1 (en) System and method for network content delivery

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
C14 Grant of patent or utility model
GR01 Patent grant
CF01 Termination of patent right due to non-payment of annual fee
CF01 Termination of patent right due to non-payment of annual fee

Granted publication date: 20100623

Termination date: 20190328