日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
深入分析WCF事務(wù)投票實現(xiàn)方式

我們知道事務(wù)是通過參與方進(jìn)行WCF事務(wù)投票(Voting)來決定 "提交(Complete)" 或者 "回滾(Rollback)" 操作的。默認(rèn)情況下，WCF 通過 OperationBehavior(TransactionAutoComplete = true) 來完成投票動作。(TransactionAutoComplete = true 是缺省值，不需要顯式聲明。)

堅守“ 做人真誠 · 做事靠譜 · 口碑至上 · 高效敬業(yè) ”的價值觀，專業(yè)網(wǎng)站建設(shè)服務(wù)10余年為成都成都自拌料攪拌車小微創(chuàng)業(yè)公司專業(yè)提供企業(yè)網(wǎng)站建設(shè)營銷網(wǎng)站建設(shè)商城網(wǎng)站建設(shè)手機(jī)網(wǎng)站建設(shè)小程序網(wǎng)站建設(shè)網(wǎng)站改版，從內(nèi)容策劃、視覺設(shè)計、底層架構(gòu)、網(wǎng)頁布局、功能開發(fā)迭代于一體的高端網(wǎng)站建設(shè)服務(wù)。

我們將服務(wù)方法默認(rèn)的 TransactionAutoComplete=true 改為 false，看看結(jié)果 。

 
 
 
    
  
  
  
  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.CreateChannel(bindingClient,　 
    70. 
  
  
  
  70. new　EndpointAddress("net.tcp://localhost:8080")); 
    71. 
  
  
  
  71. IService2　client2　=　ChannelFactory.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.

運(yùn)行結(jié)果表明事務(wù)無法提交，觸發(fā) TransactionAbortedException 異常，顯示 "事務(wù)終止"。那么除了默認(rèn)被稱之為 "聲明投票(Declarative voting)" 的方式外，我們還能怎么做？OperationContext 有個 SetTransactionComplete() 方法，允許我們在代碼中完成WCF事務(wù)投票行為。這種投票方式更加靈活，便于我們在代碼中做出更多的控制，被稱之為 "顯式投票(Explicit voting)"。

在上面兩個 Test() 方法的***一行，添加 "OperationContext.Current.SetTransactionComplete();"，再次運(yùn)行，事務(wù)被正確提交。

 
 
 
    
  
  
  
  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.

接下來，我們設(shè)想另外一種情況。事務(wù)不由 Client 發(fā)起，在 Service1.Test() 調(diào)用 Service2.Test()，那么事務(wù)會是個什么樣子呢？Service1、Service2 的參數(shù) "OperationBehavior(TransactionScopeRequired = true)" 決定了如果沒有外界傳入的環(huán)境事務(wù)，那么會自動創(chuàng)建一個根事務(wù)。所以 Service1.Test() 會創(chuàng)建一個根事務(wù)，而 Service2.Test() 會參與這個事務(wù)。可問題在于 Service.Test() 中并沒有顯示調(diào)用 Transaction.Complete，事務(wù)能被提交嗎？

 
 
 
    
  
  
  
  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.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.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.

運(yùn)行結(jié)果表明，事務(wù)被正確提交?？磥磉@和客戶端使用 TransactionScope 必須顯式調(diào)用 Complete() 有所不同。同樣，如果將 Service2.Test() 設(shè)為 TransactionAutoComplete=false，在不調(diào)用 "OperationContext.Current.SetTransactionComplete();" 的情況下，也會觸發(fā)事務(wù)失敗異常。

以上就是我們?yōu)榇蠹医榻B的WCF事務(wù)投票的相關(guān)實現(xiàn)方法。


網(wǎng)站名稱：深入分析WCF事務(wù)投票實現(xiàn)方式
鏈接URL：http://www.dlmjj.cn/article/dpgdghs.html