欢迎光临
我们一直在努力
当前位置：九八云安全 行业资讯 正文

深入分析WCF事务投票实现方式

2024-08-03 分类：行业资讯 阅读(25) 评论(0)

我们知道事务是通过参与方进行WCF事务投票(Voting)来决定 “提交(Complete)” 或者 “回滚(Rollback)” 操作的。默认情况下，WCF 通过 OperationBehavior(TransactionAutoComplete = true) 来完成投票动作。(TransactionAutoComplete = true 是缺省值，不需要显式声明。)

我们将服务方法默认的 TransactionAutoComplete=true 改为 false，看看结果 。


 
    

  
  1. //　----　Service1　-----  
    2. 

  
  2. [ServiceContract(SessionModeSessionMode=SessionMode.Required)]  
    3. 

  
  3. public　interface　IService1  
    4. 

  
  4. {  
    5. 

  
  5. [OperationContract]  
    6. 

  
  6. [TransactionFlow(TransactionFlowOption.Allowed)]  
    7. 

  
  7. void　Test();  
    8. 

  
  8. }  
    9. 

  
  9. public　class　MyService1　:　IService1  
    10. 

  
  10. {  
    11. 

  
  11. [OperationBehavior(TransactionScopeRequired=true,　
    TransactionAutoComplete=false)]  
    12. 

  
  12. public　void　Test()  
    13. 

  
  13. {  
    14. 

  
  14. string　connStr　=　"server=(local);uid=sa;pwd=sa;database=temp";  
    15. 

  
  15. using　(SqlConnection　conn　=　new　SqlConnection(connStr))  
    16. 

  
  16. {  
    17. 

  
  17. conn.Open();  
    18. 

  
  18. SqlCommand　cmd　=　new　SqlCommand("insert　into　[User]　
    ([name])　values　(@name)",　  
    19. 

  
  19. conn);  
    20. 

  
  20. cmd.Parameters.Add(new　SqlParameter("@name",　"ZhangSan"));  
    21. 

  
  21. cmd.ExecuteNonQuery();  
    22. 

  
  22. }  
    23. 

  
  23. }  
    24. 

  
  24. }  
    25. 

  
  25. //　----　Service2　-----  
    26. 

  
  26. [ServiceContract(SessionMode　=　SessionMode.Required)]  
    27. 

  
  27. public　interface　IService2  
    28. 

  
  28. {  
    29. 

  
  29. [OperationContract]  
    30. 

  
  30. [TransactionFlow(TransactionFlowOption.Allowed)]  
    31. 

  
  31. void　Test();  
    32. 

  
  32. }  
    33. 

  
  33. public　class　MyService2　:　IService2  
    34. 

  
  34. {  
    35. 

  
  35. [OperationBehavior(TransactionScopeRequired　=　true,　
    TransactionAutoComplete　=　false)]  
    36. 

  
  36. public　void　Test()  
    37. 

  
  37. {  
    38. 

  
  38. string　connStr　=　"server=(local);uid=sa;pwd=sa;database=temp";  
    39. 

  
  39. using　(SqlConnection　conn　=　new　SqlConnection(connStr))  
    40. 

  
  40. {  
    41. 

  
  41. conn.Open();  
    42. 

  
  42. SqlCommand　cmd　=　new　SqlCommand("insert　into　Account　([user],　
    [money])　values　(@user,　@money)",　  
    43. 

  
  43. conn);  
    44. 

  
  44. cmd.Parameters.Add(new　SqlParameter("@user",　"ZhangSan"));  
    45. 

  
  45. cmd.Parameters.Add(new　SqlParameter("@money",　100));  
    46. 

  
  46. cmd.ExecuteNonQuery();  
    47. 

  
  47. }  
    48. 

  
  48. }  
    49. 

  
  49. }  
    50. 

  
  50. public　class　WcfTest  
    51. 

  
  51. {  
    52. 

  
  52. public　static　void　Test()  
    53. 

  
  53. {  
    54. 

  
  54. //　----　Host　-----  
    55. 

  
  55. AppDomain.CreateDomain("Server").DoCallBack(delegate  
    56. 

  
  56. {  
    57. 

  
  57. NetTcpBinding　bindingServer　=　new　NetTcpBinding();  
    58. 

  
  58. bindingServer.TransactionFlow　=　true;  
    59. 

  
  59. ServiceHost　host1　=　new　ServiceHost(typeof(MyService1),　
    new　Uri("net.tcp://localhost:8080"));  
    60. 

  
  60. host1.AddServiceEndpoint(typeof(IService1),　bindingServer,　"");  
    61. 

  
  61. host1.Open();  
    62. 

  
  62. ServiceHost　host2　=　new　ServiceHost(typeof(MyService2),　
    new　Uri("net.tcp://localhost:8081"));  
    63. 

  
  63. host2.AddServiceEndpoint(typeof(IService2),　bindingServer,　"");  
    64. 

  
  64. host2.Open();  
    65. 

  
  65. });  
    66. 

  
  66. //　----　Client　-----  
    67. 

  
  67. NetTcpBinding　bindingClient　=　new　NetTcpBinding();  
    68. 

  
  68. bindingClient.TransactionFlow　=　true;  
    69. 

  
  69. IService1　client1　=　ChannelFactory<IService1>.CreateChannel(bindingClient,　  
    70. 

  
  70. new　EndpointAddress("net.tcp://localhost:8080"));  
    71. 

  
  71. IService2　client2　=　ChannelFactory<IService2>.CreateChannel(bindingClient,　  
    72. 

  
  72. new　EndpointAddress("net.tcp://localhost:8081"));  
    73. 

  
  73. using　(TransactionScope　scope　=　new　TransactionScope())  
    74. 

  
  74. {  
    75. 

  
  75. try  
    76. 

  
  76. {  
    77. 

  
  77. client1.Test();  
    78. 

  
  78. client2.Test();  
    79. 

  
  79. scope.Complete();  
    80. 

  
  80. }  
    81. 

  
  81. finally  
    82. 

  
  82. {  
    83. 

  
  83. (client1　as　IDisposable).Dispose();  
    84. 

  
  84. (client2　as　IDisposable).Dispose();  
    85. 

  
  85. }  
    86. 

  
  86. }  
    87. 

  
  87. }  
    88. 

  
  88. } 
    89.

运行结果表明事务无法提交，触发 TransactionAbortedException 异常，显示 “事务终止”。那么除了默认被称之为 “声明投票(Declarative voting)” 的方式外，我们还能怎么做？OperationContext 有个 SetTransactionComplete() 方法，允许我们在代码中完成WCF事务投票行为。这种投票方式更加灵活，便于我们在代码中做出更多的控制，被称之为 “显式投票(Explicit voting)”。

在上面两个 Test() 方法的***一行，添加 “OperationContext.Current.SetTransactionComplete();”，再次运行，事务被正确提交。


 
    

  
  1. [OperationBehavior(TransactionScopeRequired=true,　
    TransactionAutoComplete=false)]  
    2. 

  
  2. public　void　Test()  
    3. 

  
  3. {  
    4. 

  
  4. //　...  
    5. 

  
  5. OperationContext.Current.SetTransactionComplete();  
    6. 

  
  6. }　  
    7. 

  
  7. ... 
    8.

接下来，我们设想另外一种情况。事务不由 Client 发起，在 Service1.Test() 调用 Service2.Test()，那么事务会是个什么样子呢？Service1、Service2 的参数 “OperationBehavior(TransactionScopeRequired = true)” 决定了如果没有外界传入的环境事务，那么会自动创建一个根事务。所以 Service1.Test() 会创建一个根事务，而 Service2.Test() 会参与这个事务。可问题在于 Service.Test() 中并没有显示调用 Transaction.Complete，事务能被提交吗？


 
    

  
  1. //　----　Service1　-----  
    2. 

  
  2. [ServiceContract]  
    3. 

  
  3. public　interface　IService1  
    4. 

  
  4. {  
    5. 

  
  5. [OperationContract]  
    6. 

  
  6. [TransactionFlow(TransactionFlowOption.Allowed)]  
    7. 

  
  7. void　Test();  
    8. 

  
  8. }  
    9. 

  
  9. public　class　MyService1　:　IService1  
    10. 

  
  10. {  
    11. 

  
  11. [OperationBehavior(TransactionScopeRequired=true)]  
    12. 

  
  12. public　void　Test()  
    13. 

  
  13. {  
    14. 

  
  14. string　connStr　=　"server=(local);uid=sa;pwd=sa;database=temp";  
    15. 

  
  15. using　(SqlConnection　conn　=　new　SqlConnection(connStr))  
    16. 

  
  16. {  
    17. 

  
  17. conn.Open();  
    18. 

  
  18. SqlCommand　cmd　=　new　SqlCommand("insert　into　[User]　
    ([name])　values　(@name)",　  
    19. 

  
  19. conn);  
    20. 

  
  20. cmd.Parameters.Add(new　SqlParameter("@name",　"ZhangSan"));  
    21. 

  
  21. cmd.ExecuteNonQuery();  
    22. 

  
  22. }  
    23. 

  
  23. InvokeService2();  
    24. 

  
  24. }  
    25. 

  
  25. public　void　InvokeService2()  
    26. 

  
  26. {  
    27. 

  
  27. NetTcpBinding　bindingClient　=　new　NetTcpBinding();  
    28. 

  
  28. bindingClient.TransactionFlow　=　true;  
    29. 

  
  29. IService2　client2　=　ChannelFactory<IService2>.CreateChannel
    (bindingClient,　  
    30. 

  
  30. new　EndpointAddress("net.tcp://localhost:8081"));  
    31. 

  
  31. using　(client2　as　IDisposable)  
    32. 

  
  32. {  
    33. 

  
  33. client2.Test();  
    34. 

  
  34. }  
    35. 

  
  35. }  
    36. 

  
  36. }  
    37. 

  
  37. //　----　Service2　-----  
    38. 

  
  38. [ServiceContract]  
    39. 

  
  39. public　interface　IService2  
    40. 

  
  40. {  
    41. 

  
  41. [OperationContract]  
    42. 

  
  42. [TransactionFlow(TransactionFlowOption.Allowed)]  
    43. 

  
  43. void　Test();  
    44. 

  
  44. }  
    45. 

  
  45. public　class　MyService2　:　IService2  
    46. 

  
  46. {  
    47. 

  
  47. [OperationBehavior(TransactionScopeRequired　=　true)]  
    48. 

  
  48. public　void　Test()  
    49. 

  
  49. {  
    50. 

  
  50. string　connStr　=　"server=(local);uid=sa;pwd=sa;database=temp";  
    51. 

  
  51. using　(SqlConnection　conn　=　new　SqlConnection(connStr))  
    52. 

  
  52. {  
    53. 

  
  53. conn.Open();  
    54. 

  
  54. SqlCommand　cmd　=　new　SqlCommand("insert　into　Account　
    ([user],　[money])　values　(@user,　@money)",　  
    55. 

  
  55. conn);  
    56. 

  
  56. cmd.Parameters.Add(new　SqlParameter("@user",　"ZhangSan"));  
    57. 

  
  57. cmd.Parameters.Add(new　SqlParameter("@money",　100));  
    58. 

  
  58. cmd.ExecuteNonQuery();  
    59. 

  
  59. }  
    60. 

  
  60. }  
    61. 

  
  61. }  
    62. 

  
  62. public　class　WcfTest  
    63. 

  
  63. {  
    64. 

  
  64. public　static　void　Test()  
    65. 

  
  65. {  
    66. 

  
  66. //　----　Host　-----  
    67. 

  
  67. AppDomain.CreateDomain("Server").DoCallBack(delegate  
    68. 

  
  68. {  
    69. 

  
  69. NetTcpBinding　bindingServer　=　new　NetTcpBinding();  
    70. 

  
  70. bindingServer.TransactionFlow　=　true;  
    71. 

  
  71. ServiceHost　host1　=　new　ServiceHost(typeof(MyService1),　
    new　Uri("net.tcp://localhost:8080"));  
    72. 

  
  72. host1.AddServiceEndpoint(typeof(IService1),　bindingServer,　"");  
    73. 

  
  73. host1.Open();  
    74. 

  
  74. ServiceHost　host2　=　new　ServiceHost(typeof(MyService2),　
    new　Uri("net.tcp://localhost:8081"));  
    75. 

  
  75. host2.AddServiceEndpoint(typeof(IService2),　bindingServer,　"");  
    76. 

  
  76. host2.Open();  
    77. 

  
  77. });  
    78. 

  
  78. //　----　Client　-----  
    79. 

  
  79. NetTcpBinding　bindingClient　=　new　NetTcpBinding();  
    80. 

  
  80. bindingClient.TransactionFlow　=　true;  
    81. 

  
  81. IService1　client1　=　ChannelFactory<IService1>.CreateChannel
    (bindingClient,　  
    82. 

  
  82. new　EndpointAddress("net.tcp://localhost:8080"));  
    83. 

  
  83. try  
    84. 

  
  84. {  
    85. 

  
  85. client1.Test();  
    86. 

  
  86. }  
    87. 

  
  87. finally  
    88. 

  
  88. {  
    89. 

  
  89. (client1　as　IDisposable).Dispose();  
    90. 

  
  90. }  
    91. 

  
  91. }  
    92. 

  
  92. } 
    93.

运行结果表明，事务被正确提交。看来这和客户端使用 TransactionScope 必须显式调用 Complete() 有所不同。同样，如果将 Service2.Test() 设为 TransactionAutoComplete=false，在不调用 “OperationContext.Current.SetTransactionComplete();” 的情况下，也会触发事务失败异常。

以上就是我们为大家介绍的WCF事务投票的相关实现方法。

【编辑推荐】

  1. WCF MSMQ队列基本概念简述
  2. PDA访问WCF实现重点在过程
  3. WCF标准终结点基本概念剖析
  4. WCF回调操作是鸡应用技巧讲解
  5. WCF元数据交换应用技巧分享

赞(0) 打赏
未经允许不得转载：九八云安全 » 深入分析WCF事务投票实现方式
分享到

相关推荐

评论 抢沙发

取消

攻防案列