c#消息队列应用程式 -1_c#应用

简介

　　Microsoft近期推出一种用于生成集成应用程式的新平台——Microsoft
.NET框架。.NET 框架允许研发人员使用任何编程语言迅速生成和部署Web
服务和应用程式。Microsoft Intermediate Language （MSIL）和实时
（JIT ）编译器使这种不依赖语言的框架得以实现。

　　和.NET框架同时面世的更有一种新的编程语言C#（读“C sharp”）。
C#是一种简单、新颖、面向对象和类型安全的编程语言。利用 .NET 框架
和 C# （除 Microsoft？ Visual Basic ？和 Managed C 之外），用户
能够编写功能强大的 Microsoft Windows？和 Web应用程式及服务。本文
提供了这样的一个解决方案，他的重点是 .NET 框架和 C# 而不是编程语
言。C#语言的介绍能够在“ C# 简介和概述（英文）”找到。

　　近期的文章“MSMQ：可伸缩、高可用性的负载平衡解决方案（英文）”
介绍了一种解决方案，用于高可用性消息队列（MSMQ）的可伸缩负载平衡
解决方案体系结构。此解决方案中涉及了一种将 Windows服务用作智能消
息路由器的研发方案。这样的解决方案以前只有 Microsoft Visual C
程式员才能实现，而 .NET 框架的出现改变了这种情况。从下面的解决方
案中，您能够看到这一点。

.NET 框架应用程式

　　这里介绍的解决方案是一种用来处理若干消息队列的 Windows服务；
其中每个队列都是由多个线程进行处理（接收和处理消息）。处理程式使
用循环法技术或应用程式特定值（消息 AppSpecific属性）从目的队列列
表中路由消息，并使用消息属性来调用组件方法。（示例进程也属于这种
情况。）在后一种情况下，组件的需要是他能够实现给定的接口IWeb
Message要处理错误，应用程式需要将不能处理的消息发送到错误队列中。

　　消息应用程式的结构和以前的活动模板库（ATL ）应用程式相似，他
们之间的主要不同在于用于管理服务的代码的封装和 .NET 框架组件的使
用。要创建Windows服务，.NET框架用户仅仅需要创建一个从 ServiceBase
（来自System.ServiceControl程式集）继承的类。这毫不奇怪，因为.NET
框架是面向对象的。

应用程式结构

　　应用程式中主要的类是 ServiceControl ，他是从 ServiceBase继承
的。因而，他必须实现 OnStart和 OnStop 方法，连同可选的 OnPause和
OnContinue方法。事实上，类是在静态方法 Main 内构造的：

using System;
using System.ServiceProcess;

public class ServiceControl: ServiceBase
{
　 // 创建服务对象的主入口点
　 public static void Main()
　 {
　　　ServiceBase.Run(new ServiceControl());
　 }

　 // 定义服务参数的构造对象
　 public ServiceControl()
　 {
　　　CanPauseAndContinue = true;
　　　ServiceName = "MSDNMessageService";
　　　AutoLog = false;
　 }

　 protected override void OnStart(string[] args) {...}
　 protected override void OnStop() {...}
　 protected override void OnPause() {...}
　 protected override void OnContinue() {...}
}

　　ServiceControl类创建一系列 CWorker对象，即，为需要处理的每个
消息队列创建 CWorker类的一个实例。根据定义中处理队列所需的线程数
目，CWorker 类依次创建了一系列的 CWorkerThread对象。CWorkerThread
类创建的一个处理线程将执行实际的服务工作。

　　使用 CWorker和 CWorkerThread类的主要目的是确认服务控件 Start、
Stop、Pause 和 Continue 命令。因为这些进程必须是无阻塞的，命令操
作最终将在后台处理线程上执行。

　　CWorkerThread 是个抽象类，被 CWorkerThreadAppSpecific 、
CWorkerThreadRoundRobin 和 CWorkerThreadAssembly继承。这些类以不
同的方式处理消息。前两个类通过给另一队列发送消息来处理消息（其不
同之处在于确定接收队列路径的方式），最后一个类则使用消息属性来调
用组件方法。

　　.NET 框架内部的错误处理是以基类 Exception为基础的。当系统引
发或捕获错误时，这些错误必须是从 Exception中导出的类。CWorker
ThreadException 类就是这样一种实现，他通过附加额外属性（用于定义
服务是否应继续运行）来扩展基类。

　　最后，应用程式包含两种结构。这些值类型定义了辅助进程或线程的
运行时参数，以简化 CWorker和 CWorkerThread对象的结构。使用值类型
结构（而不是引用类型类）能够确保这些运行时参数维护的是数值（而不
是引用）。

IWebMessage 接口

　　CWorkerThread 的实现之一是个调用组件方法的类。这个名为
CWorkerThreadAssembly 的类使用 IWebMessage接口来定义服务和组件之
间的约定。

　　和当前版本的 Microsoft Visual Studio？不同，C#接口能够在任何
语言中显式定义，而无需创建和编译 IDL文档。C# IWebMessage接口的
定义如下：
public interface IWebMessage
{
　 WebMessageReturn Process(string sMessageLabel, string sMessage
　 Body, int iAppSpecific);
　 void Release();
}

ATL 代码中的 Process 方法是为处理消息而指定的。Process 方法的返
回代码定义为枚举类型 WebMessageReturn：

public enum WebMessageReturn
{
　 ReturnGood,
　 ReturnBad,
　 ReturnAbort
}

　　枚举的定义如下：Good表示继续处理，Bad 表示将消息写入错误队列，
Abort 表示终止处理。Release 方法为服务提供了轻松清除类实例的途径。
因为仅在垃圾回收的过程中才调用类实例的析构函数，所以确保任何占用
昂贵资源（例如数据库连接）的类都有一个能够在析构之前被调用的方法，
用来释放这些资源，这是一种很好的构思。

名称空间

　　在这里先简单介绍一下名称空间。名称空间允许在内部和外部表示中
将应用程式组织成为逻辑元素。服务内的任何代码都包含在 MSDNMessage

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有