到 Windows Communication Foundation 的消息队列

项目
09/04/2008

本示例演示消息队列 (MSMQ) 应用程序如何将 MSMQ 消息发送到 Windows Communication Foundation (WCF) 服务。此服务是自承载控制台应用程序，通过它可以观察服务接收排队消息。

服务协定是 IOrderProcessor，它定义了适合与队列一起使用的单向服务。MSMQ 消息没有 Action 标头，因此无法将不同的 MSMQ 消息自动映射到操作协定。所以只能有一个操作协定。如果希望为服务定义多个操作协定，则应用程序必须提供有关 MSMQ 消息中的哪个标头（例如，标签或 correlationID）可用于确定要调度的操作协定的信息。这在自定义多路分解器中进行了演示。

MSMQ 消息不包含有关哪些标头可映射到操作协定的不同参数的信息。该参数属于 MsmqMessage(MsmqMessage<T>) 类型，包含基础 MSMQ 消息。MsmqMessage(MsmqMessage<T>) 类中的“T”类型代表序列化到 MSMQ 消息正文中的数据。在此示例中，PurchaseOrder 类型序列化到 MSMQ 消息正文中。

下面的示例代码演示订单处理服务的服务协定。

// Define a service contract.
[ServiceContract(Namespace = "http://Microsoft.ServiceModel.Samples")]
[ServiceKnownType(typeof(PurchaseOrder))]
public interface IOrderProcessor
{
    [OperationContract(IsOneWay = true, Action = "*")]
    void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg);
}

服务是自承载服务。使用 MSMQ 时，必须提前创建所使用的队列。可以手动或通过代码完成此操作。在此示例中，该服务检查队列是否存在并在必要时创建队列。从配置文件中读取队列名称。

public static void Main()
{
    // Get the MSMQ queue name from the application settings in 
    // configuration.
    string queueName = ConfigurationManager.AppSettings["queueName"];
    // Create the MSMQ queue if necessary.
    if (!MessageQueue.Exists(queueName))
        MessageQueue.Create(queueName, true);
    …
}

该服务为 OrderProcessorService 创建和打开 ServiceHost，如下面的示例代码所示。

using (ServiceHost serviceHost = new ServiceHost(typeof(OrderProcessorService)))
{
    serviceHost.Open();
    Console.WriteLine("The service is ready.");
    Console.WriteLine("Press <ENTER> to terminate service.");
    Console.ReadLine();
    serviceHost.Close();
}

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

提示

队列名称使用圆点 (.)来表示本地计算机，并在其路径中使用反斜杠分隔符。WCF 终结点地址指定 msmq.formatname 方案，并为本地计算机使用 localhost。用于每个 MSMQ 格式名寻址指南的队列地址遵从 msmq.formatname 方案。

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

该客户端应用程序是一个 MSMQ 应用程序，它使用 Send 方法向队列发送持久的事务性消息，如下面的示例代码所示。

//Connect to the queue.
MessageQueue orderQueue = new MessageQueue(ConfigurationManager.AppSettings["orderQueueName"]);

// Create the purchase order.
PurchaseOrder po = new PurchaseOrder();
po.CustomerId = "somecustomer.com";
po.PONumber = Guid.NewGuid().ToString();

PurchaseOrderLineItem lineItem1 = new PurchaseOrderLineItem();
lineItem1.ProductId = "Blue Widget";
lineItem1.Quantity = 54;
lineItem1.UnitCost = 29.99F;

PurchaseOrderLineItem lineItem2 = new PurchaseOrderLineItem();
lineItem2.ProductId = "Red Widget";
lineItem2.Quantity = 890;
lineItem2.UnitCost = 45.89F;

po.orderLineItems = new PurchaseOrderLineItem[2];
po.orderLineItems[0] = lineItem1;
po.orderLineItems[1] = lineItem2;

// Submit the purchase order.
Message msg = new Message();
msg.Body = po;
//Create a transaction scope.
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
{
    
    orderQueue.Send(msg, MessageQueueTransactionType.Automatic);
    // Complete the transaction.
    scope.Complete();
   
}
Console.WriteLine("Placed the order:{0}", po);
Console.WriteLine("Press <ENTER> to terminate client.");
Console.ReadLine();

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

设置、生成和运行示例

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

跨计算机运行示例

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

另请参见

其他资源

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