CN105656959A - 基于路由机制的多终端pub/sub消息同步方法 - Google Patents
基于路由机制的多终端pub/sub消息同步方法 Download PDFInfo
- Publication number
- CN105656959A CN105656959A CN201410639742.9A CN201410639742A CN105656959A CN 105656959 A CN105656959 A CN 105656959A CN 201410639742 A CN201410639742 A CN 201410639742A CN 105656959 A CN105656959 A CN 105656959A
- Authority
- CN
- China
- Prior art keywords
- message
- theme
- routing
- rule
- server
- 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.)
- Pending
Links
- 238000000034 method Methods 0.000 title abstract description 13
- 230000007246 mechanism Effects 0.000 title abstract description 8
- 230000001360 synchronised effect Effects 0.000 abstract description 3
- 230000000977 initiatory effect Effects 0.000 abstract 1
- 230000008878 coupling Effects 0.000 description 10
- 238000010168 coupling process Methods 0.000 description 10
- 238000005859 coupling reaction Methods 0.000 description 10
- 230000005540 biological transmission Effects 0.000 description 4
- 230000008569 process Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 230000008901 benefit Effects 0.000 description 1
- 230000007812 deficiency Effects 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000008447 perception Effects 0.000 description 1
Landscapes
- Computer And Data Communications (AREA)
Abstract
本发明涉及一种基于路由机制的多终端PUB/SUB消息同步方法，为基于订阅发布模型应用的服务器定义消息路由规则；当所述服务器接收到所述应用发送的消息后，所述服务器根据消息的接收主题查找匹配的路由规则；若所述服务器在消息路由规则中查找到匹配的路由规则，则所述服务器根据路由规则中的路由方式向路由规则目的主题发起相应的消息路由操作。本发明能够在应用发布消息到一个主题后，服务器根据主题查询消息路由规则向查询到的路由规则对应的目的主题发起消息同步操作，进一步可以通过路由规则的定制实现用户多终端的消息同步，实现了自动化、可定制化的多终端消息同步。
Description
技术领域
本发明涉及通信领域的多终端消息同步技术，具体地说是一种基于路由机制的多终端PUB/SUB消息同步方法。
背景技术
订阅发布模型，是一种异步消息传输模型，它定义了应用程序模型，把消息的发布者与消息的订阅者以一种松耦合的方式联系在一起，它们不需要知道对方的任何信息，甚至不需要知道对方是否存在，就可以实现消息的异步传递。发布者和订阅者之间通过主题交换信息：发布者把信息发布到主题字符串，订阅者在主题上注册并接收信息，通过这种方式主题字符串把发布者和订阅者连接起来。
现有技术中，同一用户如果拥有多个终端设备，多个终端设备同时使用基于订阅发布模型的应用程序，任意一个终端发布消息给其订阅者时，该用户的各终端之间无法感知其他终端的动作，即消息不能做到发送方的多个终端同步，导致用户可能会重复在多个终端中执行相同的操作，给用户带来极大的不便。
发明内容
针对现有技术的不足，本发明提供一种基于路由机制的多终端PUB/SUB消息同步方法，可在基于订阅发布模型的消息系统中实现多终端消息的同步。
本发明为实现上述目的所采用的技术方案是：一种基于路由机制的多终端PUB/SUB消息同步方法，包括以下步骤：
步骤1：为基于订阅发布模型应用的服务器定义消息路由规则；
步骤2：当所述服务器接收到所述应用发送的消息后，所述服务器根据消息的接收主题查找匹配的路由规则；
步骤3：若所述服务器在消息路由规则中查找到匹配的路由规则，则所述服务器根据路由规则中的路由方式向路由规则目的主题发起相应的消息路由操作。
若所述匹配到的消息路由规则目的主题为所述应用所在用户对应的其他终端的主题，且消息路由方式为复制消息，则向用户的其他终端发起消息同步操作。
所述消息路由规则包括源主题、目的主题、路由方式。
所述路由方式包括复制消息、转发消息、丢弃消息、忽略消息。
所述查找匹配的路由规则的过程为：比较服务器接收消息的目的主题与消息路由规则中的源主题，找到与消息路由规则中源主题相同或属于源主题类中一个具体主题的目的主题和消息路由方式，即为匹配的路由规则。
所述比较服务器接收消息的目的主题与消息路由规则中的源主题包括：完全比较和模糊比较。
所述完全比较为：服务器接收消息的目的主题与消息路由规则中的源主题是同一个主题。
所述模糊比较为：消息路由规则的源主题是一类主题，服务器接收消息的目的主题属于其中一个。
本发明具有以下有益效果及优点：
本发明能够在所述基于订阅发布模型的应用中，若应用发布消息到一个主题后，服务器可以根据主题查询消息路由规则向查询到的路由规则对应的目的主题发起消息同步操作，进一步可以通过路由规则的定制实现用户多终端的消息同步，避免了现有技术中由于不能同步所导致的用户可能会重复在多个应用终端中执行相同的操作的问题，实现了自动化、可定制化的多终端消息同步。
附图说明
图1为本发明的方法流程图。
具体实施方式
下面结合附图及实施例对本发明做进一步的详细说明。
以下将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，应当理解，此处所描述的实施例仅仅用于说明和解释本发明，但不用于限定本发明。
如图1所示，本实施例的所述基于路由机制的多终端PUB/SUB消息同步方法包括：
图中客户端1-1、客户端1-2、客户端2是三个基于订阅发布模型的应用的客户端，客户端1-1和客户端1-2是客户1的两个终端，客户端2是客户2的一个终端；服务器是基于订阅发布模型的服务器，其中内置了消息路由模块。假设消息路由规则已经定义好，并且已经加载到服务器中。
具体的，所述消息路由规则包括源主题、目的主题、路由方式。
具体的，所述路由方式包括复制消息、转发消息、丢弃消息、忽略消息。
S101：消息发送方的第一终端，即所述客户1的客户端1-1向客户2发送消息。消息首先发往客户2在服务器的主题上。
S102：服务器接收到客户1的终端即所述客户端1-1发来的消息，向客户1的终端即所述客户端1-1回复接收到消息的通知。
S103：服务器根据接收到的客户1的终端即所述客户端1-1发来的消息的接收者的主题，调用消息路由模块，查找是否有匹配的路由规则。若没有匹配到相关路由规则，则消息正常转发给接收者。此处，查找到匹配的路由规则，路由规则的目的主题为客户端1-2的主题，路由方式为复制消息。
其中，所述查找匹配的路由规则的过程为：比较服务器接收消息的目的主题与消息路由规则中的源主题，找到与消息路由规则中源主题相同或属于源主题类中一个具体主题的目的主题和消息路由方式，即为匹配的路由规则。
具体的，所述比较服务器接收消息的目的主题与消息路由规则中的源主题包括：完全比较和模糊比较。
具体的，所述完全比较为：服务器接收消息的目的主题与消息路由规则中的源主题是同一个主题。
具体的，所述模糊比较为：消息路由规则的源主题是一类主题，服务器接收消息的目的主题属于其中一个。
S104：S103中根据消息接收者的主题，查询到了匹配的路由规则，根据路由规则中的目的地址及路由方式，将消息复制一份发送给客户1的第二终端即所述终端1-2。
其中，所述路由方式为复制消息，即将接收到的消息复制一份到路由规则目的主题，消息仍会发送到原目的主题。
S105：客户1的其他终端即所述客户端1-2向服务器回复已接收到消息的通知。
S106：服务器向客户2的终端即所述终端2发送客户1发送给客户2的消息。
S107：客户2的终端即所述客户端2向服务器回复已接收到消息的通知。流程结束。
客户1的非消息发送终端即客户端1-2接收到客户1消息发送终端即客户端1-1发送给客户2的消息，实现了发送方的多终端消息同步操作。
Claims (8)
1.一种基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：包括以下步骤：
步骤1：为基于订阅发布模型应用的服务器定义消息路由规则；
步骤2：当所述服务器接收到所述应用发送的消息后，所述服务器根据消息的接收主题查找匹配的路由规则；
步骤3：若所述服务器在消息路由规则中查找到匹配的路由规则，则所述服务器根据路由规则中的路由方式向路由规则目的主题发起相应的消息路由操作。
2.根据权利要求1所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：若所述匹配到的消息路由规则目的主题为所述应用所在用户对应的其他终端的主题，且消息路由方式为复制消息，则向用户的其他终端发起消息同步操作。
3.根据权利要求1或2所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述消息路由规则包括源主题、目的主题、路由方式。
4.根据权利要求3所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述路由方式包括复制消息、转发消息、丢弃消息、忽略消息。
5.根据权利要求1所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述查找匹配的路由规则的过程为：比较服务器接收消息的目的主题与消息路由规则中的源主题，找到与消息路由规则中源主题相同或属于源主题类中一个具体主题的目的主题以及消息路由方式，即为匹配的路由规则。
6.根据权利要求5所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述比较服务器接收消息的目的主题与消息路由规则中的源主题包括：完全比较和模糊比较。
7.根据权利要求6所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述完全比较为：服务器接收消息的目的主题与消息路由规则中的源主题是同一个主题。
8.根据权利要求6所述的基于路由机制的多终端PUB/SUB消息同步方法，其特征在于：所述模糊比较为：消息路由规则的源主题是一类主题，服务器接收消息的目的主题属于其中一个。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201410639742.9A CN105656959A (zh) | 2014-11-13 | 2014-11-13 | 基于路由机制的多终端pub/sub消息同步方法 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201410639742.9A CN105656959A (zh) | 2014-11-13 | 2014-11-13 | 基于路由机制的多终端pub/sub消息同步方法 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN105656959A true CN105656959A (zh) | 2016-06-08 |
Family
ID=56478682
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201410639742.9A Pending CN105656959A (zh) | 2014-11-13 | 2014-11-13 | 基于路由机制的多终端pub/sub消息同步方法 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN105656959A (zh) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106528307A (zh) * | 2016-11-14 | 2017-03-22 | 济南浪潮高新科技投资发展有限公司 | 一种可扩展的消息路由实现方法 |
| CN110365587A (zh) * | 2018-03-26 | 2019-10-22 | 阿里巴巴集团控股有限公司 | 设备间通信方法、装置、设备和存储介质 |
| US10841390B2 (en) | 2018-11-22 | 2020-11-17 | Industrial Technology Research Institute | Method and system for synchronizing publication and subscription of message queues |
| CN113609384A (zh) * | 2021-07-16 | 2021-11-05 | 广州云从凯风科技有限公司 | 数据订阅方法、设备及计算机存储介质 |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20060036679A1 (en) * | 2002-07-26 | 2006-02-16 | International Business Machines Corporation | Pub/sub message invoking a subscribers client application program |
| CN102227927A (zh) * | 2008-11-28 | 2011-10-26 | 三星电子株式会社 | 用于提供通信历史的方法和装置 |
| CN103647776A (zh) * | 2013-12-13 | 2014-03-19 | 国家图书馆 | 面向多终端的媒体资源同步方法和系统 |
| CN103944924A (zh) * | 2014-05-15 | 2014-07-23 | 重庆邮电大学 | 一种基于RESTful的泛在网发布订阅中间件模型 |
-
2014
- 2014-11-13 CN CN201410639742.9A patent/CN105656959A/zh active Pending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20060036679A1 (en) * | 2002-07-26 | 2006-02-16 | International Business Machines Corporation | Pub/sub message invoking a subscribers client application program |
| CN102227927A (zh) * | 2008-11-28 | 2011-10-26 | 三星电子株式会社 | 用于提供通信历史的方法和装置 |
| CN103647776A (zh) * | 2013-12-13 | 2014-03-19 | 国家图书馆 | 面向多终端的媒体资源同步方法和系统 |
| CN103944924A (zh) * | 2014-05-15 | 2014-07-23 | 重庆邮电大学 | 一种基于RESTful的泛在网发布订阅中间件模型 |
Non-Patent Citations (2)
| Title |
|---|
| 王广泽: ""基于Pub/Sub模式的智能消息中间件研究"", 《信息技术》 * |
| 马建刚等: ""面向大规模分布式计算发布订阅系统核心技术"", 《软件学报》 * |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106528307A (zh) * | 2016-11-14 | 2017-03-22 | 济南浪潮高新科技投资发展有限公司 | 一种可扩展的消息路由实现方法 |
| CN106528307B (zh) * | 2016-11-14 | 2019-08-02 | 浪潮通用软件有限公司 | 一种可扩展的消息路由实现方法 |
| CN110365587A (zh) * | 2018-03-26 | 2019-10-22 | 阿里巴巴集团控股有限公司 | 设备间通信方法、装置、设备和存储介质 |
| US10841390B2 (en) | 2018-11-22 | 2020-11-17 | Industrial Technology Research Institute | Method and system for synchronizing publication and subscription of message queues |
| CN113609384A (zh) * | 2021-07-16 | 2021-11-05 | 广州云从凯风科技有限公司 | 数据订阅方法、设备及计算机存储介质 |
| CN113609384B (zh) * | 2021-07-16 | 2024-05-10 | 广州云从凯风科技有限公司 | 数据订阅方法、设备及计算机存储介质 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US9948575B2 (en) | Issuing method for forwarding adjacency link | |
| US9319241B2 (en) | Flow-based packet transport device and packet management method thereof | |
| EP2866395B1 (en) | Maximum transmission unit negotiation method and data terminal | |
| US11307843B2 (en) | Automatic device-to-device firmware upgrade of a wireless network | |
| CN107196859B (zh) | 消息转发方法、广播方法、消息应答方法及通信设备 | |
| US10148739B2 (en) | M2M data querying and invoking methods, querying and invoking devices, and system | |
| CN105656959A (zh) | 基于路由机制的多终端pub/sub消息同步方法 | |
| CN108243262A (zh) | Arp表的学习方法、装置及网络三层设备 | |
| CN104270302B (zh) | 在线订单的传送系统及传送方法 | |
| CN103546258A (zh) | 一种数据传输方法及装置 | |
| CN102223378B (zh) | 一种文件同步方法和系统 | |
| US20170142004A1 (en) | Path Setup in a Mesh Network | |
| US9350606B2 (en) | System and method for assigning server to terminal and efficiently delivering messages to the terminal | |
| CN105357329A (zh) | 跨idc网络环境下业务数据的传输方法、装置及系统 | |
| RU2586598C2 (ru) | Тиражирование данных | |
| JP2016111428A (ja) | ゲートウェイ装置、スマートメータおよび無線メッシュネットワーク | |
| WO2016074572A1 (zh) | 业务数据处理方法、装置及系统 | |
| US8755397B2 (en) | Asynchronous communication in an unstable network | |
| CN103281369A (zh) | 报文处理方法及广域网加速控制器woc | |
| CN106230730A (zh) | 一种组播传输方法和装置 | |
| CN105119805A (zh) | 一种即时通信数据传输方法及即时通信数据传输系统 | |
| KR20140142138A (ko) | 무선 네트워크에서 멀티캐스트 그룹을 관리하는 장치 및 방법 | |
| CN105530189A (zh) | Trill网络中转发报文的方法和路由桥 | |
| KR20150033871A (ko) | 분산 이동성 관리 방법 및 장치 | |
| CN102932360A (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 | ||
| WD01 | Invention patent application deemed withdrawn after publication | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20160608 |