ASP.NET MVC 長鏈接（服務器推）完整實現

1.什麼是「服務器推」（百科來一波）？

---

• 傳統模式的 Web 系統以客戶端發出請求、服務器端響應的方式工做。這種方式並不能知足不少現實應用的需求，譬如：
• 監控系統：後臺硬件熱插拔、LED、溫度、電壓發生變化； 即時通訊系統：其它用戶登陸、發送信息； 即時報價系統：後臺數據庫內容發生變化； 這些應用都須要服務器能實時地將更新的信息傳送到客戶端，而無須客戶端發出請求。「服務器推」技術在現實應用中有一些解決方案，本文將這些解決方案分爲兩類：一類須要在瀏覽器端安裝插件，基於套接口傳送信息，或是使用 RMI、CORBA 進行遠程調用；而另外一類則無須瀏覽器安裝任何插件、基於 HTTP 長鏈接。
• 將「服務器推」應用在 Web 程序中，首先考慮的是如何在功能有限的瀏覽器端接收、處理信息：
• 客戶端如何接收、處理信息，是否須要使用套接口或是使用遠程調用。客戶端呈現給用戶的是 HTML 頁面仍是 Java applet 或 Flash 窗口。若是使用套接口和遠程調用，怎麼和 JavaScript 結合修改 HTML 的顯示。 客戶與服務器端通訊的信息格式，採起怎樣的出錯處理機制。 客戶端是否須要支持不一樣類型的瀏覽器如 IE、Firefox，是否須要同時支持 Windows 和 Linux 平臺。

---

## 2.需求

1. RFID中間件實現，上百級硬件設備集羣管理，大量數據實時上傳。
2. 中間件管理界面簡單大方，帶來的是後臺異常及日誌沒法在運行過程當中實時跟蹤。
3. WEB端實時、簡單、穩定輸出日誌。
4. 要求輸出不一樣類型的日誌，如操做日誌、異常日誌等。

3.實現

---

3.1生產者

• 存在的多個瀏覽器同時打開長鏈接，也就是存在日誌輸出一對多的狀況，因此生產的回調必需要用到委託鏈。
• 日誌輸出不能影響到正常工做流程，因此日誌的回調輸出必需要用異步加緩存的方式，不然日誌將會阻塞。
  直接亮代碼（已經徹底實現）：

public delegate void DebugCallback(Int32 type, String str);                                    // 委託 
public class DebugMsg
{ 
    public int Type { get; set; } 
    public String Message { get; set; } 
    public DebugMsg(Int32 type, String str) 
    { 
        this.Type = type; this.Message = str; 
    } 
}  // 調試消息

public class CallbackManager
{

    #region 單例
    private static CallbackManager instance = null;
    public static CallbackManager Instance                  // 只讀屬性
    {
        get
        {
            if (instance == null)
            {
                instance = new CallbackManager();
                instance.StartProcess();               // 啓用處理線程
            }
            return CallbackManager.instance;
        }
    }
    #endregion

    public static DebugCallback G_D = new DebugCallback(delegate(Int32 type, String str) {
        // System.Diagnostics.Debug.WriteLine("異常類型：" + type + "異常信息：" + str);
    });
    private static int G_D_ClientCount = 0;
    private static int G_D_MAX = 10;                                    // 最大接入客戶端數目
    private static object G_D_LOCK = new object();                      // 同步鎖

    private static Queue<DebugMsg> QUEUE_BUFF = new Queue<DebugMsg>();  // 調試信息緩存
    private static object QUEUE_BUFF_LOCK = new object();               // 同步鎖
    private static Boolean IS_PROCESS = true;

    public CallbackManager() { }

    #region 對外接口

    // 輸出調試信息
    public void _D(Int32 type, String str) 
    {
        lock (QUEUE_BUFF_LOCK)                                 // 同步操做
        {
            try
            {
                QUEUE_BUFF.Enqueue(new DebugMsg(type, str));
                Monitor.Pulse(QUEUE_BUFF_LOCK);
            }
            catch { };
        }
    }

    // 輸出調試信息
    public void _D(String str)
    {
        lock (QUEUE_BUFF_LOCK)                  // 同步操做
        {
            try
            {
                QUEUE_BUFF.Enqueue(new DebugMsg(0, str));
                Monitor.Pulse(QUEUE_BUFF_LOCK);
            }
            catch { };
        }
    }

    // 添加客戶端調試信息輸出
    public void AddClient(DebugCallback client) 
    {
        lock (G_D_LOCK)                  // 同步操做
        {
            try
            {
                if (G_D_ClientCount >= G_D_MAX) return;
                G_D += client;
                G_D_ClientCount++;
                _D("當前調試客戶端個數：" + G_D_ClientCount);
            }
            catch { }
        }
    }

    // 刪除客戶端調試信息輸出
    public void RemoveClient(DebugCallback client) 
    {
        lock (G_D_LOCK)                  // 同步操做
        {
            try
            {
                G_D -= client;
                G_D_ClientCount--;
                _D("當前調試客戶端個數：" + G_D_ClientCount);
            }
            catch { }
        }
    }

    #endregion

    // 處理緩存隊列消息
    private void StartProcess()
    {
        ThreadPool.QueueUserWorkItem(new WaitCallback(delegate(object o){
            while (IS_PROCESS)
            {
                lock (QUEUE_BUFF_LOCK)                              // 同步操做
                {
                    if (QUEUE_BUFF.Count > 0)
                    {
                        lock (G_D_LOCK) 
                        {
                            try
                            {                                       // 輸出異常消息
                                DebugMsg deque = QUEUE_BUFF.Dequeue();
                                G_D(deque.Type, deque.Message);      // 從隊列中輸出調試消息
                            }
                            catch { }
                        }
                    }
                    else 
                    {
                        Monitor.Wait(QUEUE_BUFF_LOCK);
                    }
                }
            }
        }));
    }

3.2消費者

Boolean isOnline = true;

// GET: /System/

public ActionResult Index()
{
    #region 滾動條控制

    Response.Write("<html onclick=\"clearInterval(i_1);\" ondblclick =\"reInterval()\"><head><title>服務器實時監控</title></head>");
    Response.Write("<script type=\"text/javascript\">");
    Response.Write("function scrollWindow() { document.body.scrollTop = document.body.scrollHeight; }");
    Response.Write("function reInterval() { i_1 = setInterval('scrollWindow()', 50); }");
    Response.Write("i_1 = setInterval('scrollWindow()', 50);");
    Response.Write("scrollWindow();");
    Response.Write("</script> ");
    Response.Flush();

    #endregion
    Dictionary<int, string> dicColor = new Dictionary<int, string>() 
    {
        {0,"#0000FF"},          // 藍色
        {1,"#FF3333"},          // 紅色
        {2,"#FFFF00"},          // 黃色
        {3,"#FF3EFF"},
        {4,"#0000FF"},
        {5,"#0000FF"}
    };
    DebugCallback callback = new DebugCallback(delegate(int type, string str)
    {
        if (dicColor.ContainsKey(type))
        {
            Response.Write("<span style = 'color:" + dicColor[type] + ";'>" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "--" + str + "</span>  <br />");
        }
        Response.Flush();
    });

    Log.AddCallBack(callback);

    while (isOnline)
    {
        try
        {
            Response.Write("...<br>");
            Response.Flush();
        }
        catch { }
        System.Threading.Thread.Sleep(1000);
        if (!Response.IsClientConnected)            // 鏈接關閉
        {
            Log.RemoveCallBack(callback);
            Response.Write("</html>");
            break;
        }
    }
    return null;
}

長連接會涉及到Session阻塞問題，詳細說明請見：http://www.cnblogs.com/fanqie-liuxiao/p/5702633.html