IHttpAsyncHandler实现广播功能

public class CometAsyncHandler:IHttpAsyncHandler
{
    public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback callback, object extraData)
    {
        WebAsynResult asyncResult = new WebAsynResult(context,callback,extraData);
        String content = context.Request.Params["content"];
        HttpResult.Instance().AddMessage(content, asyncResult);
        return asyncResult;
    }
    public void EndProcessRequest(IAsyncResult asyncResult)
    {
       
    }
    public void ProcessRequest(HttpContext context)
    {
        throw new NotImplementedException();
    }
    public bool IsReusable
    {
        get { return false; }
    }
}

public class WebAsynResult : IAsyncResult
{
    bool _IsCompleted = false;
    private HttpContext context;
    private AsyncCallback cb;
    private object extraData;
    public WebAsynResult(HttpContext context, AsyncCallback cb, object extraData)
    {
        this.context = context;
        this.cb = cb;
        this.extraData = extraData;
    }
    private string _content;
    public string Content
    {
        get { return _content; }
        set { _content = value; }
    }

    #region IAsyncResult接口
    public object AsyncState
    {
        get { return null; }
    }

    public System.Threading.WaitHandle AsyncWaitHandle
    {
        get { return null; }
    }

    public bool CompletedSynchronously
    {
        get { return false; }
    }
    public bool IsCompleted
    {
        get { return _IsCompleted; }
    }
    #endregion

    //调用此方法，实现返回数据到客户端
    public void Send(object data)
    {
        context.Response.Write(this.Content);
        if (cb != null)
        {
            cb(this);
        }
        _IsCompleted = true; ;
    }
}

public class HttpResult
{
    //所有请求
    List<WebAsynResult> clients = new List<WebAsynResult>();

    //类的单例
    private static HttpResult _Instance = new HttpResult();
    private HttpResult()
    {
    }
    public static HttpResult Instance()
    {
        return _Instance;
    }


    public void AddMessage(string content, WebAsynResult asyncResult)
    {
        //内容为connect，就挂起这个请求
        if (content == "connect")
        {
            clients.Add(asyncResult);
        }
        else
        {
            asyncResult.Content = content;
            asyncResult.Send(null);

            //遍历client,内容输出到客户端
            foreach (WebAsynResult result in clients)
            {
                result.Content = content;
                result.Send(null);
            }

            //清空所有缓存
            clients.Clear();
        }
    }
}

    <script>
        function coment() {
            var cont = "connect";
            $.ajax({
                type: "POST",
                url: "comet.asyn",
                data: { content: cont },
                success: function (data) {
                    coment();
                },
                error: function () {
                    coment();
                }
            })
        }
        window.onload = coment;
    </script>

  <system.webServer>
    <handlers>
      <add name="comet" verb="GET,POST" path="comet.asyn" type="CometAsyncHandler"/>
    </handlers>
  </system.webServer>

WebAsynResult asyncResult = new WebAsynResult(HttpContext.Current, null, null);
HttpResult.Instance().AddMessage("广播内容", asyncResult);