一种信息发布订阅平台及方法和信息发布订阅系统

摘要

本发明提供一种信息发布订阅平台及方法和信息发布订阅系统。该信息发布订阅平台包括信息订阅单元和信息发布单元，信息订阅单元用于接受下级平台的信息订阅，还用于向上级平台订阅信息；信息发布单元用于向下级平台发布信息，还用于接收上级平台发布的信息；信息订阅单元与信息发布单元连接，且信息订阅单元与信息发布单元之间能进行信息传递。该信息发布订阅平台实现了信息在相互之间具有发布订阅关系的两级平台之间的直接传输，从而实现了信息发布订阅的多级嵌套模式，进而提高了信息的发布订阅效率，继而提高了信息的传输效率。该信息发布订阅平台无需额外编程即可实现信息发布订阅的多级嵌套，从而节约了该信息发布订阅平台的软件成本。

说明书

技术领域

本发明涉及网络信息传输技术领域，具体地，涉及一种信息 发布订阅平台及方法和信息发布订阅系统。

背景技术

目前，在网络信息传输领域，通常通过发布订阅机制进行网 络信息的传输，如通过发布订阅机制在多级信息传输平台之间进 行基于各种主题的信息传输。

Kafka是一种分布式发布订阅消息系统。Kafka提供了一种 通用的发布订阅服务，如图1所示。其具体工作流程如下：

1.当订阅平台8或订阅终端启动订阅时，向Kafka信息平台 9去订阅基于某个主题的信息；

2.当发布平台10有了基于某个主题的更新信息之后，向 Kafka信息平台9进行发布；发布平台10为一个或多个；

3.然后，Kafka信息平台9再将更新信息分发给一个或多个 订阅平台8或订阅终端。

Kafka所提供的发布订阅服务存在以下不足：1)kafka仅是 基本的发布订阅，不支持多级嵌套的发布订阅；即所有的订阅平 台或订阅终端都只能直接向Kafka信息平台订阅信息，所有的发 布平台也都只能向Kafka信息平台发布信息，然后由Kafka信息 平台将信息发布给各个订阅平台或订阅终端。要实现多级嵌套的 发布订阅，需要在kafka系统中编写专门的程序来支持这一点。 2)Kafka不支持基于版本的发布订阅，即kafka可以将基于特 定主题的信息更新发布给一个或多个订阅平台或订阅终端，但是 由于它只保留特定天数的数据信息，当一个新的订阅平台或订阅 终端接入的时候，可能其需要的数据信息已经被kafka删掉。因 为Kafka不支持基于版本的发布订阅，所以无法保证新接入的订 阅平台或订阅终端获取到完整的信息。

发明内容

本发明针对现有技术中存在的上述技术问题，提供一种信息 发布订阅平台及方法和信息发布订阅系统。该信息发布订阅平台 实现了信息在相互之间具有发布订阅关系的两级平台之间的直 接传输，从而实现了信息发布订阅的多级嵌套模式，进而提高了 信息的发布订阅效率，继而提高了信息的传输效率。

本发明提供一种信息发布订阅平台，包括信息订阅单元和信 息发布单元，所述信息订阅单元用于接受下级平台的信息订阅， 还用于向上级平台订阅信息；

所述信息发布单元用于向所述下级平台发布信息，还用于接 收所述上级平台发布的信息；

所述信息订阅单元与所述信息发布单元连接，且所述信息订 阅单元与所述信息发布单元之间能进行信息传递。

优选地，还包括存储单元，所述存储单元与所述信息订阅单 元和所述信息发布单元连接，用于存储所述下级平台订阅的信息 和所述上级平台发布的信息；

所述下级平台订阅的信息和所述上级平台发布的信息均为 带有版本的主题信息。

优选地，所述信息订阅单元包括订阅模块，用于接受所述下 级平台的信息订阅，还用于向所述上级平台订阅信息；

所述信息发布单元包括发布模块，用于向所述下级平台发布 信息，还用于接收所述上级平台发布的信息；

所述订阅模块和所述发布模块连接，所述订阅模块还用于将 向所述上级平台订阅的信息发送给所述发布模块。

优选地，所述信息订阅单元还包括判断模块，用于判断本地 信息的版本是否大于或等于所述下级平台订阅信息的版本；

所述发布模块用于在所述本地信息的版本大于或等于所述 下级平台订阅信息的版本时，将所述本地信息的版本与订阅信息 的版本之差对应的信息发布给所述下级平台；所述订阅模块用于 在所述本地信息的版本大于或等于所述下级平台订阅信息的版 本时，向所述上级平台订阅大于所述本地信息版本的信息，并将 大于所述本地信息版本的信息发送给所述发布模块；所述发布模 块还用于将信息版本大于所述本地信息版本的信息发布给所述 下级平台；

所述订阅模块还用于在所述本地信息的版本小于所述下级 平台订阅信息的版本时，向所述上级平台订阅大于所述本地信息 版本的信息，并将大于所述本地信息版本的信息发送给所述发布 模块；所述发布模块还用于将信息版本大于所述下级平台订阅信 息版本的信息发布给所述下级平台。

本发明还提供一种上述信息发布订阅平台的信息发布订阅 方法，包括：

接受下级平台的信息订阅，向所述下级平台发布信息；

向上级平台订阅信息，接收所述上级平台发布的信息。

优选地，还包括存储所述下级平台订阅的信息和所述上级平 台发布的信息；

所述下级平台订阅的信息和所述上级平台发布的信息均为 带有版本的主题信息。

优选地，所述接受下级平台的信息订阅，向所述下级平台发 布信息；向上级平台订阅信息，接收所述上级平台发布的信息包 括：

接受所述下级平台的信息订阅；判断本地信息的版本是否大 于或等于所述下级平台订阅信息的版本；

当所述本地信息的版本大于或等于所述下级平台订阅信息 的版本时，将所述本地信息的版本与订阅信息的版本之差对应的 信息发布给所述下级平台；同时，向所述上级平台订阅大于所述 本地信息版本的信息，并将信息版本大于所述本地信息版本的信 息发布给所述下级平台；

当所述本地信息的版本小于所述下级平台订阅信息的版本 时，向所述上级平台订阅大于所述本地信息版本的信息，并将信 息版本大于所述下级平台订阅信息版本的信息发布给所述下级 平台。

本发明还提供一种信息发布订阅系统，包括多级上述的信息 发布订阅平台，多级所述信息发布订阅平台依次级联连接。

优选地，所述信息发布订阅系统的第n级信息发布订阅平台 用于接受第n+1级信息发布订阅平台的信息订阅，并向所述第 n+1级信息发布订阅平台发布信息；所述第n级信息发布订阅平 台还用于向第n-1级信息发布订阅平台订阅信息，并接收所述第 n-1级信息发布订阅平台发布的信息。

优选地，所述信息发布订阅系统的第1级信息发布订阅平台 为所述信息发布订阅系统的最高一级信息发布订阅平台；

所述第1级信息发布订阅平台的信息发布单元还包括更新 模块，用于对信息进行更新，并将更新后的信息发送给所述信息 发布单元的发布模块；所述发布模块还用于将所述更新后的信息 发布给第2级信息发布订阅平台。

优选地，还包括多个订阅终端，多个所述订阅终端分别连接 不同级的所述信息发布订阅平台，以分别向不同级所述信息发布 订阅平台订阅信息。

本发明的有益效果：本发明所提供的信息发布订阅平台，通 过设置信息订阅单元和信息发布单元，实现了信息在相互之间具 有发布订阅关系的两级平台之间的直接传输，从而实现了信息发 布订阅的多级嵌套模式，进而提高了信息的发布订阅效率，继而 提高了信息的传输效率。该信息发布订阅平台通过配置信息订阅 单元和信息发布单元，无需额外编程即可实现信息发布订阅的多 级嵌套，从而节约了该信息发布订阅平台的软件成本。另外，该 信息发布订阅平台支持基于信息版本的发布订阅，不仅避免了信 息的丢失，同时还确保了信息发布订阅的时效性和完整性。

附图说明

图1为现有技术中Kafka信息发布订阅系统的原理框图；

图2为本发明实施例1中信息发布订阅平台的原理框图；

图3为本发明实施例1中信息发布订阅方法的流程图；

图4为本发明实施例2中信息发布订阅系统的原理框图；

图5为图4中第1级信息发布订阅平台的原理框图。

其中的附图标记说明：

1.信息订阅单元；11.订阅模块；12.判断模块；2.信息发布 单元；21.发布模块；22.更新模块；3.存储单元；4.下级平台； 5.上级平台；6.第1级信息发布订阅平台；7.第2级信息发布订 阅平台；8.订阅平台；9.Kafka信息平台；10.发布平台。

具体实施方式

为使本领域的技术人员更好地理解本发明的技术方案，下面 结合附图和具体实施方式对本发明所提供的一种信息发布订阅 平台及方法和信息发布订阅系统作进一步详细描述。

实施例1：

本实施例提供一种信息发布订阅平台，如图2所示，包括信 息订阅单元1和信息发布单元2，信息订阅单元1用于接受下级 平台4的信息订阅，还用于向上级平台5订阅信息；信息发布单 元2用于向下级平台4发布信息，还用于接收上级平台5发布的 信息；信息订阅单元1与信息发布单元2连接，且信息订阅单元 1与信息发布单元2之间能进行信息传递。

其中，下级平台4和上级平台5均为信息服务平台(如网络 信息服务平台)，信息服务平台用于为挂接到其上的用户终端提 供信息(如网络信息)。

该信息发布订阅平台通过设置信息订阅单元1和信息发布 单元2，实现了信息在相互之间具有发布订阅关系的两级平台之 间的直接传输，从而实现了信息发布订阅的多级嵌套模式，进而 提高了信息的发布订阅效率，继而提高了信息的传输效率。另外， 该信息发布订阅平台通过配置信息订阅单元1和信息发布单元 2，无需额外编程即可实现信息发布订阅的多级嵌套，从而节约 了该信息发布订阅平台的软件成本。

本实施例中，信息发布订阅平台还包括存储单元3，存储单 元3与信息订阅单元1和信息发布单元2连接，用于存储下级平 台4订阅的信息和上级平台5发布的信息；下级平台4订阅的信 息和上级平台5发布的信息均为带有版本的主题信息。通过设置 存储单元3，能够实现对带有版本的主题信息的持久化存储，从 而使该信息发布订阅平台不会丢失信息，进而使被下级平台4 订阅的信息在任何时候都能够完整获得，即该信息发布订阅平台 支持基于信息版本的发布订阅。存储单元3的设置，能够避免信 息的丢失，从而避免当新的下级平台4向该信息发布订阅平台订 阅较旧版本的信息时，较旧版本的信息已经被删除而无法获得。

本实施例中，信息订阅单元1包括订阅模块11，用于接受 下级平台4的信息订阅，还用于向上级平台5订阅信息。信息发 布单元2包括发布模块21，用于向下级平台4发布信息，还用 于接收上级平台5发布的信息。订阅模块11和发布模块21连接， 订阅模块11还用于将向上级平台5订阅的信息发送给发布模块 21。即该信息发布订阅平台兼具信息订阅和信息发布的功能，从 而使其能够在信息发布订阅过程中与上级平台5和下级平台进 行相互嵌套，进而实现信息发布订阅的多级嵌套，提高信息发布 订阅速率和信息传输速率。

本实施例中，信息订阅单元1还包括判断模块12，用于判 断本地信息的版本是否大于或等于下级平台4订阅信息的版本。 发布模块21用于在本地信息的版本大于或等于下级平台4订阅 信息的版本时，将本地信息的版本与订阅信息的版本之差对应的 信息发布给下级平台4，从而确保下级平台4获取信息的完整性。 订阅模块11用于在本地信息的版本大于或等于下级平台4订阅 信息的版本时，向上级平台5订阅大于本地信息版本的信息，并 将大于本地信息版本的信息发送给发布模块21。发布模块21还 用于将信息版本大于本地信息版本的信息发布给下级平台4，从 而确保下级平台4能够及时获取到最新信息。本实施例中，订阅 模块11还用于在本地信息的版本小于下级平台4订阅信息的版 本时，向上级平台5订阅大于本地信息版本的信息，并将大于本 地信息版本的信息发送给发布模块21。发布模块21还用于将信 息版本大于下级平台4订阅信息版本的信息发布给下级平台4， 从而确保下级平台4能够及时获取到最新信息。

例如：当判断模块12判断本地信息的版本大于下级平台4 订阅信息的版本时，如本地信息的版本为V5和V6，下级平台4 订阅信息的版本为V4；发布模块21将本地信息的版本与订阅信 息的版本之差对应的信息发布给下级平台4，这里发布模块21 会将版本为V5和V6的本地信息发布给下级平台4，从而确保下 级平台4获取信息的完整性；同时，订阅模块11向上级平台5 订阅大于本地信息版本的信息，如上级平台5的最新信息版本为 V7，则订阅模块11向上级平台5订阅该版本为V7的信息，同时， 发布模块21将该版本为V7的信息发布给下级平台4，从而确保 下级平台4能够及时获取到最新信息。

当判断模块12判断本地信息的版本小于下级平台4订阅信 息的版本时，如本地信息的版本为V4，下级平台4订阅信息的 版本为V5；订阅模块11向上级平台5订阅大于本地信息版本的 信息，如订阅模块11向上级平台5订阅版本大于V4的信息；假 如上级平台5的版本为V5、V6和V7，此时，发布模块21将版 本为V6和V7的信息发布给下级平台4，从而确保下级平台4能 够及时获取到最新信息。

判断模块12、发布模块21和订阅模块11的设置，能够确 保该信息发布订阅平台及时将下级平台4订阅的信息和上级平 台5更新的信息发布给下级平台4，以使下级平台4能够及时并 完整地获取到更新信息，从而提高了下级平台4获取信息的时效 性和完整性。

基于本实施例中信息发布订阅平台的上述结构，本实施例还 提供一种该信息发布订阅平台的信息发布订阅方法，包括：接受 下级平台的信息订阅，向下级平台发布信息；向上级平台订阅信 息，接收上级平台发布的信息。

该信息发布订阅方法能够实现信息在相互之间具有发布订 阅关系的两级平台之间的直接传输，从而实现信息发布订阅的多 级嵌套模式，进而提高了信息的发布订阅效率，继而提高了信息 的传输效率。

本实施例中，该信息发布订阅方法还包括存储下级平台订阅 的信息和上级平台发布的信息；下级平台订阅的信息和上级平台 发布的信息均为带有版本的主题信息。通过该步骤，能够实现对 带有版本的主题信息的持久化存储，从而使信息不会丢失，进而 使被下级平台订阅的信息在任何时候都能够完整获得，即该信息 发布订阅方法支持基于信息版本的发布订阅。该存储步骤能够避 免信息的丢失，从而避免当新的下级平台4接入并订阅较旧版本 的信息时，较旧版本的信息已经被删除而无法获得。

本实施例中，接受下级平台的信息订阅，向下级平台发布信 息；向上级平台订阅信息，接收上级平台发布的信息包括：如图 3所示，

步骤101：接受下级平台的信息订阅。

步骤102：判断本地信息的版本是否大于或等于下级平台订 阅信息的版本。当本地信息的版本大于或等于下级平台订阅信息 的版本时，执行步骤103：将本地信息的版本与订阅信息的版本 之差对应的信息发布给下级平台；同时，向上级平台订阅大于本 地信息版本的信息，并将信息版本大于本地信息版本的信息发布 给下级平台。当本地信息的版本小于下级平台订阅信息的版本 时，执行步骤104：向上级平台订阅大于本地信息版本的信息， 并将信息版本大于下级平台订阅信息版本的信息发布给下级平 台。

通过步骤101、102、103和104，能够确保及时将下级平台 订阅的信息和上级平台更新的信息发布给下级平台，以使下级平 台能够及时并完整地获取到更新信息，从而提高了下级平台获取 信息的时效性和完整性。

实施例1的有益效果：实施例1中所提供的信息发布订阅平 台，通过设置信息订阅单元和信息发布单元，实现了信息在相互 之间具有发布订阅关系的两级平台之间的直接传输，从而实现了 信息发布订阅的多级嵌套模式，进而提高了信息的发布订阅效 率，继而提高了信息的传输效率。该信息发布订阅平台通过配置 信息订阅单元和信息发布单元，无需额外编程即可实现信息发布 订阅的多级嵌套，从而节约了该信息发布订阅平台的软件成本。 另外，该信息发布订阅平台支持基于信息版本的发布订阅，不仅 避免了信息的丢失，同时还确保了信息发布订阅的时效性和完整 性。

实施例2：

本实施例提供一种信息发布订阅系统，如图4所示，包括多 级如实施例1中所述的信息发布订阅平台，多级信息发布订阅平 台依次级联连接。

其中，信息发布订阅系统的第n级信息发布订阅平台用于接 受第n+1级信息发布订阅平台的信息订阅，并向所述第n+1级信 息发布订阅平台发布信息；所述第n级信息发布订阅平台还用于 向第n-1级信息发布订阅平台订阅信息，并接收所述第n-1级信 息发布订阅平台发布的信息。

该信息发布订阅系统通过采用实施例1中的信息发布订阅 平台，能够实现多级嵌套的信息发布订阅模式，从而提高了信息 的发布订阅效率，进而提高了信息的传输效率。

本实施例中，如图5所示，信息发布订阅系统的第1级信息 发布订阅平台6为信息发布订阅系统的最高一级信息发布订阅 平台；第1级信息发布订阅平台6的信息发布单元2还包括更新 模块22，用于对信息进行更新，并将更新后的信息发送给信息 发布单元2的发布模块21；发布模块21还用于将更新后的信息 发布给第2级信息发布订阅平台7。信息发布订阅系统的最高一 级信息发布订阅平台6通过设置更新模块22，能够实现对最高 一级信息发布订阅平台发布信息的更新，从而能够及时为第2 级信息发布订阅平台7乃至后续的各级信息发布订阅平台发布 更新信息。

本实施例中，如图4所示，信息发布订阅系统还包括多个订 阅终端，多个订阅终端分别连接不同级的信息发布订阅平台，以 分别向不同级信息发布订阅平台订阅信息。订阅终端能够直接从 与其连接的信息发布订阅平台上订阅信息，从而满足订阅终端的 信息需求。

实施例2的有益效果：实施例2中所提供的信息发布订阅系 统，通过采用实施例1中的信息发布订阅平台，能够实现多级嵌 套的信息发布订阅模式，从而提高了信息的发布订阅效率，进而 提高了信息的传输效率。另外，该信息发布订阅系统支持基于信 息版本的发布订阅，不仅避免了信息的丢失，同时还确保了信息 发布订阅的时效性和完整性。

可以理解的是，以上实施方式仅仅是为了说明本发明的原理 而采用的示例性实施方式，然而本发明并不局限于此。对于本领 域内的普通技术人员而言，在不脱离本发明的精神和实质的情况 下，可以做出各种变型和改进，这些变型和改进也视为本发明的 保护范围。