关于C#观察者模式

xinggg22

直接贴代码吧，刚刚学C#没多久，不知道算不算是C#的观察者模式。。。各位多多指教啊！
    将那些错误挖出来。

1. class Subscriber
   
2.     {
   
3. 
   
4.         private Subject subject ;
   
5. 
   
6.         public Subject Subject
   
7.         {
   
8.             get { return this.subject; }
   
9.             set { this.subject = (Subject)value; }
   
10.         }
    
11. 
    
12.         public Subscriber()
    
13.         {
    
14.             subject = new Subject();
    
15.             this.Subject.Public +=new Subject.PublicerEventHandler(Subject_Public);
    
16.         }
    
17. 
    
18.         //事件处理方法
    
19.         private void Subject_Public(object sender, EventArgs e)
    
20.         {
    
21.             System.Console.WriteLine("订阅者事件被引发！");        
    
22.         }
    
23. 
    
24.     }

复制代码

1. 
   
2. class Publicer
   
3.     {
   
4.         public void observer(Object sender ,EventArgs e)
   
5.         {
   
6.             System.Console.WriteLine("---------observer start------------");
   
7.             Subscriber sub = new Subscriber();
   
8.             sub.Subject.PublicerEvent();      
   
9.         }
   
10.     }

复制代码

1. 
   
2. 
   
3. class Subject
   
4.     {
   
5. 
   
6.         public delegate void PublicerEventHandler(object sender , EventArgs e);
   
7. 
   
8.         public virtual event PublicerEventHandler Public;
   
9. 
   
10.         //委托的事件处理方法
    
11.         public  void PublicerEvent()
    
12.         {
    
13.             if(this.Public != null)
    
14.                 this.Public(this,EventArgs.Empty);
    
15.         }
    
16.     }

复制代码

dreamwalker

不熟悉C＃
不知delegate类型函数是否是C＃内部对Observer的支持？


MS，LZ写的不是Observer..

类写好了，有没有这样的调用：
增加监听者：
publiser.addListener(listener l);
发布事件：
publiser.publish(Event);


另名，觉得命名好像有点混乱。。
publisher有个Observer方法。。

xinggg22

1. public class EventGenerator {
   
2. 
   
3.     interface Listener {
   
4.         void notify(String reason);
   
5.     }
   
6. 
   
7.     private Publisher publisher = new Publisher();
   
8. 
   
9.     /**
   
10.      * 添加监听器
    
11.      *
    
12.      * @param l
    
13.      */
    
14.     public void addEventListener(Listener l) {
    
15.         publisher.subcribe(l);
    
16.     }
    
17. 
    
18.     public void removeEventListener(Listener l) {
    
19.         publisher.cancelSubcribe(l);
    
20.     }
    
21. 
    
22.     /**
    
23.      * 事件发生
    
24.      *
    
25.      * @param reason
    
26.      */
    
27.     public void someEventHappend(final String reason) {
    
28.         publisher.publish(new Publisher.Distributor() {
    
29.             @Override
    
30.             public void deliverTo(Object subcriber) {
    
31.                 ((Listener) subcriber).notify(reason);
    
32.             }
    
33.         });
    
34.     }
    
35. }

复制代码

1. public class Publisher {
   
2. 
   
3.     interface Distributor {
   
4.         void deliverTo(Object subcriber);
   
5.     }
   
6. 
   
7.     private class Node {
   
8.         public final Object subcriber;
   
9.         public Node next;
   
10. 
    
11.         public Node(Object subcriber, Node next) {
    
12.             this.subcriber = subcriber;
    
13.             this.next = next;
    
14.         }
    
15. 
    
16.         public Node remove(Object o) {
    
17.             if (o == subcriber) {
    
18.                 return next;
    
19.             }
    
20.             if (next == null) {
    
21.                 throw new NoSuchElementException(o.toString());
    
22.             }
    
23.             return new Node(subcriber, next.remove(o));
    
24.         }
    
25. 
    
26.         public void accept(Distributor dis) {
    
27.             dis.deliverTo(subcriber);
    
28.         }
    
29.     }
    
30. 
    
31.     public volatile Node subcribers = null;
    
32. 
    
33.     public void subcribe(Object subcriber) {
    
34.         // TODO 订阅
    
35.         subcribers = new Node(subcriber, subcribers);
    
36.     }
    
37. 
    
38.     public void cancelSubcribe(Object subcriber) {
    
39.         // TODO 取消订阅
    
40.         subcribers = subcribers.remove(subcriber);
    
41.     }
    
42. 
    
43.     public void publish(Distributor distributor) {
    
44.         for (Node cursor = subcribers; cursor != null; cursor = cursor.next) {
    
45.             cursor.accept(distributor);
    
46.         }
    
47.     }
    
48. }

复制代码

[ 本帖最后由 xinggg22 于 2008-4-25 18:01 编辑 ]