2. 程式人生 > >C# 實現Remoting雙向通訊

C# 實現Remoting雙向通訊

阿新 • • 發佈：2019-01-14

本篇文章主要介紹了C# 實現Remoting雙向通訊，.Net Remoting 是由客戶端通過Remoting，訪問通道以獲得服務端物件，再通過代理解析為客戶端物件來實現通訊的

閒來無事想玩玩雙向通訊，實現類似QQ的互發訊息的功能。於是乎開始學習.Net Remoting.

.Net Remoting 是由客戶端通過Remoting，訪問通道以獲得服務端物件，再通過代理解析為客戶端物件來實現通訊的。也就是說物件是由服務端建立的。

先上程式碼

首先是ICommand庫

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

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace ICommand

{

public interface

IRemotingObject

{

event SendHandler ClientToServer;

event ReceiveHandler ServerToClient;

event UserChangedHandler Login;

event UserChangedHandler Exit;

/// <summary>

/// 加法運算

/// </summary>

/// <param name="x1">引數1</param>

/// <param name="x2">引數2</param>

/// <returns></returns>

string SUM(int x1, int x2);

/// <summary>

/// 獲取服務端事件列表

/// </summary>

Delegate[] GetServerEventList();

/// <summary>

/// 傳送訊息

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

void ToServer(object info, string toName);

/// <summary>

/// 接受資訊

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

void ToClient(object info, string toName);

void ToLogin(string name);

void ToExit(string name);

}

/// <summary>

/// 客戶端傳送訊息

/// </summary>

/// <param name="info">資訊</param>

/// <param name="toName">傳送給誰，""表示所有人，null表示沒有接收伺服器自己接收，其他表示指定某人</param>

public delegate void SendHandler(object info, string toName);

/// <summary>

/// 客戶端接收訊息

/// </summary>

/// <param name="info">資訊</param>

/// <param name="toName">傳送給誰，""表示所有人，null表示沒有接收伺服器自己接收，其他表示指定某人</param>

public delegate void ReceiveHandler(object info, string toName);

/// <summary>

/// 使用者資訊事件

/// </summary>

/// <param name="name">使用者名稱</param>

public delegate void UserChangedHandler(string name);

}

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

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace ICommand

{

public class SwapObject : MarshalByRefObject

{

public event ReceiveHandler SwapServerToClient

{

add { _receive += value; }

remove { _receive -= value; }

}

/// <summary>

/// 接受資訊

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

public void ToClient(object info, string toName)

{

if (_receive != null)

_receive(info, toName);

}

//無限生命週期

public override object InitializeLifetimeService()

{

return null;

}

private ReceiveHandler _receive;

}

}

第一個類就是定義一些介面，和一些委託，沒有實質性的東西。

第二個類是定義了上一個介面類中的ToClient的事件和方法，作用之後會講到。

然後就是整合ICommand介面的實質性的資料類

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

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using ICommand;

namespace NetRemoting

{

public class RemotingObject : MarshalByRefObject, IRemotingObject

{

/// <summary>

/// 傳送事件

/// </summary>

public event SendHandler ClientToServer

{

add { _send += value; }

remove { _send -= value; }

}

/// <summary>

/// 接收訊息事件

/// </summary>

public event ReceiveHandler ServerToClient;

/// <summary>

/// 傳送事件

/// </summary>

public event UserChangedHandler Login

{

add { _login += value; }

remove { _login -= value; }

}

/// <summary>

/// 傳送事件

/// </summary>

public event UserChangedHandler Exit

{

add { _exit += value; }

remove { _exit -= value; }

}

/// <summary>

/// 加法運算

/// </summary>

/// <param name="x1">引數1</param>

/// <param name="x2">引數2</param>

/// <returns></returns>

public string SUM(int x1, int x2)

{

return x1 + "+" + x2 + "=" + (x1 + x2);

}

/// <summary>

/// 繫結服務端向客戶端傳送訊息的事件方法

/// </summary>

/// <param name="receive">接收事件</param>

public Delegate[] GetServerEventList()

{

return this.ServerToClient.GetInvocationList();

}

/// <summary>

/// 傳送訊息

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

public void ToServer(object info, string toName)

{

if (_send != null)

_send(info, toName);

}

/// <summary>

/// 接收訊息

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

public void ToClient(object info, string toName)

{

if (_receive != null)

_receive(info, toName);

}

/// <summary>

/// 登入

/// </summary>

/// <param name="name">使用者名稱</param>

public void ToLogin(string name)

{

if (!_nameHash.Contains(name))

{

_nameHash.Add(name);

if (_login != null)

_login(name);

}

else

{ throw new Exception("使用者已存在"); }

}

/// <summary>

/// 退出

/// </summary>

/// <param name="name">使用者名稱</param>

public void ToExit(string name)

{

if (_nameHash.Contains(name))

{

_nameHash.Remove(name);

if (_exit != null)

_exit(name);

}

}

private SendHandler _send;

private ReceiveHandler _receive;

private UserChangedHandler _login;

private UserChangedHandler _exit;

private HashSet<string> _nameHash = new HashSet<string>();

}

}

該類集成了MarshalByRefObject

由於Remoting傳遞的物件是以引用的方式，因此所傳遞的遠端物件類必須繼承MarshalByRefObject。MSDN對MarshalByRefObject的說明是：MarshalByRefObject 是那些通過使用代理交換訊息來跨越應用程式域邊界進行通訊的物件的基類。不是從 MarshalByRefObject 繼承的物件會以隱式方式按值封送。當遠端應用程式引用一個按值封送的物件時，將跨越遠端處理邊界傳遞該物件的副本。因為您希望使用代理方法而不是副本方法進行通訊，因此需要繼承MarshallByRefObject。

該類主要是定義了一些方法用於客戶端觸發事件，ToServer，ToClient，ToLogin，ToExit以及一些事件，客戶端發向服務端的事件，和服務端發向客戶端的事件。

_nameHash 只是記錄有哪些使用者登入了。

接下去就是客戶端和服務端了。

首先服務端：

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

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Http;

using NetRemoting;

using System.Collections;

using System.Runtime.Serialization.Formatters;

using ICommand;

namespace NetRemotingServer

{

public partial class Server : Form

{

public Server()

{

InitializeComponent();

Initialize();

}

/// <summary>

/// 註冊通道

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void Server_Load(object sender, EventArgs e)

{

ChannelServices.RegisterChannel(_channel, false);

//RemotingConfiguration.RegisterWellKnownServiceType(typeof(RemotingObject), "SumMessage", WellKnownObjectMode.Singleton); //a方案

/*將給定的 System.MarshalByRefObject 轉換為具有指定 URI 的 System.Runtime.Remoting.ObjRef 類的例項。

ObjRef ：儲存生成代理以與遠端物件通訊所需要的所有資訊。*/

ObjRef objRef = RemotingServices.Marshal(_remotingObject, "SumMessage");//b方案

_remotingObject.ClientToServer += (info, toName) =>

{

rxtInfo.Invoke((MethodInvoker)(() => { rxtInfo.AppendText(info.ToString() + "\r\n"); }));

SendToClient(info, toName);

};

_remotingObject.Login += (name) =>

{

rxtInfo.Invoke((MethodInvoker)(() => { rxtInfo.AppendText(name + " 登入" + "\r\n"); }));

};

_remotingObject.Exit += (name) =>

{

rxtInfo.Invoke((MethodInvoker)(() => { rxtInfo.AppendText(name + " 退出" + "\r\n"); }));

};

}

/// <summary>

/// 登出通道

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void Server_FormClosing(object sender, FormClosingEventArgs e)

{

if (_channel != null)

{

_channel.StopListening(null);

ChannelServices.UnregisterChannel(_channel);

}

}

/// <summary>

/// 廣播訊息

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void btnSend_Click(object sender, EventArgs e)

{

SendToClient(txtSend.Text, txtName.Text);

}

/// <summary>

/// 傳送訊息到客戶端

/// </summary>

/// <param name="info"></param>

/// <param name="toName"></param>

private void SendToClient(object info, string toName)

{

//foreach (var v in _remotingObject.GetServerEventList())

//{

//  try

//  {

//    ReceiveHandler receive = (ReceiveHandler)v;

//    receive.BeginInvoke(info, toName, null, null);

//  }

//  catch

//  { }

// }

_remotingObject.ToClient(txtSend.Text, txtName.Text);

}

/// <summary>

/// 初始化

/// </summary>

private void Initialize()

{

//設定反序列化級別

BinaryServerFormatterSinkProvider serverProvider = new BinaryServerFormatterSinkProvider();

BinaryClientFormatterSinkProvider clientProvider = new BinaryClientFormatterSinkProvider();

serverProvider.TypeFilterLevel = TypeFilterLevel.Full;//支援所有型別的反序列化，級別很高

IDictionary idic = new Dictionary<string, string>();

idic["name"] = "serverHttp";

idic["port"] = "8022";

_channel = new HttpChannel(idic, clientProvider, serverProvider);

_remotingObject = new RemotingObject();

}

HttpChannel _channel;

private RemotingObject _remotingObject;

}

}

然後客戶端：

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

98

99

100

101

102

103

104

105

106

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.Remoting;

using System.Runtime.Remoting.Channels;

using System.Runtime.Remoting.Channels.Http;

using ICommand;

using System.Runtime.Serialization.Formatters;

using System.Collections;

namespace

相關推薦

C# 實現Remoting雙向通訊

本篇文章主要介紹了C# 實現Remoting雙向通訊，.Net Remoting 是由客戶端通過Remoting，訪問通道以獲得服務端物件，再通過代理解析為客戶端物件來實現通訊的 閒來無事想玩玩雙向通訊，實現類似QQ的互發訊息的功能。於是乎開始學習.Net Remoting. .Net Remotin

C++實現串列埠通訊上位機軟體

串列埠使用的是RS232匯流排進行通訊，通訊方式是半雙工。有兩種方式可以實現串列埠通訊，一種是通過ActiveX控制元件這種方法程式簡單，但欠靈活。第二個是可以通過呼叫Windows的API函式，本例程通過第二種方式。 一般通過四步來完成通訊(1)開啟串列埠(2)配置串列埠(3)讀寫串列埠(4)

C++實現websocket協議通訊

一、websocket協議原理 （一）websocket 協議的官方文件 ： https://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-13#section-5 Linux 下c語言 實現 websocket&nbs

基於C#實現串列埠通訊Demo

https://www.cnblogs.com/Zed-H/p/8651882.html 1.基本概念   2.前端winForm佈局如下（僅僅為了實現功能，佈局略醜）   3.程式碼實現如下 1 nam

windows純C++實現串列埠通訊

點h檔案 #ifndef _WZSERIALPORT_H #define _WZSERIALPORT_H #include <iostream> using namespace std; /* 作者：歐陽偉 日期：2017-12-14 類名：WZ

C#實現串列埠通訊

        .NET提供了SerialPort類進行串列埠通訊。 串列埠主要有以下幾個引數：  1.串列埠名稱（PortName）  2.波特率（BaudRate） 3.資料位（DataBits） 4.奇偶效應（Parity）  5.停止位（StopBits）         使用很簡單

golang和c通過unix域實現雙向通訊

go的程式碼如下: package main import ( "fmt" "net" "bufio" "os" "syscall" ) func writeUnix(listener *net.UnixConn,dstAddr *net.UnixAddr) { for {

【Arduino】使用C#實現Arduino與電腦進行串行通訊

可視化 action 指示 追加 停止 format reads 接受 按鈕 在給Arduino編程的時候，因為沒有調試工具，經常要通過使用串口通訊的方式調用Serial.print和Serial.println輸出Arduino運行過程中的相關信息，然後在電腦上用Ardu

【劍指offer】二叉搜索樹轉雙向鏈表，C++實現

pointer 題目 size point nod off log tco public 原創博文，轉載請註明出處！# 題目 輸入一棵二叉搜索樹，將該二叉搜索樹轉換成一個排序的雙向鏈表。要求不能創建任何新的結點，只能調整樹中結點指針的指向。要求不能創建任何新的節點

RabbitMQ初探--用C#實現通訊服務

download gin summary color 發送消息 sta 過程調用 change rod MQ全稱為Message Queue, 消息隊列(MQ)是一種應用程序對應用程序的通信方法。應用程序通過讀寫出入隊列的消息(針對應用程序的數據)來通信，而無需專用連接來鏈

網路程式設計（InetAddress類、Socket和ServerSocket、實現客戶端和伺服器之間的雙向通訊）

網路程式設計的底層是IO，通過IO將一臺計算機中的資料傳送到另一臺計算機中。傳送的時候，要知道接受方的地址，該地址即為IP地址。知道IP地址後即可進行傳送。A向B發訊息，訊息是發過去了，但是B要怎樣接受呢？因此定義了埠，B監聽了A所使用的埠。A發的訊息中含有埠號，當B接受到訊息時，知道了埠號

.Net Remoting的雙向通訊和Windows Service的宿主服務

原文:.Net Remoting的雙向通訊和Windows Service的宿主服務      作為微軟分散式技術之一的.Net Remoting,從效能、安全等各方面來說都是相對比較穩定的，也是一項比較成熟的分散式技術。   &nbs

vue.js學習筆記（六）--利用v-model實現父子元件間的雙向通訊

部落格：https://fisher-zh.github.io/ 在Vue中，我們可以使用prop屬性來進行父子元件間的通訊，在之前的文章Vue踩坑之路–父子元件通訊總結中有介紹過。 但是prop 是單向繫結的，我們無法在元件中直接修改prop傳遞的屬性。

HTTPS通訊的C++實現

 HTTPS是以安全為目標的HTTP通道，簡單講是HTTP的安全版。即HTTP下加入SSL層，HTTPS的安全基礎是SSL，因此加密的詳細內容就需要SSL。Nebula是一個為開發者提供一個快速開發高併發網路服務程式或搭建高併發分散式服務叢集的高效能事件驅動網路框架。Nebula作為通用網路框架提供HTT

C#使用SendMessage實現程序間通訊的方法

本文例項講述了C#使用SendMessage實現程序間通訊的方法。分享給大家供大家參考。具體分析如下： 為了深入理解訊息機制，先來做一個測試專案 在新建專案的Form1的程式碼中，加入方法： ?

【C語言實現串列埠通訊知識點整理（四）】關於執行緒和程序

轉載：https://www.cnblogs.com/fuchongjundream/p/3829508.html 因為在外部檔案中呼叫結構體沒有用extern修飾，導致獲取不到正確的值，一直糾結線上程上。現在大概總結執行緒和程序的特點： 概念 1、程序（process） 狹義定義：

【C語言實現串列埠通訊知識點整理（三）】串列埠開啟、設定資料成功後進行資料讀寫

int OpenDev(char *Dev) { int fd = open(Dev,O_RDWR | O_NOCTTY | O_NONBLOCK); if(-1 == fd) { perror("Can't Open Serial Port"); return -1;

【C語言實現串列埠通訊知識點整理（二）】遇到的問題整理（待續....）

1.c編譯錯誤--error:stray \357 in program UTF-8編碼問題。UTF-8編碼有BOM和無BOM格式。BOM，ByteOrderMark(位元組標記順序),表明使用UTF8來進行編碼。UTF-8的BOM通常為3個位元組EF BB BF。轉換成對應的字元檢視，就是‘\

【C語言實現串列埠通訊知識點整理（一）】執行緒、開啟串列埠、設定波特率、設定校驗位、互斥鎖等實現基本的通訊

  部分程式碼借鑑地址：https://blog.csdn.net/wangqingchuan92/article/details/73497354/ 謝謝！ 1.建立執行緒線上程內進行串列埠之間的收發 void CREAT_pthread(void) { pthr

Untiy中用C#實現TCP通訊（Socket通訊）服務端與客戶端皆可

簡而言之，TCP通訊原理大家可以從各種網路文獻上找到，這裡不做贅述。 只提出C#實現TCP通訊的一般方法和常用程式碼工具供第一次接觸TCP通訊的玩家參考，老玩家繞道。。。 為了方便大家理解我的程式碼，會適當提及通訊遠離。 1、建立服務端，TCP連線的基本： using U