企业级服务


企业级服务是唯一一种天生支持分布式两阶段提交的事务机制。当你开始编码之前，重要的是要了解企业级服务的工作机制，如果你用过VB编程，并且熟悉COM+编程，你就会了解企业级服务所提供的功能。用VB去创建COM+程序和用CLR创建企业级服务的一个不同之处是你不必再局限于单线程套间（STA），深入介绍企业级服务之前，你最好去搞清楚单线程套间（STA）和多线程套间（MTA）的区别。使用企业级服务，你的.net装配会驻留在COM+应用程序中来获得诸如DTC和对象池的服务，本文主要集中讨论COM+事务服务，但也会提一下其他服务。

为了实现企业级服务组件，要在你的class文件中用using System.EnterpriseService来引入System.EnterpriseService命名空间，每个类都需要继承ServicedComponet,这些类需要是公共的，并且需要提供一个公共的缺省的构造器，一单你扩展了ServicedComponet类，开发企业级服务仅需要配置一下属性。你也可以通过CLR来获得COM+元数据，这样所有的COM+应用程序的属性就可以在程序中来设置，利用Visual Studio.NET，这些属性可以定义在一个叫AssemblyInfo.cs的文件中，也可以定义在.cs文件中，你必须的装配属性是：

[assembly: ApplicationName("YourApplicationNameHere")]

[assembly: ApplicationActivation(ActivationOption.Library)]

[assembly: AssemblyKeyFile("..\\..\\keyfilename.snk")]

l ApplicationName 设置了显示在COM+目录中程序的名字。

l ApplicationActivation 定义了是做为库应用还是服务应用激发的。在开发中经常设为服务应用以可以监视每个组件的活动，而在测试和成为产品后要设为库应用来取得最好的性能。

l AssemblyKeyFile 给编译器提供了一个密钥文件，用来给装配一个强名字，你需要提供一个相对于装配路径的相对路径。典型地是\bin\release\myassembly.dll。

运行在CLR中的企业级服务程序都需要一个强名字，编译你的装配之前，你需要创建一个密钥文件。创建的命令行语句是：sn –k keyfilename，这样在当前的目录中会产生一个keyfilename.snk文件，这个文件必须在AssemblyKeyFile属性中引用。

现在我们可以进行属性的设置了，我们首先增加类属性，为了创建一个事务型组件，要在类定义之前加属性[Transaction(TransactionOption.Required)].类里面的每个方法就会运行在一个事务中，控制每个方法的提交或者回滚的最简单的方法是在方法之前增加属性[AutoComplete(true)]，这样如果方法执行时没有异常就缺省提交，如果有异常这个方法就会回滚。



前提

l 需要强名字

优势

l 执行分布式事务

l 获得COM+服务，诸如对象构建和对象池

限制

l 牺牲了一些性能

l COM+ 1.0要求每个事务的隔离级别都要设置为Serializable

例子：

AssemblyInfo.cs file



[assembly: ApplicationName("MyEnterpriseApplication")]

[assembly: ApplicationActivation(ActivationOption.Server)]

[assembly: AssemblyKeyFile("..\\..\\MyEntApp.snk")]



Component.cs file



using System;

using System.EnterpriseServices;

using System.Reflection;

using System.Runtime.InteropServices;

using System.Data;

using System.Data.SqlClient;

using System.Text;





namespace PetShop.ComponentsTx

{

// COM+ 1.5 (Win XP) supports setting transaction isolation level

// To use with Windows 2000, remove isolation attribute

[ Transaction(TransactionOption.Required, Isolation =

TransactionIsolationLevel.ReadCommitted) ]

public class OrderTx : ServicedComponent

{

//Must supply default constructor

public OrderTx()

{

}



//Set autocomplete to allow auto commit or rollback

[ AutoComplete(true) ]

public int purchaseitem(int customerId, int itemId, int itemQty)

{

SqlConnection con = null;

int orderId = 0;



try

{

con = new SqlConnection("Data Source=localhost; user

Id=sa;password=;Initial Catalog=trans_db;");



con.Open();



String updatesqltext = "UPDATE inventory SET qtyinstock = qtyinstock - "

+ itemQty.ToString() + " WHERE inventory.productid =

" + itemId.ToString();



SqlCommand cmd = new SqlCommand(updatesqltext, con);



cmd.ExecuteNonQuery();



String insertsqltext = "INSERT INTO orders VALUES (" +

customerId.ToString() + ",

" + itemId.ToString() + "," +

itemQty.ToStrin