wcf事务

wcf服务

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

namespace MyWcfService
{
    // 注意: 使用“重构”菜单上的“重命名”命令,可以同时更改代码和配置文件中的接口名“IService1”。
    [ServiceContract]
    public interface IService1
    {
        [OperationContract]
        [TransactionFlow(TransactionFlowOption.Allowed)]
        string ExecuteSql(string value);
    }

}

  

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

namespace MyWcfService
{

    [ServiceBehavior(ReleaseServiceInstanceOnTransactionComplete = false, InstanceContextMode = InstanceContextMode.PerCall)]
    public class Service1 : IService1
    {

        [OperationBehavior(TransactionAutoComplete = true, TransactionScopeRequired = true)]
        public string ExecuteSql(string value)
        {

            SqlHelper sql = new SqlHelper();
            return sql.ExecuteNonQuery(value).ToString();//如果是mysql帮助文档中的此方法,会报错,因为mysql数据库不支持分布式事务
        }

    }
}

  宿主serviceHost

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

namespace serviceHost
{
    class Program
    {
        static void Main(string[] args)
        {
            ServiceHost host = new ServiceHost(typeof(Service1));
            host.Open();
            Console.WriteLine("open");
            Console.ReadKey();
        }
    }
}

  宿主的配置文件

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
	<system.serviceModel>
		<behaviors>
			<serviceBehaviors>
				<behavior name="serviceDebuBehavior">
					<!--可以在客户端获取异常-->
					<serviceDebug includeExceptionDetailInFaults="true" />
				</behavior>
			</serviceBehaviors>
		</behaviors>
		<services>
			<service name="MyWcfService.Service1" behaviorConfiguration="serviceDebuBehavior">
				<!--以上异常配置-->
				<endpoint address="net.tcp://127.0.0.1:3721/calculatorservice"
						  binding="netTcpBinding"
						  contract="MyWcfService.IService1"
						  bindingConfiguration="transactionBinding"
						  />
			</service>
		</services>
		<bindings>
			<netTcpBinding>
				<!--transactionFlow=true 开启事务  必须配置,而且宿主和客户端都要配置-->
				<binding name="transactionBinding"  transactionFlow="true" >
					<reliableSession  enabled="true"/>
					<security></security>

				</binding>

			</netTcpBinding>

		</bindings>
	</system.serviceModel>
</configuration>

  //客户端 调用者ClinetAPP

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Transactions;
using MyWcfService;

namespace ClinetAPP
{
    class Program
    {
        static void Main(string[] args)
        {

            ChannelFactory<IService1> channl = new ChannelFactory<IService1>("WcfService");
            try
            {
                IService1 service = channl.CreateChannel();
                using (TransactionScope trans = new TransactionScope())
                {
                    string sql1 = "insert into demo values(‘1‘,‘2‘)";
                    string sql2 = "update demo set pwd2=‘2‘";
                    string s1 = service.ExecuteSql(sql1);
                    string s2 = service.ExecuteSql(sql2);
                    Console.WriteLine(s1 + s2);
                    Console.ReadKey();
                    trans.Complete();//此处提交事务。如果没有执行此方法,事务就会回滚。
                }
            }
            catch (Exception ex)
            {

            }
        }
    }
}

  //客户端配置文件

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
	<system.serviceModel>
		<client>

			<endpoint  name="WcfService" address="net.tcp://127.0.0.1:3721/calculatorservice"
					  binding="netTcpBinding"
					  contract="MyWcfService.IService1"
					     bindingConfiguration="transactionBinding"/>
		</client>
		<bindings>
			<netTcpBinding>
				<binding name="transactionBinding" transactionFlow="true" >
					<reliableSession  enabled="true"/>
					<security></security>

				</binding>

			</netTcpBinding>

		</bindings>
	</system.serviceModel>
</configuration>

  

wcf事务

时间: 2024-10-21 15:12:48

wcf事务的相关文章

WCF分布式开发步步为赢(12):WCF事务机制(Transaction)和分布式事务编程

今天我们继续学习WCF分布式开发步步为赢系列的12节:WCF事务机制(Transaction)和分布式事务编程.众所周知,应用系统开发过程中,事务是一个重要的概念.它是保证数据与服务可靠性的重要机制. 作为面向服务应用的开发平台,WCF也提供了对事物编程模型的支持..NET 2.0提供的System.Transactions类来开发事务应用程序.同样WCF也支持事务特性,WCF事务机制是什么,它与微软已有的技术如Microsoft 分布式事务协调器 (MSDTC)有何关系?与Enterpise

WCF入门(十)---WCF事务

事务处理在WCF(Windows Communication Foundation)是一套遵循一些性质,统称为ACID的操作.这里,如果一个操作出现故障,整个系统就会自动失败.如网上订单生成,就可能使用事务.下面的例子可以帮助理解事务的过程中更简单的术语. 例子 假设一台液晶电视是您从在线商店订购,你会通过信用卡支付的金额.当输入必要的信息来下订单,同时出现两个操作.一个特定的量被从您的银行账户中扣除,第二是供应商贷记相同.两个操作必须以有一个成功的事务成功执行. WCF事务属性 WCF事务有以

本地事务和分布式事务工作实践 【转】

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo

跟我一起学WCF(10)——WCF中事务处理

一.引言 好久没更新,总感觉自己欠了什么一样的,所以今天迫不及待地来更新了,因为后面还有好几个系列准备些,还有很多东西需要学习总结的.今天就来介绍下WCF对事务的支持. 二.WCF事务详解 2.1 事务概念与属性 首先,大家在学习数据库的时候就已经接触到事务这个概念了.所谓事务,它是一个操作序列,这些操作要么都执行,要么都不执行,它是一个不可分割的工作单元.例如,银行转账功能,这个功能涉及两个逻辑操作 从一个账户A中扣钱 另一个账户B增加对应的钱. 现实生活中,这两个操作需要要么都执行,要么都不

本地事务和分布式事务工作实践

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo

本地事务和分布式事务工作实践 [转]

一:从事务的历史说起 知已知彼,百战不败.想了解事务,我们从事务的历史说起. 在Windows平台上,事务的概念最开始出现在关系型数据库中,但是随着.net平台的发展,事务包括的的范围也越来越宽,先一睹为快, 在关系型数据库中的事务是通过begin transaction,rollback transaction, commit 等关键字来实现事务的. BEGIN TRANSACTION  UPDATE [dbo].[T_ACCOUNT] SET BALANCE = BALANCE + @amo

跟我一起学WCF(13)——WCF系列总结

引言 WCF是微软为了实现SOA的框架,它是对微乳之前多种分布式技术的继承和扩展,这些技术包括Enterprise Service..NET Remoting.XML Web Service.MSMQ等.WCF推出的原因在于:微软想将不同的分布式技术整合起来,提供一个统一的编程模型,这样对于开发者来说绝对是好事.在过去的2个月时间内,我陆续写了WCF系列文章,这些文章只是自己这段时间学习WCF内容的一个学习过程和笔记,希望通过这种写博文的方式记录下来和总结.本系列并没有对WCF机制做一个深入解析

快速入门系列--WCF--06并发限流、可靠会话和队列服务

这部分将介绍一些相对深入的知识点,包括通过并发限流来保证服务的可用性,通过可靠会话机制保证会话信息的可靠性,通过队列服务来解耦客户端和服务端,提高系统的可服务数量并可以起到削峰的作用,最后还会对之前的事务知识做一定补充. 对于WCF服务来说,其寄宿在一个资源有限的环境中,为了实现服务性能最大化,需要提高其吞吐量即服务的并发性.然而在不进行流量控制的情况下,并发量过多,会使整个服务由于资源耗尽而崩溃.因此为相对平衡的并发数和系统可用性,需要设计一个闸门(Throttling)控制并发的数量. 由于

WCF学习--Windows事务系统

最近开始WCF相关知识的学习,虽然实际工作中使用公司自己的一套SOA系统,但微软的一套服务架构还是具有很大的参考意义.除了WCF的一些基础使用,相对比较复杂的内容有分布式的事务和通信的安全等,不过基本都和WS-协议簇相关联.为了引出WCF中的事务处理,今天优先介绍Windows下的事务处理模型,说实话用了很多年的TransactionScope,其实我一直都不知道它到底是如何运作的,回想Java中不管是EJB还是Spring也有和这部分类似的实现.今天通过学习蒋金楠老师的WCF服务框架解析来了解