开发设计模式——asp.net中实现观察者模式

在中实现观察者模式？难道中的观察者模式有什么特别么？嗯基于Http协议的Application难免有些健忘我是这样实现的不知道有没有更好的办法？

先谈谈需求吧以免陷入空谈

最近一个Case 这样的需求很多客户端不断的向Web Application提交数据管理员进入Web的管理页面可以即时的看到这些数据有多个管理员可以同时浏览且管理员浏览的数据从管理员开始监视那个时刻起不能显示以前的数据从这个场景一看明显的观察者模式管理员开始监视时订阅数据数据到达的时候向所有订阅了数据的管理员广播数据

需求如下图

有了发布者还需要订阅者我们实现管理员类来订阅数据

public class Admin

{

/**//// <summary>

/// 用这个保存所有收到的数据

/// </summary>

public IList<string> MessageList

{ get; set; }

public Admin(Monitor monitor)

{

MessageList = new List<string>();

monitorDataIn += new EventHandler< DataEventArgs>(ReciveMessage);

}

private void ReciveMessage(object sender DataEventArgs e)

MessageListAdd(eMessage);

}

}

Ok需要具备的元素我们都写好了但是如何让它们工作起来？如果使Winform程序那将毫无悬念

分析我们碰到的问题

第一个问题当客户端发送一个数据包我们是实例化一个新的Monitor么？如果是哪么每次实例化一个全新的Monitor所有在它上面订阅的事件将全部消失了如果不是那这个Monitor将如何存在呢？总不能真空吧两个http请求之间如何保存数据呢？不过再把需求一读好像整个应用程序中就只需要也只能有一个这样的Monitor呢该是单件模式上场的时候了

在上面的Monitor的实现中添加下面的代码

private static Monitor _instance = null;

public static

Monitor Current

get

if (_instance == null)

_instance = new Monitor();

return _instance;

}

}

但是本系统存在多个客户端所以为了避免多线程造成问题还是来Double Check一下吧修改上面的代码如下

public static Monitor Current

get

object o = new object();

if (_instance == null)

lock (o)

if (_instance == null)

_instance = new Monitor();

}

}

return _instance;

}

}

(PS:为什么使用单件就可以跨请求保存实例了呢？因为这里使用了一个static member保存Monitor的引用static 的GC里面是被作为Root的详细内容请参见框架程序设计那本书)

第二个问题 当管理员页面的ajax请求的时候每两个请求如何保存数据？呵呵上面那个问题不是说了么用单件但是单件是全局存在的我们的管理员是多个每个管理员可以决定是否订阅数据以及什么时候订阅想起来没？除了全局数据外我们还有Session

在管理页面上我放置一个开始监视的按钮这个按钮使用ajax请求服务器端的一个HttpHandler在Handler的ProcessRequest方法里这样来做

Admin admin = contextSession[monitor_listener] as Admin;

if(admin == null)

admin = new Admin(MonitorCurrent);

contextSession[monitor_listener] = admin;

}

注意由于这个Handler需要访问Session所以你需要让这个Handler继承IRequiresSessionState接口(为什么使用继承而不用实现这个术语？实际上这个接口是一个标记接口没有任何需要实现的成员只是标记这个Handler可以访问Session我不知道为什么MS不使用Attribute是不是更合理些)

在管理页面还有个一个SetInterval不断的调用一个含有ajax的方法去请求另外一个Handler这个Handler将Admin收到的数据返回到web页面让我们来看看这个Handler的部分实现

public void ProcessRequest(HttpContext context)

contextResponseBuffer = true;

contextResponseExpiresAbsolute = SystemDateTimeNowAddSeconds();

contextResponseExpires = ;

contextResponseCacheControl = nocache;

Admin admin = contextSession[monitor_listener] as Admin;

if (admin == null || adminMessageCollection == null ||

adminMessageCollectionCount <= )

return;

string[] messages = new string[adminMessageCollectionCount];

adminMessageCollectionCopyTo(messages );

StringBuilder sb = new StringBuilder();

for (int i = ; i < messagesLength; i++)

sbAppendFormat(<li>{}</li> messages);

}

adminMessageCollectionClear();

contextSession[monitor_listener] = admin;

contextResponseWrite(sb);

contextResponseFlush();

}

OK一个在环境中实现的观察者模式基本上就算完成了不过上面只有怎样订阅那什么时候取消订阅了可以在Session_End事件里面取消订阅

还查看了一些关于长连接的文章发现这个不错准备改进一下

完整的代码稍后提供希望这块转头能引来一些玉

写完这个Post后本来想把完整代码实现传上来后来看到不少园友提出异议看了大家的留言后我也一直在思索我为什么这样做？当初我是怎样想到这个解决方案的？我在几个解决方案之间做了取捨了么？我这样做是不是矫枉过正了？经过这些思考有了现在的这个Post

首先我进一步谈一下需求

这是一个Web Application有很多客户端向服务器端提交数据(客户端是C++的以httppost方式向服务器端提交二进制数据服务器端解析这个二进制包数据提交很频繁)管理员可以进入监视页面浏览这些数据数据要即时的客户端发来一条管理员屏幕上要马上可以看到允许多个管理员同时监视即时数据所有管理员看到的数据都是一样的(目前是这样的也许以后对管理员要分角色各角色管理员看到的信息将不同)

由于数据提交非常频繁客户要求不允许频繁的数据库操作所以我将数据保存在一个IList的缓存里面当这个IList的大小超过了我在配置文件里定义的大小的时候就将数据批量插入到数据库

下面我将以我当初思考的思路为主线描述

第一个版本

//在程序里我写了一个静态类这个静态类保存整个程序中共享的一些数据

相当于原来的//Application对象但是静态成员是编译期类型检查的

public static ApplicationData

{

//这个队列用来保存客户端传递过来的数据当队列达到一定长度的时候同步到数据库

public static Queue<DataHead> OperateDataList = new Queue<DataHead>();

//这个List也是保存客户端传递过来的数据的但它是为监视准备数据的

//当一个监视页面的请求到来的时候将这个List的数据Response过去然后Clear这个//List

public static IList<DataHead> MonitorDataList = new List<DataHead>();

}

public class ReciveDataHandler : IHttpHandler

{

//……

Public void ProcessRequest(HttpContext context)

{

//解析从客户端传递过来的数据

DataHead data = GetData(context);

OperateDataListAdd(data);

If(OperateDataListCount > BufferSize)

{

//将数据写入到数据库

AddToBase();

}

MonitorDataListAdd(data);

}

}

//监视页面从这里获取数据

public class MonitorHandler : IHttpHandler

{

//……

Public void ProcessRequest(HttpContext context)

{

If(MonitorDataListCount > )

{

//将MonitorDataList里的数据Response出去

OutPut();

MonitorDataListClear();

}

}

}

说实话我当初做出这个的时候觉得一点问题都没有开始的时候客户测试也没有发现任何问题终于有一天客户和我同时测试部署在同一IIS的时候问题出现了只有一个监视页面有数据看到这个后我还百思不得其解顺着程序的执行流程一步一步走下去没有找出任何错误后来做了下日志原来MonitorDataList是一个全局共享的一个在监视把数据Clear了后别人就无法获取数据了不知道有没有人这样做过有时候忘记了自己正在做一个web程序而web程序是一个并发的对一些共享资源的访问有着微妙的问题如果没有记住这点按照程序流程的执行步骤是找不出任何问题的

怎么办？再一看这不是事件订阅所描述的场景么？所以就有了上一篇Post的Solution不过那个方案受到不少人质疑其中金色海洋提出这样的方法

Public class ReciveData : IHttpHandler

{

//………

//将客户端传递过来的数据存入数据库

}

Public class MonitorHandler : IHttpHandler

{

//………

//为null的时候说明该管理员第一次监视

If(Session[id] == null)

{

//根据时间从服务器取出数据

//并将取出数据的最后一个id保存在session中

Session[id] = id;

}

//不为null则说明该管理员已经开始监视了

Else

{

//根据session里保存的最后一个id取出大于那个id的数据

Session[id] = currentId;

}

}

看似这个方案不错我尝试着将我的程序修改为这样但是我将上面的代码编写完我发现我不可以再进行下去了上面的方案满足不了我的需求客户明确要求了客户端提交的数据要先缓存然后缓存超过配置大小(这个大小还需要可以在配置文件里面配置以便可以经过测试找出一个最合理的值)而这种Session记录的方案是依靠数据库来保存数据这个Session[id]就相当于一个游标这个游标指向的是数据库那好我们将Session[id]指向缓存数据但是请注意缓存随时可能超过设置大小而被同步到数据库并被清空

经过一番思考后我还是回到我自己的Solution上不过我又有了新的看法了不是要将数据先缓存么？看看这个缓存实际上她也是个观察者至于她执行怎样的缓存策略是她的事情如是我又有了一个新类

public class DataEventArgs : EventArgs

public string Message

{get;set;}

public DataEventArgs(string message)

thisMessage = message;

}

}

public class Monitor

{

public event EventHandler<DataEventArgs> DataIn;

private void SendData(string message)

if (DataIn != null)

DataEventArgs e = new DataEventArgs(message);

DataIn(this e);

}

}

/**//// <summary>

/// 这个方法被一个HttpHandler调用客户端向这个Handler发送数据

/// 数据处理后作为字符串传递给该方法该方法然后将数据广播出去

/// </summary>

/// <param name=message>处理后的数据</param>

public void ReciveData(string message)

SendData(message);

}

}