您的当前位置:首页正文

WEB耗时任务的处理方案

来源:华拓网

        1.前端上传文件到后台后,后台开启一个子线程处理耗时任务,主线程直接返回结果给前端,当前请求结束,无须等待子任务的处理结果。注意这里的返回结果只是表示文件上传成功,是一个阶段性的结果而已。

        2.前端开启一个轮询,每隔一秒查一下当前任务的处理进度,直到任务处理结束。

        回答一下这个思路中的几个关键点

        1.轮询检查的依据是什么?后台根据什么来知道当前是谁在查询?答案:Session.对Session不太了解的同学可以再做一下功课,这里不展开。

        2.主线程和新开的子线程之间是需要交换数据的,包括子线程和查询线程之间也是需要交换数据的,这个交换数据是用什么来实现?答案:HttpRuntime Cache,对这个不熟悉的也做一下功课,这里简单理解为就是一块可以共享数据的内存区域。

        好了,思路和关键点都解决了,这里再来贴一下关键点的代码,让大家有一个更清晰的认识

        1.开启子线程

        //sessionid是作为一个参数传到子线程里面去的,我们保存数据到cache中是以sessionid+关键字的形式来做key值,而session值是不能在子线程中直接获取的,所以传进去

        String sessionId = Session.SessionID;

        ThreadProc threadProc = new ThreadProc(sessionId);

        Thread thread = new Thread(new ThreadStart(threadProc.process));

         thread.IsBackground = true;

         thread.Start();

          子线程类:

          class ThreadProc{

                    private string sessionId = "";

                    public ThreadProc(string sessionId){

                                this.sessionId = sessionId;

                    }

                    public void process(){

                                //这里具体处理耗时任务

                                //保存结果

                                cache.WriteCache<Result>(result,sessionId+"result");

                    }

            } 

            2.cache的存取

            Cache cache = new Cache();

            //读取

             Result result = cache.GetCache<Result>(sessionId+"result");

            //保存

            cache.WriteCache<Result>(result,sessionId+"result");

             这里Cache类是对原始HttpRuntime Cache的一次封装,示例如下

             public class Cache{

                    private static System.Web.Caching.Cache cache = HttpRuntime.Cache;

                    public T GetCache<T>(string cacheKey) where T:class{

                                if(cache[cacheKey]  != null){

                                            return (T)cache[cacheKey];

                                }

                                return default(T);

                        }

                        public void WriteCache<T>(T value,string cacheKey) where T:class{

                                                                        cache.Insert(cacheKey,value,null,DateTime.Now.AddMinute(10),System.Web.Caching.Ca                                                        che.NoSlidingExpiration);

                        }

                    }

                3.轮询处理

                    public string CheckProcState(){

                                string sessionId = Session.SessionID;

                                Cache cache = new Cache();

                                Result result = cache.GetCache<Result>(sessionId+"result");

                                return result.ToJson();

                      }

            好啦,大体过程就是这样了,欢迎大家指正,也欢迎讨论其他处理长耗时任务的可具体实施的思路。