wcf系列学习5天速成——第三天事务的使用

2021-10-15 00:25:41

今天是速成的第三天，再分享一下WCF中比较常用的一种技术，也就是”事务“。

在B2B的项目中，一般用户注册后，就有一个属于自己的店铺，此时，我们就要插入两张表, User和Shop表。

当然，要么插入成功，要么全失败。

第一步：首先看一下项目的结构图：

第二步：准备工作，我们新建Commerce数据库，用EF去映射,然后新建ServiceWCF类库，具体步骤就省略，

这一块不懂可以留言。

第三步：新建一个Model类库。建立两个实体类Shop和User，当然自定义类型在WCF中传输，

必须在类上加上【DataContract】，属性上加【DataMember】。

Shop.cs

namespace Model
{
    [DataContract]
    public class Shop
    {
        [DataMember]
        public int ShopID { get; set; }

        [DataMember]
        public int UserID { get; set; }

        [DataMember]
        public string ShopName { get; set; }

        [DataMember]
        public string ShopUrl { get; set; }

    }
}

User.cs

namespace Model
{
    [DataContract]
    public class User
    {
        [DataMember]
        public int UserID { get; set; }

        [DataMember]
        public string UserName { get; set; }

        [DataMember]
        public string Password { get; set; }
    }
}

第四步：然后在ServiceWCF类库中新建两个文件Seller.cs 和 ISeller.cs.

ISeller.cs:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;

namespace ServiceWCF
{
    [ServiceContract]
    public interface ISeller
    {
        [OperationContract(Name = "AddUser")]
        bool Add(Model.User user, out int userID);

        [OperationContract(Name = "AddShop")]
        bool Add(Model.Shop shop, out int shopID);

        [OperationContract]
        bool Add(Model.User user, Model.Shop shop);
    }
}

Seller.cs

namespace ServiceWCF
{
    public class Seller : ISeller
    {
        ///<summary>
/// User的插入操作
///</summary>
///<param name="user"></param>
///<param name="userID"></param>
///<returns></returns>
        public bool Add(Model.User user, out int userID)
        {
            using (CommerceEntities db = new CommerceEntities())
            {
                try
                {
                    User userModel = new User()
                    {
                        UserName = user.UserName,
                        Passwrod = user.Password
                    };

                    db.User.AddObject(userModel);

                    db.SaveChanges();

                    userID = userModel.UserID;

                    return true;
                }
                catch (Exception)
                {
                    userID = 0;
                    throw;
                }
            }
        }

        ///<summary>
/// Shop的插入操作
///</summary>
///<param name="shop"></param>
///<param name="shopID"></param>
///<returns></returns>
        public bool Add(Model.Shop shop, out int shopID)
        {
            using (CommerceEntities db = new CommerceEntities())
            {
                try
                {

                    Shop shopModel = new Shop()
                          {
                              ShopName = shop.ShopName,
                              ShopUrl = shop.ShopUrl,
                              UserID = shop.UserID
                          };

                    db.Shop.AddObject(shopModel);

                    db.SaveChanges();

                    shopID = shopModel.ShopID;

                    return true;
                }
                catch (Exception)
                {
                    shopID = 0;
                    throw;
                }
            }
        }

///<summary>
/// User,Shop的插入的操作
///</summary>
///<param name="user"></param>
///<param name="shop"></param>
///<returns></returns>
        [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
        public bool Add(Model.User user, Model.Shop shop)
        {
            int shopID;
            int UserID;

            //注意，这个方法操作了两个数据库实例，为AddUser和AddShop。所以晋升为分布式事务
            if (Add(user, out  UserID))
            {
                shop.UserID = UserID;

                return Add(shop, out shopID);
            }

            return false;
        }
    }
}

TransactionScopeRequired：告诉ServiceHost自托管服务，进入我的方法，必须给我加上事务。

TransactionAutoComplete: 方法执行中，如果没有抛出异常，则自动提交。

第五步：新建Host来承载了，配置AppConfig，这些细节就不再说了。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace ServiceHost
{
    class Program
    {
        static void Main(string[] args)
        {
            System.ServiceModel.ServiceHost host = new System.ServiceModel.ServiceHost(typeof(ServiceWCF.Seller));

            host.Open();

            Console.WriteLine("WCF 服务已经开启！");

            Console.Read();
        }
    }
}

<?xml version="1.0" encoding="utf-8"?>
<configuration>
  <system.web>
    <compilation debug="true" />
  </system.web>
  <!-- 部署服务库项目时，必须将配置文件的内容添加到 
  主机的 app.config 文件中。System.Configuration 不支持库的配置文件。-->
  <system.serviceModel>
    <services>
      <service name="ServiceWCF.Seller">
        <endpoint address="" binding="wsHttpBinding" contract="ServiceWCF.ISeller">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:8732/Seller/" />
          </baseAddresses>
        </host>
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior>
          <!-- 为避免泄漏元数据信息，
          请在部署前将以下值设置为 false 并删除上面的元数据终结点  -->
          <serviceMetadata httpGetEnabled="True" />
          <!-- 要接收故障异常详细信息以进行调试，
          请将以下值设置为 true。在部署前设置为 false 
            以避免泄漏异常信息-->
          <serviceDebug includeExceptionDetailInFaults="False" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>
  <connectionStrings>
    <add name="CommerceEntities" connectionString="metadata=res://*/Commerce.csdl|res://*/Commerce.ssdl|res://*/Commerce.msl;provider=System.Data.SqlClient;provider connection string="Data Source=VONXCEVF0IT7JDJ;Initial Catalog=Commerce;Integrated Security=True;MultipleActiveResultSets=True"" providerName="System.Data.EntityClient" />
  </connectionStrings>
</configuration>

第六步：开启WCF服务，新建ServiceClient类库，然后用信道生成实例。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using ServiceWCF;

namespace ServiceClient
{
    class Program
    {
        static void Main(string[] args)
        {
            var user = new Model.User()
            {
                UserName = "huangxincheng520",
                Password = "i can fly"
            };

            var shop = new Model.Shop()
            {
                ShopName = "shopex",
                ShopUrl = "http://www.shopex.cn"
            };

            var factory = new ChannelFactory<ISeller>(new WSHttpBinding(),
                                  new EndpointAddress("http://localhost:8732/Seller/"));

            var client = factory.CreateChannel();

            if (client.Add(user, shop))
                Console.WriteLine("huangxincheng520, 恭喜你，数据插入成功。");
            else
                Console.WriteLine("huangxincheng520, 呜呜，数据插入失败。");

            Console.Read();
        }
    }
}

最后就是测试了：

首先：走正常流程。client.Add方法调用服务器端，运行效果如图所示：

是的，数据已经正常插入成功，对Client端而言，这个操作是透明的。

然后：我们在Seller类中的Add方法中故意加入异常。看效果咋样。

///<summary>
/// User,Shop的插入的操作
///</summary>
///<param name="user"></param>
///<param name="shop"></param>
///<returns></returns>
        [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
        public bool Add(Model.User user, Model.Shop shop)
        {
            int shopID;
            int UserID;
            
            if (Add(user, out  UserID))
            {
                //注意注意，我在Adduser成功的情况下，抛出异常，看是否回滚。
                throw new Exception();

                shop.UserID = UserID;

                return Add(shop, out shopID);
            }

            return false;
        }

截图如下：

哈哈，抛出异常了，我的Exception起到效果了，再来看一下数据库。大家都知道会发生什么了，对的，异常不再产生数据了，

还是先前产生了那条数据，说明起到效果了。

码农公寓

相关文章