1.什么是“服務器推”（百科來一波）？
- 傳統模式的 Web 系統以客戶端發出請求、服務器端響應的方式工作。這種方式並不能滿足很多現實應用的需求，譬如：
- 監控系統：后台硬件熱插拔、LED、溫度、電壓發生變化； 即時通信系統：其它用戶登錄、發送信息； 即時報價系統：后台數據庫內容發生變化； 這些應用都需要服務器能實時地將更新的信息傳送到客戶端，而無須客戶端發出請求。“服務器推”技術在現實應用中有一些解決方案，本文將這些解決方案分為兩類：一類需要在瀏覽器端安裝插件，基於套接口傳送信息，或是使用 RMI、CORBA 進行遠程調用；而另一類則無須瀏覽器安裝任何插件、基於 HTTP 長連接。
- 將“服務器推”應用在 Web 程序中，首先考慮的是如何在功能有限的瀏覽器端接收、處理信息：
- 客戶端如何接收、處理信息，是否需要使用套接口或是使用遠程調用。客戶端呈現給用戶的是 HTML 頁面還是 Java applet 或 Flash 窗口。如果使用套接口和遠程調用，怎么和 JavaScript 結合修改 HTML 的顯示。 客戶與服務器端通信的信息格式，采取怎樣的出錯處理機制。 客戶端是否需要支持不同類型的瀏覽器如 IE、Firefox，是否需要同時支持 Windows 和 Linux 平台。
2.需求
- RFID中間件實現，上百級硬件設備集群管理，大量數據實時上傳。
- 中間件管理界面簡單大方，帶來的是后台異常及日志無法在運行過程中實時跟蹤。
- WEB端實時、簡單、穩定輸出日志。
- 要求輸出不同類型的日志，如操作日志、異常日志等。
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