我找到了适合我的解决方案。在IClientMessageInspector 的实现中,我创建了CorrelationObject 类:
class CorrelationObject
{
public string RequestFileName { get; set; }
public string ResponseFileName { get; set; }
}
然后在BeforeSendRequest 中生成具有相同 ID 作为前缀的唯一名称,并将该关联对象存储在请求属性中:
public object BeforeSendRequest(ref Message request, IClientChannel channel)
{
var id = Guid.NewGuid();
var correlationObject = new CorrelationObject
{
RequestFileName = $"{id:N}_request.xml",
ResponseFileName = $"{id:N}_response.xml"
};
request.Properties.Add("CorrelationObject", correlationObject);
return correlationObject;
}
之后,WCF 将我的请求传递给消息编码器
public override ArraySegment<byte> WriteMessage(Message message,
int maxMessageSize, BufferManager bufferManager, int messageOffset)
{
// encoding and signing
var encodedMessage = string.Empty;
var correaltionObject = (CorrelationObject) message.Properties["CorrelationObject"];
File.WriteAllText(correaltionObject.RequestFileName, encodedMessage);
}
此时我保存了我的请求。为了保存响应,在消息编码器中我做了以下操作:
public override Message ReadMessage(ArraySegment<byte> buffer,
BufferManager bufferManager, string contentType)
{
var content = Encoding.UTF8.GetString(buffer.ToArray());
var response = innerEncoder.ReadMessage(buffer, bufferManager, contentType);
response.Properties.Add("RawMessage", content);
// some other staff here..
}
现在 WCF 在我的消息检查器中调用 AfterReceiveReply
public void AfterReceiveReply(ref Message reply, object correlationState)
{
var correlationObject = (CorrelationObject) correlationState;
File.WriteAllText(correlationObject.ResponseFileName,
reply.Properties["RawMessage"].ToString());
}
现在,两个文件都以相同的前缀保存。