414
WCF后续之旅（17）：通过tcpTracer进行消息的路由
服务契约：Artech.TcpTraceDemo.Contracts.ICalculate
1: //---------------------------------------------------------------
2: // EndpointAddress & WCF Addressing (c) by 2008 Jiang Jin Nan
3: //---------------------------------------------------------------
4: using System.ServiceModel;
5: namespace Artech.TcpTraceDemo.Contracts
6: {
7: [ServiceContract]
8: public interface ICalculate
9: {
10: [OperationContract]
11: double Add(double x, double y);
12: }
13: }
服务实现：Artech.TcpTraceDemo. Services. CalculateService
1: //---------------------------------------------------------------
2: // EndpointAddress & WCF Addressing (c) by 2008 Jiang Jin Nan
3: //---------------------------------------------------------------
4: using Artech.TcpTraceDemo.Contracts;
5:
6: namespace Artech.TcpTraceDemo.Services
7: {
8: public class CalculateService:ICalculate
9: {
10: #region ICalculate Members
11:
12: public double Add(double x, double y)
13: {
14: return x + y;
15: }
16:
17: #endregion
18: }
19: }
服务寄宿（代码）：Artech.TcpTraceDemo.Hosting. Program
1: //---------------------------------------------------------------
2: // EndpointAddress & WCF Addressing (c) by 2008 Jiang Jin Nan
3: //---------------------------------------------------------------
4: using System;
5: using System.ServiceModel;
6: using Artech.TcpTraceDemo.Services;
7:
8: namespace Artech.TcpTraceDemo.Hosting
9: {
10: class Program
11: {
12: static void Main(string[] args)
13: {
14: using (ServiceHost serviceHost = new ServiceHost(typeof(CalculateService)))
15: {
16: serviceHost.Opened += delegate
17: {
18: Console.WriteLine("The Calculate Service has been started up!");
19: };
20: serviceHost.Open();
21:
22: Console.Read();
23: }
24: }
25: }
26: }
27:
服务寄宿（配置）：App.config
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <bindings>
5: <customBinding>
6: <binding name="SimpleBinding">
7: <textMessageEncoding />
8: <httpTransport />
9: </binding>
10: </customBinding>
11: </bindings>
12: <services>
13: <service name="Artech.TcpTraceDemo.Services.CalculateService">
14: <endpoint address="https://127.0.0.1:9999/calculateservice" binding="customBinding" bindingConfiguration="SimpleBinding" contract="Artech.TcpTraceDemo.Contracts.ICalculate"/>
15: </service>
16: </services>
17: </system.serviceModel>
18: </configuration>
19:
注：由于本例仅仅用于模拟消息的路由，所以我们仅仅需要绑定提供的传输和编码功能，所以在这里我使用了自定义绑定，并且添加两个BindElement：HttpTransport和TextMessageEncoding。
服务访问（代码）：Artech.TcpTraceDemo.Clients.Program
1: //---------------------------------------------------------------
2: // EndpointAddress & WCF Addressing (c) by 2008 Jiang Jin Nan
3: //---------------------------------------------------------------
4: using System.ServiceModel;
5: using Artech.TcpTraceDemo.Contracts;
6: using System;
7: namespace Artech.TcpTraceDemo.Clients
8: {
9: class Program
10: {
11: static void Main(string[] args)
12: {
13: using (ChannelFactory<ICalculate> channelFactory = new ChannelFactory<ICalculate>("calculateService"))
14: {
15: ICalculate calculator = channelFactory.CreateChannel();
16: using (calculator as IDisposable)
17: {
18: Console.WriteLine("x + y = {2} where x = {0} and y = {1}",1,2,calculator.Add(1,2));
19: }
20: }
21:
22: Console.Read();
23: }
24: }
25: }
26:
服务访问（配置）：App.config
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <bindings>
5: <customBinding>
6: <binding name="SimpleBinding">
7: <textMessageEncoding />
8: <httpTransport />
9: </binding>
10: </customBinding>
11: </bindings>
12: <client>
13: <endpoint address="https://127.0.0.1:9999/calculateservice"
14: binding="customBinding" bindingConfiguration="SimpleBinding"
15: contract="Artech.TcpTraceDemo.Contracts.ICalculate" name="calculateService" />
16: </client>
17: </system.serviceModel>
18: </configuration>
19:
步骤二、通过ClientViaBehavior实现基于tcpTracer的消息路由
注：对于消息发送方来说，SOAP消息的To报头对应的地址由发送端的终结点地址（逻辑地址）决定。
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <behaviors>
5: <endpointBehaviors>
6: <behavior name="clientViaBehavior">
7: <clientVia viaUri="https://127.0.0.1:8888/calculateservice" />
8: </behavior>
9: </endpointBehaviors>
10: </behaviors>
11: <bindings>
12: <customBinding>
13: <binding name="SimpleBinding">
14: <textMessageEncoding />
15: <httpTransport />
16: </binding>
17: </customBinding>
18: </bindings>
19: <client>
20: <endpoint address="https://127.0.0.1:9999/calculateservice" behaviorConfiguration="clientViaBehavior"
21: binding="customBinding" bindingConfiguration="SimpleBinding"
22: contract="Artech.TcpTraceDemo.Contracts.ICalculate" name="calculateService" />
23: </client>
24: </system.serviceModel>
25: </configuration>
26:
1: POST /calculateservice HTTP/1.1
2: Content-Type: application/soap+xml; charset=utf-8
3: VsDebuggerCausalityData: uIDPo2sY41w6xm1DgtOSzZT5+0EAAAAAXVfsUhiXVUmLsNq6tAEl+rUZZUmtRERFvB6DbqcWQtcACQAA
4: Host: 127.0.0.1:8888
5: Content-Length: 526
6: Expect: 100-continue
7: Connection: Keep-Alive
8:
9: <s:Envelope xmlns:s="https://www.w3.org/2003/05/soap-envelope" xmlns:a="https://www.w3.org/2005/08/addressing">
10: <s:Header>
11: <a:Action s:mustUnderstand="1">https://tempuri.org/ICalculate/Add</a:Action>
12: <a:MessageID>urn:uuid:a63ec626-a350-4390-84c6-fb34be4ff208</a:MessageID>
13: <a:ReplyTo>
14: <a:Address>https://www.w3.org/2005/08/addressing/anonymous</a:Address>
15: </a:ReplyTo>
16: <a:To s:mustUnderstand="1">https://127.0.0.1:9999/calculateservice</a:To>
17: </s:Header>
18: <s:Body>
19: <Add xmlns="https://tempuri.org/">
20: <x>1</x>
21: <y>2</y>
22: </Add>
23: </s:Body>
24: </s:Envelope>
25:
1: HTTP/1.1 100 Continue
2:
3: HTTP/1.1 200 OK
4: Content-Length: 394
5: Content-Type: application/soap+xml; charset=utf-8
6: Server: Microsoft-HTTPAPI/2.0
7: Date: Sat, 13 Sep 2008 17:29:37 GMT
8:
9: <s:Envelope xmlns:s="https://www.w3.org/2003/05/soap-envelope" xmlns:a="https://www.w3.org/2005/08/addressing">
10: <s:Header>
11: <a:Action s:mustUnderstand="1">https://tempuri.org/ICalculate/AddResponse</a:Action>
12: <a:RelatesTo>urn:uuid:a63ec626-a350-4390-84c6-fb34be4ff208</a:RelatesTo>
13: </s:Header>
14: <s:Body>
15: <AddResponse xmlns="https://tempuri.org/">
16: <AddResult>3</AddResult>
17: </AddResponse>
18: </s:Body>
19: </s:Envelope>
20:
步骤三、通过ListenUri实现基于tcpTracer的消息路由
1: <?xml version="1.0" encoding="utf-8" ?>
2: <configuration>
3: <system.serviceModel>
4: <bindings>
5: <customBinding>
6: <binding name="SimpleBinding">
7: <textMessageEncoding />
8: <httpTransport />
9: </binding>
10: </customBinding>
11: </bindings>
12: <services>
13: <service name="Artech.TcpTraceDemo.Services.CalculateService">
14: <endpoint address="https://127.0.0.1:9999/calculateservice" binding="customBinding"
15: bindingConfiguration="SimpleBinding" contract="Artech.TcpTraceDemo.Contracts.ICalculate"
16: listenUri="https://127.0.0.1:8888/calculateservice" />
17: </service>
18: </services>
19: </system.serviceModel>
20: </configuration>
21:
WCF后续之旅：
WCF后续之旅(1): WCF是如何通过Binding进行通信的
WCF后续之旅(2): 如何对Channel Layer进行扩展——创建自定义Channel
WCF后续之旅(3): WCF Service Mode Layer 的中枢—Dispatcher
WCF后续之旅(4)：WCF Extension Point 概览
WCF后续之旅(5): 通过WCF Extension实现Localization
WCF后续之旅(6): 通过WCF Extension实现Context信息的传递
WCF后续之旅(7)：通过WCF Extension实现和Enterprise Library Unity Container的集成
WCF后续之旅(8)：通过WCF Extension 实现与MS Enterprise Library Policy Injection Application Block 的集成
WCF后续之旅(9)：通过WCF的双向通信实现Session管理[Part I]
WCF后续之旅(9): 通过WCF双向通信实现Session管理[Part II]
WCF后续之旅(10): 通过WCF Extension实现以对象池的方式创建Service Instance
WCF后续之旅(11): 关于并发、回调的线程关联性（Thread Affinity）
WCF后续之旅(12): 线程关联性（Thread Affinity）对WCF并发访问的影响
WCF后续之旅(13): 创建一个简单的WCF SOAP Message拦截、转发工具[上篇]
WCF后续之旅(13)：创建一个简单的SOAP Message拦截、转发工具[下篇]
WCF后续之旅(14)：TCP端口共享
WCF后续之旅(15): 逻辑地址和物理地址
WCF后续之旅(16): 消息是如何分发到Endpoint的--消息筛选(Message Filter)
WCF后续之旅(17)：通过tcpTracer进行消息的路由
作者：蒋金楠
微信公众账号：大内老A
微博：www.weibo.com/artech
如果你想及时得到个人撰写文章以及着作的消息推送，或者想看看个人推荐的技术资料，可以扫描左边二维码（或者长按识别二维码）关注个人公众号（原来公众帐号蒋金楠的自媒体将会停用）。
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
微信公众账号：大内老A
微博：www.weibo.com/artech
如果你想及时得到个人撰写文章以及着作的消息推送，或者想看看个人推荐的技术资料，可以扫描左边二维码（或者长按识别二维码）关注个人公众号（原来公众帐号蒋金楠的自媒体将会停用）。
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
最后更新：2017-10-30 16:34:23