C# Socket系列二 简单的创建 socket 通信

看了系列一 我们开启了对socket tcp的监听状态，那么这一章我们来讲解怎么创建socket的通信代码

我新建一个类 TSocketBase

<a href="http://www.cnblogs.com/soundcode/p/7238616.html#">?</a>

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

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

<code>public</code> <code>abstract</code> <code>class</code> <code>TSocketBase</code>

<code>    </code><code>{</code>

<code>        </code><code>//封装socket</code>

<code>        </code><code>internal</code> <code>Socket _Socket;</code>

<code>        </code><code>//回调</code>

<code>        </code><code>private</code> <code>AsyncCallback aCallback;</code>

<code>        </code><code>//接受数据的缓冲区</code>

<code>        </code><code>private</code> <code>byte</code><code>[] Buffers;</code>

<code>        </code><code>//标识是否已经释放</code>

<code>        </code><code>private</code> <code>volatile</code> <code>bool</code> <code>IsDispose;</code>

<code>        </code><code>//10K的缓冲区空间</code>

<code>        </code><code>private</code> <code>int</code> <code>BufferSize = 10*1024;</code>

<code>        </code><code>//收取消息状态码</code>

<code>        </code><code>private</code> <code>SocketError ReceiveError;</code>

<code>        </code><code>//发送消息的状态码</code>

<code>        </code><code>private</code> <code>SocketError SenderError;</code>

<code>        </code><code>//每一次接受到的字节数</code>

<code>        </code><code>private</code> <code>int</code> <code>ReceiveSize = 0;</code>

<code>        </code><code>//接受空消息次数</code>

<code>        </code><code>private</code> <code>byte</code> <code>ZeroCount = 0;</code>

<code>        </code><code>public</code> <code>abstract</code> <code>void</code> <code>Receive(</code><code>byte</code><code>[] rbuff);</code>

<code>        </code><code>public</code> <code>void</code> <code>SetSocket()</code>

<code>        </code><code>{</code>

<code>            </code><code>this</code><code>.aCallback =</code><code>new</code> <code>AsyncCallback(</code><code>this</code><code>.ReceiveCallback);</code>

<code>            </code><code>this</code><code>.IsDispose =</code><code>false</code><code>;</code>

<code>            </code><code>this</code><code>._Socket.ReceiveBufferSize =</code><code>this</code><code>.BufferSize;</code>

<code>            </code><code>this</code><code>._Socket.SendBufferSize =</code><code>this</code><code>.BufferSize;</code>

<code>            </code><code>this</code><code>.Buffers =</code><code>new</code> <code>byte</code><code>[</code><code>this</code><code>.BufferSize];</code>

<code>        </code><code>}</code>

<code>        </code><code>/// &lt;summary&gt;</code>

<code>        </code><code>/// 关闭并释放资源</code>

<code>        </code><code>/// &lt;/summary&gt;</code>

<code>        </code><code>/// &lt;param name="msg"&gt;&lt;/param&gt;</code>

<code>        </code><code>public</code> <code>void</code> <code>Close(</code><code>string</code> <code>msg)</code>

<code>            </code><code>if</code> <code>(!</code><code>this</code><code>.IsDispose)</code>

<code>            </code><code>{</code>

<code>                </code><code>this</code><code>.IsDispose =</code><code>true</code><code>;</code>

<code>                </code><code>try</code>

<code>                </code><code>{</code>

<code>                    </code><code>try</code>

<code>                    </code><code>{</code>

<code>                        </code><code>this</code><code>._Socket.Close();</code>

<code>                    </code><code>}</code>

<code>                    </code><code>catch</code>

<code>                    </code><code>IDisposable disposable =</code><code>this</code><code>._Socket;</code>

<code>                    </code><code>if</code> <code>(disposable !=</code><code>null</code><code>)</code>

<code>                        </code><code>disposable.Dispose();</code>

<code>                    </code><code>this</code><code>.Buffers =</code><code>null</code><code>;</code>

<code>                    </code><code>GC.SuppressFinalize(</code><code>this</code><code>);</code>

<code>                </code><code>}</code>

<code>                </code><code>catch</code> <code>(Exception)</code>

<code>            </code><code>}</code>

<code>        </code><code>/// 递归接收消息方法</code>

<code>        </code><code>internal</code> <code>void</code> <code>ReceiveAsync()</code>

<code>            </code><code>try</code>

<code>                </code><code>if</code> <code>(!</code><code>this</code><code>.IsDispose &amp;&amp;</code><code>this</code><code>._Socket.Connected)</code>

<code>                    </code><code>this</code><code>._Socket.BeginReceive(</code><code>this</code><code>.Buffers, 0,</code><code>this</code><code>.BufferSize, SocketFlags.None,</code><code>out</code> <code>SenderError,</code>

<code>                        </code><code>this</code><code>.aCallback,</code><code>this</code><code>);</code>

<code>                    </code><code>CheckSocketError(ReceiveError);</code>

<code>            </code><code>catch</code> <code>(System.Net.Sockets.SocketException)</code>

<code>                </code><code>this</code><code>.Close(</code><code>"链接已经被关闭"</code><code>);</code>

<code>            </code><code>catch</code> <code>(System.ObjectDisposedException)</code>

<code>        </code><code>/// 接收消息回调函数</code>

<code>        </code><code>/// &lt;param name="iar"&gt;&lt;/param&gt;</code>

<code>        </code><code>private</code> <code>void</code> <code>ReceiveCallback(IAsyncResult iar)</code>

<code>                    </code><code>//接受消息</code>

<code>                    </code><code>ReceiveSize = _Socket.EndReceive(iar,</code><code>out</code> <code>ReceiveError);</code>

<code>                    </code><code>//检查状态码</code>

<code>                    </code><code>if</code> <code>(!CheckSocketError(ReceiveError) &amp;&amp; SocketError.Success == ReceiveError)</code>

<code>                        </code><code>//判断接受的字节数</code>

<code>                        </code><code>if</code> <code>(ReceiveSize &gt; 0)</code>

<code>                        </code><code>{</code>

<code>                            </code><code>byte</code><code>[] rbuff =</code><code>new</code> <code>byte</code><code>[ReceiveSize];</code>

<code>                            </code><code>Array.Copy(</code><code>this</code><code>.Buffers, rbuff, ReceiveSize);</code>

<code>                            </code><code>this</code><code>.Receive(rbuff);</code>

<code>                            </code><code>//重置连续收到空字节数</code>

<code>                            </code><code>ZeroCount = 0;</code>

<code>                            </code><code>//继续开始异步接受消息</code>

<code>                            </code><code>ReceiveAsync();</code>

<code>                        </code><code>}</code>

<code>                        </code><code>else</code>

<code>                            </code><code>ZeroCount++;</code>

<code>                            </code><code>if</code> <code>(ZeroCount == 5)</code>

<code>                            </code><code>{</code>

<code>                                </code><code>this</code><code>.Close(</code><code>"错误链接"</code><code>);</code>

<code>                            </code><code>}</code>

<code>                </code><code>catch</code> <code>(System.Net.Sockets.SocketException)</code>

<code>                    </code><code>this</code><code>.Close(</code><code>"链接已经被关闭"</code><code>);</code>

<code>                </code><code>catch</code> <code>(System.ObjectDisposedException)</code>

<code>        </code><code>/// 错误判断</code>

<code>        </code><code>/// &lt;param name="socketError"&gt;&lt;/param&gt;</code>

<code>        </code><code>/// &lt;returns&gt;&lt;/returns&gt;</code>

<code>        </code><code>private</code> <code>bool</code> <code>CheckSocketError(SocketError socketError)</code>

<code>            </code><code>switch</code> <code>((socketError))</code>

<code>                </code><code>case</code> <code>SocketError.SocketError:</code>

<code>                </code><code>case</code> <code>SocketError.VersionNotSupported:</code>

<code>                </code><code>case</code> <code>SocketError.TryAgain:</code>

<code>                </code><code>case</code> <code>SocketError.ProtocolFamilyNotSupported:</code>

<code>                </code><code>case</code> <code>SocketError.ConnectionAborted:</code>

<code>                </code><code>case</code> <code>SocketError.ConnectionRefused:</code>

<code>                </code><code>case</code> <code>SocketError.ConnectionReset:</code>

<code>                </code><code>case</code> <code>SocketError.Disconnecting:</code>

<code>                </code><code>case</code> <code>SocketError.HostDown:</code>

<code>                </code><code>case</code> <code>SocketError.HostNotFound:</code>

<code>                </code><code>case</code> <code>SocketError.HostUnreachable:</code>

<code>                </code><code>case</code> <code>SocketError.NetworkDown:</code>

<code>                </code><code>case</code> <code>SocketError.NetworkReset:</code>

<code>                </code><code>case</code> <code>SocketError.NetworkUnreachable:</code>

<code>                </code><code>case</code> <code>SocketError.NoData:</code>

<code>                </code><code>case</code> <code>SocketError.OperationAborted:</code>

<code>                </code><code>case</code> <code>SocketError.Shutdown:</code>

<code>                </code><code>case</code> <code>SocketError.SystemNotReady:</code>

<code>                </code><code>case</code> <code>SocketError.TooManyOpenSockets:</code>

<code>                    </code><code>this</code><code>.Close(socketError.ToString());</code>

<code>                    </code><code>return</code> <code>true</code><code>;</code>

<code>            </code><code>return</code> <code>false</code><code>;</code>

<code>        </code><code>/// 发送消息方法</code>

<code>        </code><code>internal</code> <code>int</code> <code>SendMsg(</code><code>byte</code><code>[] buffer)</code>

<code>            </code><code>int</code> <code>size = 0;</code>

<code>                </code><code>if</code> <code>(!</code><code>this</code><code>.IsDispose)</code>

<code>                    </code><code>size =</code><code>this</code><code>._Socket.Send(buffer, 0, buffer.Length, SocketFlags.None,</code><code>out</code> <code>SenderError);</code>

<code>                    </code><code>CheckSocketError(SenderError);</code>

<code>            </code><code>buffer =</code><code>null</code><code>;</code>

<code>            </code><code>return</code> <code>size;</code>

<code>    </code><code>}</code>

　　

上面我们事先了socket的异步接受消息，和同步发送消息已经关闭释放资源代码

接受消息net底层提供的接受消息的方法有很多，为什么我们要选择上面所写的呢？那是为了兼容U3D，silverlight， wpf， wp， wf，等程序可执行，不在重复做相同工作。

现在我们来创建一个实现类 TSocketClient

<code>public</code> <code>class</code> <code>TSocketClient : TSocketBase</code>

<code>        </code><code>/// 是否是服务器端的资源</code>

<code>        </code><code>private</code> <code>bool</code> <code>isServer =</code><code>false</code><code>;</code>

<code>        </code><code>/// 客户端主动请求服务器</code>

<code>        </code><code>/// &lt;param name="ip"&gt;&lt;/param&gt;</code>

<code>        </code><code>/// &lt;param name="port"&gt;&lt;/param&gt;</code>

<code>        </code><code>public</code> <code>TSocketClient(</code><code>string</code> <code>ip =</code><code>"127.0.0.1"</code><code>,</code><code>int</code> <code>port = 9527)</code>

<code>            </code><code>isServer =</code><code>false</code><code>;</code>

<code>            </code><code>this</code><code>._Socket =</code><code>new</code> <code>System.Net.Sockets.Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);</code>

<code>            </code><code>this</code><code>._Socket.Connect(ip, port);</code>

<code>            </code><code>this</code><code>.SetSocket();</code>

<code>            </code><code>this</code><code>.ReceiveAsync();</code>

<code>        </code><code>/// 这个是服务器收到有效链接初始化</code>

<code>        </code><code>/// &lt;param name="socket"&gt;&lt;/param&gt;</code>

<code>        </code><code>public</code> <code>TSocketClient(Socket socket)</code>

<code>            </code><code>isServer =</code><code>true</code><code>;</code>

<code>            </code><code>this</code><code>._Socket = socket;</code>

<code>        </code><code>/// 收到消息后</code>

<code>        </code><code>/// &lt;param name="rbuff"&gt;&lt;/param&gt;</code>

<code>        </code><code>public</code> <code>override</code> <code>void</code> <code>Receive(</code><code>byte</code><code>[] rbuff)</code>

<code>            </code><code>Console.WriteLine(</code><code>"Receive Msg："</code> <code>+ System.Text.UTF8Encoding.Default.GetString(rbuff));</code>

<code>            </code><code>if</code> <code>(isServer)</code>

<code>                </code><code>this</code><code>.SendMsg(System.Text.UTF8Encoding.Default.GetBytes(</code><code>"Holle Client！"</code><code>));</code>

因为是测试示例，所以我把服务器和客户端实现类写成了，只是用来不同的构造函数来区分，是客户端还是服务器的标识

接下来我们测试一下代码

运行结果看出，我们连接成功并且发送消息成功。