今天在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_socketclient
    
14. {
    
15. public partial class SocketClient : Form
    
16. {
    
17. Socket socketClient = null; //客户端套接字
    
18. bool connectioned = false; //连接断开标识
    
19. Thread sendThread = null; //发送线程
    
20. Thread receiveThread = null; //接受线程
    
21. delegate void SetTextCallback(string text);//invoke的方式实现安全调用
    
22. delegate void ClearTextCallback();
    
23. 
    
24. public SocketClient()
    
25. {
    
26. InitializeComponent();
    
27. }
    
28. 
    
29. private void btnConnection_Click(object sender, EventArgs e)
    
30. {
    
31. if (connectioned)
    
32. {
    
33. //结束接受线程
    
34. if (receiveThread.IsAlive)
    
35. receiveThread.Abort();
    
36. //关闭套接字
    
37. socketClient.Close();
    
38. ShowMsg("断开连接。");
    
39. 
    
40. btnConnection.Text = "Connection";
    
41. connectioned = false;
    
42. //设置发送不可用
    
43. btnSend.Enabled = connectioned;
    
44. }
    
45. else
    
46. {
    
47. //创建客户端套接字
    
48. socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
49. 
    
50. IPAddress adress = null;
    
51. IPEndPoint endpoint = null;
    
52. 
    
53. try
    
54. {
    
55. //IP不为空
    
56. adress = IPAddress.Parse(txtIP.Text.Trim());
    
57. }
    
58. catch
    
59. {
    
60. //IP为空
    
61. txtIP.Text = "192.168.1.100";
    
62. }
    
63. try
    
64. {
    
65. //PORT不为空
    
66. endpoint = new IPEndPoint(adress, int.Parse(txtPort.Text.Trim()));
    
67. }
    
68. catch
    
69. {
    
70. //PORT为空
    
71. txtPort.Text = "52113";
    
72. }
    
73. //连接服务器
    
74. try
    
75. {
    
76. ShowMsg("连接到 " + txtIP.Text.ToString() + ":" + txtPort.Text.ToString());
    
77. socketClient.Connect(endpoint);
    
78. ShowMsg("成功连接到服务器。");
    
79. }
    
80. catch
    
81. {
    
82. ShowMsg("连接服务器失败。");
    
83. return;
    
84. }
    
85. 
    
86. //实例接收线程
    
87. receiveThread = new Thread(new ThreadStart(RecevieThread));
    
88. //设置为后台线程
    
89. receiveThread.IsBackground = true;
    
90. //启动接受线程
    
91. receiveThread.Start();
    
92. 
    
93. btnConnection.Text = "Broke";
    
94. connectioned = true;
    
95. //设置发送可用
    
96. btnSend.Enabled = connectioned;
    
97. 
    
98. }//else
    
99. 
    
100. }
     
101. 
     
102. /// <summary>
     
103. /// 显示文本信息
     
104. /// </summary>
     
105. /// <param name="msg"></param>
     
106. private void ShowMsg(string msg)
     
107. {
     
108. if (txtShow.InvokeRequired)
     
109. {
     
110. 
     
111. SetTextCallback d = new SetTextCallback(ShowMsg); ;
     
112. Invoke(d, new object[] { msg });
     
113. }
     
114. else
     
115. {
     
116. txtShow.AppendText(msg + "\r\n");
     
117. }
     
118. }
     
119. 
     
120. private void SendTextClear()
     
121. {
     
122. if (txtSend.InvokeRequired)
     
123. {
     
124. ClearTextCallback d = new ClearTextCallback(SendTextClear);
     
125. Invoke(d);
     
126. }
     
127. else
     
128. txtSend.Clear();
     
129. 
     
130. }
     
131. 
     
132. /// <summary>
     
133. /// 发送线程函数
     
134. /// </summary>
     
135. private void SendThread()
     
136. {
     
137. 
     
138. if (txtSend.Text.ToString() == "")
     
139. {
     
140. MessageBox.Show("发送内容不能为空！");
     
141. }
     
142. else
     
143. {
     
144. //获取发送字符数组
     
145. byte[] arrSend = System.Text.Encoding.Default.GetBytes(txtSend.Text.ToString());
     
146. //回显发送内容
     
147. ShowMsg(txtSend.Text.ToString());
     
148. //清空发送区
     
149. SendTextClear();
     
150. try
     
151. {
     
152. //发送信息
     
153. socketClient.Send(arrSend);
     
154. }
     
155. catch
     
156. {
     
157. ShowMsg("服务器已关闭。");
     
158. //关闭服务端套接字
     
159. socketClient.Close();
     
160. }
     
161. 
     
162. }
     
163. sendThread.Abort();
     
164. MessageBox.Show("sendThread dead");
     
165. 
     
166. }
     
167. 
     
168. /// <summary>
     
169. /// 接收线程执行方法
     
170. /// </summary>
     
171. private void RecevieThread()
     
172. {
     
173. while (true)
     
174. {
     
175. byte[] arrRec = new byte[1024 * 1024 * 2];
     
176. int num = 0;
     
177. 
     
178. try
     
179. {
     
180. num = socketClient.Receive(arrRec);
     
181. string strMsg = socketClient.RemoteEndPoint.ToString();
     
182. strMsg += ":" + System.Text.Encoding.Default.GetString(arrRec, 0, num);
     
183. ShowMsg(strMsg);
     
184. }
     
185. catch
     
186. {
     
187. //ShowMsg("连接已断开。");
     
188. socketClient.Close();
     
189. return;
     
190. }
     
191. 
     
192. }//while
     
193. }
     
194. 
     
195. /// <summary>
     
196. /// 发送按钮
     
197. /// </summary>
     
198. /// <param name="sender"></param>
     
199. /// <param name="e"></param>
     
200. private void btnSend_Click(object sender, EventArgs e)
     
201. {
     
202. //绑定发送线程函数
     
203. sendThread = new Thread(new ThreadStart(SendThread));
     
204. //设置为后台线程
     
205. sendThread.IsBackground = true;
     
206. //启动发送线程
     
207. sendThread.Start();
     
208. 
     
209. }
     
210. }
     
211. }
     

复制代码

-The End-

© Jervis

你可以写一哈 客户端通过客户端发送文件盒消息!!!     其原理就是运用 服务器 当做中间装换的桥梁

值得学习ing!

杞文明 发表于 2013-6-25 00:13
你可以写一哈 客户端通过客户端发送文件盒消息!!!     其原理就是运用 服务器 当做中间装换的桥梁 ...

o！    当时刚看socket那个视频还不知道文件读取呢，就是随便写写。  呵呵~