346
WCF后续之旅（8）：通过WCF Extension 实现与MS Enterprise Library Policy Injection Application Block 的集成
在上一篇文章中，我们通过自定义InstanceProvider实现了WCF和微软Enterprise Library Unity Application Block的集成， 今天我们已相同的方式实现WCF与Enterprise Library的另一个Application Block的集成：Policy Injection Application Block (PIAB)。
一、创建基于PolicyInjection的InstanceProvider
1: namespace Artech.WCFExtensions
2: {
3: public class PolicyInjectionInstanceProvider : IInstanceProvider
4: {
5: private Type _serviceContractType;
6: private string _policyInjectorName;
7:
8: public PolicyInjectionInstanceProvider(Type serviceContractType, string policyInjectorName)
9: {
10: this._serviceContractType = serviceContractType;
11: this._policyInjectorName = policyInjectorName;
12: }
13: public object GetInstance(InstanceContext instanceContext, Message message)
14: {
15: PolicyInjector policyInjector = null;
16: if (string.IsNullOrEmpty(this._policyInjectorName))
17: {
18: policyInjector = new PolicyInjectorFactory().Create();
19: }
20: else
21: {
22: policyInjector = new PolicyInjectorFactory().Create(this._policyInjectorName);
23: }
24:
25: Type serviceType = instanceContext.Host.Description.ServiceType;
26: object serviceInstance = Activator.CreateInstance(serviceType);
27: if (!this._serviceContractType.IsInterface && !serviceType.IsMarshalByRef && policyInjector is RemotingPolicyInjector)
28: {
29: return serviceInstance;
30: }
31:
32: return policyInjector.Wrap(serviceInstance, this._serviceContractType);
33: }
34:
35: public object GetInstance(InstanceContext instanceContext)
36: {
37: return this.GetInstance(instanceContext, null);
38: }
39:
40: public void ReleaseInstance(InstanceContext instanceContext, object instance)
41: {
42: IDisposable disposable = instance as IDisposable;
43: if (disposable != null)
44: {
45: disposable.Dispose();
46: }
47: }
48: }
49: }
1: PolicyInjector policyInjector = null;
2: if (string.IsNullOrEmpty(this._policyInjectorName))
3: {
4: policyInjector = new PolicyInjectorFactory().Create();
5: }
6: else
7: {
8: policyInjector = new PolicyInjectorFactory().Create(this._policyInjectorName);
9: }
1: Type serviceType = instanceContext.Host.Description.ServiceType;
2: object serviceInstance = Activator.CreateInstance(serviceType);
3: if (!this._serviceContractType.IsInterface && !serviceType.IsMarshalByRef && policyInjector is RemotingPolicyInjector)
4: {
5: return serviceInstance;
6: }
1: return policyInjector.Wrap(serviceInstance, this._serviceContractType);
二、为PolicyInjectionInstanceProvider创建Behavior
I、ContractBehavior：PolicyInjectionBehaviorAttribute
1: namespace Artech.WCFExtensions
2: {
3: public class PolicyInjectionBehaviorAttribute : Attribute, IContractBehavior
4: {
5: public string PolicyInjectorName{ get; set; }
6: public void AddBindingParameters(ContractDescription contractDescription, ServiceEndpoint endpoint, BindingParameterCollection bindingParameters){ }
7: public void ApplyClientBehavior(ContractDescription contractDescription, ServiceEndpoint endpoint, ClientRuntime clientRuntime){ }
8: public void ApplyDispatchBehavior(ContractDescription contractDescription, ServiceEndpoint endpoint, DispatchRuntime dispatchRuntime)
9: {
10: Type serviceContractType = contractDescription.ContractType;
11: dispatchRuntime.InstanceProvider = new PolicyInjectionInstanceProvider(serviceContractType, this.PolicyInjectorName);
12: }
13: public void Validate(ContractDescription contractDescription, ServiceEndpoint endpoint){
14: }
15: }
1: namespace Artech.WCFExtensions
2: {
3: public class PolicyInjectionBehavior : IEndpointBehavior
4: {
5: private string _policyInjectorName;
6: public PolicyInjectionBehavior(string policyInjectorName)
7: {
8: this._policyInjectorName = policyInjectorName;
9: }
10: public void AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters){ }
11: public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime){ }
12: public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
13: {
14: Type serviceContractType = endpoint.Contract.ContractType;
15: endpointDispatcher.DispatchRuntime.InstanceProvider = new PolicyInjectionInstanceProvider(serviceContractType, this._policyInjectorName);
16: }
17: public void Validate(ServiceEndpoint endpoint){ }
18: }
19: }
1: namespace Artech.WCFExtensions
2: {
3: public class PolicyInjectionBehaviorElement:BehaviorExtensionElement
4: {
5: [ConfigurationProperty("policyInjectorName",IsRequired = false, DefaultValue = "")]
6: public string PolicyInjectorName
7: {
8: get
9: {
10: return this["policyInjectorName"] as string;
11: }
12: set
13: {
14: this["policyInjectorName"] = value;
15: }
16: }
17:
18: public override Type BehaviorType
19: {
20: get { return typeof(PolicyInjectionBehavior); }
21: }
22:
23: protected override object CreateBehavior()
24: {
25: return new PolicyInjectionBehavior(this.PolicyInjectorName);
26: }
27: }
28: }
29:
三、应用我们的PolicyInjectionBehavior
I、Artech.TimeService.Contract
1: namespace Artech.TimeService.Contract
2: {
3: [ServiceContract]
4: [PolicyInjectionBehavior]
5: public interface ITime
6: {
7: [OperationContract]
8: DateTime GetCurrentTime();
9: }
10: }
II、Artech.TimeService.Service
1: namespace Artech.TimeService.Service
2: {
3: public class TimeService:ITime
4: {
5: [CachingCallHandler]
6: public DateTime GetCurrentTime()
7: {
8: return DateTime.Now;
9: }
10: }
11: }
III、Artech.TimeService.Hosting
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <services>
5: <service name="Artech.TimeService.Service.TimeService">
6: <endpoint behaviorConfiguration="" binding="basicHttpBinding"
7: contract="Artech.TimeService.Contract.ITime" />
8: <host>
9: <baseAddresses>
10: <add baseAddress="https://127.0.0.1/timeservice" />
11: </baseAddresses>
12: </host>
13: </service>
14: </services>
15: </system.serviceModel>
16: </configuration>
1: namespace Artech.TimeService.Hosting
2: {
3: class Program
4: {
5: static void Main(string[] args)
6: {
7: using (ServiceHost host = new ServiceHost(typeof(Artech.TimeService.Service.TimeService)))
8: {
9: host.Opened += delegate
10: {
11: Console.WriteLine("Time service has been started up!");
12: };
13: host.Open();
14:
15: Console.Read();
16: }
17: }
18: }
19: }
20:
IV、Artech.TimeService.Client
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <client>
5: <endpoint address="https://127.0.0.1/timeservice" binding="basicHttpBinding"
6: contract="Artech.TimeService.Contract.ITime" name="timeservice" />
7: </client>
8: </system.serviceModel>
9: </configuration>
1: namespace Artech.TimeService.Client
2: {
3: class Program
4: {
5: static void Main(string[] args)
6: {
7: using (ChannelFactory<ITime> channelFactory = new ChannelFactory<ITime>("timeservice"))
8: {
9: ITime proxy = channelFactory.CreateChannel();
10:
11: for (int i = 0; i < 10; i++)
12: {
13: Console.WriteLine(proxy.GetCurrentTime());
14: Thread.Sleep(1000);
15: }
16: }
17:
18: Console.Read();
19: }
20: }
21: }
22:
1: namespace Artech.TimeService.Contract
2: {
3: [ServiceContract]
4: //[PolicyInjectionBehavior]
5: public interface ITime
6: {
7: [OperationContract]
8: DateTime GetCurrentTime();
9: }
10: }
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <behaviors>
5: <endpointBehaviors>
6: <behavior name="PolicyInjectionBehavior">
7: <PolicyInjectionBehaviorExtension />
8: </behavior>
9: </endpointBehaviors>
10: </behaviors>
11: <extensions>
12: <behaviorExtensions>
13: <add name="PolicyInjectionBehaviorExtension" type="Artech.WCFExtensions.PolicyInjectionBehaviorElement, Artech.WCFExtensions, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null" />
14: </behaviorExtensions>
15: </extensions>
16: <services>
17: <service name="Artech.TimeService.Service.TimeService">
18: <endpoint behaviorConfiguration="PolicyInjectionBehavior" binding="basicHttpBinding"
19: contract="Artech.TimeService.Contract.ITime" />
20: <host>
21: <baseAddresses>
22: <add baseAddress="https://127.0.0.1/timeservice" />
23: </baseAddresses>
24: </host>
25: </service>
26: </services>
27: </system.serviceModel>
28: </configuration>
WCF后续之旅：
WCF后续之旅(1): WCF是如何通过Binding进行通信的
WCF后续之旅(2): 如何对Channel Layer进行扩展——创建自定义Channel
WCF后续之旅(3): WCF Service Mode Layer 的中枢—Dispatcher
WCF后续之旅(4)：WCF Extension Point 概览
WCF后续之旅(5): 通过WCF Extension实现Localization
WCF后续之旅(6): 通过WCF Extension实现Context信息的传递
WCF后续之旅(7)：通过WCF Extension实现和Enterprise Library Unity Container的集成
WCF后续之旅(8)：通过WCF Extension 实现与MS Enterprise Library Policy Injection Application Block 的集成
WCF后续之旅(9)：通过WCF的双向通信实现Session管理[Part I]
WCF后续之旅(9): 通过WCF双向通信实现Session管理[Part II]
WCF后续之旅(10): 通过WCF Extension实现以对象池的方式创建Service Instance
WCF后续之旅(11): 关于并发、回调的线程关联性（Thread Affinity）
WCF后续之旅(12): 线程关联性（Thread Affinity）对WCF并发访问的影响
WCF后续之旅(13): 创建一个简单的WCF SOAP Message拦截、转发工具[上篇]
WCF后续之旅(13)：创建一个简单的SOAP Message拦截、转发工具[下篇]
WCF后续之旅(14)：TCP端口共享
WCF后续之旅(15): 逻辑地址和物理地址
WCF后续之旅(16): 消息是如何分发到Endpoint的--消息筛选(Message Filter)
WCF后续之旅(17)：通过tcpTracer进行消息的路由
作者：蒋金楠
微信公众账号：大内老A
微博：www.weibo.com/artech
如果你想及时得到个人撰写文章以及着作的消息推送，或者想看看个人推荐的技术资料，可以扫描左边二维码（或者长按识别二维码）关注个人公众号（原来公众帐号蒋金楠的自媒体将会停用）。
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
微信公众账号：大内老A
微博：www.weibo.com/artech
如果你想及时得到个人撰写文章以及着作的消息推送，或者想看看个人推荐的技术资料，可以扫描左边二维码（或者长按识别二维码）关注个人公众号（原来公众帐号蒋金楠的自媒体将会停用）。
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
最后更新：2017-10-30 17:04:47