Windows Communication Foundation 到消息队列

项目
09/04/2008

本示例演示 Windows Communication Foundation (WCF) 应用程序如何向消息队列 (MSMQ) 应用程序发送消息。此服务是自承载控制台应用程序，通过它可以观察服务接收排队消息。服务和客户端不需要同时运行。

服务从队列接收消息并处理订单。服务创建一个事务性队列，并为收到的消息设置消息处理程序，如下面的示例代码所示。

static void Main(string[] args)
{
    if (!MessageQueue.Exists(
              ConfigurationManager.AppSettings["queueName"]))
       MessageQueue.Create(
           ConfigurationManager.AppSettings["queueName"], true);
        //Connect to the queue
        MessageQueue Queue = new 
    MessageQueue(ConfigurationManager.AppSettings["queueName"]);
    Queue.ReceiveCompleted += 
                 new ReceiveCompletedEventHandler(ProcessOrder);
    Queue.BeginReceive();
    Console.WriteLine("Order Service is running");
    Console.ReadLine();
}

当消息到达队列中时，将调用消息处理程序 ProcessOrder。

public static void ProcessOrder(Object source,
    ReceiveCompletedEventArgs asyncResult)
{
    try
    {
        // Connect to the queue.
        MessageQueue Queue = (MessageQueue)source;
        // End the asynchronous receive operation.
        System.Messaging.Message msg = 
                     Queue.EndReceive(asyncResult.AsyncResult);
        msg.Formatter = new System.Messaging.XmlMessageFormatter(
                                new Type[] { typeof(PurchaseOrder) });
        PurchaseOrder po = (PurchaseOrder) msg.Body;
        Random statusIndexer = new Random();
        po.Status = PurchaseOrder.OrderStates[statusIndexer.Next(3)];
        Console.WriteLine("Processing {0} ", po);
        Queue.BeginReceive();
    }
    catch (System.Exception ex)
    {
        Console.WriteLine(ex.Message);
    }

}

服务从 MSMQ 消息正文中提取 ProcessOrder 并处理订单。

MSMQ 队列名称在配置文件的 appSettings 节中指定，如以下示例配置所示。

<appSettings>
    <add key="orderQueueName" value=".\private$\Orders" />
</appSettings>

提示

队列名称使用圆点 (.)来表示本地计算机，并在其路径中使用反斜杠分隔符。

客户端创建采购订单并在事务的范围内提交该采购订单，如下面的示例代码所示。

// Create the purchase order
PurchaseOrder po = new PurchaseOrder();
// Fill in the details
...

OrderProcessorClient client = new OrderProcessorClient("OrderResponseEndpoint");

MsmqMessage<PurchaseOrder> ordermsg = new MsmqMessage<PurchaseOrder>(po);
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
{
    client.SubmitPurchaseOrder(ordermsg);
    scope.Complete();
}
Console.WriteLine("Order has been submitted:{0}", po);

//Closing the client gracefully closes the connection and cleans up resources
client.Close();

客户端按顺序使用自定义客户端将 MSMQ 消息发送给队列。由于接收和处理消息的应用程序是 MSMQ 应用程序，而不是 WCF 应用程序，因此这两个应用程序之间没有隐式服务协定。所以在此方案中，我们不能使用 Svcutil.exe 工具创建代理。

对于使用 MsmqIntegration 绑定发送消息的所有 WCF 应用程序而言，自定义客户端在本质上都是相同的。与其他客户端不同，它不包含一系列服务操作。它只是一个提交消息操作。

[System.ServiceModel.ServiceContractAttribute(Namespace = "http://Microsoft.ServiceModel.Samples")]
public interface IOrderProcessor
{
    [OperationContract(IsOneWay = true, Action = "*")]
    void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg);
}

public partial class OrderProcessorClient : System.ServiceModel.ClientBase<IOrderProcessor>, IOrderProcessor
{
    public OrderProcessorClient(){}

    public OrderProcessorClient(string configurationName)
        : base(configurationName)
    { }

    public OrderProcessorClient(System.ServiceModel.Channels.Binding binding, System.ServiceModel.EndpointAddress address)
        : base(binding, address)
    { }

    public void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg)
    {
        base.Channel.SubmitPurchaseOrder(msg);
    }
}

运行示例时，客户端和服务活动将显示在服务和客户端控制台窗口中。您可以看到服务从客户端接收消息。在每个控制台窗口中按 Enter 可以关闭服务和客户端。请注意：由于正在使用队列，因此不必同时启动和运行客户端和服务。例如，可以先运行客户端，再将其关闭，然后启动服务，这样服务仍然会收到客户端的消息。

提示

此示例需要安装消息队列。请参见消息队列（可能为英文网页）中的安装说明。

设置、生成和运行示例

请确保已经执行了 Windows Communication Foundation 示例的一次性安装过程。
若要生成 C# 或 Visual Basic .NET 版本的解决方案，请按照生成 Windows Communication Foundation 示例中的说明进行操作。
若要用单一计算机配置运行此示例，请按照运行 Windows Communication Foundation 示例中的说明进行操作。

跨计算机运行示例

将 \service\bin\ 文件夹（在语言特定文件夹内）中的服务程序文件复制到服务计算机上。
将 \client\bin\ 文件夹（在语言特定文件夹内）中的客户端程序文件复制到客户端计算机上。
在 Client.exe.config 文件中，更改客户端终结点地址以指定服务计算机名称，而不是使用“.”。
在服务计算机上的命令提示符下启动 Service.exe。
在客户端计算机上，在命令提示符下启动 Client.exe。

另请参见

其他资源

How To: Exchange Messages with WCF Endpoints and MSMQ applications
消息队列（可能为英文网页）