采用Asp.net的定时处理方式，在WEB服务器层处理业务
核心处理就是System.Threading.Timer。这个定时类可以用于在后台定时执行用户提交操作，

它的使用方法：

System.Threading.TimerCallback t=new System.Threading.TimerCallback (你的处理方法);
System.Threading.Timer t = new System.Threading.Timer(t,null,1000,5000);
 这一段说明是在启动1秒后每隔5秒就调用所指定的代理。

在具体实现时我定义了三个类。

1、BkExecItem用于保存用户提交操作，同时它也可以序列化到磁盘上，以免关键后台任务丢失。

2、BkExec用于执行。它通过反射来调用BkExecItem中所指定的方法。另外它中间还维护一个先入

先出队列Queue，这个队列记录全部的后台处理项。

3、BkManager完成定时器的初始化，模块的参数配置等功能。

呵，暂时总结到这里。下次我会将代码也贴上来，供大家参考下。

一个实用ASP.Net 后台处理类

呵.这回跟大家讨论下ASP.net 后台处理 ,并会把我们当前项目中应用的一个后台处理类的代码贴上来参考.

后台处理也是现在管理系统设计中需要考虑到的一个问题.

什么是后台处理,可以简单认为不是在用户进程处理中完成用户提交的操作,而是将这一处理放到服务端后台进程来处理.

加入后台处理后,可以提高前台用户的操作速度,改善用户操作体验.

对于一般用户来说他对于一个系统的基本要求就是响应及时,用户很难对一个提交操作后需要等待10秒以后的管理系统产生好感,但在实际系统运行中用户操作是很难在短时间内得到响应,所以这个时候后台处理就可以发挥作用了.

我在后面所帖代码中,将需要后台处理的任务均定义成一个ExecItem对象.用户提交操作后,系统将就操作转成一个ExecItem对象加入到BkExecManager(后台处理管理对象)中的一个先入先出的队列中.

网站在启动时会自动启动BkExecManager,而BkExecManager则启动一个定时器来定时处理后台任务队列.

在处理完成时BkExecManager就队列中移去任务对象,如果操作失败将以邮件方式通知管理员来完成问题处理.

呵.现在贴代码!

1,后台处理管理对象

public class BkExecManager
{ 
    //定时回调。
    private static TimerCallback timerDelegate;
    private static Timer stateTimer;
    private static BkExecer m_Execer;
    public static string DataPath;
    public static string BkManager = "XXXX";
    public static int BkBufSize = 100;
    private static int Interval = 10000;

    public static BkExecer Execer
    {
        get { return m_Execer; }
    }

    static BkExecManager()
    {
        DataPath = System.AppDomain.CurrentDomain.BaseDirectory + "BkItem\";
        if (System.Configuration.ConfigurationManager.AppSettings["Interval"] != null)
            Interval = Convert.ToInt32(System.Configuration.ConfigurationManager.AppSettings["Interval"]);

        if (System.Configuration.ConfigurationManager.AppSettings["BkBufSize"] != null)
            BkBufSize = Convert.ToInt32(System.Configuration.ConfigurationManager.AppSettings["BkBufSize"]);

        if (System.Configuration.ConfigurationManager.AppSettings["BkManager"] != null)
            BkManager = System.Configuration.ConfigurationManager.AppSettings["BkManager"];

        m_Execer = new BkExecer();
        //初始化回调
        timerDelegate = new TimerCallback(m_Execer.DoBkExec);
        //初始化定时器
        stateTimer = new Timer(timerDelegate, null, 5000, Interval);
    }

    /**//**//**////

public class BkExecer
{
    //维护一个前进前出的队列。
    private Queue m_BkExecItemList;
    private static object lockHelper = new object();
    private static bool m_IsBusy = false;

    public static bool IsBusy
    {
        get { return m_IsBusy; }
    }

    public BkExecer()
    {
        m_BkExecItemList = new Queue(BkExecManager.BkBufSize);
        /**//**//**/////读入待处理事项
        InitData();
    }

    private void InitData()
    {
        lock (lockHelper)
        {
            string[] fnl = Directory.GetFiles(BkExecManager.DataPath);
            foreach (string s in fnl)
            {
                if (!s.Contains(BKExecItemState.出错.ToString()))
                {
                    ExecItem ei = ExecItem.GetObject(s);
                    m_BkExecItemList.Enqueue(ei);
                }
            }
        }
    }

    public void AddBkExecItem(ExecItem ei)
    {
        lock (lockHelper)
        {
            //锁定资源。
            m_BkExecItemList.Enqueue(ei);
        }
    }

    public void DoBkExec(object Msg)
    {
        ExecItem ei;
        while (m_BkExecItemList.Count > 0)
        {
            lock (lockHelper)
            {
                ei = m_BkExecItemList.Dequeue();
            }

            int rv = -1;
            try
            {
                BindingFlags flags = BindingFlags.InvokeMethod | BindingFlags.Instance |
                BindingFlags.Public | BindingFlags.Static;
                object t = ei.ExecItemClass.InvokeMember(ei.ExecItemMethed, flags,
                    null, null, ei.ExecItemParamList);

                if (t != null)
                    rv = Convert.ToInt32(t);
                else
                    rv = 0;     //如果是无返回则直接设置零．
            }
            catch (Exception e)
            {
                //更新Ei的状态，保存到磁盘。
                ei.FinishBkExec(false, e.Message);
            }
            finally
            {
                //更新Ei的状态，删除存件
                //保存到磁盘。
                if (rv >= 0)
                    ei.FinishBkExec(true, "");
                else
                    ei.FinishBkExec(false, rv.ToString());
            }
        }
    }
}
3,任务对象

public enum BKExecItemState { 待执行, 完成, 出错 };

[Serializable]
/**//**//**////

    public BKExecItemState ItemState
    {
        get { return m_ItemState; }
    }

    private DateTime m_ExecItemExecTime;
    public DateTime ExecItemExecTime
    {
        get { return m_ExecItemExecTime; }
    }

    private DateTime m_ExecItemCreateTime;
    public DateTime ExecItemCreateTime
    {
        get { return m_ExecItemCreateTime; }
    }

    private string m_ExecItemName;
    public string ExecItemName
    {
        get { return m_ExecItemName; }
    }

    private Type m_ExecItemClass;
    public Type ExecItemClass
    {
        get { return m_ExecItemClass; }
    }
    private string m_ExecItemMethed;
    public string ExecItemMethed
    {
        get { return m_ExecItemMethed; }
    }

    private object[] m_ExecItemParamList;
    public object[] ExecItemParamList
    {
        get { return m_ExecItemParamList; }
    }

    private string m_Op;
    /**//**//**////

        this.m_ExecItemClass = objtype;
        this.m_ExecItemCreateTime = DateTime.Now;
        this.m_ExecItemExecTime = DateTime.Now;
        this.m_ExecItemMethed = ExecMethod;
        this.m_ExecItemName = ExecName;
        this.m_ExecItemParamList = param;
        this.m_ItemState = BKExecItemState.待执行;
        this.m_Op = Op;

        if (SavetoDisk)
            SaveToDisk();
    }

    private void SaveToDisk()
    {
        IFormatter formatter = new BinaryFormatter();
        Stream stream = new FileStream(BkExecManager.DataPath + BKStoreFileName,
            FileMode.Create, FileAccess.Write, FileShare.None);
        formatter.Serialize(stream, this);
        stream.Close();
    }

    private void SaveToDisk2()
    {
        //
        string basedir = System.AppDomain.CurrentDomain.BaseDirectory;
        this.BKStoreFileName = String.Format("{0} {1} {2} {3}.bin",
            m_ExecItemCreateTime.ToString("yyyy-MM-dd HH-mm-ss"),
            this.m_ExecItemMethed,
            m_Op,
            m_ItemState.ToString());

        IFormatter formatter = new BinaryFormatter();
        Stream stream = new FileStream(BkExecManager.DataPath + BKStoreFileName,
            FileMode.Create, FileAccess.Write, FileShare.None);
        formatter.Serialize(stream, this);
        stream.Close();
    }

    public static ExecItem GetObject(string s)
    {
        IFormatter formatter = new BinaryFormatter();
        Stream stream = new FileStream(s, FileMode.Open, FileAccess.Read, FileShare.None);
        ExecItem e = (ExecItem) formatter.Deserialize(stream);
        stream.Close();
        return e;
    }

    public void FinishBkExec(bool DoneOk, string Msg)
    {
        string FileName = BkExecManager.DataPath + BKStoreFileName;
        m_ExecItemExecTime = DateTime.Now;

        if (File.Exists(FileName))
            File.Delete(FileName);

        if (!DoneOk)
        {
            m_ItemState = BKExecItemState.出错;
            ErrMsg = Msg;
            SaveToDisk2();
            MakeMail();
        }
    }

    private void MakeMail()
    {
        StringBuilder sb = new StringBuilder();
        sb.Append("提交人:").Append(this.m_Op).Append("
");
        sb.Append("提交时间:").Append(this.ExecItemCreateTime).Append("
");
        sb.Append("对象:").Append(this.m_ExecItemClass.Name).Append("
");
        sb.Append("方法:").Append(this.m_ExecItemMethed).Append("
");
        sb.Append("参数:");
        foreach (object o in this.m_ExecItemParamList)
            sb.Append(o.ToString()).Append(",");
        sb.Append("
");
        sb.Append("执行时间:").Append(this.m_ExecItemExecTime).Append("
");
        sb.Append("错误信息:").Append(this.ErrMsg).Append("
");
        string mb = sb.ToString();
        //APP.Mail.Send(m_Op + ":" + m_ExecItemClass.Name + "后台处理错", mb, "", BkExecManager.BkManager, "");
    }
}
具体调用方法为

1,首先新调一个后台任务对象.
2,将之加入到任务队列中.

ExecItem ei = new ExecItem(typeof(CacheManager),
    "RefreshObject",
    new object[] { Objtype, Params, ct },
    "缓存刷新",
    "",
    false);  //注意以后可以设置为false,即刷新任务不保存到磁盘,以免影响磁盘性能.

BkExecManager.Execer.AddBkExecItem(ei);