以下の OperationContract を持つメソッドを持つクラスであることに慣れていない人のために、私は一般的な WCF プロキシを持っています。
[OperationContract(Action = "*", ReplyAction = "*")]
void Proxy(Message requestMessage);
最近明らかになった要件の 1 つは、IPAddress 型の Message 内のすべてのプロパティを、要求メッセージを提供した IPAddress 値に置き換える必要があるということです。
つまり、次のようなものです。
public void Proxy(Message requestMessage)
{
try
{
// Client IP address, not currently used!
IPAddress clientIP = IPAddress.Parse((requestMessage
.Properties[RemoteEndpointMessageProperty.Name]
as RemoteEndpointMessageProperty).Address);
var factory = new ChannelFactory<IDmzProxy>("client");
IDmzProxy dmzProxy = factory.CreateChannel();
dmzProxy.Proxy(requestMessage);
factory.Close();
}
// No leakage of data! Any exceptions still return void!
catch (Exception exception)
{
Log.Fatal(
"Exception occurred on proxying the request",
exception);
return;
}
}
問題は、IPAddress タイプの requestMessage の要素を、取得した clientIP に設定する方法です。
編集 1
私が試して失敗したこと、
requestMessage.GetBodyAttribute("ipAddress", "http://schemas.datacontract.org/2004/07/System.Net")
編集 2
1 つの方法は、MessageBody の XML を置き換えているようです。私にはやり過ぎのように思えます (WCF のポイントは何ですか?)。
また、MessageBody は要素名ではなく属性名で要素を照合する必要があるため、特に簡単ではありません。
<ipAddress xmlns:a="http://schemas.datacontract.org/2004/07/System.Net" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">
<a:m_Address>3772007081</a:m_Address>
<a:m_Family>InterNetwork</a:m_Family>
<a:m_HashCode>0</a:m_HashCode>
<a:m_Numbers xmlns:b="http://schemas.microsoft.com/2003/10/Serialization/Arrays">
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
<b:unsignedShort>0</b:unsignedShort>
</a:m_Numbers>
<a:m_ScopeId>0</a:m_ScopeId>
</ipAddress>
編集 3
確かに重複ではありません。これは大まかに機能しているものであり、私が求めているノードを置き換えるためにまだいくつかの作業が必要です。
public void Proxy(Message requestMessage)
{
try
{
Log.Info("Received request");
requestMessage = SourceNATMessage(requestMessage);
// Check if there is an accepted action we have to catch
// If the Accepted Action is set, and the action is not the same
// then just return);)
if (!String.IsNullOrEmpty(AcceptedAction) &&
!requestMessage.Headers.Action.EndsWith(AcceptedAction))
{
Log.WarnFormat(
"Invalid request received with the following action {0}\n" +
"expected action ending with {1}",
requestMessage.Headers.Action,
AcceptedAction);
return;
}
// otherwise, let's proxy the request
Log.Debug("Proceeding with forwarding the request");
var factory = new ChannelFactory<IDmzProxy>("client");
IDmzProxy dmzProxy = factory.CreateChannel();
dmzProxy.Proxy(requestMessage);
factory.Close();
}
// No leakage of data! Any exceptions still return void!
catch (Exception exception)
{
Log.Fatal(
"Exception occurred on proxying the request",
exception);
return;
}
}
private static Message SourceNATMessage(Message message)
{
IPAddress clientIp =
IPAddress.Parse(
((RemoteEndpointMessageProperty)
message.Properties[
RemoteEndpointMessageProperty.Name]).Address);
Log.DebugFormat("Retrieved client IP address {0}", clientIp);
var stringBuilder = new StringBuilder();
XDocument document;
using (XmlWriter writer = XmlWriter.Create(stringBuilder))
{
message.WriteBody(writer);
writer.Flush();
document = XDocument.Parse(stringBuilder.ToString());
}
var deserializer = new DataContractSerializer(typeof(IPAddress));
foreach (XElement element in
from element in document.DescendantNodes().OfType<XElement>()
let aNameSpace = element.GetNamespaceOfPrefix("a")
let iNameSpace = element.GetNamespaceOfPrefix("i")
where
aNameSpace != null &&
aNameSpace.NamespaceName.Equals(SystemNetNameSpace) &&
iNameSpace != null &&
iNameSpace.NamespaceName.Equals(XmlSchemaNameSpace) &&
deserializer.ReadObject(element.CreateReader(), false) is IPAddress
select element)
{
element.ReplaceWith(new XElement(element.Name, deserializer.WriteObject());
}
return Message.CreateMessage(message.Version,
message.Headers.Action,
document.CreateReader());
}
編集 4
興味のある人のための作業コードは、質問が閉じられているため、回答として投稿できません。
private static Message SourceNatMessage(Message message)
{
IPAddress clientIp =
IPAddress.Parse(
((RemoteEndpointMessageProperty)
message.Properties[
RemoteEndpointMessageProperty.Name]).Address);
Log.DebugFormat("Retrieved client IP address {0}", clientIp);
var stringBuilder = new StringBuilder();
XDocument document;
using (XmlWriter writer = XmlWriter.Create(stringBuilder))
using (XmlDictionaryWriter dictionaryWriter =
XmlDictionaryWriter.CreateDictionaryWriter(writer))
{
message.WriteBodyContents(dictionaryWriter);
dictionaryWriter.Flush();
document = XDocument.Parse(stringBuilder.ToString());
}
var deserializer = new DataContractSerializer(typeof(IPAddress));
var clientIpXml = new StringBuilder();
using (var xmlWriter = XmlWriter.Create(clientIpXml))
{
deserializer.WriteObject(xmlWriter, clientIp);
xmlWriter.Flush();
}
var clientElement = XElement.Parse(clientIpXml.ToString());
foreach (XElement element in
from element in document.DescendantNodes().OfType<XElement>()
let aNameSpace = element.GetNamespaceOfPrefix("a")
let iNameSpace = element.GetNamespaceOfPrefix("i")
where
aNameSpace != null &&
aNameSpace.NamespaceName.Equals(SystemNetNameSpace) &&
iNameSpace != null &&
iNameSpace.NamespaceName.Equals(XmlSchemaNameSpace) &&
element.NodeType == XmlNodeType.Element
select element)
{
try
{
deserializer.ReadObject(element.CreateReader(), false);
element.ReplaceNodes(clientElement);
}
catch (SerializationException) { }
}
Message sourceNatMessage = Message.CreateMessage(message.Version,
null,
document.CreateReader());
sourceNatMessage.Headers.CopyHeadersFrom(message);
sourceNatMessage.Properties.CopyProperties(message.Properties);
return sourceNatMessage;
}