序列化和反序列化,异步调用web/wcf/函数

时间:2023-03-09 02:32:59
序列化和反序列化,异步调用web/wcf/函数
  1. //xml序列化
  2. public static string Seria(DataSet ds)
  3. {
  4. XmlSerializer serializer = new XmlSerializer(typeof(DataSet));
  5. StringBuilder sb = new StringBuilder();
  6. XmlWriter writer = XmlWriter.Create(sb);
  7. serializer.Serialize(writer, ds);
  8. return sb.ToString();
  9. }
  10. //xml反序列化
  11. public static DataSet DeSeria(string sb)
  12. {
  13. XmlSerializer serializer = new XmlSerializer(typeof(DataSet));
  14. StringReader sr = new StringReader(sb);
  15. XmlReader xr = XmlReader.Create(sr);
  16. DataSet ds = (DataSet)serializer.Deserialize(xr);
  17. return ds;
  18. }
  19. public static string Seria<T>(T ds)
  20. {
  21. XmlSerializer serializer = new XmlSerializer(typeof(T));
  22. StringBuilder sb = new StringBuilder();
  23. XmlWriter writer = XmlWriter.Create(sb);
  24. serializer.Serialize(writer, ds);
  25. return sb.ToString();
  26. }
  27. //xml反序列化
  28. public static T DeSeria<T>(string sb)
  29. {
  30. XmlSerializer serializer = new XmlSerializer(typeof(T));
  31. StringReader sr = new StringReader(sb);
  32. XmlReader xr = XmlReader.Create(sr);
  33. T ds = (T)serializer.Deserialize(xr);
  34. return ds;
  35. }

核心测试代码:

  1. private void butCallWebservice1_Click(object sender, EventArgs e)
  2. {
  3. ServiceReference1.WebService1SoapClient wc = new ServiceReference1.WebService1SoapClient();
  4. string ret = wc.HelloWorld();
  5. MessageBox.Show("web服务返回值:"+ret);
  6. }
  7. public int add(int a, int b)
  8. {
  9. System.Threading.Thread.Sleep(4000);//耗时的操作
  10. return a + b;
  11. }
  12. public delegate int defun(int a,int b);//定义一个委托
  13. public void f2()
  14. {
  15. MessageBox.Show(DateTime.Now.ToString());
  16. }
  17. private void btnTestseria_Click(object sender, EventArgs e)
  18. {
  19. DataSet ds = new DataSet();
  20. DataTable dt = new DataTable();
  21. dt.Columns.Add("id",typeof(string));
  22. dt.Columns.Add("name", typeof(string));
  23. dt.Columns.Add("age", typeof(int));
  24. DataRow dr = dt.NewRow();
  25. dr["id"] = "1";
  26. dr["name"] = "testname1";
  27. dr["age"] = 22;
  28. dt.Rows.Add(dr);
  29. ds.Tables.Add(dt);
  30. string s= Common.Common.Seria(ds);//DataSet序列化和反序列化
  31. DataSet dsde = Common.Common.DeSeria(s);
  32. MessageBox.Show(s+"\n "+ds.Tables[0].Rows.Count);
  33. List<Student> list=new List<Student>();
  34. list.Add(new Student("2","testname2",25));
  35. string s2 = Common.Common.Seria<List<Student>>(list);
  36. List<Student> listde = Common.Common.DeSeria<List<Student>>(s2);
  37. MessageBox.Show(s2+" \n "+listde.Count);//List<对象>序列化和反序列化
  38. }
  39. private void btnCall1_Click(object sender, EventArgs e)
  40. {
  41. f2();
  42. }
  43. private void btnAsynCall2_Click(object sender, EventArgs e)
  44. {
  45. //异步调用
  46. defun objDe = new defun(add);
  47. IAsyncResult Iasyn = objDe.BeginInvoke(12, 34, null, null);
  48. int re = objDe.EndInvoke(Iasyn);//这里会阻塞线程
  49. MessageBox.Show("异步调用返回结果:" + re);
  50. }
  51. defun objDe2 = null;
  52. bool isCalling = false;
  53. /// <summary>
  54. /// 自动回调方式调用函数
  55. /// </summary>
  56. /// <param name="sender"></param>
  57. /// <param name="e"></param>
  58. private void btnAsynCall3_Click(object sender, EventArgs e)
  59. {
  60. if (isCalling == false)
  61. {
  62. objDe2 = new defun(add);
  63. AsyncCallback AsynCallback = new AsyncCallback(AsynCallbackfun);
  64. isCalling = true;
  65. objDe2.BeginInvoke(23, 45, AsynCallback, null);//完成后自动触发回调函数,不会阻塞线程
  66. }
  67. }
  68. void AsynCallbackfun(IAsyncResult Iasy)//异步回调函数
  69. {
  70. if (objDe2 != null)
  71. {
  72. int re = objDe2.EndInvoke(Iasy);//这里会阻塞线程
  73. isCalling = false;
  74. MessageBox.Show("异步调用返回结果:" + re);
  75. }
  76. }
  77. void AsynCallbackfun2(IAsyncResult Iasy)//异步回调函数
  78. {
  79. if (objService != null)
  80. {
  81. string re = objService.EndGetData(Iasy);//这里会阻塞线程
  82. isCalling2 = false;
  83. MessageBox.Show("Wcf异步调用返回结果:" + re);
  84. }
  85. }
  86. ServiceReference2.WcfService2Client objService = null;
  87. bool isCalling2 = false;
  88. /// <summary>
  89. /// 自动回调方法调用WCF/Web 服务
  90. /// </summary>
  91. /// <param name="sender"></param>
  92. /// <param name="e"></param>
  93. private void btnWcfAsynCall1_Click(object sender, EventArgs e)
  94. {
  95. if (isCalling2 == false)
  96. {
  97. objService = new ServiceReference2.WcfService2Client();
  98. AsyncCallback AsynCallback = new AsyncCallback(AsynCallbackfun2);
  99. isCalling2 = true;
  100. //添加引用时在“高级”中选择“允许生成异步操作”
  101. //或者在已有的服务引用上“配置服务引用”
  102. objService.BeginGetData
  103. (AsynCallback, null);
  104. }
  105. }
示例源代码下载:http://download.****.net/detail/pukuimin1226/6953713