CN112559913B - 一种数据处理方法、装置、计算设备及可读存储介质 - Google Patents

Abstract

本发明公开了一种数据处理方法，适于在服务器中执行，服务器包括第一数据存储设备、第二数据存储设备和消息中间件，服务器分别与客户端、评论管理终端连接，方法包括：从客户端获取用户的第一评论信息，第一评论信息的字段包括：主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容以及评论时间；将第一评论信息存储到第一数据存储设备，以便通过管理终端查看第一评论信息；将第一评论信息通过消息中间件同步到第二数据存储设备，以便根据用户请求在客户端展示第一评论信息。本发明一并公开了相应的装置、计算设备及可读存储介质。

Description

一种数据处理方法、装置、计算设备及可读存储介质

技术领域

本发明涉及互联网技术领域，尤其涉及一种数据处理方法、装置、计算设备及可读存储介质。

背景技术

进入信息时代以来，互联网上出现各种形态的数据信息，每个内容都给阅读者留有讨论区，比如新闻、视频等的留言板、评论区、弹幕等，给用户提供了不同方式的讨论空间，满足用户之间的意见交互。

用户所发表的评论在具体存储时，可以按照评论的某个维度对评论逐条展示，比如根据评论时间的先后顺序以列表的形式进行展示，这种存储方式通常是使用关系型数据库将评论数据以行列的结构形式进行存储，每一行记录一条评论信息，在列上记录每条评论的主键、评论内容、评论时间等字段信息。在每条评论中存放本条评论的上级节点数据，通过上级节点来回溯评论在发表时，是针对主体内容的评论还是对某一条评论的评论。

用户在客户端浏览这些评论时，需要从存储端请求这些数据，并根据评论之间的上下级关系进行展示，而上述存储方式需要根据每条评论的上级节点对评论的展示关系进行回溯，因为存储结构是按照时间进行存储的，并不是根据评论之间的树形结构来存储的，需要对数据进行多次查询和树形结构的拼接，树形层级越多，查询的逻辑越复杂，对数据库的压力也越大。

发明内容

为此，本发明提供了一种数据处理方法、装置、计算设备及可读存储介质，以力图解决或者至少缓解上面存在的问题。

根据本发明的一个方面，提供一种数据处理方法，适于在服务器中执行，所述服务器包括第一数据存储设备、第二数据存储设备和消息中间件，所述服务器分别与客户端、评论管理终端连接，所述方法包括：从所述客户端获取用户的第一评论信息，所述第一评论信息的字段包括：主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容以及评论时间；将所述第一评论信息存储到所述第一数据存储设备，以便通过所述管理终端查看所述第一评论信息；将所述第一评论信息通过所述消息中间件同步到所述第二数据存储设备，以便根据用户请求在所述客户端展示所述第一评论信息。

可选的，在根据本发明的数据处理方法中，所述将所述第一评论信息存储到所述第一数据存储设备包括：生成所述第一评论信息的主键ID；根据所述主键ID和所述第一评论信息生成新的第一评论记录存储到所述第一数据存储设备；返回所述第一评论信息的处理结果。

可选的，在根据本发明的数据处理方法中，所述生成所述第一评论信息的主键ID包括：通过自增的方式生成所述第一评论信息的主键ID。

可选的，在根据本发明的数据处理方法中，所述将所述第一评论信息通过所述消息中间件同步到所述第二数据存储设备包括：将所述第一评论信息和对应的主键ID存储到所述消息中间件；所述第二数据存储设备从所述消息中间件中获取第一评论信息和对应的主键ID；将所述第一评论信息和主键ID存储到所述第二数据存储设备。

可选的，在根据本发明的数据处理方法中，所述第一评论信息的类型包括主评论和非主评论，当所述评论信息为主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备包括：根据所述第一评论信息和所述主键ID生成第二评论记录；将所述第二评论记录存储到所述第二数据存储设备。

可选的，在根据本发明的数据处理方法中，当所述第一评论信息为非主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备中包括：根据内容标识、主评论标识和回复对象标识在所述第二数据存储设备中获取该第一评论信息对应的上一级评论记录；根据所述第一评论信息和所述主键ID生成第二评论记录；将所述第二评论记录添加到所述上一级评论记录的回复字段中。

可选的，在根据本发明的数据处理方法中，还包括：从所述管理终端获取第二评论信息，所述第二评论信息为管理员对用户的原评论信息的更新内容，所述第二评论信息包括的字段有主键ID，更新类型，以及评论内容，所述更新类型包括修改和删除；根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备。

可选的，在根据本发明的数据处理方法中，当所述更新类型为修改时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并根据所述第二评论信息对所述评论记录中的数据进行更新；将所述第二评论信息同步所述消息中间件；根据所述消息中间件的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并进行更新。

可选的，在根据本发明的数据处理方法中，当所述更新的类型为删除时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并将所述评论记录置为删除状态；将所述第二评论信息同步所述信息系统；根据所述信息系统中的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并置为删除状态。

可选的，在根据本发明的数据处理方法中，还包括：根据用户在客户端的查看请求，将所述第二数据存储设备中的评论信息在所述客户端进行展示。

可选的，在根据本发明的数据处理方法中，所述第一数据存储设备为关系型数据库。

可选的，在根据本发明的数据处理方法中，所述第二数据存储设备为非关系型数据库。

根据本发明的另一个方面，提供一种数据处理装置，适于驻留在服务器中，所述服务器分别与客户端、评论管理终端连接，所述装置包括：第一数据存储设备、第二数据存储设备和消息中间件，其中，第一数据存储设备，适于从所述客户端获取用户的第一评论信息，所述第一评论信息包括主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容、评论时间，还适于存储所述第一评论信息，以便管理员通过所述管理终端管理评论信息；消息中间件，适于将所述第一数据存储设备中的数据同步到所述第二数据存储设备中；第二数据存储设备，适于存储通过所述消息中间件同步过来的第一数据存储设备中的评论消息，以便提高在所述客户端进行评论展示时的查询效率。

根据本发明的又一个方面，提供一种计算设备，包括：至少一个处理器；以及存储器，存储有程序指令，其中，程序指令被配置为适于由至少一个处理器执行，程序指令包括用于执行上述数据处理方法的指令。

根据本发明的又一个方面，提供一种存储有程序指令的可读存储介质，当程序指令被计算设备读取并执行时，使得计算设备执行上述数据处理方法。

根据本发明的数据管理方法，通过将用户的评论信息首先存储在第一数据存储设备中，并通过消息中间件同步到第二数据存储设备中，根据用户请求在客户端展示评论信息时，通过搜索第二数据存储设备实现，管理员通过管理终端查看评论信息时，根据第一数据存储设备上的数据存储展示给管理员，可以根据需要，将两个数据存储设备分别设置成适应用户客户端和管理终端的数据存储方式，以满足不同的数据搜索的需要。

附图说明

为了实现上述以及相关目的，本文结合下面的描述和附图来描述某些说明性方面，这些方面指示了可以实践本文所公开的原理的各种方式，并且所有方面及其等效方面旨在落入所要求保护的主题的范围内。通过结合附图阅读下面的详细描述，本公开的上述以及其它目的、特征和优势将变得更加明显。遍及本公开，相同的附图标记通常指代相同的部件或元素。

图1示出了根据本发明一个实施例的数据处理系统100的示意图；

图2示出了根据本发明一个实施例的计算设备200的框图；

图3示出了根据本发明一个实施例的数据处理方法300的流程图；

图4示出了根据本发明一个实施例的数据处理方法400的流程图；

图5示出了根据本发明一个实施例的第二数据存储设备中的数据存储示意图；

图6示出了根据本发明一个实施例的第二数据存储设备中的数据存储示意图。

具体实施方式

下面将参照附图更详细地描述本公开的示例性实施例。虽然附图中显示了本公开的示例性实施例，然而应当理解，可以以各种形式实现本公开而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本公开，并且能够将本公开的范围完整的传达给本领域的技术人员。

关于网络信息的评论区的数据存储，目前应用最多的就是通过关系型数据库存储评论信息，通常根据时间顺序进行存储，这种存储方式在客户端进行展示时，需要复杂的查询逻辑进行树形拼接，数据存储设备的查询压力过大。

评论信息的另一种存储方式是采用树形的存储方式，将评论分为主评论和非主评论，主评论就是对内容主题的评论，比如，在某新闻内容的评论区，直接对新闻内容的评论为主评论，而非主评论指对评论(包括主评论和非主评论)的回复，这种存储方式通常采用非关系型数据库，以展示的树形结构存储在非关系型数据库中。评论内容中不需要记录上级节点的数据，只需要存储评论中关注的内容即可，所以这种结构的查询时不需要处理上下级节点关系，查询速度会比使用关系型数据库的方案快很多。

但是这种存储方式对于后台管理者来说，因为数据的存储是松散的，单一数据的内容不全面，需要根据内容的上下文进行判断，无法直接给管理者进行使用，需要对数据进行处理、补全之后，再使用便于后台管理员进行管理的数据展示结构对原始数据进行排版，所存储的数据不能直接使用。

在本发明中，根据两种数据存储方式的特点，建立两套数据存储，并通过消息中间件进行同步，既解决客户端进行展示时对于数据库多次查询的效率问题，又方便了管理员对评论数据的管理。

图1示出了根据本发明一个实施例的数据处理系统100的示意图。如图1所示，数据处理系统100包括服务器110、客户端120和管理终端130，服务器110分别与客户端120和管理终端130通信连接。需要说明的是，图1所示的数据处理系统仅为示例性的，在实践中，客户端和管理终端可以有多个，本发明对数据处理系统中所包含的客户端和管理终端不做限制。

服务器110是具备通信、计算、存储功能的设备，其可以实现为服务器，例如应用服务器、Web服务器等，但不限于此。服务器110可以实现为一台服务器，也可以实现为由多台服务器所构成的集群或分布式系统；当为多台服务器时，这多台服务器可以部署于同一地理位置，也可以分散布置于多个地理位置，本发明对服务器110所包括的服务器的数量以及各服务器的部署位置均不做限制。

客户端120例如可以是桌面计算机、笔记本计算机等个人配置的计算机，也可以是手机、平板电脑、多媒体播放器、智能可穿戴设备等移动终端，还可以是智能电视等设备，但不限于此。

管理终端130一般为桌面计算机、笔记本计算机等个人配置的计算机。

根据本发明的一个实施例，用户可以通过客户端120对网络上的新闻、视频等数据信息进行评论，例如在新闻、视频等信息的留言板或评论区进行留言或评论，该留言或评论的数据信息被发送给服务器110，服务器110包括两个数据存储设备(图1中未示出)，第一数据存储设备和第二数据存储设备，服务器110获取到留言或评论信息之后将数据存储在第一数据存储设备中，并同步到第二数据存储设备中。用户在客户端120进行浏览时，从第二数据存储设备中获取，管理员在管理终端对用户的评论信息进行敏感信息过滤时，从第一数据存储设备中获取评论数据。

图1中的服务器110可以通过计算设备实现，图2示出了根据本发明一个实施例的计算设备200的框图。需要说明的是，图2所示的计算设备200仅为一个示例，在实践中，用于实施本发明的数据处理方法300/400的计算设备可以是任意型号的设备，其硬件配置情况可以与图2所示的计算设备200相同，也可以与图2所示的计算设备200不同。实践中用于实施本发明的数据处理方法300/400的计算设备可以对图2所示的计算设备200的硬件组件进行增加或删减，本发明对计算设备的具体硬件配置情况不做限制。

如图2所示，在基本的配置202中，计算设备200典型地包括系统存储器206和一个或者多个处理器204。存储器总线208可以用于在处理器204和系统存储器206之间的通信。

取决于期望的配置，处理器204可以是任何类型的处理，包括但不限于：微处理器(μP)、微控制器(μC)、数字信息处理器(DSP)或者它们的任何组合。处理器204可以包括诸如一级高速缓存210和二级高速缓存212之类的一个或者多个级别的高速缓存、处理器核心214和寄存器216。示例的处理器核心214可以包括运算逻辑单元(ALU)、浮点数单元(FPU)、数字信号处理核心(DSP核心)或者它们的任何组合。示例的存储器控制器218可以与处理器204一起使用，或者在一些实现中，存储器控制器218可以是处理器204的一个内部部分。

取决于期望的配置，系统存储器206可以是任意类型的存储器，包括但不限于：易失性存储器(诸如RAM)、非易失性存储器(诸如ROM、闪存等)或者它们的任何组合。计算设备中的物理内存通常指的是易失性存储器RAM，磁盘中的数据需要加载至物理内存中才能够被处理器204读取。系统存储器206可以包括操作系统220、一个或者多个应用222以及程序数据224。在一些实施方式中，应用222可以布置为在操作系统上由一个或多个处理器204利用程序数据224执行指令。操作系统220例如可以是Linux、Windows等，其包括用于处理基本系统服务以及执行依赖于硬件的任务的程序指令。应用222包括用于实现各种用户期望的功能的程序指令，应用222例如可以是浏览器、即时通讯软件、软件开发工具(例如集成开发环境IDE、编译器等)等，但不限于此。当应用222被安装到计算设备200中时，可以向操作系统220添加驱动模块。

在计算设备200启动运行时，处理器204会从存储器206中读取操作系统220的程序指令并执行。应用222运行在操作系统220之上，利用操作系统220以及底层硬件提供的接口来实现各种用户期望的功能。当用户启动应用222时，应用222会加载至存储器206中，处理器204从存储器206中读取并执行应用222的程序指令。

计算设备200还包括储存设备232，储存设备232包括可移除储存器236和不可移除储存器238，可移除储存器236和不可移除储存器238均与储存接口总线234连接。

计算设备200还可以包括有助于从各种接口设备(例如，输出设备242、外设接口244和通信设备246)到基本配置202经由总线/接口控制器230的通信的接口总线240。示例的输出设备242包括图形处理单元248和音频处理单元250。它们可以被配置为有助于经由一个或者多个A/V端口252与诸如显示器或者扬声器之类的各种外部设备进行通信。示例外设接口244可以包括串行接口控制器254和并行接口控制器256，它们可以被配置为有助于经由一个或者多个I/O端口258和诸如输入设备(例如，键盘、鼠标、笔、语音输入设备、触摸输入设备)或者其他外设(例如打印机、扫描仪等)之类的外部设备进行通信。示例的通信设备246可以包括网络控制器260，其可以被布置为便于经由一个或者多个通信端口264与一个或者多个其他计算设备262通过网络通信链路的通信。

网络通信链路可以是通信介质的一个示例。通信介质通常可以体现为在诸如载波或者其他传输机制之类的调制数据信号中的计算机可读指令、数据结构、程序模块，并且可以包括任何信息递送介质。“调制数据信号”可以这样的信号，它的数据集中的一个或者多个或者它的改变可以在信号中编码信息的方式进行。作为非限制性的示例，通信介质可以包括诸如有线网络或者专线网络之类的有线介质，以及诸如声音、射频(RF)、微波、红外(IR)或者其它无线介质在内的各种无线介质。这里使用的术语计算机可读介质可以包括存储介质和通信介质二者。

在根据本发明的计算设备200中，应用222包括用于执行本发明的数据处理方法300/400的指令，该指令可以指示处理器204执行本发明的数据处理方法300/400。

图3示出了根据本发明一个实施例的数据处理方法300的流程图，方法300适于在服务器(例如由图2中的计算设备实现)中执行，服务器与客户端通信连接，用户通过客户端浏览网站中的新闻、视频等主体内容，以及主体内容中用户的评论信息或留言，还可以通过客户端发表评论，这些评论信息最终都会存储到服务器中，服务器包括第一数据存储设备、第二数据存储设备和消息中间件，第一数据存储设备中的信息通过消息中间件存储到第二数据存储设备中。

根据本发明的实施例，第一数据存储设备可以通过关系型数据库实现，可以是Oracle，SQLServer，DB2，Mysql等任意一种关系型数据库，但不限于此。第二数据存储设备可以通过非关系型数据库实现，可以是CouchDB、MongoDb、SequoiaDB等任意一种，但不限于此。本发明对数据存储方式的具体实现不做限制，其他具有类似功能的数据存储方式也都在本发明的保护范围之内。

如图3所示，方法300始于步骤S310。在步骤S310中，从客户端获取用户发表的评论信息，称为第一评论信息。第一评论信息中会包括有主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容、评论时间，以便服务器端能够根据这些信息将当前收到的评论信息进行相应的存储，并更新到网站，便于用户浏览。

根据本发明的实施例，主体内容标识就是最上级主体内容的唯一标识码，比如今天的焦点访谈视频对应一个唯一标识码010101，用以区别同一网站上其他的主体内容，则010101为今天的焦点访谈的主体内容标识，主体内容的唯一标识一般是在主体内容发送到网站上时生成的。

每个主体内容对应一个评论区，评论区中包括对主体内容的直接评论，称为主评论(也称为一级评论)，还包括对主评论(一级评论)的评论，称为二级评论，对二级评论的评论称为三级评论，以此类推，一级评论之后的评论统称为非主评论。评论区的每一条评论(包括主评论和非主评论)都对应一个主键ID，以唯一标识该条评论。评论信息中所包含的主评论标识指代当前获取到的评论信息所对应的主评论的主键ID。若当前收到的第一评论信息携带的主评论标识为“0”，表示该评论信息本身为主评论。

回复对象标识为当前收到的第一评论信息的上一级评论信息的主键ID，若当前收到的评论信息携带的主评论标识为“0”，表示该评论信息为主评论。

评论对象为该评论信息的上一级评论的用户网名，当第一评论信息为主评论时，其携带的评论对象为空。

评论用户是发表当前评论信息的用户的网名，评论内容是用户所发表的相关内容，评论时间为用户发表评论的时间。

在收到第一评论信息后，进入步骤S320，将收到的第一评论信息存储到第一数据存储设备。

根据本发明的一个实施例，A网站上存在一个主体内容标识为030303的主体内容，目前包括三条评论，包括用户“张三”的主评论、用户“李四”对“张三”主评论的评论，以及用户“王五”对张三主评论的评论。本实施例中以关系型数据库实现第一存储设备，关系型数据库通常按照时间以列表的方式进行存储，根据当前的评论信息，第一数据存储设备中的数据存储如表1所示。

表1

根据本发明的一个实施例，在步骤S310中收到的第一评论信息，主体内容为“030303”，主评论标识为“1”，回复对象标识为“2”，评论对象为“李四”，评论用户为“小明”，评论内容为“同情你”，评论时间为“2020/1/1/12:03”。则本步骤中，首先为当前收到的第一评论信息生成一个主键ID，以通过主键ID自增的方式生成该评论信息的主键ID“4”，根据主键ID以及第一评论信息中的字段生成一条新的评论信息记录存储到第一存储设备中。

根据本发明的又一个实施例，在步骤S310中，又收到的一个评论信息评论信息，主体内容为“040404”，主评论标识为“0”，回复对象标识为“0”，评论对象为“”，评论用户为“小白”，评论内容为“今天有日食”，评论时间为“2020/1/1/12:04”，“小白”的评论信息在进入本步骤后，同样，首先生成该评论信息的主键ID“5”，根据主键ID以及收到的第一评论信息生成对应第一数据存储设备实现方式的添加记录的指令，例如，第一数据存储设备有SQLserver实现，则生成一条SQLserver的添加记录的指令，将新生成的评论记录存储到第一数据存储设备中。最终，第一数据存储设备中的数据更新为如表2所示。

表2

在步骤S320中，还包括将评论信息处理结果返回客户端。

在步骤S330，将第一评论信息同步到消息中间件中。消息中间件可以屏蔽掉不同存储设备之间的特性的不同，从而降低第一存储设备和第二存储设备间的耦合度，降低用户发布评论时的逻辑负责度，从而更快响应用户的操作。消息中间件可以使用ActiveMQ、RabbitMQ、Kafka等中的任意一种，本发明对此不做限制。

根据本发明的一个实施例，将第一评论消息和对应的主键ID存储到消息中间件(例如RabbitMQ)中，也可以理解为将第一数据存储设备(关系型数据库)中新创建的评论记录存储到消息中间件中，以激活第二数据存储设备对该评论信息的同步，在向消息中间件中同步消息时，添加操作类型，添加新的评论信息时，操作类型可以用“A”标识。

随后进入步骤S340，将消息中间件中的评论信息和主键ID同步到第二数据存储设备中。当中间件收到消息更新时，即第一数据存储设备同步到中间件时，将激活第二存储设备根据消息中间件中的消息进行消息同步，根据本发明的实施例，第二数据存储设备以非关系型数据库实现，以树形结构进行存储，因此，在数据结构上，评论信息会多一个“回复”字段，用以存储下一级评论信息。具体实现时，可以是CouchDB、MongoDb、SequoiaDB等任意一种，但不限于此。

继续以上述实施例进行说明，在更新“小明”对李四的评论，以及“小白”对主体内容“040404”的评论前，第二数据存储设备中的数据如图5所示。

以“小明”对“李四”的评论为例，在本步骤中，首先获取操作类型为添加评论信息，后根据该评论信息中的回复对象标识，获取到其上一级评论信息，根据图4可知，其上一级评论信息的主键ID为2，在该评论信息中增加“回复”字段，并将“小明”对“李四”的评论添加到该“回复”字段。

根据本发明的实施例，“小白”对主体内容“040404”的评论，为用户对另一个主体内容的主评论，则直接创建新的数据记录，记录该评论信息，更新后的第二数据存储设备中的数据存储如图6所示。

在每一条用户发表的评论信息都会根据方法300进行存储，以便当用户打开对应的内容时，能够从服务器端的非关系型数据库快速获取到评论区的用户评论，因为该存储结构直接以树形结构存储，不需要根据上下级之间的节点关系进行树形结构拼接，查询的逻辑复杂度大大降低，加快了客户端的查询速度，提高了用户体验。

图4示出了根据本发明一个实施例的数据处理方法400的流程图；方法400适于在服务器(例如由图2中的计算设备实现)中执行，服务器与管理终端通信连接，管理员可以通过管理终端从服务器的第一数据存储设备中获取到用户的评论信息，因为第一数据存储设备由关系型数据库实现，评论数据是根据时间顺序存储的，这对于关注最新发布信息的管理员来说，信息搜索过程更为简单。管理员通过对用户评论中敏感信息的过滤，对相应的评论信息进行相应的修改或删除等操作。

如图4所示，方法400始于步骤S410，在本步骤中，从管理终端获取管理员提交的更新的评论信息(即第二评论信息)，第二评论信息中包括主键ID、操作标识、和\或修改的字段，修改的字段为主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容以及评论时间中的一个或者多个，操作标识可以用“U”表示修改，用“D”表示删除。以表2中的评论信息为例，比如，管理员要删除主键为4的评论记录，则通过管理终端提交过来的第二评论信息包括主键ID“4”，操作标识“D”，对于删除操作，可以不包括修改的字段。

在步骤S420中，根据第二评论信息中数据更新第一数据存储设备中的数据。当获取到的第二评论信息中的操作标识为“U”时，则根据主键ID获取到相应的评论信息，根据第二评论信息中所携带的字段修改评论信息中的响应的字段。若操作标识为“D”，则根据主键ID获取到相应的评论信息，并将其置为“删除”状态，或者直接删除。

随后进入步骤S430，将第二评论信息存储到消息中间件，并同步到第二数据存储设备中。第二评论信息写到消息中间件时，会触发第二数据存储设备从消息中间件中获取相应的信息进行同步。

根据本发明的一个实施例，第二评论信息中包括主键ID“5”、操作标识“U”和评论内容“今天没有日食”，第二数据存储设备在获取到该同步消息后，根据主键ID查找到该评论记录，将其中的评论内容修改为“今天没有日食”，应当指出，该实施例仅为示例性说明。

需要说明的是，在删除操作时，可以根据需要在数据操作时直接删除或者将响应的评论记录置为删除状态，如果是置为“删除”状态，在客户端从第二数据存储设备中获取评论内容时，只是不显示该评论内容，而该评论的下一级的评论仍正常显示，当为直接删除时，则在第二数据存储设备中直接删除该评论及下面的评论，客户端也不会获取到该删除的评论信息及下面的评论，在具体实践中，可以根据需要进行设置。

图5示出了根据本发明一个实施例的数据处理装置500的示意图，装置500适于驻留在服务器中，执行方法300/400，服务器分别与客户端和管理终端通信连接。

如图5所示，数据处理装置500包括第一数据存储设备510、消息中间件520和第二数据存储设备530。

第一数据存储设备510，适于从所述客户端获取用户的第一评论信息，并为该评论信息生成主键ID，存储第一评论信息。还适于从管理终端接收管理员对评论信息的更新，并根据所收到的更新内容进行相应的更新。

根据本发明的实施例，第一数据存储设备通过关系型数据库实现，可以是Oracle，SQLServer，DB2，Mysql等任意一种关系型数据库，但不限于此。

消息中间件520，适于将第一数据存储设备510中的数据同步到第二数据存储设备520中。消息中间件可以屏蔽掉不同存储设备之间的特性的不同，从而降低第一存储设备和第二存储设备间的耦合度，降低用户发布评论时的逻辑负责度，从而更快响应用户的操作。

根据本发明的实施例，消息中间件520可以使用ActiveMQ、RabbitMQ、Kafka等中的任意一种，本发明对此不做限制。

第二数据存储设备520，适于存储消息中间件520同步过来的评论数据，最终保持与第一数据存储设备510中的数据一致。

根据本发明的实施例，第二数据存储设备520可以是CouchDB、MongoDb、SequoiaDB等任意一种，但不限于此。

根据本发明的数据处理方法，将用户发表的评论信息首先存储在关系型数据库实现的第一数据存储设备中，并通过消息中间件同步到由非关系型数据库实现的第二数据存储设备中，由于关系型数据库中的数据是根据时间进行存储的，管理员在管理终端可以通过关系型数据库获取最新的评论信息进行敏感信息查询，并对评论信息进行更新，同时，因为非关系型数据中的数据是根据评论信息之间的关系以树状结构进行存储的，可以提高用户通过客户端从非关系型数据库中获取评论信息的处理速率，提高了用户体验。

这里描述的各种技术可结合硬件或软件，或者它们的组合一起实现。从而，本发明的方法和设备，或者本发明的方法和设备的某些方面或部分可采取嵌入有形媒介，例如可移动硬盘、U盘、软盘、CD-ROM或者其它任意机器可读的存储介质中的程序代码(即指令)的形式，其中当程序被载入诸如计算机之类的机器，并被所述机器执行时，所述机器变成实践本发明的设备。

在程序代码在可编程计算机上执行的情况下，计算设备一般包括处理器、处理器可读的存储介质(包括易失性和非易失性存储器和/或存储元件)，至少一个输入装置，和至少一个输出装置。其中，存储器被配置用于存储程序代码；处理器被配置用于根据该存储器中存储的所述程序代码中的指令，执行本发明的数据处理方法。

以示例而非限制的方式，可读介质包括可读存储介质和通信介质。可读存储介质存储诸如计算机可读指令、数据结构、程序模块或其它数据等信息。通信介质一般以诸如载波或其它传输机制等已调制数据信号来体现计算机可读指令、数据结构、程序模块或其它数据，并且包括任何信息传递介质。以上的任一种的组合也包括在可读介质的范围之内。

在此处所提供的说明书中，算法和显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与本发明的示例一起使用。根据上面的描述，构造这类系统所要求的结构是显而易见的。此外，本发明也不针对任何特定编程语言。应当明白，可以利用各种编程语言实现在此描述的本发明的内容，并且上面对特定语言所做的描述是为了披露本发明的最佳实施方式。

在此处所提供的说明书中，说明了大量具体细节。然而，能够理解，本发明的实施例可以在没有这些具体细节的情况下被实践。在一些实例中，并未详细示出公知的方法、结构和技术，以便不模糊对本说明书的理解。

应当理解，为了精简本公开并帮助理解各个发明方面中的一个或多个，在上面对本发明的示例性实施例的描述中，本发明的各个特征有时被一起分组到单个实施例、图、或者对其的描述中。然而，并不应将该公开的方法解释成反映如下意图：即所要求保护的本发明要求比在每个权利要求中所明确记载的特征更多特征。更确切地说，如下面的权利要求书所反映的那样，发明方面在于少于前面公开的单个实施例的所有特征。因此，遵循具体实施方式的权利要求书由此明确地并入该具体实施方式，其中每个权利要求本身都作为本发明的单独实施例。

本领域那些技术人员应当理解在本文所公开的示例中的设备的模块或单元或组件可以布置在如该实施例中所描述的设备中，或者可替换地可以定位在与该示例中的设备不同的一个或多个设备中。前述示例中的模块可以组合为一个模块或者此外可以分成多个子模块。

本领域那些技术人员可以理解，可以对实施例中的设备中的模块进行自适应性地改变并且把它们设置在与该实施例不同的一个或多个设备中。可以把实施例中的模块或单元或组件组合成一个模块或单元或组件，以及此外可以把它们分成多个子模块或子单元或子组件。除了这样的特征和/或过程或者单元中的至少一些是相互排斥之外，可以采用任何组合对本说明书(包括伴随的权利要求、摘要和附图)中公开的所有特征以及如此公开的任何方法或者设备的所有过程或单元进行组合。除非另外明确陈述，本说明书(包括伴随的权利要求、摘要和附图)中公开的每个特征可以由提供相同、等同或相似目的的替代特征来代替。

A8、如A1-A7中任意一项所述的方法，其中，当所述更新类型为修改时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：

根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并根据所述第二评论信息对所述评论记录中的数据进行更新；

将所述第二评论信息同步所述消息中间件；

根据所述消息中间件的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并进行更新。

A9、如A7或A8所述的方法，其中，当所述更新的类型为删除时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：

根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并将所述评论记录置为删除状态；

将所述第二评论信息同步所述信息系统；

根据所述信息系统中的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并置为删除状态。

A10、如A1-A9中任意一项所述的方法，还包括：

根据用户在客户端的查看请求，将所述第二数据存储设备中的评论信息在所述客户端进行展示。

A11、如A1-A10中任意一项所述的方法，其中，所述第一数据存储设备为关系型数据库。

A12、如A1-A11中任意一项所述的方法，其中，所述第二数据存储设备为非关系型数据库。

此外，本领域的技术人员能够理解，尽管在此所述的一些实施例包括其它实施例中所包括的某些特征而不是其它特征，但是不同实施例的特征的组合意味着处于本发明的范围之内并且形成不同的实施例。例如，在下面的权利要求书中，所要求保护的实施例的任意之一都可以以任意的组合方式来使用。

此外，所述实施例中的一些在此被描述成可以由计算机系统的处理器或者由执行所述功能的其它装置实施的方法或方法元素的组合。因此，具有用于实施所述方法或方法元素的必要指令的处理器形成用于实施该方法或方法元素的装置。此外，装置实施例的在此所述的元素是如下装置的例子：该装置用于实施由为了实施该发明的目的的元素所执行的功能。

如在此所使用的那样，除非另行规定，使用序数词“第一”、“第二”、“第三”等等来描述普通对象仅仅表示涉及类似对象的不同实例，并且并不意图暗示这样被描述的对象必须具有时间上、空间上、排序方面或者以任意其它方式的给定顺序。

尽管根据有限数量的实施例描述了本发明，但是受益于上面的描述，本技术领域内的技术人员明白，在由此描述的本发明的范围内，可以设想其它实施例。此外，应当注意，本说明书中使用的语言主要是为了可读性和教导的目的而选择的，而不是为了解释或者限定本发明的主题而选择的。因此，在不偏离所附权利要求书的范围和精神的情况下，对于本技术领域的普通技术人员来说许多修改和变更都是显而易见的。对于本发明的范围，对本发明所做的公开是说明性的，而非限制性的，本发明的范围由所附权利要求书限定。

Claims (12)

1.一种数据处理方法，适于在服务器中执行，所述服务器包括第一数据存储设备、第二数据存储设备和消息中间件，所述服务器分别与客户端、评论管理终端连接，所述方法包括：

从所述客户端获取用户的第一评论信息，所述第一评论信息的字段包括：主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容以及评论时间；

将所述第一评论信息存储到所述第一数据存储设备，以便通过所述管理终端查看所述第一评论信息；

将所述第一评论信息通过所述消息中间件同步到所述第二数据存储设备，以便根据用户请求在所述客户端展示所述第一评论信息；

其中，所述将所述第一评论信息通过所述消息中间件同步到所述第二数据存储设备包括：

将所述第一评论信息和对应的主键ID存储到所述消息中间件；

所述第二数据存储设备从所述消息中间件中获取第一评论信息和对应的主键ID；

将所述第一评论信息和主键ID存储到所述第二数据存储设备；

其中，所述第一评论信息的类型包括主评论和非主评论，当所述评论信息为主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备包括：

根据所述第一评论信息和所述主键ID生成第二评论记录；

将所述第二评论记录存储到所述第二数据存储设备；

其中，当所述第一评论信息为非主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备中包括：

根据内容标识、主评论标识和回复对象标识在所述第二数据存储设备中获取该第一评论信息对应的上一级评论记录；

根据所述第一评论信息和所述主键ID生成第二评论记录；

将所述第二评论记录添加到所述上一级评论记录的回复字段中。

2.如权利要求1所述的方法，其中，所述将所述第一评论信息存储到所述第一数据存储设备包括：

生成所述第一评论信息的主键ID；

根据所述主键ID和所述第一评论信息生成新的第一评论记录存储到所述第一数据存储设备；

返回所述第一评论信息的处理结果。

3.如权利要求2所述的方法，其中，所述生成所述第一评论信息的主键ID包括：

通过自增的方式生成所述第一评论信息的主键ID。

4.如权利要求1-3中任意一项所述的方法，还包括：

从所述管理终端获取第二评论信息，所述第二评论信息为管理员对用户的原评论信息的更新内容，所述第二评论信息包括的字段有主键ID，更新类型，以及评论内容，所述更新类型包括修改和删除；

根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备。

5.如权利要求4所述的方法，其中，当所述更新类型为修改时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：

根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并根据所述第二评论信息对所述评论记录中的数据进行更新；

将所述第二评论信息同步所述消息中间件；

根据所述消息中间件的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并进行更新。

6.如权利要求5所述的方法，其中，当所述更新的类型为删除时，所述根据所述第二评论信息对所述第一数据存储设备中的评论信息进行更新，并同步到所述第二数据存储设备包括：

根据所述主键ID从所述第一数据存储设备查找到对应该主键ID的评论记录，并将所述评论记录置为删除状态；

将所述第二评论信息同步所述消息中间件；

根据所述消息中间件中的第二评论信息中的主键ID，从所述第二数据存储设备中获取相应的评论记录，并置为删除状态。

7.如权利要求1-3中任意一项所述的方法，还包括：

根据用户在客户端的查看请求，将所述第二数据存储设备中的评论信息在所述客户端进行展示。

8.如权利要求1-3中任意一项所述的方法，其中，所述第一数据存储设备为关系型数据库。

9.如权利要求1-3中任意一项所述的方法，其中，所述第二数据存储设备为非关系型数据库。

10.一种数据处理装置，适于驻留在服务器中，所述服务器分别与客户端、评论管理终端连接，所述装置包括：第一数据存储设备、第二数据存储设备和消息中间件，其中，

第一数据存储设备，适于从所述客户端获取用户的第一评论信息，所述第一评论信息包括主体内容标识、主评论标识、回复对象标识、评论对象、评论用户、评论内容、评论时间，还适于存储所述第一评论信息，以便管理员通过所述管理终端管理评论信息；

消息中间件，适于将所述第一数据存储设备中的数据同步到所述第二数据存储设备中；

第二数据存储设备，适于存储通过所述消息中间件同步过来的第一数据存储设备中的评论消息，以便提高在所述客户端进行评论展示时的查询效率；

其中，所述将所述第一评论信息通过所述消息中间件同步到所述第二数据存储设备包括：

将所述第一评论信息和对应的主键ID存储到所述消息中间件；

所述第二数据存储设备从所述消息中间件中获取第一评论信息和对应的主键ID；

将所述第一评论信息和主键ID存储到所述第二数据存储设备；

其中，所述第一评论信息的类型包括主评论和非主评论，当所述评论信息为主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备包括：

根据所述第一评论信息和所述主键ID生成第二评论记录；

将所述第二评论记录存储到所述第二数据存储设备；

其中，当所述第一评论信息为非主评论时，所述将所述第一评论信息和主键ID存储到所述第二数据存储设备中包括：

根据内容标识、主评论标识和回复对象标识在所述第二数据存储设备中获取该第一评论信息对应的上一级评论记录；

根据所述第一评论信息和所述主键ID生成第二评论记录；

将所述第二评论记录添加到所述上一级评论记录的回复字段中。

11.一种计算设备，包括：

至少一个处理器；以及

存储器，存储有程序指令，其中，所述程序指令被配置为适于由所述至少一个处理器执行，所述程序指令包括用于执行如权利要求1-9中任一项所述方法的指令。

12.一种存储有程序指令的可读存储介质，当所述程序指令被计算设备读取并执行时，使得所述计算设备执行如权利要求1-9中任一项所述方法。