欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

快速响应请求浅谈

程序员文章站 2022-03-22 18:59:34
排着前不见头后不见尾的队,内心是崩溃的,又进退两难,是一种等待。 叫号,玩手机等,是一种等待。 一句我等你,然后遥遥无期,是一种等待。 此为信物,待我长发及腰...,是一种等待。 关于响应 发起请求,接收到反馈即算响应。响应的内容是想要的结果,或仅是一句安慰,在合适的场景下合适的呈现都能有好的体验, ......

排着前不见头后不见尾的队,内心是崩溃的,又进退两难,是一种等待。
叫号,玩手机等,是一种等待。
一句我等你,然后遥遥无期,是一种等待。
此为信物,待我长发及腰...,是一种等待。

关于响应

发起请求,接收到反馈即算响应。响应的内容是想要的结果,或仅是一句安慰,在合适的场景下合适的呈现都能有好的体验,响应顾及这种反馈体验,出发点就对了。

快速响应方式

不同的应用场景,决定快速响应的方式。

(1)发起型,只关心提交的数据是否到达。

发起型只关心提交是否成功,不关心后续处理过程,此时,应在接收数据成功后立即反馈成功,处理过程交给其它异步线程或进程处理。

(2)实时结果型,等着出结果。

提交请求数据后,如果处理时间较短(如3秒以内),则可处理完成之后反馈结果。否则,可先反馈数据接收成功,提示处理中,然后异步标记处理状态供前端查询或是通知前端进度,此时前端已经收到反馈,然后以一种非阻塞的方式呈现处理进度。

前端也可以是收到反馈之后,直接引导用户进入下一步,进入下一步后,如果已经处理完了则皆大欢喜,未处理完,仍然可以通过状态信息,给用户反馈当前处理情况。

(3)信息查询型

信息查询,通常可以先加载页面,再异步加载查询结果。而数据部分,可以通过使用缓存减少数据库查询,当缓存中存在相关信息时,直接使用缓存中的数据返回。缓存需要适当的刷新策略,简单方式,如无缓存则查询数据库,有则检测是否超过刷新时间决定是否刷新。通常可以使用成熟的缓存框架。

快速响应方法

基本原则:尽早反馈

基本方法:先返回,异步处理,再通知

(1)线程化

接收到请求数据后,处理过程以线程方式进行,请求直接返回。如下 c# 代码,假设处理过程耗时 3 秒,则使用以下方式,耗时接近 0 秒。

stopwatch sw = new stopwatch();
sw.start(); -- 计时开始

var thread = new thread(new threadstart(() => {
    // 处理过程
    thread.sleep(3000);
}));

thread.start();            

--  显示耗时
return sw.elapsedmilliseconds.tostring(); 

这种方式的主要问题在于,当处理时长偏长而请求数较多时,线程数据会急剧增加可能耗尽所有资源,而使得应用不可用。

(2)线程池

使用线程池能降低反复创建销毁线程的损耗,并对资源的使用加以控制!在 c# 中,我们可以通过以下线程池的方法达到线程化的效果。

threadpool.queueuserworkitem((state) => {
    // 处理过程
    thread.sleep(3000);
    debug.write("处理完毕!");
});  

(3)队列化

任务请求不均衡,高峰期特别集中,而应用处理能力有限,此时可以建立一种排队机制,来的任务加入队列,不紧不慢的去执行,可以充分发挥机器性能又不至于超过其处理能力。任务的执行主体简要形式如以下 c# 示例。

/// <summary>
/// 任务执行线程主体
/// </summary>
private void taskrunning()
{
    while (_working)
    {
        queuetask<t> task = null;
        lock (_runlocker)   
        {
            if (_taskrunqueue.count > 0)
            {
                task = _taskrunqueue.dequeue();  
            }
        }
        // 还存在任务执行其任务过程
        if (task != null)
        {
            task.callback(task.objectkey, task.context);
        }
        else
        {
            // 等待新任务通知
            _waithandle.waitone();
        }
    }
} 

(4)中间件

使用中间件,能有效进行应用间的解藕,并使得应用极具扩展性与伸缩性,相关数据丢给中间件,中间件负责分发任务给相关工作进程,并管理好其状态。如 rabbitmq,通过它可以在不同应用进程中进行通信与任务管理。

任务处理方式

(1)发布订阅方式

确定一个主题,需要该主题相关的数据的应用订阅该主题即可,当数据方发布该主题时,订阅方会收到相应的消息然后触发业务处理。当同一数据(消息)多方应用依据其进行处理时,发布订阅方式非常合适。

(2)生产者消费者方式

当很多耗时任务到达时,可以开启多个工作进程来并行处理这些任务。发起任务方是生产者,工作进程就是消费者,生产一个,空闲工作进程马上接手一个(即消费一个)。仍然处理不过来了,可以继续增加工作进程。

容错处理

容错处理主要针对任务执行失败的情形,如何确保任务一定有结果的执行。其一,需要确保在任务派发后,其工作进程执行失败时,能自动重新委派给其它工作进程。其二,当分配者自身中断后能恢复任务队列。实现这些,需要有相应的处理机制,如任务执行结果 ack 通知、持久化消息等。而这些,都有较为成熟的解决方案,如 rabbitmq 等。