1 /// <summary>
2 /// 继承自ChannelFactory实现自主创建信道工厂，在绑定元素中的创建信道工厂使用
3 /// </summary>
4 /// <typeparam name="TChannel"></typeparam>
5   class MyChannelFactory<TChannel>: ChannelFactoryBase<IRequestChannel>
6 {
7 IChannelFactory<TChannel> innerChannelFactory = null;
8
9 /// <summary>
10 /// 为内部创建的变量信道工厂初始化，使用绑定元素
11 /// </summary>
12 /// <param name="bindingElement"></param>
13 /// <param name="context"></param>
14   public MyChannelFactory(MyBindingElement bindingElement, BindingContext context) : base(context.Binding)
15 {

17 this.innerChannelFactory = context.BuildInnerChannelFactory<TChannel>();
18 if (this.innerChannelFactory == null)
19 {
20 throw new InvalidOperationException("MyCustomChannelFactory requires an inner IChannelFactory.");
21 }
22 }
23
24 //创建请求信道，请求信道基于创建的内部信道工厂
25 protected override IRequestChannel OnCreateChannel(System.ServiceModel.EndpointAddress address, Uri via)
26 {

28 IRequestChannel innerChannel = (IRequestChannel)this.innerChannelFactory.CreateChannel(address, via);
29 return new MyCustomRequestChannel(innerChannel);
30
31 }
32
33 protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state)
34 {
35 throw new Exception("The method or operation is not implemented.");
36 }
37
38 protected override void OnEndOpen(IAsyncResult result)
39 {
40 throw new Exception("The method or operation is not implemented.");
41 }
42
43 protected override void OnOpen(TimeSpan timeout)
44 {

46 this.innerChannelFactory.Open(timeout);
47 }
48

1 namespace Extensibility
2 {
3 class MyChannelListener<TChannel>: ChannelListenerBase<IReplyChannel> where TChannel: class, IChannel
4 {
5 IChannelListener<TChannel> innerChannelListener = null;
6
7 //创建内部监听信道，又传递过来的绑定上下文创建
8 public MyChannelListener(MyCustomBindingElement bindingElement, BindingContext context)
9 : base(context.Binding)
10 {

12 this.innerChannelListener = context.BuildInnerChannelListener<TChannel>();
13 if (this.innerChannelListener == null)
14 {
15 throw new InvalidOperationException("MyCustomChannelListener requires an inner IChannelFactory.");
16 }
17
18 }
19
20
21
22
23 protected override IReplyChannel OnAcceptChannel(TimeSpan timeout)
24 {
25 throw new Exception("The method or operation is not implemented.");
26 }
27
28 protected override IAsyncResult OnBeginAcceptChannel(TimeSpan timeout, AsyncCallback callback, object state)
29 {
31 return this.innerChannelListener.BeginAcceptChannel(timeout, callback, state);
32 }
33
34 //接受信道
35 protected override IReplyChannel OnEndAcceptChannel(IAsyncResult result)
36 {
38 IReplyChannel replyChannel = ((IReplyChannel)this.innerChannelListener.EndAcceptChannel(result));
39 if (replyChannel == null)
40 {
41 return null;
42 }
43 return new MyCustomReplyChannel(replyChannel);
44 }
45
46 protected override IAsyncResult OnBeginWaitForChannel(TimeSpan timeout, AsyncCallback callback, object state)
47 {
48 throw new Exception("The method or operation is not implemented.");
49 }
50
51 protected override bool OnEndWaitForChannel(IAsyncResult result)
52 {
53 throw new Exception("The method or operation is not implemented.");
54 }
55
56 protected override bool OnWaitForChannel(TimeSpan timeout)
57 {
58 throw new Exception("The method or operation is not implemented.");
59 }
60
61 public override Uri Uri
62 {
63 get
64 {
66 return this.innerChannelListener.Uri;
67 }
68 }
69
70 protected override void OnAbort()
71 {
72 throw new Exception("The method or operation is not implemented.");
73 }
74
75 protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state)
76 {
77 throw new Exception("The method or operation is not implemented.");
78 }
79
80 protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state)
81 {
82 throw new Exception("The method or operation is not implemented.");
83 }
84
85 protected override void OnClose(TimeSpan timeout)
86 {

88 this.innerChannelListener.Close(timeout);
89 }
90
91 protected override void OnEndClose(IAsyncResult result)
92 {
93 throw new Exception("The method or operation is not implemented.");
94 }
95
96 protected override void OnEndOpen(IAsyncResult result)
97 {
98 throw new Exception("The method or operation is not implemented.");
99 }
100
101 protected override void OnOpen(TimeSpan timeout)
102 {
104 this.innerChannelListener.Open(timeout);
105
106 }
107 }
108 }
109