以下代码实现利用ServerContextSink来实现多截获
//框架代码
//ObjectWithAspect.cs
using System;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Framework
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
[ObjectSinkChain]
public abstract class ObjectWithAspects:ContextBoundObject
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
}
}
![](/Images/OutliningIndicators/None.gif)
//ServerContextSinkChainProperty.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Framework
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
[Serializable]
class ServerContextSinkChainProperty:
IContextProperty,
//IContributeObjectSink, //如果不需捕获构造函数,则可使用ObjectSink
IContributeServerContextSink //如果构造函数也要捕获,则使用ServerContextSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
string _name;
Type _type;
![](/Images/OutliningIndicators/InBlock.gif)
public ServerContextSinkChainProperty(Type type,string name)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
_name = name;
_type = type;
}
![](/Images/OutliningIndicators/InBlock.gif)
private AspectAttribute[] GetAspectAttributes(Type type)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return (AspectAttribute[])_type.GetCustomAttributes(typeof(AspectAttribute), true);
}
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IContextProperty 成员#region IContextProperty 成员
![](/Images/OutliningIndicators/InBlock.gif)
public void Freeze(Context newContext)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
}
![](/Images/OutliningIndicators/InBlock.gif)
public bool IsNewContextOK(Context newCtx)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return true;
}
![](/Images/OutliningIndicators/InBlock.gif)
public string Name
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
get
{ return _name; }
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IContributeObjectSink 成员#region IContributeObjectSink 成员
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageSink GetObjectSink(MarshalByRefObject obj, IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
![](/Images/OutliningIndicators/InBlock.gif)
AspectAttribute[] sinks = GetAspectAttributes(_type);
for (int i = 0; i < sinks.Length; i++ )
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
AspectAttribute aspectAttribute = sinks[i];
nextSink = aspectAttribute.CreateAspectSink(nextSink);
}
return nextSink;
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IContributeServerContextSink 成员#region IContributeServerContextSink 成员
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageSink GetServerContextSink(IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
AspectAttribute[] sinks = GetAspectAttributes(_type);
for (int i = 0; i < sinks.Length; i++)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
AspectAttribute aspectAttribute = sinks[i];
nextSink = aspectAttribute.CreateAspectSink(nextSink);
}
return nextSink;
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
}
}
![](/Images/OutliningIndicators/None.gif)
//ServerContextSinkChainAttribute.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Framework
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
[AttributeUsage(AttributeTargets.Class)]
class ObjectSinkChainAttribute:ContextAttribute
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public ObjectSinkChainAttribute()
: base("ServerContextSink_Framework_ObjectSinkChainAttribute")
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
}
![](/Images/OutliningIndicators/InBlock.gif)
public override void GetPropertiesForNewContext(IConstructionCallMessage ctorMsg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Type type = ctorMsg.ActivationType;
ctorMsg.ContextProperties.Add(new ServerContextSinkChainProperty(type,this.AttributeName));
}
public override bool IsContextOK(Context ctx, IConstructionCallMessage ctorMsg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return (ctx.GetProperty(this.AttributeName) != null );
}
}
}
![](/Images/OutliningIndicators/None.gif)
//AsyncReplyHelperSink.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
![](/Images/OutliningIndicators/None.gif)
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Framework
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
class AsyncReplyHelperSink : IMessageSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public delegate IMessage AsyncReplyHelperSinkDelegate(IMessage msg);
![](/Images/OutliningIndicators/InBlock.gif)
IMessageSink _nextSink = null;
AsyncReplyHelperSinkDelegate _delegate = null;
![](/Images/OutliningIndicators/InBlock.gif)
public AsyncReplyHelperSink(IMessageSink nextSink, AsyncReplyHelperSinkDelegate delegates)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
_nextSink = nextSink;
_delegate = delegates;
}
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IMessageSink 成员#region IMessageSink 成员
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageCtrl AsyncProcessMessage(IMessage msg, IMessageSink replySink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return null;
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageSink NextSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
get
{ return _nextSink; }
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessage SyncProcessMessage(IMessage msg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
if (_delegate == null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return new ReturnMessage(new Exception("没有处理消息委拖"), (IMethodCallMessage)msg);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
IMessage back = _delegate(msg);
return _nextSink.SyncProcessMessage(back);
}
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
}
}
![](/Images/OutliningIndicators/None.gif)
//AspectAttribute.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Framework
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
public abstract class AspectAttribute:Attribute
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public abstract IMessageSink CreateAspectSink(IMessageSink nextSink);
}
}
![](/Images/OutliningIndicators/None.gif)
//Demo代码
//Program.cs
using System;
![](/Images/OutliningIndicators/None.gif)
using DotNetAOP.ServerContextSink.Framework;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Demo
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
/**//// <summary>
/// Class1 的摘要说明。
/// </summary>
class Program
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
/**//// <summary>
/// 应用程序的主入口点。
/// </summary>
[STAThread]
static void Main(string[] args)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Calculator calc = new Calculator();
Console.WriteLine(calc.Add(1,2));
Console.WriteLine(calc.Divide(2,0));
// Test2 t2 = new Test2();
// t2.Te();
Console.ReadLine();
}
}
}
![](/Images/OutliningIndicators/None.gif)
//LogSinkAttribute.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
using DotNetAOP.ServerContextSink.Framework;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Demo
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
[AttributeUsage(AttributeTargets.Class)]
public class LogSinkAttribute:AspectAttribute
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public override IMessageSink CreateAspectSink(IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return new LogSink(nextSink);
}
![](/Images/OutliningIndicators/InBlock.gif)
}
}
![](/Images/OutliningIndicators/None.gif)
//LogSink.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
using DotNetAOP.ServerContextSink.Framework;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Demo
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
public class LogSink:IMessageSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
readonly IMessageSink _nextSink;
public LogSink(IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
_nextSink = nextSink;
}
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IMessageSink 成员#region IMessageSink 成员
![](/Images/OutliningIndicators/InBlock.gif)
public IMessage SyncProcessMessage(IMessage msg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
IMethodCallMessage call = msg as IMethodCallMessage;
IConstructionCallMessage ctr = call as IConstructionCallMessage;
![](/Images/OutliningIndicators/InBlock.gif)
IMethodReturnMessage back = null;
if(ctr != null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("构造函数:\t"+ctr.MethodName);
back = (IMethodReturnMessage)NextSink.SyncProcessMessage(msg);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("普通方法:\t" + call.MethodName);
back = (IMethodReturnMessage)NextSink.SyncProcessMessage(msg);
bool exception = false;
if(back.ReturnValue is double)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
if(double.IsInfinity((double)back.ReturnValue))
exception = true;
}
if( !exception)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
exception = (back.Exception != null);
}
if(!exception)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("返回结果为:"+back.ReturnValue);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("出现异常了:\t"+back.ReturnValue);
back = new ReturnMessage(1.0,null,0,back.LogicalCallContext,call);
}
}
return back;
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageSink NextSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
get
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return _nextSink;
}
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageCtrl AsyncProcessMessage(IMessage msg, IMessageSink replySink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
AsyncReplyHelperSink.AsyncReplyHelperSinkDelegate asd = new AsyncReplyHelperSink.AsyncReplyHelperSinkDelegate(AsyncProcessMessage);
![](/Images/OutliningIndicators/InBlock.gif)
replySink = new AsyncReplyHelperSink(replySink, asd);
![](/Images/OutliningIndicators/InBlock.gif)
if (_nextSink != null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return _nextSink.AsyncProcessMessage(msg, replySink);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return null;
}
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
![](/Images/OutliningIndicators/InBlock.gif)
private IMessage AsyncProcessMessage(IMessage msg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
IMethodCallMessage call = msg as IMethodCallMessage;
IConstructionCallMessage ctr = call as IConstructionCallMessage;
if (ctr != null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("构造函数:\t" + ctr.MethodName);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("普通方法:\t" + call.MethodName);
}
return msg;
![](/Images/OutliningIndicators/InBlock.gif)
}
}
}
![](/Images/OutliningIndicators/None.gif)
//Log2Sink.cs
using System;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Activation;
using System.Runtime.Remoting.Contexts;
using System.Runtime.Remoting.Messaging;
using System.Runtime.Remoting.Proxies;
using System.Runtime.Remoting.Services;
![](/Images/OutliningIndicators/None.gif)
using DotNetAOP.ServerContextSink.Framework;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Demo
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
public class Log2Sink : IMessageSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
readonly IMessageSink _nextSink;
public Log2Sink(IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
_nextSink = nextSink;
}
![](/Images/OutliningIndicators/ContractedSubBlock.gif)
IMessageSink 成员#region IMessageSink 成员
![](/Images/OutliningIndicators/InBlock.gif)
public IMessage SyncProcessMessage(IMessage msg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
IMethodCallMessage call = msg as IMethodCallMessage;
IConstructionCallMessage ctr = call as IConstructionCallMessage;
![](/Images/OutliningIndicators/InBlock.gif)
IMethodReturnMessage back = null;
![](/Images/OutliningIndicators/InBlock.gif)
Console.WriteLine("第二个处理器");
![](/Images/OutliningIndicators/InBlock.gif)
back = (IMethodReturnMessage)NextSink.SyncProcessMessage(msg);
return back;
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageSink NextSink
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
get
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return _nextSink;
}
}
![](/Images/OutliningIndicators/InBlock.gif)
public IMessageCtrl AsyncProcessMessage(IMessage msg, IMessageSink replySink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
AsyncReplyHelperSink.AsyncReplyHelperSinkDelegate asd = new AsyncReplyHelperSink.AsyncReplyHelperSinkDelegate(AsyncProcessMessage);
![](/Images/OutliningIndicators/InBlock.gif)
replySink = new AsyncReplyHelperSink(replySink, asd);
![](/Images/OutliningIndicators/InBlock.gif)
if (_nextSink != null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return _nextSink.AsyncProcessMessage(msg, replySink);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return null;
}
}
![](/Images/OutliningIndicators/InBlock.gif)
#endregion
![](/Images/OutliningIndicators/InBlock.gif)
private IMessage AsyncProcessMessage(IMessage msg)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
IMethodCallMessage call = msg as IMethodCallMessage;
IConstructionCallMessage ctr = call as IConstructionCallMessage;
if (ctr != null)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("构造函数:\t" + ctr.MethodName);
}
else
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
Console.WriteLine("普通方法:\t" + call.MethodName);
}
return msg;
![](/Images/OutliningIndicators/InBlock.gif)
}
}
![](/Images/OutliningIndicators/InBlock.gif)
![](/Images/OutliningIndicators/InBlock.gif)
[AttributeUsage(AttributeTargets.Class)]
public class Log2SinkAttribute : AspectAttribute
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public override IMessageSink CreateAspectSink(IMessageSink nextSink)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return new Log2Sink(nextSink);
}
![](/Images/OutliningIndicators/InBlock.gif)
}
}
![](/Images/OutliningIndicators/None.gif)
//Calculator.cs
using System;
![](/Images/OutliningIndicators/None.gif)
using DotNetAOP.ServerContextSink.Framework;
![](/Images/OutliningIndicators/None.gif)
namespace DotNetAOP.ServerContextSink.Demo
![](/Images/OutliningIndicators/ExpandedBlockStart.gif)
![](/Images/OutliningIndicators/ContractedBlock.gif)
{
[LogSink,Log2Sink]
public class Calculator:ObjectWithAspects
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
public Calculator()
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
}
public double Add(double a , double b)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return a + b;
}
public double Divide(double a, double b)
![](/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
return a/b;
}
}
}
![](/Images/OutliningIndicators/None.gif)
需要上面完整代码请留下Email。
查看其它框架实现请转到此页
利用消息机制实现.NET AOP(面向方面编程)--通过RealProxy实现
利用消息机制实现.NET AOP(面向方面编程)--利用RealProxy和消息接收器实现多截获
利用消息机制实现.NET AOP(面向方面编程)--利用ServerContextSink实现多截获