WCF 的一切都是围绕着 Message 进行&＃xff0c;那么 Message 究竟是什么样子&＃xff1f;
[ServiceContract]
public interface ICalculate
{
[OperationContract]
double Add(double a, double b);
}
public class CalculateService : ICalculate
{
public double Add(double a, double b)
{
Message msg &＃61; OperationContext.Current.RequestContext.RequestMessage;
Console.WriteLine(msg);
return a &＃43; b;
}
}
public class WcfTest
{
public static void Test()
{
AppDomain.CreateDomain("Server").DoCallBack(delegate
{
ServiceHost host &＃61; new ServiceHost(typeof(CalculateService));
host.AddServiceEndpoint(typeof(ICalculate), new BasicHttpBinding(),
"http://localhost:8080/calc");
host.Open();
});
ChannelFactory factory &＃61; new ChannelFactory(new BasicHttpBinding(),
"http://localhost:8080/calc");
ICalculate o &＃61; factory.CreateChannel();
Console.WriteLine(o.Add(1, 2));
}
}
输出
http://localhost:8080/calc
http://tempuri.org/ICalculate/Add
1
2
事实上我们可以直接基于 Message Layer 进行编程&＃xff0c;利用 OperationContract.Action 捕获特定 Action 的消息。
[ServiceContract]
public interface ICalculate
{
[OperationContract(Action &＃61; "Add", ReplyAction&＃61;"Add")]
Message ProcessMessage(Message m);
}
public class CalculateService : ICalculate
{
public Message ProcessMessage(Message m)
{
Data d &＃61; m.GetBody();
Console.WriteLine(d.I);
return Message.CreateMessage(MessageVersion.Soap11, "Add", new Data(9999));
}
}
[DataContract]
public class Data
{
[DataMember]
public int I;
public Data(int i)
{
this.I &＃61; i;
}
}
public class WcfTest
{
public static void Test()
{
AppDomain.CreateDomain("Server").DoCallBack(delegate
{
ServiceHost host &＃61; new ServiceHost(typeof(CalculateService));
host.AddServiceEndpoint(typeof(ICalculate), new BasicHttpBinding(),
"http://localhost:8080/calc");
host.Open();
});
ChannelFactory factory &＃61; new ChannelFactory(
new BasicHttpBinding(), "http://localhost:8080/calc");
IRequestChannel channel &＃61; factory.CreateChannel();
channel.Open();
Message request &＃61; Message.CreateMessage(MessageVersion.Soap11, "Add", new Data(1234));
Message reply &＃61; channel.Request(request);
Console.WriteLine("-------------------");
Console.WriteLine(reply);
channel.Close();
factory.Close();
}
}
输出&＃xff1a;
1234
-------------------
9999
正 如上面所看到的&＃xff0c;所有的调用都被转换成消息后发送。这也符合 SOA 的规范&＃xff0c;完全隔离&＃xff0c;清晰的边界。(调用 "m.GetBody()" 后&＃xff0c;会导致 Message.State 变更&＃xff0c;再次访问会出错&＃xff0c;有关详细信息请参考 MSDN 文档。)
我们还可以使用 MessageContractAttribute / MessageHeaderAttribute 来控制消息格式&＃xff0c;这比 DataContractAttribute 要更加灵活。我们可以设置消息标头、消息体&＃xff0c;包括是否对其中某些进行签名和加密处理。
[ServiceContract]
public interface ICalculate
{
[OperationContract]
void Add(Data d);
}
public class CalculateService : ICalculate
{
public void Add(Data d)
{
Console.WriteLine(OperationContext.Current.RequestContext.RequestMessage);
Console.WriteLine("----------------");
Console.WriteLine("{0}/{1}", d.a, d.b);
}
}
[MessageContract]
public class Data
{
[MessageHeader]
public double a &＃61; 1;
[MessageBodyMember]
public double b &＃61; 2;
}
public class WcfTest
{
public static void Test()
{
AppDomain.CreateDomain("Server").DoCallBack(delegate
{
ServiceHost host &＃61; new ServiceHost(typeof(CalculateService));
host.AddServiceEndpoint(typeof(ICalculate), new BasicHttpBinding(),
"http://localhost:8080/calc");
host.Open();
});
ChannelFactory factory &＃61; new ChannelFactory(new BasicHttpBinding(),
"http://localhost:8080/calc");
ICalculate o &＃61; factory.CreateChannel();
Data d &＃61; new Data();
d.a &＃61; 1234;
d.b &＃61; 5678;
o.Add(d);
}
}
输出&＃xff1a;
1
http://localhost:8080/calc
http://tempuri.org/ICalculate/Add
2
----------------
1234/5678
有关 Message 更详细的信息&＃xff0c;可以参考 MSDN (Microsoft Windows SDK) 文档。
京公网安备 11010802041100号