欢迎光临小豌豆知识网!
当前位置:首页 > 电学技术 > 电通讯技术> 消息处理方法、系统、装置及电子设置独创技术35828字

消息处理方法、系统、装置及电子设置

2021-03-10 14:32:02

消息处理方法、系统、装置及电子设置

  技术领域

  本申请涉及消息处理技术领域,具体而言,涉及一种消息处理方法、系统、装置及电子设置。

  背景技术

  一句话语音识别常见于智能家居、语音助手等场景中。例如,用户使用遥控器或手机进行语音输入,先按键或按钮开始录音,然后说出指令,最后再次按键或松开按钮结束录音,过程中将录音进行压缩,并采用流式分片的方式发送给语音识别服务器进行语音识别。

  相关技术中,由于http协议标准,易于对接联调,通常使用http协议实现一句话语音识别过程中的数据传输,具体地,客户端发送音频时在请求头携带会话的唯一标识、分片序号、结束标识等信息,服务端收到分片序号为1的请求,创建流式任务,并在流式任务中等待每个分片到达,全部分片到达后开始进行语音识别。具体地,在同一个会话的唯一标识下,有从1开始的连续序号的分片,且序号最大的一个分片带有结束标识,即表明全部分片到达。但是,使用http协议实现数据传输存在的缺陷时,http协议的每个分片在逻辑上是独立的,使得实际业务中可能会偶发出现分片丢包或分片到达乱序等问题。

  进一步需要说明的是,为规避突发大流量导致的业务访问问题,一般需要根据等效测试结果设置过载保护的线程数;为规避客户端发送错误或网络阻塞等请求异常问题,一般需要给每个分片和会话分别设置等待超时时间,超过指定时间后未能触发后续流程,则会超时返回错误,清除当前分片或会话占用的资源。

  具体地,对于低流量或网络稳定的场景,即使存在偶发的分片丢包或分片到达乱序问题,也不会影响系统整体的业务使用。但对于高流量或网络不稳定的场景,有可能请求数会大于过载保护的线程数,一旦出现该问题,超过线程数后到达的请求会直接返回错误,主动丢弃,不再处理。客户端仍会继续发送会话的其它请求分片,而会话中只要有一个分片因过载不处理,其余分片均会等待,直到等待超时;后续流量恢复到过载线程数以下,也会有大量已经占用了线程数的等待中的请求,使得系统实际能够正常处理的请求数远远低于预期值。此时继续对部分分片过载不处理,而其余分片继续占用线程等待,会导致出现恶性循环,系统将逐渐无法正常处理业务请求。从用户角度看,体现为用户量出现一个突增后,最开始会有一部分过载的用户无法使用,随着时间推移,流量逐渐恢复正常,但却有越来越多的用户无法使用,最终直至全部用户均无法使用系统。

  针对相关技术中采用HTTP协议完成流式任务时,在流量过载的情况下大量丢包的问题,目前尚未提出有效的解决方案。

  发明内容

  本申请提供一种消息处理方法、系统、装置及电子设置,以解决相关技术中采用HTTP协议完成流式任务时,在流量过载的情况下大量丢包的问题。

  根据本申请的一个方面,提供了一种消息处理方法。该方法包括:接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;在存在的情况下,判断目标会话的流式任务是否携带有过载标签;在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理。

  可选地,在查询待办任务流中是否已存在目标会话的流式任务之前,该方法还包括:判断当前是否存在目标操作,其中,目标操作包括以下之一:查询流式任务的操作,创建流式任务的操作;在当前不存在目标操作的情况下,执行查询待办任务流中是否已存在目标会话的流式任务的步骤。

  可选地,在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理包括:判断已存在的分片的处理请求的数目是否大于等于请求过载线程数目;在已存在的分片的处理请求的数目大于等于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第一处理;在已存在的分片的处理请求的数目小于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第二处理。

  可选地,在已存在的分片的处理请求的数目大于等于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第一处理包括:判断在预设时间内是否存在空闲的请求处理线程;在预设时间内存在空闲的请求处理线程的情况下,将目标分片添加至目标会话的流式任务中;在预设时间内不存在空闲的请求处理线程的情况下,丢弃目标分片,并释放目标会话的流式任务所占用的会话处理线程,以及目标会话的流式任务中的分片所占用的请求处理线程。

  可选地,在已存在的分片的处理请求的数目小于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第二处理包括:将目标分片添加至目标会话的流式任务中;判断目标会话的流式任务中存在的分片是否等于目标会话包含的分片;在目标会话的流式任务中存在的分片等于目标会话包含的分片的情况下,执行对目标会话的分析处理的步骤。

  可选地,在查询待办任务流中是否已存在目标会话的流式任务之后,该方法还包括:在不存在的情况下,判断当前存在的会话的流式任务的数目是否大于等于会话过载线程数目;在当前存在的会话的流式任务的数目大于等于会话过载线程数目的情况下,创建目标会话的流式任务,并为目标会话的流式任务创建过载标签;在当前存在的会话的流式任务的数目小于会话过载线程数目的情况下,创建未携带有过载标签的目标会话的流式任务。

  可选地,在存在的情况下,判断目标会话的流式任务是否携带有过载标签之后,该方法还包括:在目标会话的流式任务携带有过载标签的情况下,丢弃目标分片。

  根据本申请的另一方面,提供了一种消息处理系统。该系统包括:客户端,用于发送目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;服务端,用于接收目标分片的处理请求,并查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;在存在的情况下,判断目标会话的流式任务是否携带有过载标签;在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理,并将处理结果发送至客户端。

  根据本申请的另一方面,提供了一种消息处理装置。该装置包括:接收单元,用于接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;查询单元,用于查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;第一判断单元,用于在存在的情况下,判断目标会话的流式任务是否携带有过载标签;处理单元,用于在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理。

  根据本发明实施例的另一方面,还提供了一种电子装置,包含处理器和存储器;存储器中存储有计算机可读指令,处理器用于运行计算机可读指令,其中,计算机可读指令运行时执行一种消息处理方法。

  通过本申请,采用以下步骤:接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;在存在的情况下,判断目标会话的流式任务是否携带有过载标签;在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理,解决了相关技术中采用http协议完成流式任务时,在流量过载的情况下大量丢包的问题。进而达到了流量过载的情况下减少丢包的效果。

  附图说明

  构成本申请的一部分的附图用来提供对本申请的进一步理解,本申请的示意性实施例及其说明用于解释本申请,并不构成对本申请的不当限定。在附图中:

  图1是根据本申请实施例提供的消息处理方法的流程图;

  图2是根据本申请实施例提供的消息处理系统的示意图;

  图3是根据本申请实施例提供的另一种消息处理方法的流程图;以及

  图4是根据本申请实施例提供的消息处理装置的示意图。

  具体实施方式

  需要说明的是,在不冲突的情况下,本申请中的实施例及实施例中的特征可以相互组合。下面将参考附图并结合实施例来详细说明本申请。

  为了使本技术领域的人员更好地理解本申请方案,下面将结合本申请实施例中的附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本申请一部分的实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本申请保护的范围。

  需要说明的是,本申请的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象,而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换,以便这里描述的本申请的实施例。此外,术语“包括”和“具有”以及他们的任何变形,意图在于覆盖不排他的包含,例如,包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元,而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。

  根据本申请的实施例,提供了一种消息处理方法。

  图1是根据本申请实施例的消息处理方法的流程图。如图1所示,该方法包括以下步骤:

  步骤S101,接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片。

  具体地,目标分片的处理请求由客户端发送,由服务端接收。

  步骤S102,查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立。

  需要说明的是,服务端收到的目标分片的处理请求可能不是第一片请求,也即,目标会话中的顺序号为第一的分片的请求。本申请实施例中无论收到的第一个分片的请求是不是第一片请求,都将在不存流式任务的情况下进行流式任务的创建。

  也即,本申请实施例中由服务端根据收到的第一个分片请求创建会话的流式任务,而非仅根据第一片请求创建会话的流式任务。

  还需要说明的是,因网络原因导致的客户端发送的第一分片请求最后到达,相关技术中其他分片会额外占用接口资源进行等待,本申请实施例根据收到的第一个分片请求创建会话的流式任务,无需额外占用资源等待客户端发送第一分片请求,避免了接口资源的浪费,从而减轻分片到达乱序对服务的影响。

  此外,本申请实施例在分片的处理请求到达后,先根据请求头的唯一标识进行流式任务查询,该唯一标识用于表征唯一的会话,如果查询到了唯一标识对应的流式任务,则该请求不是第一个收到的请求,不需要创建流式任务;如果没有查询到唯一标识对应的流式任务,则该请求是第一个收到的请求,以唯一标识创建流式任务。

  为了避免创建流式任务出现冲突,可选地,在本申请实施例提供的消息处理方法中,在查询待办任务流中是否已存在目标会话的流式任务之前,该方法还包括:判断当前是否存在目标操作,其中,目标操作包括以下之一:查询流式任务的操作,创建流式任务的操作;在当前不存在目标操作的情况下,执行查询待办任务流中是否已存在目标会话的流式任务的步骤。

  需要说明的是,同时只创建或查询一个流式任务,在创建流式任务时,不允许同时创建或查询其它的流式任务,保证同一个会话的请求不会创建重复的流式任务,避免同一个会话创建为不同的流式任务,或避免不同的会话创建为同一个流式任务,也即,避免创建流式任务出现冲突式任务。

  可选地,在本申请实施例提供的消息处理方法中,在查询待办任务流中是否已存在目标会话的流式任务之后,该方法还包括:在不存在的情况下,判断当前存在的会话的流式任务的数目是否大于等于会话过载线程数目;在当前存在的会话的流式任务的数目大于等于会话过载线程数目的情况下,创建目标会话的流式任务,并为目标会话的流式任务创建过载标签;在当前存在的会话的流式任务的数目小于会话过载线程数目的情况下,创建未携带有过载标签的目标会话的流式任务。

  需要说明的是,设置会话过载线程数目,流量过载时以会话为维度限流,服务端创建会话的流式任务时进行标记,可以有效避免过载时的分片主动丢包对服务的影响。

  具体地,当会话线程数已占满时,服务接口收到第一个分片的请求,将创建流式任务,并对该流式任务打上线程占满过载的标签。当会话线程数未占满时,服务端的接口收到第一个分片的请求,将正常创建流式任务。

  步骤S103,在存在的情况下,判断目标会话的流式任务是否携带有过载标签。

  步骤S104,在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理。

  具体地,当会话线程数未占满时,服务端的接口收到分片的请求,查询不为第一个分片的请求的情况下,也即,不为未创建会话的分片的请求的情况下,将查询已存在流式任务,由于会话线程数未占满,会话的流式任务未携带有过载标签,可以对该会话的流式任务进行分析处理。从而保证会话线程数占满时的会话中的全部请求,避免了在未过载的情况下创建的流式任务的分片主动丢包的情况。

  本申请实施例提供的消息处理方法,通过接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;在存在的情况下,判断目标会话的流式任务是否携带有过载标签;在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理,解决了相关技术中采用HTTP协议完成流式任务时,在流量过载的情况下大量丢包的问题。进而达到了流量过载的情况下减少丢包的效果。

  请求的维度也存在限流的情况,可选地,在本申请实施例提供的消息处理方法中,在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理包括:判断已存在的分片的处理请求的数目是否大于等于请求过载线程数目;在已存在的分片的处理请求的数目大于等于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第一处理;在已存在的分片的处理请求的数目小于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第二处理。

  需要说明的是,除了对会话维度进行限流,设置会话过载线程数目,还需要对请求进行限流,设置请求过载线程数目。

  具体地,可以设置请求过载线程数目大于会话过载线程数目,在会话的流式任务未携带有过载标签,且请求未过载的情况下,对分片的请求进行处理。但由于分片的处理需求大于会话的流式任务的创建需求,会出现会话的流式任务未携带有过载标签,但请求过载的情况,此时需要等待其他请求释放请求处理线程,再对分片请求进行进一步的处理。

  可选地,在本申请实施例提供的消息处理方法中,在已存在的分片的处理请求的数目大于等于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第一处理包括:判断在预设时间内是否存在空闲的请求处理线程;在预设时间内存在空闲的请求处理线程的情况下,将目标分片添加至目标会话的流式任务中;在预设时间内不存在空闲的请求处理线程的情况下,丢弃目标分片,并释放目标会话的流式任务所占用的会话处理线程,以及目标会话的流式任务中的分片所占用的请求处理线程。

  具体地,在请求过载的情况下,将等待其它请求线程释放资源。如在分片超时前仍没有释放请求线程,该分片的请求将超时失败,该分片被丢弃,该会话也将超时失败,释放本会话占用的会话线程,同时释放本回会话的其它分片的占用的请求线程。如在分片超时前出现释放请求线程的操作,存在空闲的请求线程,将正常进行会话的流式任务的处理。

  可选地,在本申请实施例提供的消息处理方法中,在已存在的分片的处理请求的数目小于请求过载线程数目的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行第二处理包括:将目标分片添加至目标会话的流式任务中;判断目标会话的流式任务中存在的分片是否等于目标会话包含的分片;在目标会话的流式任务中存在的分片等于目标会话包含的分片的情况下,执行对目标会话的分析处理的步骤。

  需要说明的是,由于分片乱序到达,在一个会话的所有分片均到达的情况,对会话进行分析,会话存在未到达的分片的情况下,将等待所有未达到分片到达后再进行会话的处理。

  例如,任务处理场景为一句话语音识别,在一条语音的所有语音分片均到达的情况,将语音分片按顺序排列,从而进行语音识别,在一条语音存在未到达的语音分片的情况下,进行等待。

  可选地,在本申请实施例提供的消息处理方法中,在存在的情况下,判断目标会话的流式任务是否携带有过载标签之后,该方法还包括:在目标会话的流式任务携带有过载标签的情况下,丢弃目标分片。

  具体地,在目标会话的流式任务携带有过载标签的情况下,不对目标会话进行处理,丢弃目标分片,同时该目标分片不占用请求线程。

  通过本申请实施例,可以保证会话线程数占满时的会话中的全部请求,避免了在未过载的情况下创建的流式任务的分片主动丢包的情况。同时,在请求的线程空闲时将分片发送到带有过载标签的流式任务上,对带有过载标签的流式任务不再进行处理。从而就避免出现丢弃了线程占满的流式任务请求,而请求的线程空闲时建立不完整的流式任务等问题,系统将逐渐无法正常处理业务请求的问题。

  本申请实施例还提供了一种消息处理系统,图2是根据本申请实施例的消息处理系统的示意图。如图2所示,该系统包括:客户端21和服务端22。

  客户端21,用于发送目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片。

  需要说明的是,服务端22收到的目标分片的处理请求可能不是第一片请求,无论收到的第一个分片的请求是不是第一片请求,都将在不存流式任务的情况下进行流式任务的创建。无需额外占用资源等待客户端21发送第一分片请求,避免了接口资源的浪费,从而减轻分片到达乱序对服务的影响。

  服务端22,用于接收目标分片的处理请求,并查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;在存在的情况下,判断目标会话的流式任务是否携带有过载标签;在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理,并将处理结果发送至客户端21。

  具体地,当会话线程数未占满时,服务端22的接口收到分片的请求,查询不为第一个分片的请求的情况下,也即,不为未创建会话的分片的请求的情况下,将查询已存在流式任务,由于会话线程数未占满,会话的流式任务未携带有过载标签,可以对该会话的流式任务进行分析处理。从而保证会话线程数占满时的会话中的全部请求,避免了在未过载的情况下创建的流式任务的分片主动丢包的情况。

  本申请实施例还提供了一种消息处理方法,图3是根据本申请实施例的消息处理方法的流程图。如图3所示,该方法包括:

  客户端发送请求,也即,创建流式任务的请求。

  服务端收到请求的情况下,判断是否存在正在创建任务或查询任务的操作,在存在的情况,由于会对操作进行加锁,无法执行操作,等待锁释放后,再查询是否已有流式任务,也即,是否已有请求创建的流式任务。

  在没有请求创建的流式任务的情况下,判断流量是否过载,在流量未过载的情况下,创建流式任务并不打过载标签,在流量过载的情况下,创建流式任务并打过载标签。

  此外,已有请求创建的流式任务的情况下,判断流式任务是否有过载标签,在没有过载标签的情况下,对流式任务正常处理,并将处理结果返回至客户端,在有过载标签的情况下,不对流式任务进行处理,并返回不处理的结果至客户端。

  需要说明的是,在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行,并且,虽然在流程图中示出了逻辑顺序,但是在某些情况下,可以以不同于此处的顺序执行所示出或描述的步骤。

  本申请实施例还提供了一种消息处理装置,需要说明的是,本申请实施例的消息处理装置可以用于执行本申请实施例所提供的用于消息处理方法。以下对本申请实施例提供的消息处理装置进行介绍。

  图4是根据本申请实施例的消息处理装置的示意图。如图4所示,该装置包括:接收单元10、查询单元20第一判断单元30和处理单元40。

  具体地,接收单元10,用于接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片。

  查询单元20,用于查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立。

  第一判断单元30,用于在存在的情况下,判断目标会话的流式任务是否携带有过载标签。

  处理单元40,用于在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理。

  本申请实施例提供的消息处理装置,通过接收单元10接收目标分片的处理请求,其中,目标分片为目标会话中的任意一个分片;查询单元20查询待办任务流中是否已存在目标会话的流式任务,其中,目标会话的流式任务基于目标会话的任意一个分片的处理请求建立;第一判断单元30在存在的情况下,判断目标会话的流式任务是否携带有过载标签;处理单元40在目标会话的流式任务未携带有过载标签的情况下,将目标分片添加至目标会话的流式任务中,并对目标会话的流式任务进行处理,解决了相关技术中采用HTTP协议完成流式任务时,在流量过载的情况下大量丢包的问题,进而达到了流量过载的情况下减少丢包的效果。

  可选地,在本申请实施例提供的消息处理装置中,装置还包括:第二判断单元,用于在查询待办任务流中是否已存在目标会话的流式任务之前,判断当前是否存在目标操作,其中,目标操作包括以下之一:查询流式任务的操作,创建流式任务的操作;执行单元,用于在当前不存在目标操作的情况下,执行查询待办任务流中是否已存在目标会话的流式任务的步骤。

  可选地,在本申请实施例提供的消息处理装置中,处理单元40包括:判断模块,用于判断已存在的分片的处理请求的数目是否大于等于请求过载线程数目;第一处理模块,用于在已存在的分片的处理请求的数目大于等于请求过载线程数目的情况下,对目标会话的流式任务进行处理进行第一处理;第二处理模块,用于在已存在的分片的处理请求的数目小于请求过载线程数目的情况下,对目标会话的流式任务进行处理进行第二处理。

  可选地,在本申请实施例提供的消息处理装置中,第一处理模块包括:第一判断子模块,用于判断在预设时间内是否存在空闲的请求处理线程;第一添加子模块,用于在预设时间内存在空闲的请求处理线程的情况下,将目标分片添加至目标会话的流式任务中;释放子模块,用于在预设时间内不存在空闲的请求处理线程的情况下,丢弃目标分片,并释放目标会话的流式任务所占用的会话处理线程,以及目标会话的流式任务中的分片所占用的请求处理线程。

  可选地,在本申请实施例提供的消息处理装置中,第二处理模块包括:第二添加子模块,用于将目标分片添加至目标会话的流式任务中;第二判断子模块,用于判断目标会话的流式任务中存在的分片是否等于目标会话包含的分片;执行子模块,用于在目标会话的流式任务中存在的分片等于目标会话包含的分片的情况下,执行对目标会话的分析处理的步骤。

  可选地,在本申请实施例提供的消息处理装置中,该装置还包括:第三判断单元,用于在查询待办任务流中是否已存在目标会话的流式任务之后,在不存在的情况下,判断当前存在的会话的流式任务的数目是否大于等于会话过载线程数目;第一创建单元,用于在当前存在的会话的流式任务的数目大于等于会话过载线程数目的情况下,创建目标会话的流式任务,并为目标会话的流式任务创建过载标签;第二创建单元,用于在当前存在的会话的流式任务的数目小于会话过载线程数目的情况下,创建未携带有过载标签的目标会话的流式任务。

  可选地,在本申请实施例提供的消息处理装置中,该装置还包括:丢弃单元,用于在存在的情况下,判断目标会话的流式任务是否携带有过载标签之后,在目标会话的流式任务携带有过载标签的情况下,丢弃目标分片。

  所述消息处理装置包括处理器和存储器,上述接收单元10、查询单元20第一判断单元30和处理单元40等均作为程序单元存储在存储器中,由处理器执行存储在存储器中的上述程序单元来实现相应的功能。

  处理器中包含内核,由内核去存储器中调取相应的程序单元。内核可以设置一个或以上,通过调整内核参数来解决相关技术中采用http协议完成流式任务时,在流量过载的情况下大量丢包的问题。

  存储器可能包括计算机可读介质中的非永久性存储器,随机存取存储器(RAM)和/或非易失性内存等形式,如只读存储器(ROM)或闪存(flash RAM),存储器包括至少一个存储芯片。

  本申请实施例还提供了一种非易失性存储介质,非易失性存储介质包括存储的程序,其中,程序运行时控制非易失性存储介质所在的设备执行一种消息处理方法。

  本申请实施例还提供了一种电子装置,包含处理器和存储器;存储器中存储有计算机可读指令,处理器用于运行计算机可读指令,其中,计算机可读指令运行时执行一种消息处理方法。本文中的电子装置可以是服务器、PC、PAD、手机等。

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

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

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

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

  在一个典型的配置中,计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。

  存储器可能包括计算机可读介质中的非永久性存储器,随机存取存储器(RAM)和/或非易失性内存等形式,如只读存储器(ROM)或闪存(flash RAM)。存储器是计算机可读介质的示例。

  计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括,但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带,磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质,可用于存储可以被计算设备访问的信息。按照本文中的界定,计算机可读介质不包括暂存电脑可读媒体(transitory media),如调制的数据信号和载波。

  还需要说明的是,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括要素的过程、方法、商品或者设备中还存在另外的相同要素。

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

  以上仅为本申请的实施例而已,并不用于限制本申请。对于本领域技术人员来说,本申请可以有各种更改和变化。凡在本申请的精神和原理之内所作的任何修改、等同替换、改进等,均应包含在本申请的权利要求范围之内。

《消息处理方法、系统、装置及电子设置.doc》
将本文的Word文档下载到电脑,方便收藏和打印
推荐度:
点击下载文档

文档为doc格式(或pdf格式)