《WCF技术内幕》翻译12：第1部分_第2章_面向服务:概念汇总

<Order> 
<ProdID>xs:integer</ProdID> 
<Qty>xs:integer</Qty> 
<Status>xs:string</Status> 
</Order>

// file: Contracts.cs 
using System; 
 
using System.ServiceModel; 
 
using System.ServiceModel.Channels; 
// define the contract for the service 
[ServiceContract(Namespace =  "http://wintellect.com/ProcessOrder")] 
public interface IProcessOrder { 
        [OperationContract(Action="urn:SubmitOrder")] 
        void SubmitOrder(Message order); 
}

// File: Receiver.cs 
// Implement the interface defined in the contract assembly 
public  sealed  class MyService : IProcessOrder { 
  public  void SubmitOrder(Message order) { 
         // Do work here 
 } 
}

// File: Receiver.cs 
using System; 
using System.Xml; 
using System.IO; 
using System.ServiceModel; 
using System.ServiceModel.Channels; 
// Implement the interface defined in the contract assembly实现程序集里定义的契约接口 
public  sealed  class MyService : IProcessOrder { 
  public  void SubmitOrder(Message order) { 
         // Create a file name from the MessageID根据MessageID创建文件名 
        String fileName =  "Order" + order.Headers.MessageId.ToString() +  ".xml"; 
         // Signal that a message has arrived提示消息到达 
        Console.WriteLine( "Message ID {0} received", 
            order.Headers.MessageId.ToString()); 
         // create an XmlDictionaryWriter to write to a file创建一个XmlDictionaryWriter去写文件 
        XmlDictionaryWriter writer = XmlDictionaryWriter.CreateTextWriter( 
             new FileStream(fileName, FileMode.Create)); 
         // write the message to a file写消息到文件里 
        order.WriteMessage(writer); 
        writer.Close(); 
 } 
}

// File: ReceiverHost.cs 
using System; 
using System.Xml; 
using System.ServiceModel; 
internal  static  class ReceiverHost { 
  public  static  void Main() { 
         // Define the binding for the service定义服务绑定 
        WSHttpBinding binding =  new WSHttpBinding(SecurityMode.None); 
         // Use the text encoder 
        binding.MessageEncoding = WSMessageEncoding.Text; 
         // Define the address for the service定义服务地址 
        Uri addressURI =  new Uri( @"http://localhost:4000/Order"); 
     // Instantiate a Service host using the MyService type使用MyService实例化服务宿主 
        ServiceHost svc = new ServiceHost(typeof(MyService)); 
        // Add an endpoint to the service with the给服务增加一个终结点 
        // contract, binding, and address 
        svc.AddServiceEndpoint(typeof(IProcessOrder), 
                                                     binding, 
                                                     addressURI); 
    
        // Open the service host to start listening打开服务宿主开始侦听 
        svc.Open(); 
        Console.WriteLine("The receiver is ready"); 
        Console.ReadLine(); 
        svc.Close(); 
 } 
}

// File: Sender.cs 
using System; 
using System.Text; 
using System.Xml; 
using System.ServiceModel; 
using System.Runtime.Serialization; 
using System.IO; 
using System.ServiceModel.Channels; 
public  static  class Sender { 
  public  static  void Main(){ 
        Console.WriteLine( "Press ENTER when the receiver is ready"); 
        Console.ReadLine(); 
         // address of the receiving application接受程序的地址 
        EndpointAddress address = 
             new EndpointAddress( @"http://localhost:4000/Order"); 
        // Define how we will communicate with the service定义一个我们通信的服务 
        // In this case, use the WS-* compliant HTTP binding这个例子里，我们可以使用WS的HTTP绑定 
        WSHttpBinding binding = new WSHttpBinding(SecurityMode.None); 
        binding.MessageEncoding = WSMessageEncoding.Text; 
        // Create a channel创建通道 
        ChannelFactory<IProcessOrder> channel = 
            new ChannelFactory<IProcessOrder>(binding, address); 
        // Use the channel factory to create a proxy使用通道工厂创建代理 
        IProcessOrder proxy = channel.CreateChannel(); 
        // Create some messages创建一些消息 
        Message msg = null; 
        for (Int32 i = 0; i < 10; i++) { 
            // Call our helper method to create the message调用我们的helper方法创建消息 
            // notice the use of the Action defined in注意使用在IProcessOrder契约里定义的Action 
            // the IProcessOrder contract 
            msg = GenerateMessage(i,i); 
            // Give the message a MessageID SOAP headerSOAP消息头里加MessageID 
            UniqueId uniqueId = new UniqueId(i.ToString()); 
            msg.Headers.MessageId = uniqueId; 
            Console.WriteLine("Sending Message # {0}", uniqueId.ToString()); 
            // Give the message an Action SOAP headerSOAP消息头里加Action 
            msg.Headers.Action = "urn:SubmitOrder"; 
            // Send the message发送消息 
            proxy.SubmitOrder(msg); 
        } 
 } 
 // method for creating a Message创建消息的方法 
 private static Message GenerateMessage(Int32 productID, Int32 qty) { 
        MemoryStream stream = new MemoryStream(); 
        XmlDictionaryWriter writer = XmlDictionaryWriter.CreateTextWriter( 
            stream, Encoding.UTF8, false); 
        writer.WriteStartElement("Order"); 
        writer.WriteElementString("ProdID", productID.ToString()); 
        writer.WriteElementString("Qty", qty.ToString()); 
        writer.WriteEndElement(); 
        writer.Flush(); 
        stream.Position = 0; 
        XmlDictionaryReader reader = XmlDictionaryReader.CreateTextReader( 
            stream, XmlDictionaryReaderQuotas.Max); 
        // Create the message with the Action and the body使用Action和body创建消息 
        return Message.CreateMessage(MessageVersion.Soap12WSAddressing10, 
                                                                 String.Empty, 
                                                                 reader); 
 } 
}

The receiver is ready 
Message ID 0 received 
Message ID 1 received 
Message ID 2 received 
Message ID 3 received 
Message ID 4 received 
Message ID 5 received 
Message ID 6 received 
Message ID 7 received 
Message ID 8 received 
Message ID 9 received

<s:Envelope xmlns:s="http://www.w3.org/2003/05/soap-envelope"                    xmlns:a="http://www.w3.org/2005/08/addressing"> 
<s:Header> 
        <a:Action s:mustUnderstand="1">urn:SubmitOrder</a:Action> 
        <a:MessageID>1</a:MessageID> 
        <a:ReplyTo> 
<a:Address>http://www.w3.org/2005/08/addressing/anonymous</a:Address> 
        </a:ReplyTo> 
        <a:To s:mustUnderstand="1">http://localhost:4000/Order</a:To> 
</s:Header> 
<s:Body> 
        <Order> 
            <ProdID>1</ProdID> 
            <Qty>1</Qty> 
        </Order> 
</s:Body> 
</s:Envelope>