今天在VS2010上做点练习，用Socket编程写的聊天程序。
长的比较丑


这是服务器的主要代码：

1. using System;
   
2. using System.Collections.Generic;
   
3. using System.ComponentModel;
   
4. using System.Data;
   
5. using System.Drawing;
   
6. using System.Linq;
   
7. using System.Text;
   
8. using System.Windows.Forms;
   
9. using System.Net.Sockets;
   
10. using System.Net;
    
11. using System.Threading;
    
12. 
    
13. namespace _01_socketserver
    
14. {
    
15. public partial class SocketServer : Form
    
16. {
    
17. Socket socketWatch = null;
    
18. delegate void SetTextCallback(string text);
    
19. Dictionary<string, Socket> dict = new Dictionary<string, Socket>();
    
20. Thread receiveThread = null;
    
21. 
    
22. public SocketServer()
    
23. {
    
24. InitializeComponent();
    
25. }
    
26. 
    
27. private void SocketServer_Load(object sender, EventArgs e)
    
28. {
    
29. //可以通过将 CheckForIllegalCrossThreadCalls 属性的值设置为 false 来禁用此异常
    
30. //如果创建某控件的线程之外的其他线程试图调用该控件，则调试器会引发一个 InvalidOperationException
    
31. //TextBox.CheckForIllegalCrossThreadCalls = false;
    
32. 
    
33. //创建监听端口
    
34. socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
35. 
    
36. IPAddress adress = IPAddress.Parse(txtIP.Text.Trim());
    
37. IPEndPoint endPoint = new IPEndPoint(adress, int.Parse(txtPort.Text.Trim()));
    
38. //绑定端口
    
39. socketWatch.Bind(endPoint);
    
40. //设置监听队列
    
41. socketWatch.Listen(10);
    
42. ShowMsg("等待客户端连接...");
    
43. 
    
44. //等待客户端连接
    
45. //Socket connection = socketWatch.Accept();
    
46. Thread thread = new Thread(new ThreadStart(WaitAccept));
    
47. thread.IsBackground = true;
    
48. thread.Start();
    
49. 
    
50. }
    
51. 
    
52. /// <summary>
    
53. /// 显示文本信息
    
54. /// </summary>
    
55. /// <param name="msg"></param>
    
56. private void ShowMsg(string msg)
    
57. {
    
58. if (txtShow.InvokeRequired)
    
59. {
    
60. 
    
61. SetTextCallback d = new SetTextCallback(ShowMsg); ;
    
62. Invoke(d, new object[] { msg });
    
63. }
    
64. else
    
65. {
    
66. txtShow.AppendText(msg + "\r\n");
    
67. }
    
68. 
    
69. }
    
70. 
    
71. /// <summary>
    
72. /// 添加连接的客户端选项
    
73. /// </summary>
    
74. /// <param name="endpoint"></param>
    
75. private void addEndPoint(string endpoint)
    
76. {
    
77. if (lbEndPoint.InvokeRequired)
    
78. {
    
79. SetTextCallback d = new SetTextCallback(addEndPoint);
    
80. Invoke(d, new object[] { endpoint });
    
81. }
    
82. else
    
83. lbEndPoint.Items.Add(endpoint);
    
84. }
    
85. 
    
86. /// <summary>
    
87. /// 删除断开连接的客户端选项
    
88. /// </summary>
    
89. /// <param name="endpoint"></param>
    
90. private void deleteEndPoint(int index)
    
91. {
    
92. if (lbEndPoint.InvokeRequired)
    
93. {
    
94. SetTextCallback d = new SetTextCallback(deleteEndPoint);
    
95. Invoke(d, new object[] { index });
    
96. }
    
97. else
    
98. lbEndPoint.Items.RemoveAt(index);
    
99. }
    
100. private void deleteEndPoint(string endpoint)
     
101. {
     
102. if (lbEndPoint.InvokeRequired)
     
103. {
     
104. SetTextCallback d = new SetTextCallback(deleteEndPoint);
     
105. Invoke(d, new object[] { endpoint });
     
106. }
     
107. else
     
108. lbEndPoint.Items.Remove(endpoint);
     
109. }
     
110. 
     
111. /// <summary>
     
112. /// 等待连接线程函数
     
113. /// </summary>
     
114. private void WaitAccept()
     
115. {
     
116. while (true)
     
117. {
     
118. //等待客户端连接
     
119. Socket connSocket = socketWatch.Accept();
     
120. ShowMsg(connSocket.RemoteEndPoint.ToString() + "连接成功");
     
121. //存储客户端列表
     
122. dict.Add(connSocket.RemoteEndPoint.ToString(), connSocket);
     
123. addEndPoint(connSocket.RemoteEndPoint.ToString());
     
124. 
     
125. //接受线程启动
     
126. receiveThread = new Thread(new ParameterizedThreadStart(ReceiveThread));
     
127. receiveThread.IsBackground = true;
     
128. receiveThread.Start((Object)connSocket.RemoteEndPoint.ToString());
     
129. }
     
130. 
     
131. }
     
132. 
     
133. /// <summary>
     
134. /// 接受数据线程方法
     
135. /// </summary>
     
136. /// <param name="obj"></param>
     
137. private void ReceiveThread(Object obj)
     
138. {
     
139. while (true)
     
140. {
     
141. string endPoint = (string)obj;
     
142. byte[] arrRec = new byte[1024 * 1024 * 2];
     
143. int num = 0;
     
144. try
     
145. {
     
146. num = dict[endPoint].Receive(arrRec);
     
147. string strRec = dict[endPoint].RemoteEndPoint.ToString();
     
148. strRec += ":" + System.Text.Encoding.Default.GetString(arrRec, 0, num);
     
149. ShowMsg(strRec);
     
150. }
     
151. catch
     
152. {
     
153. ShowMsg(dict[endPoint].RemoteEndPoint.ToString() + "客户端关闭。");
     
154. //关闭服务端套接字
     
155. dict[endPoint].Close();
     
156. //移除服务器列表项
     
157. dict.Remove(endPoint);
     
158. deleteEndPoint(endPoint);
     
159. return;
     
160. 
     
161. }
     
162. 
     
163. }
     
164. 
     
165. }
     
166. 
     
167. /// <summary>
     
168. /// 发送按钮
     
169. /// </summary>
     
170. /// <param name="sender"></param>
     
171. /// <param name="e"></param>
     
172. private void btnSend_Click(object sender, EventArgs e)
     
173. {
     
174. if (txtSend.Text.ToString() == "")
     
175. {
     
176. MessageBox.Show("发送内容不能为空！");
     
177. }
     
178. else
     
179. {
     
180. try
     
181. {
     
182. if (lbEndPoint.SelectedIndex == -1)
     
183. lbEndPoint.SelectedIndex = 0;
     
184. }
     
185. catch
     
186. {
     
187. MessageBox.Show("没有可用的客户端");
     
188. return;
     
189. }
     
190. //获取发送字符数组
     
191. byte[] arrSend = System.Text.Encoding.Default.GetBytes(txtSend.Text.ToString());
     
192. ShowMsg("to " + lbEndPoint.SelectedItem.ToString() + ":" + txtSend.Text.ToString());
     
193. txtSend.Clear();
     
194. try
     
195. {
     
196. //发送信息
     
197. dict[lbEndPoint.SelectedItem.ToString()].Send(arrSend);
     
198. }
     
199. catch
     
200. {
     
201. ShowMsg("客户端已关闭。");
     
202. //关闭服务端套接字
     
203. dict[lbEndPoint.SelectedItem.ToString()].Close();
     
204. //移除服务器列表项
     
205. dict.Remove(lbEndPoint.SelectedItem.ToString());
     
206. deleteEndPoint(lbEndPoint.SelectedIndex);
     
207. }
     
208. 
     
209. }//else
     
210. 
     
211. }
     
212. 
     
213. }
     
214. }
     

复制代码

-The End-

© Jervis

点发表之后我笑了  {:3_54:}

编辑的时候好好的，发出来就   :@:@