您的位置：首页 > 编程语言 > ASP

ASP.NET MVC 长连接（服务器推）完整实现

2016-07-25 11:49 603 查看

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
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息
标签： 
相关文章推荐
新的分享
章节导航