一种互联网用户发布信息的处理方法和系统

本发明涉及互联网的海量数据处理技术，尤其涉及一种互联网用户发布信 息的处理方法和系统。

互联网业务飞速发展，用户在使用互联网业务的同时也有信息发布的需求， 如：用户在浏览新闻的同时有发表评论的需求、用户在的朋友圈有发言和 发表评论的需求、用户在浏览BBS(论坛)网站时有发帖和发表评论的需求等 等。现有技术中，大部分互联网业务平台各自维护自身的用户发布信息，其用 于维护用户发布信息的平台架构不具有通用性，大都无法适应多种不同的业务 场景，这不利于互联网资源的整合，造成了互联网资源的浪费。

为解决现有存在的技术问题，本发明提供一种互联网用户发布信息的处理 方法和系统。

本发明提供了一种互联网用户发布信息的处理方法，所述方法包括：

接收业务系统的申请，为申请的所述业务系统分配相应的业务标识ID，并 根据所述业务系统的多维度索引集注册请求，在索引系统中为所述业务ID创建 多维度的索引集并保存与每个索引集对应的索引集加入条件；

在获得用户发布信息时，确定所述用户发布信息所属的业务ID，并判断所 述用户发布信息是否满足所属业务ID的索引集加入条件；

在判断所述用户发布信息满足所述业务ID的索引集加入条件时，将所述用 户发布信息的信息ID存入满足加入条件的索引集中，并保存所述用户发布信 息。

上述方案中，所述根据业务系统的多维度索引集注册请求，在索引系统中 为所述业务ID创建多维度的索引集并保存与每个索引集对应的索引集加入条 件，包括：

根据所述业务系统的注册请求，在所述索引系统中为所述业务ID创建至少 一个维度的索引集，并为创建的每个维度的索引集分配相应的索引集ID；

为创建的每个维度的索引集设定相应的索引集加入条件，并保存所述索引 集加入条件。

上述方案中，所述保存用户发布信息包括：

将所有的所述用户发布信息按所述业务ID分类存入全量数据库DB系统 中，所述用户发布信息由相应的信息ID进行索引；并将其中满足分布式缓存系 统存入条件的用户发布信息存入所述分布式缓存系统中，所述分布式缓存系统 中存入的用户发布信息由相应的信息ID进行索引。

上述方案中，所述方法还包括：

在收到维度信息查询请求时，在所述索引系统中查获得相应业务下相应 维度的索引集，并根据所得索引集中的信息ID，从所述分布式缓存系统中查 获得相应的用户发布信息；对于所述分布式缓存系统中无法查到用户发布信 息的所述信息ID，依据所述信息ID从所述全量DB系统中查获得相应的用 户发布信息。

上述方案中，所述方法进一步包括：

对于所述分布式缓存系统中无法查到用户发布信息的所述信息ID，在所 述分布式缓存系统中创建相应的信息ID索引，并设置所述信息ID索引的信息 内容为空。

本发明还提供了一种互联网用户发布信息的处理系统，所述系统包括：业 务信息维护系统、索引系统和信息存储系统，其中，

所述业务信息维护系统，用于接收业务系统的申请，为申请的所述业务系 统分配相应的业务标识ID，并将所述业务系统的多维度索引集注册请求转发到 所述索引系统；

所述索引系统，用于根据所述注册请求，为所述业务ID创建多维度的索引 集并保存与每个索引集对应的索引集加入条件；

所述业务信息维护系统还用于，在获得用户发布信息时，确定所述用户发 布信息所属的业务ID；

所述索引系统还用于，判断所述用户发布信息是否满足所属业务ID的索引 集加入条件，并在判断所述用户发布信息满足所述业务ID的索引集加入条件 时，将所述用户发布信息的信息ID存入满足加入条件的索引集中；

所述信息存储系统，用于保存所述用户发布信息。

上述方案中，所述索引系统进一步用于，

根据所述业务系统的注册请求，在所述索引系统中为所述业务ID创建至少 一个维度的索引集，并为创建的每个维度的索引集分配相应的索引集ID；

为创建的每个维度的索引集设定相应的索引集加入条件，并保存所述索引 集加入条件。

上述方案中，所述信息存储系统包括：全量数据库DB系统和分布式缓存 系统；

所述全量DB系统，用于按所述业务ID分类保存所有的所述用户发布信息， 所述用户发布信息由相应的信息ID进行索引；

所述分布式缓存系统，用于保存满足分布式缓存系统存入条件的用户发布 信息，其中保存的用户发布信息由相应的信息ID进行索引。

上述方案中，所述业务信息维护系统还用于，接收维度信息查询请求并转 发给所述索引系统；

所述索引系统还用于，查获得相应业务下相应维度的索引集，并将所得 索引集中的信息ID提供给所述业务信息维护系统；

所述业务信息维护系统还用于，根据获得的所述信息ID，从所述分布式缓 存系统中查获得相应的用户发布信息；对于所述分布式缓存系统中无法查 到用户发布信息的所述信息ID，依据所述信息ID从所述全量DB系统中查 获得相应的用户发布信息。

上述方案中，所述分布式缓存系统还用于，对于所述分布式缓存系统中无 法查到用户发布信息的所述信息ID，在所述分布式缓存系统中创建相应的信 息ID索引，并设置所述信息ID索引的信息内容为空。

本发明提供的一种互联网用户发布信息的处理方法和系统，实现了对多种 业务系统的用户发布信息的统一维护，能够适应多种不同的业务场景，具有通 用性；本发明实施例有利于互联网资源的整合，节省了互联网资源。

本发明实施例采用分布式线上缓存系统结合全量DB系统的存储方式，将 重要或热点的用户发布信息存入分布式线上缓存系统，可以实现快速访问，提 高查询效率；另外，将所有注册业务系统的用户发布信息由统一的全量DB系 统进行存储和管理，实现了互联网资源的有效整合，并确保了用户发布信息状 态的统一性。再有，本发明实施例将用户发布信息的信息ID由专门的索引系统 进行维护，并在索引系统中实现了多维度划分，不仅能够获得有效的多维度统 计信息，还能提高维度信息的查询效率和准确性。

图1为本发明实施例一的互联网用户发布信息的处理方法流程图；

图2为本发明实施例二的互联网用户发布信息的处理系统结构示意图；

图3为本发明实施例三的互联网用户发布信息的处理系统结构示意图。

下面结合附图和具体实施例对本发明的技术方案进一步详细阐述。

实施例一

本发明实施例一提供的一种互联网用户发布信息的处理方法，如图1所示， 主要包括：

步骤101，接收业务系统的申请，为申请的所述业务系统分配相应的业务 标识(ID)，并根据所述业务系统的多维度索引集注册请求，在索引系统中为所 述业务ID创建多维度的索引集并保存与每个索引集对应的索引集加入条件。

其中，所述业务系统的申请，是指业务系统申请由本发明实施例的业务信 息维护系统统一的进行业务信息的维护；所述多维度索引集注册请求，是指业 务系统请求在本发明实施例的索引系统中创建至少一个维度的索引集，用以统 计不同维度下的用户发布信息，所述维度可以是用户年龄、性别、信息主题等 等，本发明实施例不对维度的范围进行限制，实际应用中任何可以实施的维度 应当都属于本发明实施例所保护的范围。

另外，本发明实施例中业务系统的申请和多维度索引集注册请求可以由一 条消息来实现，当然也可以由两条单独的消息来实现。

其中，接收到业务系统的申请后，为所述业务系统分配的相应业务ID，用 于唯一的标识相应的业务。

其中，所述根据业务系统的多维度索引集注册请求，在索引系统中为所述 业务ID创建多维度的索引集并保存与每个索引集对应的索引集加入条件，包 括：

根据所述业务系统的注册请求，在所述索引系统中为所述业务ID创建至少 一个维度的索引集，并为创建的每个维度的索引集分配相应的索引集ID；

为创建的每个维度的索引集设定相应的索引集加入条件，并保存所述索引 集加入条件。

例如：多维度索引集注册请求用以请求在索引系统中创建20～30年龄段的 用户发布的信息的索引集(为描述方便，后续简称索引集一)、以及女性用户发 布的信息的索引集(为描述方便，后续简称索引集二)，那么，根据所述注册请 求，在索引系统中分别创建相应业务ID下的维度为20～30年龄段的用户发布信 息的索引集、以及维度为女性的用户发布信息的索引集，并分别为创建的每个 维度的索引集分配相应的索引集ID，该ID用以唯一的标识该索引集；此外， 还为维度为20～30年龄段的用户发布信息的索引集设定相应的索引集加入条件 为：用户年龄在20～30之间；为维度为女性的用户发布信息的索引集设定相应 的索引集加入条件为：用户为女性；随后对应保存为每个索引集设定的加入条 件。每个索引集用以保存满足相应索引集加入条件的用户发布信息的信息ID。 其中，信息ID用于唯一的标识一条用户发布信息，而前述的业务ID则是用于 唯一的标识一个业务。

步骤102，在获得用户发布信息时，确定所述用户发布信息所属的业务ID， 并判断所述用户发布信息是否满足所属业务ID的索引集加入条件。

其中，可以根据提供所述用户发布信息的业务系统，获得相应用户发布信 所属的业务ID。

接续上述举例，在获得用户发布信息，并确定所述用户发布信息所属的业 务ID时，判断所述用户发布信息是否满足所属业务ID的索引集一的加入条件、 以及索引集二的加入条件；在判断所述用户发布信息是否满足所属业务ID的索 引集一的加入条件时，提取所述用户发布信息相关的用户年龄进行判断；在判 断所述用户发布信息是否满足所属业务ID的索引集二的加入条件时，提取所述 用户发布信息相关的用户性别进行判断。

步骤103，在判断所述用户发布信息满足所述业务ID的索引集加入条件时， 将所述用户发布信息的信息ID存入满足加入条件的索引集中，并保存所述用户 发布信息。

接续上述举例，在判断所述用户发布信息满足所属业务ID的索引集一的加 入条件时，将所述用户发布信息的信息ID存入索引集一中；在判断所述用户发 布信息不满足所属业务ID的索引集二的加入条件时，不将所述用户发布信息的 信息ID存入索引集二中。

其中，所述保存用户发布信息包括：

将所有的所述用户发布信息按所述业务ID分类存入全量数据库(DB)系 统中，所述用户发布信息由相应的信息ID进行索引；并将其中满足分布式缓存 系统存入条件的用户发布信息存入所述分布式缓存系统中，所述分布式缓存系 统中存入的用户发布信息由相应的信息ID进行索引。

在上述方案中，所述方法还可包括：

在收到维度信息查询请求时，在所述索引系统中查获得相应业务下相应 维度的索引集，并根据所得索引集中的信息ID，从所述分布式缓存系统中查 获得相应的用户发布信息；对于所述分布式缓存系统中无法查到用户发布信 息的所述信息ID，依据所述信息ID从所述全量DB系统中查获得相应的用 户发布信息。

通过本发明上述实施例的方法，实现了对多种业务系统的用户发布信息的 统一维护，能够适应多种不同的业务场景，具有通用性；本发明实施例的实施 有利于互联网资源的整合，节省了互联网资源。本发明实施例采用分布式线上 缓存系统结合全量DB系统的存储方式，将重要或热点的用户发布信息存入分 布式线上缓存系统，可以实现快速访问，提高查询效率；另外，将所有注册业 务系统的用户发布信息由统一的全量DB系统进行存储和管理，实现了互联网 资源的有效整合，并确保了用户发布信息状态的统一性。再有，本发明实施例 将用户发布信息的信息ID由专门的索引系统进行维护，并在索引系统中实现了 多维度划分，不仅能够获得有效的多维度统计信息，还能提高多维度信息的查 询效率和准确性。

另外，在上述方案中，所述方法还可包括：

对于所述分布式缓存系统中无法查到用户发布信息的所述信息ID，在所 述分布式缓存系统中创建相应的信息ID索引，并设置所述信息ID索引的信息 内容为空。这样，在下次查时，若发现某信息ID索引的信息内容为空，则可 以直接获知分布式缓存系统中无所述信息ID对应的信息内容，从而可以直接向 全量DB系统请求查询所述信息ID相应信息内容，实现快速查询，提高了查询 响应效率。

实施例二

对应本发明实施例一所述的互联网用户发布信息的处理方法，本发明实施 例二提供了一种互联网用户发布信息的处理系统，如图2所示，该系统包括： 业务信息维护系统10、索引系统20和信息存储系统30，其中，

业务信息维护系统10，用于接收业务系统的申请，为申请的所述业务系统 分配相应的业务ID，并将所述业务系统的多维度索引集注册请求转发到索引系 统20；其中，所述业务系统的申请，是指业务系统申请由本发明实施例的业务 信息维护系统统一的进行业务信息的维护；所述多维度索引集注册请求，是指 业务系统请求在本发明实施例的索引系统中创建至少一个维度的索引集，用以 统计不同维度下的用户发布信息；

索引系统20，用于根据所述注册请求，为所述业务ID创建多维度的索引 集并保存与每个索引集对应的索引集加入条件；

业务信息维护系统10还用于，在获得用户发布信息时，确定所述用户发布 信息所属的业务ID；

索引系统20还用于，判断所述用户发布信息是否满足所属业务ID的索引 集加入条件，并在判断所述用户发布信息满足所述业务ID的索引集加入条件 时，将所述用户发布信息的信息ID存入满足加入条件的索引集中；

信息存储系统30，用于保存所述用户发布信息。

上述方案中，索引系统20进一步用于，

根据所述业务系统的注册请求，在所述索引系统20中为所述业务ID创建 至少一个维度的索引集，并为创建的每个维度的索引集分配相应的索引集ID；

为创建的每个维度的索引集设定相应的索引集加入条件，并保存所述索引 集加入条件。

上述方案中，信息存储系统30可以包括：全量DB系统31和分布式缓存 系统32；

全量DB系统31，用于按所述业务ID分类保存所有的所述用户发布信息， 所述用户发布信息由相应的信息ID进行索引；

分布式缓存系统32，用于保存满足分布式缓存系统存入条件的用户发布信 息，其中保存的用户发布信息由相应的信息ID进行索引。

上述方案中，业务信息维护系统10还用于，接收维度信息查询请求并转发 给所述索引系统20；

索引系统20还用于，查获得相应业务下相应维度的索引集，并将所得索 引集中的信息ID提供给所述业务信息维护系统10；

业务信息维护系统10还用于，根据获得的所述信息ID，从所述分布式缓 存系统32中查获得相应的用户发布信息；对于所述分布式缓存系统32中无 法查到用户发布信息的所述信息ID，依据所述信息ID从所述全量DB系统 31中查获得相应的用户发布信息。

上述方案中，分布式缓存系统32还用于，对于所述分布式缓存系统中无法 查到用户发布信息的所述信息ID，在所述分布式缓存系统中创建相应的信息 ID索引，并设置所述信息ID索引的信息内容为空。这样，在下次查时，若 发现分布式缓存系统32中某信息ID索引的信息内容为空，则可以直接获知分 布式缓存系统32中无所述信息ID对应的信息内容，从而可以直接向全量DB 系统31请求查询所述信息ID相应信息内容，实现快速查询，提高了查询响应 效率。

本发明实施例的系统实现了对多种业务系统的用户发布信息的统一维护， 能够适应多种不同的业务场景，该系统具有通用性；本发明实施例的实施有利 于互联网资源的整合，节省了互联网资源。本发明实施例的系统采用分布式线 上缓存系统结合全量DB系统的存储方式，将重要或热点的用户发布信息存入 分布式线上缓存系统，可以实现快速访问，提高查询效率；另外，将所有注册 业务系统的用户发布信息由统一的全量DB系统进行存储和管理，实现了互联 网资源的有效整合，并确保了用户发布信息状态的统一性。再有，本发明实施 例的系统将用户发布信息的信息ID由专门的索引系统进行维护，并在索引系统 中实现了多维度划分，不仅能够获得有效的多维度统计信息，还能提高多维度 信息的查询效率和准确性。

实施例三

本发明实施例适用于对用户评论信息的处理，下面以用户评论信息为例进 一步详细阐述本发明。用户评论信息如：用户在浏览新闻时针对某新闻文章的 评论信息，用户在朋友圈针对某好友发言的评论信息，用户在浏览BBS网 站时针对某发帖发表的评论信息等等。应当理解的是，本发明实施例所述的用 户发表信息不仅限于是用户评论信息，当然也可以是其他类型的用户通过互联 网发表的信息。

如图3所示，为本发明实施例三的一种用户评论信息的处理系统，该系统 包括：评论业务系统(相当于实施例二中的业务信息维护系统)、评论索引系统 (相当于实施例二中的索引系统)、分布式缓存系统和全量DB系统，其中，

评论业务系统，用于接收业务系统的申请，为申请的所述业务系统分配相 应的业务ID，并将所述业务系统的多维度索引集注册请求转发到评论索引系 统；

评论索引系统，用于根据所述注册请求，为所述业务ID创建多维度的索引 集并保存与每个索引集对应的索引集加入条件；

评论业务系统还用于，在获得用户评论信息时，确定所述用户评论信息所 属的业务ID；

评论索引系统还用于，判断所述用户评论信息是否满足所属业务ID的索引 集加入条件，并在判断所述用户评论信息满足所述业务ID的索引集加入条件 时，将所述用户评论信息的信息ID存入满足加入条件的索引集中；

分布式缓存系统和全量DB系统，用于保存所述用户评论信息。

其中，评论业务系统还用于对各个注册的业务系统的用户评论信息进行统 一的维护，包括：读评论、写评论、删除评论、置顶评论、赞评论等等。

上述方案中，评论索引系统进一步用于，

根据所述业务系统的注册请求，在评论索引系统中为所述业务ID创建至少 一个维度的索引集，并为创建的每个维度的索引集分配相应的索引集ID；

为创建的每个维度的索引集设定相应的索引集加入条件，并保存所述索引 集加入条件。维度如：最新评论、热门评论、用户维度评论、主题维度评论、 文章维度评论等等。所谓最新评论的索引集用以保存最新评论的评论ID，热门 评论的索引集用以保存热门评论的评论ID，用户维度评论的索引集用以保存特 定用户的评论ID，主题维度评论的索引集用以保存特定主题的评论ID，文章 维度评论的索引集用以保存特定文章的评论ID。

上述方案中，全量DB系统，用于按所述业务ID分类保存所有的所述用户 评论信息，所述用户评论信息由相应的信息ID进行索引；

分布式缓存系统，用于保存满足分布式缓存系统存入条件的用户评论信息， 其中保存的用户评论信息由相应的信息ID进行索引。

上述方案中，评论业务系统还用于，接收维度信息查询请求并转发给评论 索引系统；

评论索引系统还用于，查获得相应业务下相应维度的索引集，并将所得 索引集中的信息ID提供给评论业务系统；

评论业务系统还用于，根据获得的所述信息ID，从所述分布式缓存系统中 查获得相应的用户评论信息；对于所述分布式缓存系统中无法查到用户评 论信息的所述信息ID，依据所述信息ID从所述全量DB系统中查获得相应 的用户评论信息。

上述方案中，分布式缓存系统还用于，对于所述分布式缓存系统中无法查 到用户评论信息的所述信息ID，在所述分布式缓存系统中创建相应的信息ID 索引，并设置所述信息ID索引的信息内容为空。这样，在下次查时，若发现 分布式缓存系统中某信息ID索引的信息内容为空，则可以直接获知分布式缓存 系统中无所述信息ID对应的信息内容，从而可以直接向全量DB系统请求查询 所述信息ID相应信息内容，实现快速查询，提高了查询响应效率。

本发明实施例还提供了一种计算机可读存储介质，所述存储介质包括一组 计算机可执行指令，所述指令用于执行本发明实施例所述的互联网用户发布信 息的处理方法。

本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计 算机程序产品。因此，本发明可采用硬件实施例、软件实施例、或结合软件和 硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算 机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器和光学存储 器等)上实施的计算机程序产品的形式。

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品 的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方 框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结 合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或 其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可 编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个 流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备 以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的 指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流 程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使 得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处 理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个 流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

以上所述，仅为本发明的较佳实施例而已，并非用于限定本发明的保护范 围。