一种消息存放方法和装置的制造方法
一种消息存放方法和装置的制造方法
【技术领域】
[0001]本发明涉及计算机技术领域，特别是涉及一种消息存放方法和一种消息存放装置。
【背景技术】
[0002]随着计算机与互联网等与人们的生活越来越密不可分，为了更好地为提供服务，越来越多的消息会被记录以备用，例如日志消息等。目前常用的处理日志消息的消息队列是Kafka消息队列，Kafka消息队列是一种分布式消息队列，其有自己的传递消息的协议，称为kafka协议。目前常用的消息队列存放方案是利用Kafka协议将日志消息传递至Kafka消息队列中，若需要用到Kafka消息队列中的部分日志消息，则会通过调用API，将上述日志消息传递至所需的服务器。
[0003]对于上述常用的消息队列存放方案，存在两方面问题。一方面，利用Kafka协议传递消息的过程中不会对消息加密，从而导致安全性不高；另外一方面，在上述方案中，没有经过身份认证，任何一个转发服务器相连接的服务器都可以向Kafka消息队列中存放消息，会将不需要存放的应用服务器上的消息也都被存放至同一Kafka消息队列中，进而降低了所存放消息的有效性和安全性。
【发明内容】
[0004]鉴于上述问题，提出了本发明以便提供一种克服上述问题或者至少部分地解决上述问题的第一队列消息存放方法和相应的第一队列消息存放装置。
[0005]依据本发明的一个方面，提供了一种消息存放方法，包括:
[0006]接收应用服务器发送的认证请求；
[0007]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0008]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0009]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0010]可选地，所述接收应用服务器发送的认证请求的步骤包括:
[0011 ] 接收应用服务器通过https协议发送的https认证请求。
[0012]可选地，所述接收所述应用服务器发送的消息请求的步骤包括:
[0013]接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。
[0014]可选地，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括:
[0015]对所述https消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。
[0016]可选地，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0017]从所述https消息请求或者http消息请求的数据区提取第一队列消息；
[0018]将所述第一队列消息转发至队列服务器的任务队列。
[0019]可选地，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0020]将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[0021]将所述第二队列消息转发至队列服务器的任务队列。
[0022]可选地，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括:
[0023]判断指定时间周期内，是否接收到至少两个消息请求；
[0024]如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤；
[0025]如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。
[0026]可选地，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括:
[0027]在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0028]可选地，在还包括:
[0029]当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0030]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0031 ]根据本发明的另一方面，提供了一种消息存放装置，包括:
[0032]认证请求接收模块，适于接收应用服务器发送的认证请求；
[0033]第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；
[0034]消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0035]转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0036]可选地，所述认证请求接收模块，包括:
[0037]https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0038]可选地，所述消息请求接收模块，包括:
[0039]https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的https消息请求；[°04°]和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0041 ]可选地，在https消息请求接收模块之后，还包括:
[0042]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块。
[0043]可选地，所述转发模块，包括:
[0044]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0045]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0046]可选地，所述转发模块，包括:
[0047]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;
[0048]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0049]可选地，所述合并子模块之前，还包括:
[0050]判断模块，适于判断指定时间周期内，是否接收到至少两个消息请求；
[0051 ]如果未接收到至少两个消息请求，则进入转发模块；
[0052]如果接收到至少两个消息请求，则进入合并子模块。
[0053]可选地，所述合并子模块包括:
[0054]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0055]可选地，还包括:
[0056]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0057]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0058]根据本发明的另一方面，提供了一种消息存放设备，包括:
[0059]存储器，加载有多条可执行指令；
[0060]处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0061 ]接收应用服务器发送的认证请求；
[0062]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0063]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0064]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0065]根据本发明的消息存放方法可以先对应用服务器进行身份验证，还可以对身份验证信息加密后在发送，而且，对于身份验证信息以外的信息，也可以根据其保密要求选择性地加密后再传送，另外，对于指定时间周期收到的多个消息请求，会将其中的第一队列消息合并为一个第二队列消息，由此解决了任何应用服务器都可以将其第一队列消息向队列服务器的任务队列存放消息，导致数据不安全、数据冗余较多，使任务队列的数据有效性和安全性低的问题，取得了可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性的有益效果Ο
[0066]上述说明仅是本发明技术方案的概述，为了能够更清楚了解本发明的技术手段，而可依照说明书的内容予以实施，并且为了让本发明的上述和其它目的、特征和优点能够更明显易懂，以下特举本发明的【具体实施方式】。
【附图说明】
[0067]通过阅读下文优选实施方式的详细描述，各种其他的优点和益处对于本领域普通技术人员将变得清楚明了。附图仅用于示出优选实施方式的目的，而并不认为是对本发明的限制。而且在整个附图中，用相同的参考符号表示相同的部件。在附图中:
[0068]图1示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0069]图2示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0070]图3示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0071]图4示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0072]图5示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0073]图6示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0074]图7示出了根据本发明一个实施例的一种系统的结构示意图；
[0075]图8示出了根据本发明一个实施例的一种设备的结构示意图。
【具体实施方式】
[0076]下面将参照附图更详细地描述本公开的示例性实施例。虽然附图中显示了本公开的示例性实施例，然而应当理解，可以以各种形式实现本公开而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本公开，并且能够将本公开的范围完整的传达给本领域的技术人员。
[0077]参照图1，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[0078]步骤S110，接收应用服务器发送的认证请求。
[0079]其中，应用服务器提供访问商业逻辑的途径以供客户端应用程序使用，例如游戏应用服务器、杀毒服务器等。
[0080]在本发明实施例中，应用服务器发送的认证请求中的目的是为了认证是否可以接收该应用服务发送消息请求，即是否能与该应用服务器建立通信。所以该认证请求中应包 含该应用服务器的身份验证信息。
[0081 ] 步骤S120，对所述认证请求进行身份验证，并判断身份验证是否通过。
[0082]如上所述，应用服务器发送的认证请求的目的是为了认证是否可以接收该应用服务发送消息请求，该判断过程即为上述的身份验证过程。
[0083]在本发明实施例中，可以以应用服务器的用户名和密码作为身份验证的依据。当然，关于身份验证的【具体实施方式】本发明实施例不加以限定。
[0084]步骤S130，当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。
[0085]若身份验证通过，即可接收应用服务器发送的消息请求。在本发明实施例中，上述消息请求中包括第一队列消息。
[0086]其中的第一队列消息可以是应用服务器产生的各类消息，如日志消息等。在本发明实施例中，以日志消息为例进行介绍。
[0087]步骤S140，根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0088]其中的队列服务器是用以存储消息队列的服务器，例如常用于处理日志消息的Kafka队列服务器，任务队列可以为Kafka队列。其中，Kafka是分布式发布-订阅消息系统。
[0089]转发是指将消息请求中的第一队列消息传送至队列服务器的任务队列，对于具体的传送方式，本发明实施例不加以限定。
[0090]在本发明实施例中，以转发服务器作为载体，实现上述转发的过程。在本发明实施例中，转发服务器是一种web服务器，可以支持HTTP协议和/或HTTPS协议。
[0091]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0092]实施例二
[0093]参照图2，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[0094]步骤S210，接收应用服务器通过https协议发送的https认证请求。
[0095]其中，https(Hyper Text Transfer Protocol over Secure Socket Layer，基于SSL的http)协议提供了身份验证与加密通信方法，现在它被广泛用于互联网上安全敏感的通信。https协议使用了http协议，https协议会采用SSL (Secure Sockets Layer安全套接层)通道，对传送的信息自动加密并以加密的形式传送信息。
[0096]其中的SSL(Secure Sockets Layer，安全套接层)，可提供的服务包括:认证用户和服务器，确保数据发送到正确的客户机和服务器;加密数据以防止数据中途被窃取;维护数据的完整性，确保数据在传输过程中不被改变。而且，SSL客户端的身份验证是可选的，由SSL服务器决定是否验证SSL客户端的身份。
[0097]而其中的http协议是一个属于应用层的面向对象的协议，由于其简捷、快速的方式，适用于分布式超媒体信息系统。但是http协议本身不具有加密、身份验证的功能，SPhttp协议是以明文的形式传送信息。
[0098]在判断是否能接收应用服务器发送的消息指令之前，首先要对该应用服务器进行身份验证以与该应用服务器建立通信关系。
[0099]对于应用服务器发送的认证请求，应该包含应用服务器的应用服务器的身份验证信息，如用户名和密码等。为了避免上述应用服务器的身份验证信息被盗用，所以应对上述认证请求加密后再传送，即利用https协议发送https认证请求。在本发明实施例中，以用户名和密码作为身份验证信息进行说明。
[0100]具体的认证过程如下:
[0101](1)应用服务器发送一个连接请求给转发服务器;转发服务器将自己的证书、对称加密算法种类及其他相关信息返回应用服务器，其中的证书中包含转发服务器公钥3_PuKeyο
[0102](2)应用服务器检查转发服务器传送的证书是否由自己信赖的CA中心签发。若是，执行(4);否则，给客户一个警告信息:询问是否继续访问。
[0103](3)应用服务器比较证书里的信息，如证书有效期、服务器域名和公钥S_PK，与转发服务器传回的信息是否一致，如果一致，则应用服务器完成对转发服务器的初步身份认证。
[0104](4)应用服务器发送应用服务器的证书、支持的对称加密方案及其他相关信息到转发服务器，其中的应用服务器的证书包含应用服务器公钥C_PuKey。收到后，转发服务器比较证书里的信息，如证书有效期、服务器域名和公钥S_PK，与应用服务器发送信息是否一致，若不一致，则拒绝连接。若一致，则进入(5)。
[0105](5)转发服务器根据应用服务器发送的到密码种类，选择一种加密程度最高的方案，利用公钥(:_?1!1(#加密后，返回至应用服务器。
[0106](6)应用服务器通过私钥C_PrKey解密后，得知转发服务器选择的加密方案，并选择一个通话密钥key，接着用转发服务器公钥3_?1!1(^加密后发送给转发服务器。
[0107](7)转发服务器接收到的应用服务器传送的消息，用私解密，获得通话密钥key。
[0108](8)应用服务器利用上述通话密钥key对应用服务器发送的认证请求加密后发送至转发服务器，其中认证请求中包括身份验证信息，如用户名和密码。
[0109]步骤S220，对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入步骤S230。
[0110]在本发明实施例中，对于各有资格存放消息的应用服务器，会将其对应身份信息，包括用户名、密码等，按照一定格式存储于数据库中，例如以cookie的形式存入数据库中。
[0111]则将上述认证请求中所包含的用户名和密码，与已存储于数据库中的身份信息相匹配，若匹配成功，则通过此次身份验证，若匹配不成功，则不通过此次身份验证。
[0112]在本发明实施例中，转发服务器利用上述通话密钥key对接收到的身份验证信息解密并与数据库中存储的身份信息匹配，若匹配成功，则表明身份验证通过。若匹配不成功，则拒绝应用服务器连接转发服务器。
[0113]该身份验证过程的目的在于，确认是否接收应用服务器发送的消息请求。
[0114]步骤S230，接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过h t tp协议发送的h t tp消息请求；
[0115]其中，所述https消息请求或http消息请求中包括第一队列消息。
[0?16] 若接收所述应用服务器通过https协议发送的https消息请求，则进入步骤S240 ；若接收所述应用服务器通过http协议发送的http消息请求，则进入步骤S250。
[0117]在实际应用过程中，考虑到安全性的问题，在传送用户名和密码以完成身份验证时，为了避免应用服务器的身份验证信息被盗用，必须对其中的用户名和密码进行加密发送，所以此时通过https协议发送https消息请求，该消息请求中包括含有用户名和密码的第一队列消息。
[0118]—方面，若要进一步确保所接收的应用服务器发送的每条消息请求的安全性，可以对每条消息请求进行身份验证。此时，需要每条消息请求中都包含应用服务器的上述应用服务器的身份验证信息，而根据上述安全性的需要，对于应用服务器的身份验证信息应利用https协议加密。
[0119]因此，为了进一步确保所接收的每条消息请求的安全性，在身份验证通过后，仍然利用https协议发送消息请求，则接收到的为应用服务器通过https协议发送的https消息请求。
[0120]但是，另外一方面，若要将消息请求都加密后再转发至队列服务器，则会导致各方面的性能损耗较大。所以在身份验证后，根据消息请求中所包括的第一队列消息的内容是否需要加密，选择性地利用https协议发送或者利用http协议发送，则最终利用https协议发送的为https消息请求，利用http协议发送的为http消息请求。具体地，对于接收到的消息请求是https消息请求还是http消息请求，是通过应用服务器根据保密需求灵活设定的，对此，本发明不加以限定。
[0121]另外，若应用服务器利用http协议发送的http请求消息，其中也可以包含应用服务器的身份验证信息，此时采用明文的方式传送消息请求，为了提高安全性，也可以对明文发送的应用服务器的身份验证信息进行身份验证，只是明文形式的应用服务器的身份验证信息比加密形式的应用服务器的身份验证信息，被盗用的可能性比较大。相对来说，对用http协议发送的http消息请求进行身份验证，与对用https协议发送的https消息请求进行身份验证相比较，明显后者的安全性会高更多。所以，本发明实施例中，优选地，利用https协议发送包含应用服务器的身份验证信息的https消息请求。
[0122]步骤S240，对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入步骤S250。
[0123]其中，上述的https消息请求中同样包含上述的应用服务器的身份验证信息。对https消息请求进行身份验证，同样是将应用服务器的身份验证信息，如用户名和密码，在已存储于数据库中的身份信息中相匹配，若匹配成功，则通过身份验证;若匹配不成功，则不通过身份验证。
[0124]该身份验证过程的目的在于，在每次接收到应用服务器发送的信息请求后，确认该信息请求是有资格存放消息的应用服务器发送的，即是否将该信息请求中包含的第一消息队列转发至队列服务器的任务队列中。
[0125]在本申请实施例中，对于https消息请求的验证，只需要应用服务器以前述通话密钥key对https消息请求进行加密发送至转发服务器，不用再https消息请求再携带应用服务器的用户名和密码，转发服务器能够再以通话密钥key解密即可认为身份验证通过。当然，应用服务器也可以在https消息请求中携带用户名和密码，转发服务器也可以继续提取用户名和密码与本地的记录进行匹配，进行更进一步的验证。
[0? 26]步骤S250，从所述https消息请求或http消息请求的数据区提取第一队列消息。
[0127]一般而言，https消息请求和http消息请求中都包含消息头和数据区等部分，而本发明介绍的是一种消息存放方法，最终是要将上述https消息请求或http消息请求的数据区的第一队列消息存放至队列服务器中，所以要先从https消息请求或http消息请求的数据区中提取第一队列消息。
[0128]步骤S260，将所述第一队列消息转发至队列服务器的任务队列。
[0129]该步骤与上述步骤S140类似，在此不再赘述。
本发明实施例中，可以利用https协议发送全部认证请求和消息请求，其执行步骤3210、3220、3230(该步骤中只接收11??8消息请求)、3240、3250、3260;或者，利用11??8协议发送认证请求，利用http协议发送全部消息请求，其执行步骤S210、S220、S230 (该步骤中只接收http消息请求)、S250、S260;或者，利用https协议发送认证请求，利用https协议或http协议发送消息请求。对此，本发明不加以限定。
[0131]在本发明实施例中，同样在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0132]实施例三
[0133]参照图3，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[ΟΙ34] 步骤S310，接收应用服务器通过https协议发送的https认证请求。
[0135]步骤S320，对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入步骤S330;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0136]步骤S330，接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求，所述消息请求包括第一队列消息。
[0137]步骤S340，对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入步骤S350。
[0138]步骤S350，判断指定时间周期内，是否接收到至少两个消息请求;如果未接收到至少两个消息请求，则进入步骤S360;如果接收到至少两个消息请求，则进入步骤S370。
[0139]在利用转发服务器转发消息的过程中，会产生一定的冗余消息，很明显，上述冗余信息并没有任何存储的必要，并且如果对每个消息请求都向队列服务器转发第一队列消息，其系统资源消耗大。
[0140]在本发明实施例中，为了尽可能的减少上述冗余消息，以及降低系统资源，会将多个第一队列消息合并后再转发至队列服务器的任务队列，而同时，在合并第一队列消息的时候是一定时间期限的，比如说在5秒或者10秒时间周期内，将接收到的消息请求中的各第一队列消息合并成一个第二队列消息。所以在本发明实施例中，会预先设置指定时间周期，该指定时间周期可以在本步骤之前，或者是本步骤之前的任一步骤之前设置。另外，在本发明实施例中默认本步骤中在所设置的指定时间周期内，至少会接收到一个消息请求。然后需要判断在指定的时间周期之内，是否接收到至少两个消息请求，若未接收到至少两个消息请求，则表明只接收到一个消息请求，则只将该消息请求中的第一队列消息转发至队列服务器的任务队列；若接收到至少两个消息请求，则会将所接收的各消息请求中的各第一队列消息合并为一个第二队列消息，然后再将第二队列消息转发至队列服务器的任务队列。
[0141]步骤S360，将所述第一队列消息转发至队列服务器的任务队列。
[0142]步骤S370，将至少两个消息请求中第一队列消息，合并为一个第二队列消息。
[0143]其中，将多个第一队列消息合并为一个第二队列消息的方式有很多种，如在不同第一队列消息直接加上分隔标识后合并，其中的分隔标识必须有别于消息请求中的第一队列消息的字段，以避免造成分割标识和消息的混乱。如将A、B、C三个队列消息合并，则可以为如下种方式:
[0144]A*—*B*—*C
[0145]其中的一即为上述的分隔标识。
[0146]为了方便将上述的第二队列消息再拆分为合并前的各第一队列消息，所以优选地，在本发明实施例中，步骤S370包括:
[0147]步骤S371，在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0148]其中的分隔标识可以为由任意字符、数字或者特殊符号等随机组成的，与消息请求中第一队列消息的字段不重复的字符串，对此本发明不加以限定。而且该分隔标识是预置的，其可以在本步骤之前预置，也可以在本步骤之前的任一步骤之前预置，本发明实施例对此不加以限定。
[0149]步骤S380，将所述第二队列消息转发至队列服务器的任务队列。
[0150]该步骤与上述将所述第一队列消息转发至队列服务器的任务队列的步骤类似，在此不再赘述。
[0151]针对上述的步骤S371的内容，优选地，本发明实施例中还包括:
[0152]步骤S390，当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0153]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0154]对于处理服务器而言，所处理的消息是最初的第一队列消息。若处理由若干第一队列消息合并成的第二队列消息，与分开处理其中的各第一队列消息作对比，很明显后者的效果会更好。所以，在提取第二队列消息进行处理时，要判断该第二队列消息中是否有上述的分隔标识，若该第二队列消息中有上述的分隔标识，则以该分隔标识为界线，将该第二队列消息拆分为相应的多个第一队列消息，最终处理服务器所处理的是拆分后得到的第一队列消息。
[0155]例如上述的第二队列消息:
[0156]A*——*C
[0157]其中，A、B和C为第一队列消息，“*一*”为分隔标识。
[0158]处理服务器会先判断该第二队列消息中是否有分隔标识，很明显，该第二队列消息中有分隔标识，则，将第二队列消息中的开头到第一个出现的分隔标识之间的字段提取出来，做为一个第一队列消息A;将相邻两个分隔标识之间的字段提取出来，作为一个第一队列消息B;将最后一个分隔标识到第二队列消息结尾之间的字段提取出来，做为一个第一队列消息C。从而，将上述第二队列消息拆分为三个第一队列消息:
[0159]A
[0160]B
[0161]C
[0162]对于本发明实施例中，与发明实施例一、二类似的步骤，不在赘述。
[0163]在本发明实施例中，同样在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0164]另外，本发明实施例中，若在指定时间周期内消息请求的数量不少于两个，则会将该指令时间周期内的消息请求中的第一队列消息合并为一个第二队列消息，降低消息转发次数，降低系统资源消耗。
[0165]对于方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明实施例并不受所描述的动作顺序的限制，因为依据本发明实施例，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作并不一定是本发明实施例所必须的。
[0166]实施例四
[0167]参照图4，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0168]认证请求接收模块410，适于接收应用服务器发送的认证请求。
[0169]第一身份验证模块420，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若通过身份验证，则进入消息请求接收模块430。
[0170]若身份验证未通过，则拒绝应用服务器的连接。
[0171]消息请求接收模块430，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。
[0172]转发模块440，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0173]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0174]实施例五
[0175]参照图5，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0176]认证请求接收模块510，适于接收应用服务器发送的认证请求。具体包括:
[0177]https认证请求接收子模块511，适于接收应用服务器通过https协议发送的https认证请求。
[0178]第一身份验证模块520，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若身份验证通过，则进入消息请求接收模块530。
[0179]消息请求接收模块530，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息;具体包括:
https消息请求接收子模块531，适于接收所述应用服务器通过https协议发送的https消息请求；
[0181]第二身份验证子模块532，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块540;
[0182]http消息请求接收子模块533，适于接收所述应用服务器通过http协议发送的http消息请求。
[0183]转发模块540，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列，具体包括:
[0184]提取子模块541，适于从所述https消息请求或者http请求的数据区提取第一队列消息；
[0185]第一转发子模块542，适于将所述第一队列消息转发至队列服务器的任务队列。
[0186]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0187]实施例六
[0188]参照图6，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0189]认证请求接收模块610，适于接收应用服务器发送的认证请求。具体包括:
https认证请求接收子模块611，适于接收应用服务器通过https协议发送的https认证请求。
[0191]第一身份验证模块620，适于对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入消息请求接收模块630;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0192]消息请求接收模块630，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。具体包括:
[0193]https消息请求接收子模块631，适于接收所述应用服务器通过https协议发送的https消息请求；
[0194]第二身份验证子模块632，适于对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入判断模块640;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0195]http消息请求接收子模块633，适于接收所述应用服务器通过http协议发送的http消息请求。
[0196]判断模块640，适于判断指定时间周期内，是否接收到至少两个消息请求;如果未接收到至少两个消息请求，则进入第二转发子模块652;如果接收到至少两个消息请求，则进入合并子模块651。
[0197]转发模块650，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。具体包括:
[0198]合并子模块651，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[ΟΙ"]优选地，所述合并子模块651包括:
[0200]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0201]第二转发子模块652，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0202]优选地，在本发明实施例中，在转发模块650之后，还包括:
[0203]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识。如果所述第二队列消息中有分隔标识，则进入拆分模块。
[0204]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0205]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0206]另外，本发明实施例中，若在指定时间周期内消息请求的数量不少于两个，则会将该指令时间周期内的消息请求中的第一队列消息合并为一个第二队列消息，可以降低消息的转发次数，降低系统资源的消耗。
[0207]参照图7，示出了本发明实施例的一种系统的结构示意图，具体可以包括:
[0208]应用服务器710、转发服务器720、队列服务器730;
[0209]所述应用服务器710，适于向转发服务器发送认证请求和消息请求；
[0210]所述转发服务器720包括:
[°211 ]认证请求接收模块721，适于接收应用服务器发送的认证请求。所述认证请求接收模块721，包括:
[0212]https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0213]第一身份验证模块722，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若通过身份验证，则进入消息请求接收模块430;若身份验证未通过，则拒绝应用服务器的连接。
[0214]消息请求接收模块723，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。所述消息请求接收模块723，包括:
[02<15] https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的https消息请求；
[0216]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入判断模块。
[02M] 和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0218]判断模块724，适于判断指定时间周期内，是否接收到至少两个消息请求。如果未接收到至少两个消息请求，则进入转发模块;如果接收到至少两个消息请求，则进入合并子模块。
[0219]转发模块725，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。所述转发模块724，包括:
[0220]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0221]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0222]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;所述合并子模块包括:
[0223]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0224]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0225]所述队列服务器730，适于接收第一消息队列并存放至任务队列。
[0226]优选地，还包括数据分析服务器，与队列服务器相连接，用以对从队列服务器的任务队列中提取消息以进行分析。所述数据分析服务器包括:分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0227]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0228]实施例八
[0229]参照图8，示出了本发明实施例的一种设备的结构示意图，所述设备700具体可以包括:
[0230]存储器810，加载有多条可执行指令；
[0231]处理器820，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0232]接收应用服务器发送的认证请求；
[0233]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0234]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0235]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0236]对于装置实施例而言，由于其与方法实施例基本相似，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。
[0237]在此提供的算法和显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与基于在此的示教一起使用。根据上面的描述，构造这类系统所要求的结构是显而易见的。此外，本发明也不针对任何特定编程语言。应当明白，可以利用各种编程语言实现在此描述的本发明的内容，并且上面对特定语言所做的描述是为了披露本发明的最佳实施方式。
[0238]在此处所提供的说明书中，说明了大量具体细节。然而，能够理解，本发明的实施例可以在没有这些具体细节的情况下实践。在一些实例中，并未详细示出公知的方法、结构和技术，以便不模糊对本说明书的理解。
[0239]类似地，应当理解，为了精简本公开并帮助理解各个发明方面中的一个或多个，在上面对本发明的示例性实施例的描述中，本发明的各个特征有时被一起分组到单个实施例、图、或者对其的描述中。然而，并不应将该公开的方法解释成反映如下意图:即所要求保护的本发明要求比在每个权利要求中所明确记载的特征更多的特征。更确切地说，如下面的权利要求书所反映的那样，发明方面在于少于前面公开的单个实施例的所有特征。因此，遵循【具体实施方式】的权利要求书由此明确地并入该【具体实施方式】，其中每个权利要求本身都作为本发明的单独实施例。
[0240]本领域那些技术人员可以理解，可以对实施例中的设备中的模块进行自适应性地改变并且把它们设置在与该实施例不同的一个或多个设备中。可以把实施例中的模块或单元或组件组合成一个模块或单元或组件，以及此外可以把它们分成多个子模块或子单元或子组件。除了这样的特征和/或过程或者单元中的至少一些是相互排斥之外，可以采用任何组合对本说明书(包括伴随的权利要求、摘要和附图)中公开的所有特征以及如此公开的任何方法或者设备的所有过程或单元进行组合。除非另外明确陈述，本说明书(包括伴随的权利要求、摘要和附图)中公开的每个特征可以由提供相同、等同或相似目的的替代特征来代替。
[0241]此外，本领域的技术人员能够理解，尽管在此所述的一些实施例包括其它实施例中所包括的某些特征而不是其它特征，但是不同实施例的特征的组合意味着处于本发明的范围之内并且形成不同的实施例。例如，在下面的权利要求书中，所要求保护的实施例的任意之一都可以以任意的组合方式来使用。
[0242]本发明的各个部件实施例可以以硬件实现，或者以在一个或者多个处理器上运行的软件模块实现，或者以它们的组合实现。本领域的技术人员应当理解，可以在实践中使用微处理器或者数字信号处理器(DSP)来实现根据本发明实施例的消息存放设备中的一些或者全部部件的一些或者全部功能。本发明还可以实现为用于执行这里所描述的方法的一部分或者全部的设备或者装置程序(例如，计算机程序和计算机程序产品)。这样的实现本发明的程序可以存储在计算机可读介质上，或者可以具有一个或者多个信号的形式。这样的信号可以从因特网网站上下载得到，或者在载体信号上提供，或者以任何其他形式提供。
[0243]应该注意的是上述实施例对本发明进行说明而不是对本发明进行限制，并且本领域技术人员在不脱离所附权利要求的范围的情况下可设计出替换实施例。在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本发明可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。
[0244]本发明公开了A1、一种消息存放方法，包括:
[0245]接收应用服务器发送的认证请求；
[0246]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0247]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0248]根据所述消息请求，将所述消息请求中的第一队列消 息转发至队列服务器的任务队列。
[0249]A2、如A1所述的方法，所述接收应用服务器发送的认证请求的步骤包括:
[°250] 接收应用服务器通过https协议发送的https认证请求。
[0251]A3、如A1所述的方法，所述接收所述应用服务器发送的消息请求的步骤包括:
[0252]接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。
[0253]A4、如A3所述的方法，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括:
[0254]对所述https消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。
[0255]A5、如A3或A4所述的方法，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0256]从所述https消息请求或者http消息请求的数据区提取第一队列消息；
[0257]将所述第一队列消息转发至队列服务器的任务队列。
[0258]A6、如A1-A4其中之一所述的方法，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0259]将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[0260]将所述第二队列消息转发至队列服务器的任务队列。
[0261]A7、如A6所述的方法，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括
[0262]判断指定时间周期内，是否接收到至少两个消息请求；
[0263]如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤；
[0264]如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。
[0265]A8、如A6所述的方法，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括:
[0266]在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0267]A9、如A8所述的方法，还包括:
[0268]当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0269]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0270]本发明还公开了B10、一种消息存放装置，包括:
[0271 ]认证请求接收模块，适于接收应用服务器发送的认证请求；
[0272]第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；
[0273]消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0274]转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0275]B11、如权利要求B10所述的装置，所述认证请求接收模块，包括:
i0276] https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0277] B12、如权利要求B10所述的装置，所述消息请求接收模块，包括:
i0278] https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的
https消息请求；
[0279]和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0280]B13、如B12所述的装置，在https消息请求接收模块之后，还包括:
[0281]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块。
[0282]B14、如B12或B13所述的装置，所述转发模块，包括:
[0283]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0284]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0285]B15、如B10-B13其中之一所述的装置，所述转发模块，包括:
[0286]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;
[0287]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0288]B16、如B15所述的装置，所述合并子模块之前，还包括:
[0289]判断模块，适于判断指定时间周期内，是否接收到至少两个消息请求；
[0290]如果未接收到至少两个消息请求，则进入转发模块；
[0291 ]如果接收到至少两个消息请求，则进入合并子模块。
[0292]B17、如B15所述的装置，所述合并子模块包括:
[0293]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0294]B18、如B17所述的装置，还包括:
[0295]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0296]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0297]本发明还公开了C19、一种消息存放设备，包括:
[0298]存储器，加载有多条可执行指令；
[0299]处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0300]接收应用服务器发送的认证请求；
[0301]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0302]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0303]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
【主权项】
1.一种消息存放方法，包括: 接收应用服务器发送的认证请求； 对所述认证请求进行身份验证，并判断身份验证是否通过； 当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。2.如权利要求1所述的方法，其特征在于，所述接收应用服务器发送的认证请求的步骤包括: 接收应用服务器通过https协议发送的https认证请求。3.如权利要求1所述的方法，其特征在于，所述接收所述应用服务器发送的消息请求的步骤包括: 接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。4.根据权利要求3所述的方法，其特征在于，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括: 对所述h 11 p s消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。5.根据权利要求3或4所述的方法，其特征在于，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括: 从所述https消息请求或者http消息请求的数据区提取第一队列消息； 将所述第一队列消息转发至队列服务器的任务队列。6.根据权利要求1-4其中之一所述的方法，其特征在于，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括: 将至少两个消息请求中第一队列消息，合并为一个第二队列消息； 将所述第二队列消息转发至队列服务器的任务队列。7.根据权利要求6所述的方法，其特征在于，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括 判断指定时间周期内，是否接收到至少两个消息请求； 如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤； 如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。8.根据权利要求6所述的方法，其特征在于，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括: 在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。9.一种消息存放装置，包括: 认证请求接收模块，适于接收应用服务器发送的认证请求； 第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。10.一种消息存放设备，包括: 存储器，加载有多条可执行指令； 处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法: 接收应用服务器发送的认证请求； 对所述认证请求进行身份验证，并判断身份验证是否通过； 当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
【专利摘要】本发明实施例提供了一种消息存放方法和装置，涉及计算机技术领域。所述方法包括：接收应用服务器发送的认证请求；对所述认证请求进行身份验证，并判断身份验证是否通过；当身份验证通过，则接收所述应用服务器发送的消息请求；所述消息请求包括第一队列消息；根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。本发明解决了任何应用服务器都可以将其第一队列消息向队列服务器的任务队列存放消息，使任务队列的数据有效性和安全性低的问题，取得了避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性的有益效果。
【IPC分类】H04L29/06, H04L29/08
【公开号】CN105491012
【申请号】CN201510812910
【发明人】刘浩, 蒋凯, 王路
【申请人】北京奇虎科技有限公司, 奇智软件（北京）有限公司
【公开日】2016年4月13日
【申请日】2015年11月20日
【技术领域】
[0001]本发明涉及计算机技术领域，特别是涉及一种消息存放方法和一种消息存放装置。
【背景技术】
[0002]随着计算机与互联网等与人们的生活越来越密不可分，为了更好地为提供服务，越来越多的消息会被记录以备用，例如日志消息等。目前常用的处理日志消息的消息队列是Kafka消息队列，Kafka消息队列是一种分布式消息队列，其有自己的传递消息的协议，称为kafka协议。目前常用的消息队列存放方案是利用Kafka协议将日志消息传递至Kafka消息队列中，若需要用到Kafka消息队列中的部分日志消息，则会通过调用API，将上述日志消息传递至所需的服务器。
[0003]对于上述常用的消息队列存放方案，存在两方面问题。一方面，利用Kafka协议传递消息的过程中不会对消息加密，从而导致安全性不高；另外一方面，在上述方案中，没有经过身份认证，任何一个转发服务器相连接的服务器都可以向Kafka消息队列中存放消息，会将不需要存放的应用服务器上的消息也都被存放至同一Kafka消息队列中，进而降低了所存放消息的有效性和安全性。
【发明内容】
[0004]鉴于上述问题，提出了本发明以便提供一种克服上述问题或者至少部分地解决上述问题的第一队列消息存放方法和相应的第一队列消息存放装置。
[0005]依据本发明的一个方面，提供了一种消息存放方法，包括:
[0006]接收应用服务器发送的认证请求；
[0007]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0008]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0009]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0010]可选地，所述接收应用服务器发送的认证请求的步骤包括:
[0011 ] 接收应用服务器通过https协议发送的https认证请求。
[0012]可选地，所述接收所述应用服务器发送的消息请求的步骤包括:
[0013]接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。
[0014]可选地，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括:
[0015]对所述https消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。
[0016]可选地，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0017]从所述https消息请求或者http消息请求的数据区提取第一队列消息；
[0018]将所述第一队列消息转发至队列服务器的任务队列。
[0019]可选地，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0020]将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[0021]将所述第二队列消息转发至队列服务器的任务队列。
[0022]可选地，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括:
[0023]判断指定时间周期内，是否接收到至少两个消息请求；
[0024]如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤；
[0025]如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。
[0026]可选地，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括:
[0027]在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0028]可选地，在还包括:
[0029]当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0030]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0031 ]根据本发明的另一方面，提供了一种消息存放装置，包括:
[0032]认证请求接收模块，适于接收应用服务器发送的认证请求；
[0033]第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；
[0034]消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0035]转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0036]可选地，所述认证请求接收模块，包括:
[0037]https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0038]可选地，所述消息请求接收模块，包括:
[0039]https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的https消息请求；[°04°]和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0041 ]可选地，在https消息请求接收模块之后，还包括:
[0042]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块。
[0043]可选地，所述转发模块，包括:
[0044]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0045]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0046]可选地，所述转发模块，包括:
[0047]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;
[0048]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0049]可选地，所述合并子模块之前，还包括:
[0050]判断模块，适于判断指定时间周期内，是否接收到至少两个消息请求；
[0051 ]如果未接收到至少两个消息请求，则进入转发模块；
[0052]如果接收到至少两个消息请求，则进入合并子模块。
[0053]可选地，所述合并子模块包括:
[0054]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0055]可选地，还包括:
[0056]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0057]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0058]根据本发明的另一方面，提供了一种消息存放设备，包括:
[0059]存储器，加载有多条可执行指令；
[0060]处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0061 ]接收应用服务器发送的认证请求；
[0062]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0063]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0064]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0065]根据本发明的消息存放方法可以先对应用服务器进行身份验证，还可以对身份验证信息加密后在发送，而且，对于身份验证信息以外的信息，也可以根据其保密要求选择性地加密后再传送，另外，对于指定时间周期收到的多个消息请求，会将其中的第一队列消息合并为一个第二队列消息，由此解决了任何应用服务器都可以将其第一队列消息向队列服务器的任务队列存放消息，导致数据不安全、数据冗余较多，使任务队列的数据有效性和安全性低的问题，取得了可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性的有益效果Ο
[0066]上述说明仅是本发明技术方案的概述，为了能够更清楚了解本发明的技术手段，而可依照说明书的内容予以实施，并且为了让本发明的上述和其它目的、特征和优点能够更明显易懂，以下特举本发明的【具体实施方式】。
【附图说明】
[0067]通过阅读下文优选实施方式的详细描述，各种其他的优点和益处对于本领域普通技术人员将变得清楚明了。附图仅用于示出优选实施方式的目的，而并不认为是对本发明的限制。而且在整个附图中，用相同的参考符号表示相同的部件。在附图中:
[0068]图1示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0069]图2示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0070]图3示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图；
[0071]图4示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0072]图5示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0073]图6示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图；
[0074]图7示出了根据本发明一个实施例的一种系统的结构示意图；
[0075]图8示出了根据本发明一个实施例的一种设备的结构示意图。
【具体实施方式】
[0076]下面将参照附图更详细地描述本公开的示例性实施例。虽然附图中显示了本公开的示例性实施例，然而应当理解，可以以各种形式实现本公开而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本公开，并且能够将本公开的范围完整的传达给本领域的技术人员。
[0077]参照图1，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[0078]步骤S110，接收应用服务器发送的认证请求。
[0079]其中，应用服务器提供访问商业逻辑的途径以供客户端应用程序使用，例如游戏应用服务器、杀毒服务器等。
[0080]在本发明实施例中，应用服务器发送的认证请求中的目的是为了认证是否可以接收该应用服务发送消息请求，即是否能与该应用服务器建立通信。所以该认证请求中应包 含该应用服务器的身份验证信息。
[0081 ] 步骤S120，对所述认证请求进行身份验证，并判断身份验证是否通过。
[0082]如上所述，应用服务器发送的认证请求的目的是为了认证是否可以接收该应用服务发送消息请求，该判断过程即为上述的身份验证过程。
[0083]在本发明实施例中，可以以应用服务器的用户名和密码作为身份验证的依据。当然，关于身份验证的【具体实施方式】本发明实施例不加以限定。
[0084]步骤S130，当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。
[0085]若身份验证通过，即可接收应用服务器发送的消息请求。在本发明实施例中，上述消息请求中包括第一队列消息。
[0086]其中的第一队列消息可以是应用服务器产生的各类消息，如日志消息等。在本发明实施例中，以日志消息为例进行介绍。
[0087]步骤S140，根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0088]其中的队列服务器是用以存储消息队列的服务器，例如常用于处理日志消息的Kafka队列服务器，任务队列可以为Kafka队列。其中，Kafka是分布式发布-订阅消息系统。
[0089]转发是指将消息请求中的第一队列消息传送至队列服务器的任务队列，对于具体的传送方式，本发明实施例不加以限定。
[0090]在本发明实施例中，以转发服务器作为载体，实现上述转发的过程。在本发明实施例中，转发服务器是一种web服务器，可以支持HTTP协议和/或HTTPS协议。
[0091]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0092]实施例二
[0093]参照图2，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[0094]步骤S210，接收应用服务器通过https协议发送的https认证请求。
[0095]其中，https(Hyper Text Transfer Protocol over Secure Socket Layer，基于SSL的http)协议提供了身份验证与加密通信方法，现在它被广泛用于互联网上安全敏感的通信。https协议使用了http协议，https协议会采用SSL (Secure Sockets Layer安全套接层)通道，对传送的信息自动加密并以加密的形式传送信息。
[0096]其中的SSL(Secure Sockets Layer，安全套接层)，可提供的服务包括:认证用户和服务器，确保数据发送到正确的客户机和服务器;加密数据以防止数据中途被窃取;维护数据的完整性，确保数据在传输过程中不被改变。而且，SSL客户端的身份验证是可选的，由SSL服务器决定是否验证SSL客户端的身份。
[0097]而其中的http协议是一个属于应用层的面向对象的协议，由于其简捷、快速的方式，适用于分布式超媒体信息系统。但是http协议本身不具有加密、身份验证的功能，SPhttp协议是以明文的形式传送信息。
[0098]在判断是否能接收应用服务器发送的消息指令之前，首先要对该应用服务器进行身份验证以与该应用服务器建立通信关系。
[0099]对于应用服务器发送的认证请求，应该包含应用服务器的应用服务器的身份验证信息，如用户名和密码等。为了避免上述应用服务器的身份验证信息被盗用，所以应对上述认证请求加密后再传送，即利用https协议发送https认证请求。在本发明实施例中，以用户名和密码作为身份验证信息进行说明。
[0100]具体的认证过程如下:
[0101](1)应用服务器发送一个连接请求给转发服务器;转发服务器将自己的证书、对称加密算法种类及其他相关信息返回应用服务器，其中的证书中包含转发服务器公钥3_PuKeyο
[0102](2)应用服务器检查转发服务器传送的证书是否由自己信赖的CA中心签发。若是，执行(4);否则，给客户一个警告信息:询问是否继续访问。
[0103](3)应用服务器比较证书里的信息，如证书有效期、服务器域名和公钥S_PK，与转发服务器传回的信息是否一致，如果一致，则应用服务器完成对转发服务器的初步身份认证。
[0104](4)应用服务器发送应用服务器的证书、支持的对称加密方案及其他相关信息到转发服务器，其中的应用服务器的证书包含应用服务器公钥C_PuKey。收到后，转发服务器比较证书里的信息，如证书有效期、服务器域名和公钥S_PK，与应用服务器发送信息是否一致，若不一致，则拒绝连接。若一致，则进入(5)。
[0105](5)转发服务器根据应用服务器发送的到密码种类，选择一种加密程度最高的方案，利用公钥(:_?1!1(#加密后，返回至应用服务器。
[0106](6)应用服务器通过私钥C_PrKey解密后，得知转发服务器选择的加密方案，并选择一个通话密钥key，接着用转发服务器公钥3_?1!1(^加密后发送给转发服务器。
[0107](7)转发服务器接收到的应用服务器传送的消息，用私解密，获得通话密钥key。
[0108](8)应用服务器利用上述通话密钥key对应用服务器发送的认证请求加密后发送至转发服务器，其中认证请求中包括身份验证信息，如用户名和密码。
[0109]步骤S220，对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入步骤S230。
[0110]在本发明实施例中，对于各有资格存放消息的应用服务器，会将其对应身份信息，包括用户名、密码等，按照一定格式存储于数据库中，例如以cookie的形式存入数据库中。
[0111]则将上述认证请求中所包含的用户名和密码，与已存储于数据库中的身份信息相匹配，若匹配成功，则通过此次身份验证，若匹配不成功，则不通过此次身份验证。
[0112]在本发明实施例中，转发服务器利用上述通话密钥key对接收到的身份验证信息解密并与数据库中存储的身份信息匹配，若匹配成功，则表明身份验证通过。若匹配不成功，则拒绝应用服务器连接转发服务器。
[0113]该身份验证过程的目的在于，确认是否接收应用服务器发送的消息请求。
[0114]步骤S230，接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过h t tp协议发送的h t tp消息请求；
[0115]其中，所述https消息请求或http消息请求中包括第一队列消息。
[0?16] 若接收所述应用服务器通过https协议发送的https消息请求，则进入步骤S240 ；若接收所述应用服务器通过http协议发送的http消息请求，则进入步骤S250。
[0117]在实际应用过程中，考虑到安全性的问题，在传送用户名和密码以完成身份验证时，为了避免应用服务器的身份验证信息被盗用，必须对其中的用户名和密码进行加密发送，所以此时通过https协议发送https消息请求，该消息请求中包括含有用户名和密码的第一队列消息。
[0118]—方面，若要进一步确保所接收的应用服务器发送的每条消息请求的安全性，可以对每条消息请求进行身份验证。此时，需要每条消息请求中都包含应用服务器的上述应用服务器的身份验证信息，而根据上述安全性的需要，对于应用服务器的身份验证信息应利用https协议加密。
[0119]因此，为了进一步确保所接收的每条消息请求的安全性，在身份验证通过后，仍然利用https协议发送消息请求，则接收到的为应用服务器通过https协议发送的https消息请求。
[0120]但是，另外一方面，若要将消息请求都加密后再转发至队列服务器，则会导致各方面的性能损耗较大。所以在身份验证后，根据消息请求中所包括的第一队列消息的内容是否需要加密，选择性地利用https协议发送或者利用http协议发送，则最终利用https协议发送的为https消息请求，利用http协议发送的为http消息请求。具体地，对于接收到的消息请求是https消息请求还是http消息请求，是通过应用服务器根据保密需求灵活设定的，对此，本发明不加以限定。
[0121]另外，若应用服务器利用http协议发送的http请求消息，其中也可以包含应用服务器的身份验证信息，此时采用明文的方式传送消息请求，为了提高安全性，也可以对明文发送的应用服务器的身份验证信息进行身份验证，只是明文形式的应用服务器的身份验证信息比加密形式的应用服务器的身份验证信息，被盗用的可能性比较大。相对来说，对用http协议发送的http消息请求进行身份验证，与对用https协议发送的https消息请求进行身份验证相比较，明显后者的安全性会高更多。所以，本发明实施例中，优选地，利用https协议发送包含应用服务器的身份验证信息的https消息请求。
[0122]步骤S240，对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入步骤S250。
[0123]其中，上述的https消息请求中同样包含上述的应用服务器的身份验证信息。对https消息请求进行身份验证，同样是将应用服务器的身份验证信息，如用户名和密码，在已存储于数据库中的身份信息中相匹配，若匹配成功，则通过身份验证;若匹配不成功，则不通过身份验证。
[0124]该身份验证过程的目的在于，在每次接收到应用服务器发送的信息请求后，确认该信息请求是有资格存放消息的应用服务器发送的，即是否将该信息请求中包含的第一消息队列转发至队列服务器的任务队列中。
[0125]在本申请实施例中，对于https消息请求的验证，只需要应用服务器以前述通话密钥key对https消息请求进行加密发送至转发服务器，不用再https消息请求再携带应用服务器的用户名和密码，转发服务器能够再以通话密钥key解密即可认为身份验证通过。当然，应用服务器也可以在https消息请求中携带用户名和密码，转发服务器也可以继续提取用户名和密码与本地的记录进行匹配，进行更进一步的验证。
[0? 26]步骤S250，从所述https消息请求或http消息请求的数据区提取第一队列消息。
[0127]一般而言，https消息请求和http消息请求中都包含消息头和数据区等部分，而本发明介绍的是一种消息存放方法，最终是要将上述https消息请求或http消息请求的数据区的第一队列消息存放至队列服务器中，所以要先从https消息请求或http消息请求的数据区中提取第一队列消息。
[0128]步骤S260，将所述第一队列消息转发至队列服务器的任务队列。
[0129]该步骤与上述步骤S140类似，在此不再赘述。
本发明实施例中，可以利用https协议发送全部认证请求和消息请求，其执行步骤3210、3220、3230(该步骤中只接收11??8消息请求)、3240、3250、3260;或者，利用11??8协议发送认证请求，利用http协议发送全部消息请求，其执行步骤S210、S220、S230 (该步骤中只接收http消息请求)、S250、S260;或者，利用https协议发送认证请求，利用https协议或http协议发送消息请求。对此，本发明不加以限定。
[0131]在本发明实施例中，同样在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0132]实施例三
[0133]参照图3，示出了根据本发明一个实施例的一种消息存放方法实施例的步骤流程图，具体可以包括如下步骤:
[ΟΙ34] 步骤S310，接收应用服务器通过https协议发送的https认证请求。
[0135]步骤S320，对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入步骤S330;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0136]步骤S330，接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求，所述消息请求包括第一队列消息。
[0137]步骤S340，对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入步骤S350。
[0138]步骤S350，判断指定时间周期内，是否接收到至少两个消息请求;如果未接收到至少两个消息请求，则进入步骤S360;如果接收到至少两个消息请求，则进入步骤S370。
[0139]在利用转发服务器转发消息的过程中，会产生一定的冗余消息，很明显，上述冗余信息并没有任何存储的必要，并且如果对每个消息请求都向队列服务器转发第一队列消息，其系统资源消耗大。
[0140]在本发明实施例中，为了尽可能的减少上述冗余消息，以及降低系统资源，会将多个第一队列消息合并后再转发至队列服务器的任务队列，而同时，在合并第一队列消息的时候是一定时间期限的，比如说在5秒或者10秒时间周期内，将接收到的消息请求中的各第一队列消息合并成一个第二队列消息。所以在本发明实施例中，会预先设置指定时间周期，该指定时间周期可以在本步骤之前，或者是本步骤之前的任一步骤之前设置。另外，在本发明实施例中默认本步骤中在所设置的指定时间周期内，至少会接收到一个消息请求。然后需要判断在指定的时间周期之内，是否接收到至少两个消息请求，若未接收到至少两个消息请求，则表明只接收到一个消息请求，则只将该消息请求中的第一队列消息转发至队列服务器的任务队列；若接收到至少两个消息请求，则会将所接收的各消息请求中的各第一队列消息合并为一个第二队列消息，然后再将第二队列消息转发至队列服务器的任务队列。
[0141]步骤S360，将所述第一队列消息转发至队列服务器的任务队列。
[0142]步骤S370，将至少两个消息请求中第一队列消息，合并为一个第二队列消息。
[0143]其中，将多个第一队列消息合并为一个第二队列消息的方式有很多种，如在不同第一队列消息直接加上分隔标识后合并，其中的分隔标识必须有别于消息请求中的第一队列消息的字段，以避免造成分割标识和消息的混乱。如将A、B、C三个队列消息合并，则可以为如下种方式:
[0144]A*—*B*—*C
[0145]其中的一即为上述的分隔标识。
[0146]为了方便将上述的第二队列消息再拆分为合并前的各第一队列消息，所以优选地，在本发明实施例中，步骤S370包括:
[0147]步骤S371，在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0148]其中的分隔标识可以为由任意字符、数字或者特殊符号等随机组成的，与消息请求中第一队列消息的字段不重复的字符串，对此本发明不加以限定。而且该分隔标识是预置的，其可以在本步骤之前预置，也可以在本步骤之前的任一步骤之前预置，本发明实施例对此不加以限定。
[0149]步骤S380，将所述第二队列消息转发至队列服务器的任务队列。
[0150]该步骤与上述将所述第一队列消息转发至队列服务器的任务队列的步骤类似，在此不再赘述。
[0151]针对上述的步骤S371的内容，优选地，本发明实施例中还包括:
[0152]步骤S390，当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0153]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0154]对于处理服务器而言，所处理的消息是最初的第一队列消息。若处理由若干第一队列消息合并成的第二队列消息，与分开处理其中的各第一队列消息作对比，很明显后者的效果会更好。所以，在提取第二队列消息进行处理时，要判断该第二队列消息中是否有上述的分隔标识，若该第二队列消息中有上述的分隔标识，则以该分隔标识为界线，将该第二队列消息拆分为相应的多个第一队列消息，最终处理服务器所处理的是拆分后得到的第一队列消息。
[0155]例如上述的第二队列消息:
[0156]A*——*C
[0157]其中，A、B和C为第一队列消息，“*一*”为分隔标识。
[0158]处理服务器会先判断该第二队列消息中是否有分隔标识，很明显，该第二队列消息中有分隔标识，则，将第二队列消息中的开头到第一个出现的分隔标识之间的字段提取出来，做为一个第一队列消息A;将相邻两个分隔标识之间的字段提取出来，作为一个第一队列消息B;将最后一个分隔标识到第二队列消息结尾之间的字段提取出来，做为一个第一队列消息C。从而，将上述第二队列消息拆分为三个第一队列消息:
[0159]A
[0160]B
[0161]C
[0162]对于本发明实施例中，与发明实施例一、二类似的步骤，不在赘述。
[0163]在本发明实施例中，同样在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0164]另外，本发明实施例中，若在指定时间周期内消息请求的数量不少于两个，则会将该指令时间周期内的消息请求中的第一队列消息合并为一个第二队列消息，降低消息转发次数，降低系统资源消耗。
[0165]对于方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明实施例并不受所描述的动作顺序的限制，因为依据本发明实施例，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作并不一定是本发明实施例所必须的。
[0166]实施例四
[0167]参照图4，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0168]认证请求接收模块410，适于接收应用服务器发送的认证请求。
[0169]第一身份验证模块420，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若通过身份验证，则进入消息请求接收模块430。
[0170]若身份验证未通过，则拒绝应用服务器的连接。
[0171]消息请求接收模块430，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。
[0172]转发模块440，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0173]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0174]实施例五
[0175]参照图5，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0176]认证请求接收模块510，适于接收应用服务器发送的认证请求。具体包括:
[0177]https认证请求接收子模块511，适于接收应用服务器通过https协议发送的https认证请求。
[0178]第一身份验证模块520，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若身份验证通过，则进入消息请求接收模块530。
[0179]消息请求接收模块530，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息;具体包括:
https消息请求接收子模块531，适于接收所述应用服务器通过https协议发送的https消息请求；
[0181]第二身份验证子模块532，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块540;
[0182]http消息请求接收子模块533，适于接收所述应用服务器通过http协议发送的http消息请求。
[0183]转发模块540，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列，具体包括:
[0184]提取子模块541，适于从所述https消息请求或者http请求的数据区提取第一队列消息；
[0185]第一转发子模块542，适于将所述第一队列消息转发至队列服务器的任务队列。
[0186]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0187]实施例六
[0188]参照图6，示出了根据本发明一个实施例的一种消息存放装置实施例的结构框图，具体可以包括如下模块:
[0189]认证请求接收模块610，适于接收应用服务器发送的认证请求。具体包括:
https认证请求接收子模块611，适于接收应用服务器通过https协议发送的https认证请求。
[0191]第一身份验证模块620，适于对所述认证请求进行身份验证，并判断身份验证是否通过。当身份验证通过，则进入消息请求接收模块630;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0192]消息请求接收模块630，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。具体包括:
[0193]https消息请求接收子模块631，适于接收所述应用服务器通过https协议发送的https消息请求；
[0194]第二身份验证子模块632，适于对所述https消息请求进行身份验证，判断身份验证是否通过；当验证通过后，进入判断模块640;当身份验证未通过，则拒绝应用服务器连接转发服务器。
[0195]http消息请求接收子模块633，适于接收所述应用服务器通过http协议发送的http消息请求。
[0196]判断模块640，适于判断指定时间周期内，是否接收到至少两个消息请求;如果未接收到至少两个消息请求，则进入第二转发子模块652;如果接收到至少两个消息请求，则进入合并子模块651。
[0197]转发模块650，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。具体包括:
[0198]合并子模块651，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[ΟΙ"]优选地，所述合并子模块651包括:
[0200]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0201]第二转发子模块652，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0202]优选地，在本发明实施例中，在转发模块650之后，还包括:
[0203]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识。如果所述第二队列消息中有分隔标识，则进入拆分模块。
[0204]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0205]在本发明实施例中，在接收应用服务器发送的消息请求之前，会先根据应用服务器发送的认证请求进行身份认证，以确定是否接收该应用服务器所发送的消息请求，可以筛选将要向队列服务器存储第一队列消息的应用服务器，避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性。
[0206]另外，本发明实施例中，若在指定时间周期内消息请求的数量不少于两个，则会将该指令时间周期内的消息请求中的第一队列消息合并为一个第二队列消息，可以降低消息的转发次数，降低系统资源的消耗。
[0207]参照图7，示出了本发明实施例的一种系统的结构示意图，具体可以包括:
[0208]应用服务器710、转发服务器720、队列服务器730;
[0209]所述应用服务器710，适于向转发服务器发送认证请求和消息请求；
[0210]所述转发服务器720包括:
[°211 ]认证请求接收模块721，适于接收应用服务器发送的认证请求。所述认证请求接收模块721，包括:
[0212]https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0213]第一身份验证模块722，适于对所述认证请求进行身份验证，并判断身份验证是否通过。若通过身份验证，则进入消息请求接收模块430;若身份验证未通过，则拒绝应用服务器的连接。
[0214]消息请求接收模块723，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息。所述消息请求接收模块723，包括:
[02<15] https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的https消息请求；
[0216]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入判断模块。
[02M] 和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0218]判断模块724，适于判断指定时间周期内，是否接收到至少两个消息请求。如果未接收到至少两个消息请求，则进入转发模块;如果接收到至少两个消息请求，则进入合并子模块。
[0219]转发模块725，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。所述转发模块724，包括:
[0220]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0221]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0222]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;所述合并子模块包括:
[0223]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0224]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0225]所述队列服务器730，适于接收第一消息队列并存放至任务队列。
[0226]优选地，还包括数据分析服务器，与队列服务器相连接，用以对从队列服务器的任务队列中提取消息以进行分析。所述数据分析服务器包括:分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0227]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0228]实施例八
[0229]参照图8，示出了本发明实施例的一种设备的结构示意图，所述设备700具体可以包括:
[0230]存储器810，加载有多条可执行指令；
[0231]处理器820，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0232]接收应用服务器发送的认证请求；
[0233]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0234]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0235]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0236]对于装置实施例而言，由于其与方法实施例基本相似，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。
[0237]在此提供的算法和显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与基于在此的示教一起使用。根据上面的描述，构造这类系统所要求的结构是显而易见的。此外，本发明也不针对任何特定编程语言。应当明白，可以利用各种编程语言实现在此描述的本发明的内容，并且上面对特定语言所做的描述是为了披露本发明的最佳实施方式。
[0238]在此处所提供的说明书中，说明了大量具体细节。然而，能够理解，本发明的实施例可以在没有这些具体细节的情况下实践。在一些实例中，并未详细示出公知的方法、结构和技术，以便不模糊对本说明书的理解。
[0239]类似地，应当理解，为了精简本公开并帮助理解各个发明方面中的一个或多个，在上面对本发明的示例性实施例的描述中，本发明的各个特征有时被一起分组到单个实施例、图、或者对其的描述中。然而，并不应将该公开的方法解释成反映如下意图:即所要求保护的本发明要求比在每个权利要求中所明确记载的特征更多的特征。更确切地说，如下面的权利要求书所反映的那样，发明方面在于少于前面公开的单个实施例的所有特征。因此，遵循【具体实施方式】的权利要求书由此明确地并入该【具体实施方式】，其中每个权利要求本身都作为本发明的单独实施例。
[0240]本领域那些技术人员可以理解，可以对实施例中的设备中的模块进行自适应性地改变并且把它们设置在与该实施例不同的一个或多个设备中。可以把实施例中的模块或单元或组件组合成一个模块或单元或组件，以及此外可以把它们分成多个子模块或子单元或子组件。除了这样的特征和/或过程或者单元中的至少一些是相互排斥之外，可以采用任何组合对本说明书(包括伴随的权利要求、摘要和附图)中公开的所有特征以及如此公开的任何方法或者设备的所有过程或单元进行组合。除非另外明确陈述，本说明书(包括伴随的权利要求、摘要和附图)中公开的每个特征可以由提供相同、等同或相似目的的替代特征来代替。
[0241]此外，本领域的技术人员能够理解，尽管在此所述的一些实施例包括其它实施例中所包括的某些特征而不是其它特征，但是不同实施例的特征的组合意味着处于本发明的范围之内并且形成不同的实施例。例如，在下面的权利要求书中，所要求保护的实施例的任意之一都可以以任意的组合方式来使用。
[0242]本发明的各个部件实施例可以以硬件实现，或者以在一个或者多个处理器上运行的软件模块实现，或者以它们的组合实现。本领域的技术人员应当理解，可以在实践中使用微处理器或者数字信号处理器(DSP)来实现根据本发明实施例的消息存放设备中的一些或者全部部件的一些或者全部功能。本发明还可以实现为用于执行这里所描述的方法的一部分或者全部的设备或者装置程序(例如，计算机程序和计算机程序产品)。这样的实现本发明的程序可以存储在计算机可读介质上，或者可以具有一个或者多个信号的形式。这样的信号可以从因特网网站上下载得到，或者在载体信号上提供，或者以任何其他形式提供。
[0243]应该注意的是上述实施例对本发明进行说明而不是对本发明进行限制，并且本领域技术人员在不脱离所附权利要求的范围的情况下可设计出替换实施例。在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本发明可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。
[0244]本发明公开了A1、一种消息存放方法，包括:
[0245]接收应用服务器发送的认证请求；
[0246]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0247]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0248]根据所述消息请求，将所述消息请求中的第一队列消 息转发至队列服务器的任务队列。
[0249]A2、如A1所述的方法，所述接收应用服务器发送的认证请求的步骤包括:
[°250] 接收应用服务器通过https协议发送的https认证请求。
[0251]A3、如A1所述的方法，所述接收所述应用服务器发送的消息请求的步骤包括:
[0252]接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。
[0253]A4、如A3所述的方法，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括:
[0254]对所述https消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。
[0255]A5、如A3或A4所述的方法，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0256]从所述https消息请求或者http消息请求的数据区提取第一队列消息；
[0257]将所述第一队列消息转发至队列服务器的任务队列。
[0258]A6、如A1-A4其中之一所述的方法，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括:
[0259]将至少两个消息请求中第一队列消息，合并为一个第二队列消息；
[0260]将所述第二队列消息转发至队列服务器的任务队列。
[0261]A7、如A6所述的方法，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括
[0262]判断指定时间周期内，是否接收到至少两个消息请求；
[0263]如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤；
[0264]如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。
[0265]A8、如A6所述的方法，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括:
[0266]在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0267]A9、如A8所述的方法，还包括:
[0268]当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识；
[0269]如果所述第二队列消息中有分隔标识，则将所述第二队列消息拆分为相应的多个第一队列消息。
[0270]本发明还公开了B10、一种消息存放装置，包括:
[0271 ]认证请求接收模块，适于接收应用服务器发送的认证请求；
[0272]第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；
[0273]消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0274]转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
[0275]B11、如权利要求B10所述的装置，所述认证请求接收模块，包括:
i0276] https认证请求接收子模块，适于接收应用服务器通过https协议发送的https认证请求。
[0277] B12、如权利要求B10所述的装置，所述消息请求接收模块，包括:
i0278] https消息请求接收子模块，适于接收所述应用服务器通过https协议发送的
https消息请求；
[0279]和/或http消息请求接收子模块，适于接收所述应用服务器通过http协议发送的http消息请求。
[0280]B13、如B12所述的装置，在https消息请求接收模块之后，还包括:
[0281]第二身份验证子模块，适于对所述https消息请求进行身份验证，判断身份验证是否通过;当验证通过后，进入转发模块。
[0282]B14、如B12或B13所述的装置，所述转发模块，包括:
[0283]提取子模块，适于从所述https消息请求或者http请求的数据区提取第一队列消息;
[0284]第一转发子模块，适于将所述第一队列消息转发至队列服务器的任务队列。
[0285]B15、如B10-B13其中之一所述的装置，所述转发模块，包括:
[0286]合并子模块，适于将至少两个消息请求中第一队列消息，合并为一个第二队列消息;
[0287]第二转发子模块，适于将所述第一队列消息或第二队列消息转发至队列服务器的任务队列。
[0288]B16、如B15所述的装置，所述合并子模块之前，还包括:
[0289]判断模块，适于判断指定时间周期内，是否接收到至少两个消息请求；
[0290]如果未接收到至少两个消息请求，则进入转发模块；
[0291 ]如果接收到至少两个消息请求，则进入合并子模块。
[0292]B17、如B15所述的装置，所述合并子模块包括:
[0293]分隔标识添加模块，适于在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。
[0294]B18、如B17所述的装置，还包括:
[0295]分隔标识判断模块，适于当处理服务器从所述队列服务器的任务队列中，提取所述第二队列消息进行处理时，判断所述第二队列消息中是否有分隔标识;如果所述第二队列消息中有分隔标识，则进入拆分模块；
[0296]拆分模块，适于将所述第二队列消息拆分为相应的多个第一队列消息。
[0297]本发明还公开了C19、一种消息存放设备，包括:
[0298]存储器，加载有多条可执行指令；
[0299]处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法:
[0300]接收应用服务器发送的认证请求；
[0301]对所述认证请求进行身份验证，并判断身份验证是否通过；
[0302]当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息；
[0303]根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
【主权项】
1.一种消息存放方法，包括: 接收应用服务器发送的认证请求； 对所述认证请求进行身份验证，并判断身份验证是否通过； 当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。2.如权利要求1所述的方法，其特征在于，所述接收应用服务器发送的认证请求的步骤包括: 接收应用服务器通过https协议发送的https认证请求。3.如权利要求1所述的方法，其特征在于，所述接收所述应用服务器发送的消息请求的步骤包括: 接收所述应用服务器通过https协议发送的https消息请求;或者接收所述应用服务器通过http协议发送的http消息请求。4.根据权利要求3所述的方法，其特征在于，在接收所述应用服务器通过https协议发送的消息请求的步骤之后，还包括: 对所述h 11 p s消息请求进行身份验证，判断身份验证是否通过，判断身份验证是否通过;当验证通过后，进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤。5.根据权利要求3或4所述的方法，其特征在于，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括: 从所述https消息请求或者http消息请求的数据区提取第一队列消息； 将所述第一队列消息转发至队列服务器的任务队列。6.根据权利要求1-4其中之一所述的方法，其特征在于，所述根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤，包括: 将至少两个消息请求中第一队列消息，合并为一个第二队列消息； 将所述第二队列消息转发至队列服务器的任务队列。7.根据权利要求6所述的方法，其特征在于，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤之前，还包括 判断指定时间周期内，是否接收到至少两个消息请求； 如果未接收到至少两个消息请求，则进入根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列的步骤； 如果接收到至少两个消息请求，则进入将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤。8.根据权利要求6所述的方法，其特征在于，所述将至少两个消息请求中第一队列消息，合并为一个第二队列消息的步骤包括: 在将至少两个消息请求中第一队列消息合并时，在前后两个队列之间添加分隔标识，以合并得到第二队列消息。9.一种消息存放装置，包括: 认证请求接收模块，适于接收应用服务器发送的认证请求； 第一身份验证模块，适于对所述认证请求进行身份验证，并判断身份验证是否通过；消息请求接收模块，适于当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 转发模块，适于根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。10.一种消息存放设备，包括: 存储器，加载有多条可执行指令； 处理器，执行所述多条可执行指令;所述多条指令包括执行以下步骤的方法: 接收应用服务器发送的认证请求； 对所述认证请求进行身份验证，并判断身份验证是否通过； 当身份验证通过，则接收所述应用服务器发送的消息请求;所述消息请求包括第一队列消息； 根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。
【专利摘要】本发明实施例提供了一种消息存放方法和装置，涉及计算机技术领域。所述方法包括：接收应用服务器发送的认证请求；对所述认证请求进行身份验证，并判断身份验证是否通过；当身份验证通过，则接收所述应用服务器发送的消息请求；所述消息请求包括第一队列消息；根据所述消息请求，将所述消息请求中的第一队列消息转发至队列服务器的任务队列。本发明解决了任何应用服务器都可以将其第一队列消息向队列服务器的任务队列存放消息，使任务队列的数据有效性和安全性低的问题，取得了避免未经认证的应用服务器的第一队列消息存储到队列服务器的任务队列，提高了任务队列中数据的安全性，并且避免产生过多的冗余消息，提高了任务队列中数据的有效性的有益效果。
【IPC分类】H04L29/06, H04L29/08
【公开号】CN105491012
【申请号】CN201510812910
【发明人】刘浩, 蒋凯, 王路
【申请人】北京奇虎科技有限公司, 奇智软件（北京）有限公司
【公开日】2016年4月13日
【申请日】2015年11月20日
最新回复(0)