Html5服务器推送事件分析

   <script>
     if (typeof (EventSource) !== "undefined") {
       //推送服务接口地址
       var eventSource = new EventSource("http://localhost:2242/webservice/ServerSent/SentNews");
       //当通往服务器的连接被打开
       eventSource.onopen = function () {
         console.log("连接打开...");
       }
       //当错误发生
       eventSource.onerror= function (e) {
         console.log(e);
       };
       //当接收到消息，此事件为默认事件
       eventSource.onmessage = function (event) {
         console.log("onmessage...");
      eventSource.close()//关闭SSE链接
       };
       //服务器推送sentMessage事件
       eventSource.addEventListener('sentMessage', function (event) { 
         var data = eval('('+event.data+')');//服务器端推送的数据，eval装换Json对象
         var origin = event.origin;//服务器 URL 的域名部分，即协议、域名和端口，表示消息的来源。
         var lastEventId = event.lastEventId;////数据的编号，由服务器端发送。如果没有编号，这个属性为空。
         //此处根据需求编写业务逻辑
         console.log(data);       }, false);
     } else {
       //浏览器不支持server-sent events 所有主流浏览器均支持服务器发送事件，除了 Internet Explorer。
       document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
     }
   </script>

/// <summary>
    /// 推送消息
    /// </summary>
    /// <returns></returns>
    [HttpGet]
    public HttpResponseMessage SentNews()
    {
      HttpResponseMessage response = Request.CreateResponse(HttpStatusCode.OK);
      try
      {
        //response.Headers.Add("Access-Control-Allow-Origin", "*");//如需要跨域可配置
        string data_str = “推送至客户端的数据”;//当然可以是json字符串格式
        string even = "", data = "";
        if (!string.IsNullOrWhiteSpace(data_str))
        {
          even = "event:sentMessage\n";
          data = "data:" + data_str + "\n\n";
        }
        string retry = "retry:" + 1000 + "\n";//连接断开后重连时间（毫秒），其实可以理解为轮询时间 2333...
        byte[] array = Encoding.UTF8.GetBytes(even + data + retry);
        Stream stream_result = new MemoryStream(array);
        response.Content = new StreamContent(stream_result);
        response.Content.Headers.ContentType = new MediaTypeHeaderValue("text/event-stream");//此处一定要配置
        response.Headers.CacheControl = new CacheControlHeaderValue();
        response.Headers.CacheControl.NoCache = false;
      }
      catch (Exception ex)
      {
        LogHelper.WriteWebLog(ex);
      }
      return response;
    }