一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - C# - WCF實現進程間管道通信Demo分享

WCF實現進程間管道通信Demo分享

2022-02-16 15:40秋荷雨翔 C#

下面小編就為大家分享一篇WCF實現進程間管道通信Demo,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧

一、代碼結構:

WCF實現進程間管道通信Demo分享

二、數據實體類:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
using system;
using system.collections.generic;
using system.linq;
using system.runtime.serialization;
using system.text;
using system.threading.tasks;
 
namespace datastruct
{
 /// <summary>
 /// 測試數據實體類
 /// </summary>
 [datacontract]
 public class testdata
 {
  [datamember]
  public double x { get; set; }
 
  [datamember]
  public double y { get; set; }
 }
}

三、服務端服務接口和實現:

接口:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
using system;
using system.collections.generic;
using system.linq;
using system.servicemodel;
using system.text;
using system.threading.tasks;
using datastruct;
 
namespace wcfserver
{
 /// <summary>
 /// 服務接口
 /// </summary>
 [servicecontract]
 public interface iclientserver
 {
  /// <summary>
  /// 計算(測試方法)
  /// </summary>
  [operationcontract]
  double calculate(testdata data);
 }
}

實現:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
using system;
using system.collections.generic;
using system.linq;
using system.servicemodel;
using system.text;
using system.threading.tasks;
using datastruct;
 
namespace wcfserver
{
 /// <summary>
 /// 服務實現
 /// </summary>
 [servicebehavior()]
 public class clientserver : iclientserver
 {
  /// <summary>
  /// 計算(測試方法)
  /// </summary>
  public double calculate(testdata data)
  {
   return math.pow(data.x, data.y);
  }
 }
}

四、服務端啟動服務:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
using system;
using system.collections.generic;
using system.componentmodel;
using system.data;
using system.drawing;
using system.linq;
using system.servicemodel;
using system.servicemodel.description;
using system.text;
using system.threading.tasks;
using system.windows.forms;
using utils;
using wcfserver;
 
namespace 服務端
{
 public partial class form1 : form
 {
  public form1()
  {
   initializecomponent();
  }
 
  private void form1_load(object sender, eventargs e)
  {
   backwork.run(() =>
   {
    openclientserver();
   }, null, (ex) =>
   {
    messagebox.show(ex.message);
   });
  }
 
  /// <summary>
  /// 啟動服務
  /// </summary>
  private void openclientserver()
  {
   netnamedpipebinding wshttp = new netnamedpipebinding();
   wshttp.maxbufferpoolsize = 524288;
   wshttp.maxreceivedmessagesize = 2147483647;
   wshttp.readerquotas.maxarraylength = 6553600;
   wshttp.readerquotas.maxstringcontentlength = 2147483647;
   wshttp.readerquotas.maxbytesperread = 6553600;
   wshttp.readerquotas.maxdepth = 6553600;
   wshttp.readerquotas.maxnametablecharcount = 6553600;
   wshttp.closetimeout = new timespan(0, 1, 0);
   wshttp.opentimeout = new timespan(0, 1, 0);
   wshttp.receivetimeout = new timespan(0, 10, 0);
   wshttp.sendtimeout = new timespan(0, 10, 0);
   wshttp.security.mode = netnamedpipesecuritymode.none;
 
   uri baseaddress = new uri("net.pipe://localhost/pipename1");
   servicehost host = new servicehost(typeof(clientserver), baseaddress);
 
   servicemetadatabehavior smb = new servicemetadatabehavior();
   host.description.behaviors.add(smb);
 
   servicebehaviorattribute sba = host.description.behaviors.find<servicebehaviorattribute>();
   sba.maxitemsinobjectgraph = 2147483647;
 
   host.addserviceendpoint(typeof(iclientserver), wshttp, "");
 
   host.open();
  }
 }
}

五、客戶端數據實體類和服務接口類與服務端相同

六、客戶端服務實現:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
using datastruct;
using system;
using system.collections.generic;
using system.linq;
using system.servicemodel;
using system.servicemodel.description;
using system.text;
using system.threading.tasks;
using wcfserver;
 
namespace dataservice
{
 /// <summary>
 /// 服務實現
 /// </summary>
 public class clientserver : iclientserver
 {
  channelfactory<iclientserver> channelfactory;
  iclientserver proxy;
 
  public clientserver()
  {
   createchannel();
  }
 
  /// <summary>
  /// 創建連接客戶終端wcf服務的通道
  /// </summary>
  public void createchannel()
  {
   string url = "net.pipe://localhost/pipename1";
   netnamedpipebinding wshttp = new netnamedpipebinding();
   wshttp.maxbufferpoolsize = 524288;
   wshttp.maxreceivedmessagesize = 2147483647;
   wshttp.readerquotas.maxarraylength = 6553600;
   wshttp.readerquotas.maxstringcontentlength = 2147483647;
   wshttp.readerquotas.maxbytesperread = 6553600;
   wshttp.readerquotas.maxdepth = 6553600;
   wshttp.readerquotas.maxnametablecharcount = 6553600;
   wshttp.sendtimeout = new timespan(0, 10, 0);
   wshttp.security.mode = netnamedpipesecuritymode.none;
 
   channelfactory = new channelfactory<iclientserver>(wshttp, url);
   foreach (operationdescription op in channelfactory.endpoint.contract.operations)
   {
    datacontractserializeroperationbehavior datacontractbehavior = op.behaviors.find<datacontractserializeroperationbehavior>() as datacontractserializeroperationbehavior;
 
    if (datacontractbehavior != null)
    {
     datacontractbehavior.maxitemsinobjectgraph = 2147483647;
    }
   }
  }
 
  /// <summary>
  /// 計算(測試方法)
  /// </summary>
  public double calculate(testdata data)
  {
   proxy = channelfactory.createchannel();
 
   try
   {
    return proxy.calculate(data);
   }
   catch (exception ex)
   {
    throw ex;
   }
   finally
   {
    (proxy as icommunicationobject).close();
   }
  }
 }
}

七、客戶端調用服務接口:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
using dataservice;
using datastruct;
using system;
using system.collections.generic;
using system.componentmodel;
using system.data;
using system.drawing;
using system.linq;
using system.text;
using system.threading.tasks;
using system.windows.forms;
using utils;
using wcfserver;
 
namespace 客戶端
{
 public partial class form1 : form
 {
  public form1()
  {
   initializecomponent();
  }
 
  //測試1
  private void button1_click(object sender, eventargs e)
  {
   button1.enabled = false;
   txtsum.text = string.empty;
 
   iclientserver client = new clientserver();
   double num1;
   double num2;
   double sum = 0;
   if (double.tryparse(txtnum1.text, out num1) && double.tryparse(txtnum2.text, out num2))
   {
    datetime dt = datetime.now;
    backwork.run(() =>
    {
     sum = client.calculate(new testdata(num1, num2));
    }, () =>
    {
     double time = datetime.now.subtract(dt).totalseconds;
     txttime.text = time.tostring();
     txtsum.text = sum.tostring();
     button1.enabled = true;
    }, (ex) =>
    {
     button1.enabled = true;
     messagebox.show(ex.message);
    });
   }
   else
   {
    button1.enabled = true;
    messagebox.show("請輸入合法的數據");
   }
  }
 
  //測試2
  private void button2_click(object sender, eventargs e)
  {
   button2.enabled = false;
   txtsum.text = string.empty;
 
   iclientserver client = new clientserver();
   double num1;
   double num2;
   double sum = 0;
   if (double.tryparse(txtnum1.text, out num1) && double.tryparse(txtnum2.text, out num2))
   {
    datetime dt = datetime.now;
    backwork.run(() =>
    {
     for (int i = 0; i < 1000; i++)
     {
      sum = client.calculate(new testdata(num1, num2));
     }
    }, () =>
    {
     double time = datetime.now.subtract(dt).totalseconds;
     txttime.text = time.tostring();
     txtsum.text = sum.tostring();
     button2.enabled = true;
    }, (ex) =>
    {
     button2.enabled = true;
     messagebox.show(ex.message);
    });
   }
   else
   {
    button2.enabled = true;
    messagebox.show("請輸入合法的數據");
   }
  }
 }
}

八、工具類backwork類:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
using system;
using system.collections.generic;
using system.componentmodel;
using system.linq;
using system.text;
 
/**
 * 使用方法:
 
backwork.run(() => //dowork
{
 
}, () => //runworkercompleted
{
 
}, (ex) => //錯誤處理
{
 
});
 
*/
 
namespace utils
{
 /// <summary>
 /// backgroundworker封裝
 /// 用于簡化代碼
 /// </summary>
 public class backwork
 {
  /// <summary>
  /// 執行
  /// </summary>
  /// <param name="dowork">dowork</param>
  /// <param name="workcompleted">runworkercompleted</param>
  /// <param name="erroraction">錯誤處理</param>
  public static void run(action dowork, action workcompleted, action<exception> erroraction)
  {
   bool isdoworkerror = false;
   exception doworkexception = null;
   backgroundworker worker = new backgroundworker();
   worker.dowork += (s, e) =>
   {
    try
    {
     dowork();
    }
    catch (exception ex)
    {
     isdoworkerror = true;
     doworkexception = ex;
    }
   };
   worker.runworkercompleted += (s, e) =>
   {
    if (!isdoworkerror)
    {
     try
     {
      if (workcompleted != null) workcompleted();
     }
     catch (exception ex)
     {
      erroraction(ex);
     }
    }
    else
    {
     erroraction(doworkexception);
    }
   };
   worker.runworkerasync();
  }
 
 }
}

九、效果圖示:

WCF實現進程間管道通信Demo分享

以上這篇wcf實現進程間管道通信demo分享就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持服務器之家。

原文鏈接:http://www.cnblogs.com/s0611163/archive/2017/12/15/8043157.html

延伸 · 閱讀

精彩推薦
  • C#深入解析C#中的交錯數組與隱式類型的數組

    深入解析C#中的交錯數組與隱式類型的數組

    這篇文章主要介紹了深入解析C#中的交錯數組與隱式類型的數組,隱式類型的數組通常與匿名類型以及對象初始值設定項和集合初始值設定項一起使用,需要的...

    C#教程網6172021-11-09
  • C#C# 實現對PPT文檔加密、解密及重置密碼的操作方法

    C# 實現對PPT文檔加密、解密及重置密碼的操作方法

    這篇文章主要介紹了C# 實現對PPT文檔加密、解密及重置密碼的操作方法,非常不錯,具有參考借鑒價值,需要的朋友可以參考下...

    E-iceblue5012022-02-12
  • C#WPF 自定義雷達圖開發實例教程

    WPF 自定義雷達圖開發實例教程

    這篇文章主要介紹了WPF 自定義雷達圖開發實例教程,本文介紹的非常詳細,具有參考借鑒價值,需要的朋友可以參考下...

    WinterFish13112021-12-06
  • C#C#設計模式之Visitor訪問者模式解決長隆歡樂世界問題實例

    C#設計模式之Visitor訪問者模式解決長隆歡樂世界問題實例

    這篇文章主要介紹了C#設計模式之Visitor訪問者模式解決長隆歡樂世界問題,簡單描述了訪問者模式的定義并結合具體實例形式分析了C#使用訪問者模式解決長...

    GhostRider9502022-01-21
  • C#C#裁剪,縮放,清晰度,水印處理操作示例

    C#裁剪,縮放,清晰度,水印處理操作示例

    這篇文章主要為大家詳細介紹了C#裁剪,縮放,清晰度,水印處理操作示例,具有一定的參考價值,感興趣的小伙伴們可以參考一下...

    吳 劍8332021-12-08
  • C#Unity3D實現虛擬按鈕控制人物移動效果

    Unity3D實現虛擬按鈕控制人物移動效果

    這篇文章主要為大家詳細介紹了Unity3D實現虛擬按鈕控制人物移動效果,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一...

    shenqingyu060520232410972022-03-11
  • C#C#通過KD樹進行距離最近點的查找

    C#通過KD樹進行距離最近點的查找

    這篇文章主要為大家詳細介紹了C#通過KD樹進行距離最近點的查找,具有一定的參考價值,感興趣的小伙伴們可以參考一下...

    帆帆帆6112022-01-22
  • C#C#實現XML文件讀取

    C#實現XML文件讀取

    這篇文章主要為大家詳細介紹了C#實現XML文件讀取的相關代碼,具有一定的參考價值,感興趣的小伙伴們可以參考一下...

    Just_for_Myself6702022-02-22
主站蜘蛛池模板: 成年人视频在线免费看 | 无人区在线观看免费完整版免费 | 無码一区中文字幕少妇熟女H | 免费视频 | 美女扒开屁股让男人进去 | 美女啪啪国产 | 国产亚洲精品视频中文字幕 | 色婷婷久| 久热这里只有精品99国产6 | 美女把腿开让我 | 国产福利在线观看91精品 | 成人久久伊人精品伊人 | 动漫美女被褥吸奶漫画漫画 | 久久精品久久久 | 日本动漫打扑克动画片樱花动漫 | jazz中国女人护士 | 亚洲国产99 | 欧美日韩国产精品综合 | 日本videossexx日本人 | 免费看片aⅴ免费大片 | 动漫美女3d被爆漫画 | 欧美三级小视频 | 国产一级毛片国语版 | 奇米影视在线视频8888 | 99视频免费在线 | 色婷婷久久综合中文久久一本 | 亚洲系列国产精品制服丝袜第 | 日本阿v精品视频在线观看 日本xxx片免费高清在线 | 美女全身体光羞羞漫画 | 日韩毛片基地一区二区三区 | 扒开双腿羞辱调教play视频 | 国产婷婷高清在线观看免费 | 福利国模私拍视频在线观看 | 国产91一区二区在线播放不卡 | 国产高清一区二区 | 国产丰满美女做爰 | 小草观看免费高清视频 | 亚洲经典 | 国产一区二区三区久久精品 | a级影视| 美女被吸乳得到大胸 |