我有一个为单例实例配置的WCF服务器。我的客户端作为参数传递给服务方法,一个实现IDisposable
接口的对象,服务器正在尝试缓存此实例,但是,在执行服务方法后的某个时刻,WCF运行时会自动处理该参数,过早地破坏我的缓存实例。
通过查看堆栈跟踪,我发现在Dispose()
方法中调用了参数的MessageRpc.DisposeParametersCore()
调用。
这是从here获取的该方法的参考源:
internal void DisposeParametersCore(bool excludeInput)
{
if (!this.ParametersDisposed)
{
if (!excludeInput)
{
this.DisposeParameterList(this.InputParameters);
}
this.DisposeParameterList(this.OutputParameters);
IDisposable disposableParameter = this.ReturnParameter as IDisposable;
if (disposableParameter != null)
{
try
{
disposableParameter.Dispose();
}
catch (Exception e)
{
if (Fx.IsFatal(e))
{
throw;
}
this.channelHandler.HandleError(e);
}
}
this.ParametersDisposed = true;
}
}
如您所见,输入参数的处理由bool参数excludeInput
控制,该参数提示我此行为是可选的。
我知道如果我缓存参数的深层副本,它将绕过这个问题,但有没有办法可以关闭特定WCF方法的这种自动行为?
这是我试图在服务器上缓存的对象类(用C ++ CLI编写):
[Serializable()]
public ref class OpaqueMediaType : ISerializable, IConcreteMediaType {
private:
static const Byte _version = 1;
private:
clr_scoped_ptr<CComPtrIMFMediaType> _ppMediaType;
protected:
virtual DMO_MEDIA_TYPE* __clrcall GetConcreteDMOMediaType() sealed
= IConcreteMediaType::GetConcreteDMOMediaType;
virtual CComPtrIMFMediaType __clrcall GetConcreteMFMediaType() sealed
= IConcreteMediaType::GetConcreteMFMediaType;
virtual void __clrcall FreeConcreteDMOMediaType(DMO_MEDIA_TYPE* pDMOMediaType) sealed
= IConcreteMediaType::FreeConcreteDMOMediaType;
protected:
OpaqueMediaType(SerializationInfo^ info, StreamingContext context);
public:
OpaqueMediaType(DMO_MEDIA_TYPE& dmoMediaType);
OpaqueMediaType(IMFMediaType* pMFMediaType);
OpaqueMediaType(PCM_MediaType pcmMediaType);
virtual void __clrcall GetObjectData(SerializationInfo^ info, StreamingContext context);
PCM_MediaType AsPCM();
};
_ppMediaType
成员获取CComPtr派生类指针的所有权,因此在释放实例时,将释放关联的COM对象。由于该成员是一次性的,因此IDisposable
类的OpaqueMediaType
接口由C ++ / CLI自动定义和实现。
以下是缓存对象的WCF方法:
Task IStorageBackendSvc.AcceptWmaMediaType(int stationId, OpaqueMediaType mediaType) {
try {
WmaWriter wmaWriter = GetWmaWriter(stationId);
wmaWriter.MediaType = mediaType; // parameter object is cached here (shallow copy)
return Task.CompletedTask;
} catch( Exception exception ) {
throw _faultFactory.Wrap(exception);
}
// the `mediaType` parameter is being disposed by WCF at some point AFTER calling this code, releasing the internal COM object held by the cached instance prematurely
}
使用OperationBehaviorAttribute.AutoDisposeParameters = false
来完成方法的实现(而不是合同)可以完成这项工作。
这是我的合同
[ServiceContract]
public interface IStorageBackendSvc {
...
[OperationContract]
[FaultContract(typeof(DescriptiveFault))]
Task AcceptWmaMediaType(int stationId, OpaqueMediaType mediaType);
}
这是实施:
[OperationBehavior(AutoDisposeParameters = false)]
Task IStorageBackendSvc.AcceptWmaMediaType(int stationId, OpaqueMediaType mediaType) {
try {
WmaWriter wmaWriter = GetWmaWriter(stationId);
wmaWriter.MediaType = mediaType;
return Task.CompletedTask;
} catch( Exception exception ) {
throw _faultFactory.Wrap(exception);
}
}
现在没有处理mediaType
参数,因此缓存的引用保持有效,我可以绕过执行参数的深层复制。
编辑:关于如何缓存对象的疑问,这里是代码:
private Dictionary<int, WmaWriter> _wmaWriters;
private WmaWriter GetWmaWriter(int stationId) {
WmaWriter wmaWriter;
lock( _wmaWriters ) {
if( !_wmaWriters.TryGetValue(stationId, out wmaWriter) ) {
wmaWriter = new WmaWriter(stationId, new DailyFileSplitter(), new WmaFileNameResolver(stationId));
_wmaWriters[stationId] = wmaWriter;
}
}
return wmaWriter;
}
_wmaWriters
是服务会员。它是一个字典,包含由电台ID键入的多个WMA编写器(我正在录制多个电视和广播电台).GetWmaWriter()
方法将返回与特定电台关联的现有WMA编写器,或者如果不存在则创建新的WMA编写器。缓存是有效的,因为对于同一站ID的多次调用,我将获得相同的WmaWriter实例。