专注于Jsp开发，为Jsp开发提供源动力 VM主机| 海外空间| JAVA网站建设| 郑州网站建设| 网站优化| 郑州网络公司| 洛阳网站建设
jsp空间
首页 Jsp空间 国外Jsp空间 Jsp资讯 空间定制 技术学院 开源 专题 在线问答 服务支持 下载

点击排行

如何发布JSP网站以及注...

三易企业邮箱在企业日...

企业邮局全民大体验

收发邮件慢的解决方案...

企业网站建设你问我答...

pop3服务器

10款常用Java测试工具...

开发设计模式——asp....

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

添加时间：[2008-9-22 14:22:46] 

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

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

public class admin
   {
     /**//// <summary>
     /// 用这个保存所有收到的数据
     /// </summary>
     public ilist<string> messagelist
     { get; set; }
     public admin(monitor monitor)
     {
         messagelist = new list<string>();
         monitor.datain += new eventhandler< dataeventargs>(recivemessage);
     }
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     private void recivemessage(object sender, dataeventargs e)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]         
messagelist.add(e.message);
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
     }
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]
   }
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]

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

分析：我们碰到的问题

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

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

[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
private static monitor _instance = null;
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]public static 
monitor current
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   get 
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]   
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     if (_instance == null)
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
       _instance = new monitor();
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     return _instance;
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
   }
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]}

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

[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
public static monitor current
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]     
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
         get 
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
         [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]           
object o = new object();
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
           if (_instance == null)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
           [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]             
lock (o)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
             [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]                 
if (_instance == null)
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
                   _instance = new monitor();
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
             }
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
           }
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]           
return _instance;
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
         }
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]
     }
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]

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

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

在管理页面上我放置一个“开始监视”的按钮，这个按钮使用ajax请求服务器端的一个httphandler，在handler的processrequest方法里这样来做： 

[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
admin admin = context.session["monitor_listener"] as admin;
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
if(admin == null)
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   admin = new admin(monitor.current);
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.session["monitor_listener"] = admin;
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]}
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]

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

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

[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
public void processrequest(httpcontext context)
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]     
context.response.buffer = true;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]     
context.response.expiresabsolute = system.datetime.now.addseconds(-1);
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.response.expires = 0;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.response.cachecontrol = "no-cache";
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   admin admin = context.session["monitor_listener"] as admin;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   if (admin == null || admin.messagecollection == null ||
 admin.messagecollection.count <= 0)
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
return;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   string[] messages = new string[admin.messagecollection.count];
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
admin.messagecollection.copyto(messages, 0);
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   stringbuilder sb = new stringbuilder();
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
   for (int i = 0; i < messages.length; i++)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]   
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]     
sb.appendformat("<li>{0}</li>", messages);
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
   }
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
admin.messagecollection.clear();
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.session["monitor_listener"] = admin;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.response.write(sb);
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]   
context.response.flush();
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]}
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]

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

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

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

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

首先我进一步谈一下需求：

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

由于数据提交非常频繁，客户要求不允许频繁的数据库操作，所以我将数据保存在一个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);
    operatedatalist.add(data);
    if(operatedatalist.count > buffersize)
    {
        //将数据写入到数据库
        addtobase();
}
    monitordatalist.add(data);
}
}
//监视页面从这里获取数据
public class monitorhandler : ihttphandler
{
  //……
  public void processrequest(httpcontext context)
  {
    if(monitordatalist.count > 0)
    {
        //将monitordatalist里的数据response出去
        output();
        monitordatalist.clear();
}
}
}

说实话，我当初做出这个的时候觉得一点问题都没有，开始的时候客户测试也没有发现任何问题，终于有一天客户和我同时测试部署在同一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上，不过我又有了新的看法了。不是要将数据先缓存么？看看这个缓存，实际上她也是个观察者，至于她执行怎样的缓存策略是她的事情，如是我又有了一个新类： 

//这里的代码接上篇post
using system;
using system.collections.generic;
using system.text;
namespace foryoursoft.nettraffic.framework
{
  public sealed class database
  {
    private ilist<string> _buffer = new list<string>();
    private static database _instance = null;
    public static void subscribe()
    {
        if (_instance == null)
          _instance = new database(monitor.current);
    }
    public database(monitor monitor)
    {
  monitor.onmessage += new eventhandler<monitor.messageeventargs>(monitor_onmessage);
    }
    void monitor_onmessage(object sender, monitor.messageeventargs e)
    {
        _buffer.add(e.message);
        if (_buffer.count >= config.buffersize)
        {
          //将数据添加到数据库
        }
    }
  }
}

ps:由于系统中我们只需要这样唯一一个订阅者，所以我将其实现为一个单件，在application_start的时候调用database.subscribe()。

现在系统是这样的结构：

[img]/admin/UploadFile/NewFile/2008922142516567.jpg[/img]

可以设想以后还会有更多的订阅者。果然，昨天客户要求在下一个版本中管理员分角色，各个角色看到的数据不同的，只有超级管理员才可以监视所有数据，omg，呵呵，不过还好，我只需要添加几个订阅者就可以轻松搞定。

后记：也许是我的文章标题没有起好，也许很多人得到模式恐惧症，提到模式总是要来考察一下你的case，不是那种enterprise级别的用了pattern就是过火了。其实这篇文章的内容里没有一点模式的气息，只是用.net的event实现观察者模式的思想，我想如果合适，今天模式的投资，明天你会有收获的。

在.net里面我们有事件(event)，那就无需使用传统的观察者模式的模型了

那么我首先实现一个monitor类，这个类用来接收客户端传递来的数据并将数据广播出去 

[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
public class dataeventargs : eventargs
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
         public string message
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
         [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{get;set;}
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
         public dataeventargs(string message)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
         [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]           
this.message = message;
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
         }
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]
     }
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]
public class monitor
[img]/upfile/2008-09/2008-09-12/20080912235203930.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235203125.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{ 
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     public event eventhandler<dataeventargs> datain;
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     private void senddata(string message)

[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]     
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
         if (datain != null)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
         [img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]           
dataeventargs e = new dataeventargs(message);
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
           datain(this, e);
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
         }
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
     }
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]
     /**//// <summary>
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     /// 这个方法被一个httphandler调用，客户端向这个handler发送数据
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     /// 数据处理后作为字符串传递给该方法，该方法然后将数据广播出去
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     /// </summary>
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
     /// <param name="message">处理后的数据</param>
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
     public void recivedata(string message)
[img]/upfile/2008-09/2008-09-12/20080912235202890.gif[/img]
[img]/upfile/2008-09/2008-09-12/20080912235202921.gif[/img]     
[img]/upfile/2008-09/2008-09-12/20080912235202953.gif[/img]{
[img]/upfile/2008-09/2008-09-12/20080912235202781.gif[/img]
         senddata(message);
[img]/upfile/2008-09/2008-09-12/20080912235202984.gif[/img]
     }
[img]/upfile/2008-09/2008-09-12/20080912235203150.gif[/img]}
[img]/upfile/2008-09/2008-09-12/20080912235203620.gif[/img]

关于我们 | 付款方式 | 客户管理 | 友情链接 | 网站导航 | 在线地图


版权所有 2008 三易网络(洛阳)科技开发有限公司 京ICP备06012028号

服务热线：0371-63653120 63658758（郑州） 0379-63921200   63265368（洛阳）

QQ在线客服： JSP空间咨询   JSP空间咨询    Email：web@suneasy.cn

郑州网络公司 郑州网站建设 洛阳网站建设

总部地址：纱厂南路41号中泰新城泰福苑803室 郑州分公司地址：金水区圣菲城