我认为当你学完某个知识点后，最好是做一个实实在在的小案例。这样才能更好对知识的运用与掌握
如果你看了我前两篇关于socket通信原理的入门文章。我相信对于做出我这个小案列是完全没有问题的！！
既然是小案列。就难免会有很多不足，所以还请大家见谅。先说下用此案例实现的功能
利用Socke的TCP协议实现了
1：端与端之间的通信(客户端和客户端)包括发送文字，小文件，抖动效果
2：同步实现好友下线与上线的效果，即有其他客户端上线会通知其他已经在线的客户端
3：实现自定义通信协议
服务器窗体布局
布局很明了。顶部一个DataGridView显示连接的客户端信息，来一个就新增一个。走一个就干掉一个。
下面就是显示服务器信息
客户端布局：
窗口布局是不是很大众呢。QQ啊。飞秋。类似的布局。
好了。现在启动服务器。连接两个客户端试试
服务器已经获取了客户端信息
客服端用户列表是空的？因为这里我的处理是不能跟自己聊天所以列表是不显示自己的ip的
那么在登陆一个客户端呢？
服务器
此时客户端都已经获取了对方上线的ip
此时就可以通信了。那来试试上面说的功能。发送文字，抖动，和图片
发送文字：
箭头的方向是发送的开始，反过来发送也是可以的
当有人下线，客户端会更新 "用户列表"，同时服务器也会端口对下线者的通信
比如：当端口号为：6477下线。即端口连接
刚下线一个客户端。所以现在登陆一个客户端
发送文件： 这里仅仅是小文件。显示发送一个图片
当选择文件文件后。文件路径会显示在框中
从图中可以看出。是一个图片。名字是 2
单击发送。接收的用户会提示是否接受该文件。
当单击是的时候。则弹出保存对话框
从图片中可以看出来，这里获取到了文件名称。那么客户端是怎么获取到的呢？在下面的代码中会一一讲解
现在重新命名 new.jpg保存看看。已经成功了
抖动效果
为了让大家看到抖动效果。这里放一个gif图片。其实跟QQ抖动类似。当然没他那么优美。那么好看。
看看一个通信的流程图
图片中红色的标记框就是
首先：我第一次登陆成功，服务器发送在线好友给我，显示在用户列表中
同时通知其他在线用户。用人(我)上线了。
当然。当有人上线。服务器也会通知我。然后把上线的ip添加到用列表中
当我下线的时候。通知服务器我下线了。服务器则通知其他在线用户。更新列表
发送消息也是先发送到服务器。然后服务器在转发。
好了。具体功能就是这些了。带着这些实现的功能读下面的代码。思绪应该会比较清晰
还记得创建服务器的三个步骤吗？
第一：创建监听的socket
第二：绑定监听用个的ip和端口号
第三：开始监听
因为监听和获取消息都是要循环的。要么用多线程。要么用socket异步。所以这两个方法要独立出来
创建StartServer()方法。用来开启服务器
1 /// <summary>
2 /// 打开服务器
3 /// </summary>
4 void StartServer()
5 {
6 try
7 {
8 string _ip = tbIp.Text;
9 int _point = int.Parse(tbPoint.Text);
10
11 //创建监听客户端请求的socket
12 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
13 //监听用的ip和端口
14 IPAddress address = IPAddress.Parse(_ip);
15 IPEndPoint point = new IPEndPoint(address, _point);
16
17 //绑定
18 socket.Bind(point);
19 socket.Listen(10);
20
21
22 //异步 开始监听
23 socket.BeginAccept(new AsyncCallback(Listen), socket);
24
25
26 //禁用当前按钮
27 btnStart.Enabled = false;
28
29 //启动时间
30 startTime.Text = DateTime.Now.ToString();
31
32 //底部提示消息
33 tssMsg.Text = "服务器已经启动";
34 }
35 catch (Exception ex)
36 {
37 MessageBox.Show(ex.Message);
38 }
39
40 }
从代码可以看出来。我用到了异步通信 BeginAccept方法 回掉方法是Listen
Listen方法即上面说的要循环监听的代码
Listen方法
1 /// <summary>
2 /// 开始监听
3 /// </summary>
4 /// <param name="result"></param>
5 void Listen(IAsyncResult result)
6 {
7
8 try
9 {
10 //获取监听的socket
11 Socket clientSocket = result.AsyncState as Socket;
12 //与服务器通信的socket
13 Socket connSocket = clientSocket.EndAccept(result);
14
15 string ip = connSocket.RemoteEndPoint.ToString();
16 //连接成功。保存信息
17 if (!Common.connSocket.ContainsKey(ip))
18 Common.connSocket.Add(ip, connSocket);
19
20 //连接成功，更新服务器信息
21 changeList(connSocket);
22
23
24 //等待新的客户端连接 ，相当于循环调用
25 clientSocket.BeginAccept(new AsyncCallback(Listen), clientSocket);
26
27 byte[] buffer = new byte[1024 * 1024];
28
29
30 //接收来自客户端信息 ，相当于循环调用
31 connSocket.BeginReceive(Common.ReceiveBuffer, 0, Common.ReceiveBuffer.Length, 0, new AsyncCallback(Receive), connSocket);
32
33 //用户第一次登陆。获取所有在线用户 如果有好友功能。则获取他的好友
34 SendesClient(connSocket);
35 }
36 catch (Exception ex)
37 {
38
39 //MessageBox.Show(ex.Message);
40 }
41
42
43 }
如果你在想为什么Listen方法要这样定义：
void Listen(IAsyncResult result)
你可以去看下多线程，异步委托方面的知识
我博客也有这方面的入门：http://www.cnblogs.com/nsky/p/4425286.html
这里把连接的客服端保存在字典中
key：当前的ip value ：当前的socke通信
//连接成功。保存信息
if (!Common.connSocket.ContainsKey(ip))
Common.connSocket.Add(ip, connSocket);
当客户端连接。就获取所有在线的ip
//用户第一次登陆。获取所有在线用户 如果有好友功能。则获取他的好友 SendesClient(connSocket);
SendesClient方法
1 /// <summary>
2 /// 把上线的人发送到客户端
3 /// </summary>
4 /// <param name="connSocket">当前连接的客户端</param>
5 void SendesClient(Socket connSocket)
6 {
7 //自定义协议：[命令 2位]
8 /*
9 * 第一位：10代表是首次登陆获取所有好友，把自己的ip放最后一位
10 * 好像这里默认已经是最后一位了？？
11 */
12 string key = connSocket.RemoteEndPoint.ToString();
13 //把自己的ip删除
14 if (Common.connSocket.ContainsKey(key))
15 Common.connSocket.Remove(key);
16
17 //把自己的key添加到最后一位
18 if (!Common.connSocket.ContainsKey(key))
19 Common.connSocket.Add(key, connSocket);
20
21 //发送到客户端
22 byte[] clientByte = Encoding.UTF8.GetBytes(string.Join(",", Common.connSocket.Keys));
23
24
25 //List<byte> bbb = new List<byte>();
26 //bbb.Add(1);
27 //bbb.AddRange(clientByte);
28
29 List<byte> li = clientByte.ToList();
30 li.Insert(0, 10);//第一位插入10 代表是获取好友
31
32 //把当前在线ip发送给自己
33 connSocket.Send(li.ToArray());
34
35 //告诉其他在线的用户。我上线啦，求勾搭
36 //var online = from onn in Common.connSocket
37 // where !onn.Key.Contains(connSocket.RemoteEndPoint.ToString()) //筛选，不包含自己的ip
38 // select onn;
39
40 //if (online.Count() <= 0) return; //当前没有上线的
41
42 foreach (KeyValuePair<string, Socket> item in Common.connSocket)
43 {
44 //不需要给自己发送。因为当自己上线的时候。就已经获取了在线的ip
45 if (item.Key == connSocket.RemoteEndPoint.ToString()) continue;
46 //多线程通知在线用户。
47 Thread thread = new Thread(() =>
48 {
49 byte[] buffer = Encoding.UTF8.GetBytes(connSocket.RemoteEndPoint.ToString());
50 List<byte> list = buffer.ToList();
51 //有人上线
52 //[命令(12)| ip(上线的ip)| ...]
53 list.Insert(0, 12);//说明有人上线
54 item.Value.Send(list.ToArray());
55 });
56 thread.IsBackground = true;
57 thread.Start();
58 }
59
60 //判断当前用户是否还处于连接状态
61 //if (Common.connSocket.ContainsKey(connSocket.RemoteEndPoint.ToString()))
62 //connSocket.Send(buffer);
63
64 //有人下线。就通知所有在线的人数
65 //如果是qq我想应该是通知我的好友。不是知道是不是
66
67 /*
68 * 如果在线有 A B C
69 * 那么A下线
70 * 是不是要通知B C
71 * 还是在B C 定时访问服务器来获取在线人数呢？
72 * 待解决
73 */
74 }
那么Listen方法是怎么循环监听的呢？其实就是在Listen里面循环调用自己
//等待新的客户端连接 ，相当于循环调用 clientSocket.BeginAccept(new AsyncCallback(Listen), clientSocket);
监听有客服端连接成功。就开始接受客户端信息
1 //接收来自客户端信息 ，相当于循环调用 2 connSocket.BeginReceive(Common.ReceiveBuffer, 0, Common.ReceiveBuffer.Length, 0, new AsyncCallback(Receive), connSocket);
Common.ReceiveBuffer是什么？？
这是我把公共的数据封装在了一个Common类里面。下面会给出
循环监听有了。那么写一个循环接收消息的也就很简单了。依葫芦画瓢
Receive方法：
1 /// <summary>
2 /// 接收来自客户端信息
3 /// </summary>
4 /// <param name="result"></param>
5 void Receive(IAsyncResult result)
6 {
7
8 //与客户端通信的socket
9 Socket clientSocket = result.AsyncState as Socket;
10
11 try
12 {
13 //获取实际的长度值
14 int num = clientSocket.EndReceive(result);
15 if (num > 0)
16 {
17 byte[] data = new byte[num];
18 //复制实际的长度到data字节数组中
19 Array.Copy(Common.ReceiveBuffer, 0, data, 0, num);
20
21 //判断协议位
22 int command = data[0];
23
24 //获取内容
25 string source = Encoding.UTF8.GetString(data, 1, num - 1);
26
27 //获取接收者的ip
28 string receiveIp = source.Split(‘,‘)[0];
29
30
31 if (command == 1) //说明发送的是文字
32 {
33 /*协议：
34 * //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
35 */
36 //获取接收者通信连接的socket
37 if (Common.connSocket.ContainsKey(receiveIp))
38 {
39 Common.connSocket[receiveIp].Send(data);
40 }
41 }
42 else if (command == 0) //说明是发送的文件
43 {
44 /*协议: 这里50位不知道是否理想。
45 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30位)|响应(文件内容) | ...]
46 */
47
48 //获取接收者通信连接的socket
49 if (Common.connSocket.ContainsKey(receiveIp))
50 {
51 Common.connSocket[receiveIp].Send(data);
52 }
53 }
54 else if (command == 2)//抖动一下
55 {
56 //协议
57 //震动
58 //[命令(2)| 对方的ip和自己的ip 50位| ...]
59
60 //获取接收者通信连接的socket
61 if (Common.connSocket.ContainsKey(receiveIp))
62 {
63 Common.connSocket[receiveIp].Send(data);
64 }
65 }
66
67 //string msg = Encoding.UTF8.GetString(data);
68 //MessageBox.Show(msg);
69
70
71 //接收其他信息
72 clientSocket.BeginReceive(Common.ReceiveBuffer, 0, Common.ReceiveBuffer.Length, 0, new AsyncCallback(Receive), clientSocket);
73
74 }
75 else //客户端断开
76 {
77 clientOff(clientSocket);
78 }
79 }
80 catch (Exception ex)
81 {
82 clientOff(clientSocket);
83 }
84
85 }
当客户端端口会执行clientOff方法。用来通知其他用户。更新列表
clientOff方法
1 /// <summary>
2 /// 客户端关闭
3 /// </summary>
4 void clientOff(Socket clientSocket)
5 {
6 //从集合删除下线的ip
7 string outIp = clientSocket.RemoteEndPoint.ToString();
8 if (Common.connSocket.ContainsKey(outIp))
9 Common.connSocket.Remove(outIp);
10
11 //更新服务器在线人数
12 changOnlineCount(false);
13
14 this.Invoke(new Action(() =>
15 {
16 //更新列表
17 //删除退出的ip
18 for (int i = 0; i < dgvList.Rows.Count; i++)
19 {
20 if (dgvList.Rows[i].Tag.ToString() == outIp)
21 {
22 dgvList.Rows.RemoveAt(i);
23 break;
24 }
25 }
26 }));
27
28 clientSocket.Shutdown(SocketShutdown.Receive);
29 clientSocket.Close();
30
31 //通知所有在线用户。有人下线了。需要更新列表，如果是qq是通知我的好友。不知道是不是这样
32 /*这里有点疑问：
33 * 是客户端定时到服务器获取在线用户？
34 * 还是服务器通知客户端
35
36 */
37
38 //有人下线 协议
39 //[命令(11)| ip(下线的ip)| ...]
40
41 //我这里通知客户端吧
42 foreach (KeyValuePair<string, Socket> item in Common.connSocket)
43 {
44 Thread thread = new Thread(() =>
45 {
46 byte[] buffer = Encoding.UTF8.GetBytes(outIp);
47 List<byte> list = buffer.ToList();
48 list.Insert(0, 11);//添加协议位
49 item.Value.Send(list.ToArray());
50 });
51 thread.IsBackground = true;
52 thread.Start();
53
54
55 //多线程。通知每个在线用户。更新列表
56 //ThreadPool.QueueUserWorkItem(new WaitCallback(new Action<object>((o) =>
57 //{
58 // string result = string.Join(",", Common.connSocket.Keys);
59 // byte[] buffer = Encoding.UTF8.GetBytes(result);
60 // try
61 // {
62 // //客户端关闭，则发送报异常
63 // item.Value.Send(buffer);
64 // }
65 // catch (Exception ex)
66 // {
67
68 // }
69 //})));
70 //string result = string.Join(",", Common.connSocket.Keys);
71 //byte[] buffer = Encoding.UTF8.GetBytes(result);
72 //item.Value.Send(buffer);
73
74 }
75 }
有没有想过。服务器是怎么知道客户端发送的是文字。文件还是抖动呢？
这里就要提到自定义协议了。双方约定好。比如：
客户端发送0 就代表是文字。 发送1 则代表是文件 2 则代表是抖动。
我这里自定义的协议如下。不能说很好。只能说马马虎虎过得去
1 /*********************协议说明***********************/ 2 //根据协议解码 3 /* 4 * 自定义协议规则 5 * [ 命令(1) | 内容(30) | ip(22)| 响应(....) | ...] 6 命令：0-文件 1-文字 2-震动 7 * 内容： 8 * 文件（长度，文件名字+后缀名） 响应(文件的字节) 9 * 文字(内容) 10 * 震动() 11 * ip(自己的ip和对方的ip) 12 * 13 * [ 命令(1) | ip(22) | 内容(30)| 响应(....) | ...] 14 * 15 * 文件： 16 * [命令(0)| ip(自己的ip和对方的ip)| 内容(文件大小和文件全名)|响应(文件内容) | ...] 17 * 文字： 18 * [命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...] 19 * 震动 20 * [命令(2)| ip(对方的ip)| ...] 21 * 更新在线人数 22 * [命令(3)| ip(自己的ip和对方的ip)| ...] 23 * 第一次登陆获取在线(好友)人数 24 * [命令(10)| ip(自己的ip和所有的ip)| ...] 25 * 有人下线 26 * [命令(11)| ip(下线的ip)| ...] 27 * 有人上线 28 * [命令(12)| ip(上线的ip)| ...] 29 * 0 30 * 1 31 * 2 32 * 3 33 * 4 34 * 5 35 * 36 */
既然协议有了。那么就可以根据协议发送数据包。服务器和其他客户端就可以根据协议解包。
这里来说下发送文件的协议
从上面可以看到我定义的文件协议：
[命令(0)| ip(自己的ip和对方的ip)| 内容(文件大小和文件全名)|响应(文件内容) | ...]
先贴上发送文件的代码(客户端发送)。然后根据我的思路来分析
客户端发送文件代码
1 /// <summary>
2 /// 发送文件
3 /// </summary>
4 /// <param name="sender"></param>
5 /// <param name="e"></param>
6 void btnSendFile_Click(object sender, EventArgs e)
7 {
8 //判断是否有选择用户
9 string sendUser = cbList.Text;
10
11 if (string.IsNullOrEmpty(sendUser))
12 {
13 //提示
14 tbHis.AppendText("请选择要发送的用户...\n");
15 return;
16 }
17 //判断是否选择了文件
18 else if (string.IsNullOrEmpty(tbFile.Text))
19 {
20 tbHis.AppendText("请选择文件\n");
21 tbHis.AppendText("\n");
22 return;
23 }
24 //开始读取文件
25 using (FileStream fs = new FileStream(tbFile.Text, FileMode.Open, FileAccess.Read))
26 {
27 //大文件会内存溢出
28 //引发类型为“System.OutOfMemoryException”的异常。
29 //所以大文件只能 续传。像QQ一样在线接收的方式。
30 byte[] buffer = new byte[fs.Length];
31 //获取实际的字节数，如果有需要的话。
32 int num = fs.Read(buffer, 0, buffer.Length);
33
34 /*协议: 这里50位不知道是否理想？？
35 * 是不是可以修改为：第一位 协议 第二位标记ip的长度 第三位标记内容的长度？？
36 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30)|响应(文件内容) | ...]
37 */
38 string allIp = string.Format("{0},{1}", cbList.Text, myIp.Text);
39 byte[] sendIp = Encoding.UTF8.GetBytes(allIp);
40
41 List<byte> list = sendIp.ToList();
42
43 //sendIp 不够50位
44 if (sendIp.Length < 50)
45 {
46 for (int i = 0; i < 50 - sendIp.Length; i++)
47 {
48 list.Add(0);
49 }
50 }
51 list.Insert(0, 0); //添加协议位
52 //添加内容
53 byte[] fileByte = Encoding.UTF8.GetBytes(Common.SafeFileName);
54 list.AddRange(fileByte);
55 //内容是否够30
56 if (fileByte.Length < 30)
57 {
58 for (int i = 0; i < 30 - fileByte.Length; i++)
59 {
60 list.Add(0);
61 }
62 }
63 //添加响应
64 list.AddRange(buffer);
65
66 //开始发送
67 Common.connSocket.Send(list.ToArray());
68 }
69 }
字节数组必须根据你定义的协议来拼接。这样在服务端才好解包
我这里把ip放到了List<byte>中
List<byte> list = sendIp.ToList();
然后在list前面插入协议位：0 ，因为我定义的协议是0代表发送文件
list.Insert(0, 0); //添加协议位
是否还记得上面提到的。客户端接收文件。打开保存对话框。自动补全了文件名。是怎么做的吗？
因为协议中发文件名发过去了
//添加内容
byte[] fileByte = Encoding.UTF8.GetBytes(Common.SafeFileName);
list.AddRange(fileByte);
还有因为不知道ip的固定长度。所以我这里限制是50位。不够的话就补加空，不知道这样是否划算
//sendIp 不够50位
if (sendIp.Length < 50)
{
for (int i = 0; i < 50 - sendIp.Length; i++)
{
list.Add(0);
}
}
所以的数据根据协议打包后。就可以发送到服务器。在服务器解包。获取目的者的ip。开始转发
Receive方法中你可以找到解包的代码，部分如下：
1 byte[] data = new byte[num];
2 //复制实际的长度到data字节数组中
3 Array.Copy(Common.ReceiveBuffer, 0, data, 0, num);
4
5 //判断协议位
6 int command = data[0];
7
8 //获取内容
9 string source = Encoding.UTF8.GetString(data, 1, num - 1);
10
11 //获取接收者的ip
12 string receiveIp = source.Split(‘,‘)[0];
13
14
15 if (command == 1) //说明发送的是文字
16 {
17 /*协议：
18 * //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
19 */
20 //获取接收者通信连接的socket
21 if (Common.connSocket.ContainsKey(receiveIp))
22 {
23 Common.connSocket[receiveIp].Send(data);
24 }
25 }
获取协议位：
int command = data[0];
注：
你会发现我这里在服务器解包判断协议毫无意义。因为第一位是命令。而后面接着是ip。这些长度都是固定的。
只有取出来ip发送到指定的客户端。让客户端解包判断协议就是了。没错。因为我这里本来加个功能。如果是文件则把文件缓存起来。所以就判断
了协议的命令。你可以根据自己的需求去做。
发送到了客户端，就理所当然的要判断协议位了。如果是抖动就抖一下。是文件。就提示是否接受。等等
看看客户端解包代码：
记住：下面的Receive方法是客户端中的方法。用力接收服务器发来的消息
1 /// <summary>
2 /// 接收来自服务器的消息
3 /// </summary>
4 /// <param name="result"></param>
5 void Receive(IAsyncResult result)
6 {
7 Socket clientSocket = result.AsyncState as Socket;
8
9 //byte[] b = new byte[1024 * 1024];
10 try
11 {
12 //获取实际的长度
13 int num = clientSocket.EndReceive(result);
14 if (num > 0)
15 {
16 //MessageBox.Show(num.ToString());
17 byte[] buffer = new byte[num];
18 Array.Copy(Common.buffer, 0, buffer, 0, num); //复制数据到data
19 //string ip = Encoding.UTF8.GetString(data);
20
21
22 //以下是客户端=》服务器==》服务器
23 /*
24 * 当if else 超过3个
25 *
26 * 建议用switch case语句
27 */
28
29 //获取口令
30 int command = buffer[0];
31 //说明是获取好友
32 if (command == 10)
33 {
34 //协议说明
35 //第一次登陆获取在线(好友)人数
36 //[命令(10)| ip(自己的ip和所有好友的ip)| ...]
37
38
39 //其实用户本地ip也可以这样获取
40 //string cy = clientSocket.LocalEndPoint;
41
42 string allIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
43 string[] temp = allIp.Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
44
45
46 //跨线程操作UI
47 this.Invoke(new Action(() =>
48 {
49 myIp.Text = temp.Length > 0 ? temp[temp.Length - 1] : "";
50
51 //排除自己的ip
52 var other = from i in temp where !i.Contains(myIp.Text) select i;
53
54 cbList.Items.Clear();//清空
55 cbList.Items.AddRange(other.ToArray()); //绑定列表
56
57 if (cbList.Items.Count > 0)
58 cbList.SelectedIndex = 0;//默认选中第一个
59 }));
60
61 }
62 else if (command == 11) //说明是有人下线
63 {
64 //协议说明
65 // 有人下线
66 //[命令(11)| ip(下线的ip)| ...]
67
68 //获取下线的ip
69 string outIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
70
71 this.Invoke(new Action(() =>
72 {
73 //删除下线的ip
74 cbList.Items.Remove(outIp);
75 if (cbList.Items.Count > 0)
76 cbList.SelectedIndex = 0;//默认选中第一个
77 }));
78 }
79 else if (command == 12) //有人上线了
80 {
81 //协议说明
82 // 有人上线
83 //[命令(12)| ip(上线的ip)| ...]
84
85 //获取上线的ip
86 string onlineIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
87 //添加上线的ip
88
89 this.Invoke(new Action(() =>
90 {
91 //添加上线的ip
92 cbList.Items.Add(onlineIp);
93 if (cbList.Items.Count > 0)
94 cbList.SelectedIndex = 0;//默认选中第一个
95 }));
96 }
97
98 //以下是客户端=》服务器==》客户端
99
100 else if (command == 1)
101 {
102 //协议：
103 //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
104
105 //获取ip段
106 string[] sourceIp = Encoding.UTF8.GetString(buffer, 1, 50).Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
107
108 //发消息来的ip
109 string fromIp = sourceIp[1];
110
111
112
113 //获取内容
114 string content = Encoding.UTF8.GetString(buffer, 50 + 1, num - 50 - 1);
115
116 this.Invoke(new Action(() =>
117 {
118 //列表框中选择当前的ip
119 cbList.Text = fromIp.ToString();
120
121 //显示内容
122 tbHis.AppendText(string.Format("时间：{0}\n", DateTime.Now.ToString()));
123 //tbHis.AppendText(string.Format("提示{0}对我说：", fromIp)); //我操。这样怎么就不行
124 tbHis.AppendText(fromIp + "\n");
125 tbHis.AppendText("对你说：\n");
126 tbHis.AppendText(content + "\n");
127 tbHis.AppendText("\n");
128 }));
129 }
130 else if (command == 0) //发送的文件
131 {
132 /*协议: 这里50位不知道是否理想。
133 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30位)|响应(文件内容) | ...]
134 */
135
136 //这里有冗余代码
137
138 //获取ip段
139 string[] sourceIp = Encoding.UTF8.GetString(buffer, 1, 50).Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
140
141 //发消息来的ip
142 string fromIp = sourceIp[1];
143
144 this.Invoke(new Action(() =>
145 {
146 //列表框中选择当前的ip
147 cbList.Text = fromIp.ToString();
148 }));
149
150
151 //获取内容
152 string content = Encoding.UTF8.GetString(buffer, 50 + 1, 30);
153
154 //获取响应
155 //string pass = Encoding.UTF8.GetString(buffer, 50 + 30 + 1, num - 50 - 30 - 1);
156
157 //显示
158 //tbHis.AppendText(string.Format("{0}给你发了一个文件：{1}\n", fromIp, content));
159 tbHis.AppendText(fromIp);
160 tbHis.AppendText("给你发了一个文件");
161 tbHis.AppendText(content + "\n");
162 tbHis.AppendText("\n");
163
164
165 //提示用户是否接收文件
166 if (MessageBox.Show("是否接受文件\n" + content, "接收文件", MessageBoxButtons.YesNo) == DialogResult.Yes)
167 {
168 //开始保存
169 SaveFileDialog sfd = new SaveFileDialog();
170 sfd.FileName = content;
171
172 //获取文件类型
173 string ex = content.Split(‘.‘)[1];
174
175 //保存文件类型
176 sfd.Filter = "|*." + ex;
177 if (sfd.ShowDialog(this) == DialogResult.OK)
178 {
179 using (FileStream fs = new FileStream(sfd.FileName, FileMode.Create))
180 {
181 fs.Write(buffer, 50 + 30 + 1, num - 50 - 30 - 1);
182 }
183 }
184
185 }
186
187 }
188 else if (command == 2) //发送抖动
189 {
190 //如果窗口在任务栏。则显示
191 this.Show();
192 this.WindowState = FormWindowState.Normal;
193 this.Activate();
194
195 int n = -1;
196
197 for (int i = 0; i < 10; i++)
198 {
199 n = -n;
200 this.Location = new Point(this.Location.X + 10 * n, this.Location.Y + 10 * n);
201 this.TopMost = true;//在所有窗口的顶部
202 System.Threading.Thread.Sleep(50);
203 }
204
205 //抖动完成。结束顶层显示
206 this.TopMost = false;
207 }
208
209 //连接成功，再一次获取服务器发来的消息
210 clientSocket.BeginReceive(Common.buffer, 0, Common.buffer.Length, 0, new AsyncCallback(Receive), clientSocket);
211
212 }
213 }
214 catch (Exception ex) //服务器端口
215 {
216 MessageBox.Show(ex.Message);
217 clientSocket.Shutdown(SocketShutdown.Receive);
218 clientSocket.Close();
219 }
220 }
都是if else if判断的。着实看着会晕乎乎的。因为是小案列。就没去过多的封装。大家可以根据自己的喜好去封装
上面大部分都是讲的服务端口的代码。相比客户端就是一样的。只是少了一个监听的代码。直接连接服务器。接收和发送消息就ok了
这里就不分析了。稍后直接贴上参考代码
当然socket通信协议方面的知识不单单就我这点皮毛。大家自己可以深入研究。
比如：很多网站右下角都会有这样一个窗口，大家都见过吧。
我想这也是相同的原理。当打开浏览器。ajax异步去连接服务器，
获取消息发送到客户端。你说呢？
因为想做微信打飞机的游戏。其实网上也有很多源码，可我认为别人的终究是别人的。只有自己做过那才叫曾经拥有。
可单机版的太没有挑战性，那就实现一个多人在线一起玩的。就涉及到了服务器
所以想用C#写一个服务器，unity3d做客户端，与之通信。所以才有了这篇博文的诞生。
最后把全部源码给大家参考下
服务端源码：
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;
10 using System.Net.Sockets;
11 using System.Threading;
12
13 namespace TopServer
14 {
15 public partial class mainServer : Form
16 {
17
18 /*********************协议说明***********************/
19 //根据协议解码
20 /*
21 * 自定义协议规则
22 * [ 命令(1) | 内容(30) | ip(22)| 响应(....) | ...]
23 命令：0-文件 1-文字 2-震动
24 * 内容：
25 * 文件（长度，文件名字+后缀名） 响应(文件的字节)
26 * 文字(内容)
27 * 震动()
28 * ip(自己的ip和对方的ip)
29 *
30 * [ 命令(1) | ip(22) | 内容(30)| 响应(....) | ...]
31 *
32 * 文件：
33 * [命令(0)| ip(自己的ip和对方的ip)| 内容(文件大小和文件全名)|响应(文件内容) | ...]
34 * 文字：
35 * [命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
36 * 震动
37 * [命令(2)| ip(对方的ip)| ...]
38 * 更新在线人数
39 * [命令(3)| ip(自己的ip和对方的ip)| ...]
40 * 第一次登陆获取在线(好友)人数
41 * [命令(10)| ip(自己的ip和所有的ip)| ...]
42 * 有人下线
43 * [命令(11)| ip(下线的ip)| ...]
44 * 有人上线
45 * [命令(12)| ip(上线的ip)| ...]
46 * 0
47 * 1
48 * 2
49 * 3
50 * 4
51 * 5
52 *
53 */
54
55 public mainServer()
56 {
57 InitializeComponent();
58 Init();
59 }
60
61 /// <summary>
62 /// 初始化datagridview属性
63 /// </summary>
64 public void Init()
65 {
66
67 #region datagridview一些属性设置
68 dgvList.AllowUserToAddRows = false;
69 dgvList.AllowUserToDeleteRows = false;
70 dgvList.AllowUserToResizeColumns = false;
71 dgvList.AllowUserToResizeRows = false;
72 dgvList.AutoSizeColumnsMode = DataGridViewAutoSizeColumnsMode.Fill;
73 dgvList.ColumnHeadersHeightSizeMode = DataGridViewColumnHeadersHeightSizeMode.AutoSize;
74 dgvList.MultiSelect = false;
75 dgvList.ReadOnly = true;
76 dgvList.RowHeadersVisible = false;
77 dgvList.BackgroundColor = Color.White;
78 dgvList.ScrollBars = ScrollBars.Vertical;
79 dgvList.SelectionMode = DataGridViewSelectionMode.FullRowSelect;
80 #endregion
81
82 //窗体加载事件
83 //this.Load += new EventHandler(mainServer_Load);
84
85 //启动服务器按钮
86 this.btnStart.Click += new EventHandler(btnStart_Click);
87
88 //关闭服务器按钮
89 this.btnStop.Click += new EventHandler(btnStop_Click);
90 }
91
92 /// <summary>
93 /// 关闭服务器
94 /// </summary>
95 /// <param name="sender"></param>
96 /// <param name="e"></param>
97 void btnStop_Click(object sender, EventArgs e)
98 {
99 if (Common.ListenSocket != null)
100 {
101 Common.ListenSocket.Close();
102 Common.ListenSocket = null;
103 btnStart.Enabled = true;
104 //底部提示消息
105 tssMsg.Text = "服务器已经关闭";
106 }
107 }
108
109 /// <summary>
110 /// 启动服务器
111 /// </summary>
112 /// <param name="sender"></param>
113 /// <param name="e"></param>
114 void btnStart_Click(object sender, EventArgs e)
115 {
116 StartServer();
117 }
118
119 /// <summary>
120 /// 窗体加载事件
121 /// </summary>
122 /// <param name="sender"></param>
123 /// <param name="e"></param>
124 void mainServer_Load(object sender, EventArgs e)
125 {
126 //启动时间
127 startTime.Text = DateTime.Now.ToString();
128
129 //启动服务器
130 StartServer();
131 }
132
133 /// <summary>
134 /// 打开服务器
135 /// </summary>
136 void StartServer()
137 {
138 try
139 {
140 string _ip = tbIp.Text;
141 int _point = int.Parse(tbPoint.Text);
142
143 //创建监听客户端请求的socket
144 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
145 //监听用的ip和端口
146 IPAddress address = IPAddress.Parse(_ip);
147 IPEndPoint point = new IPEndPoint(address, _point);
148
149 //绑定
150 socket.Bind(point);
151 socket.Listen(10);
152
153
154 //异步 开始监听
155 socket.BeginAccept(new AsyncCallback(Listen), socket);
156
157
158 //禁用当前按钮
159 btnStart.Enabled = false;
160
161 //启动时间
162 startTime.Text = DateTime.Now.ToString();
163
164 //底部提示消息
165 tssMsg.Text = "服务器已经启动";
166 }
167 catch (Exception ex)
168 {
169 MessageBox.Show(ex.Message);
170 }
171
172 }
173
174 /// <summary>
175 /// 开始监听
176 /// </summary>
177 /// <param name="result"></param>
178 void Listen(IAsyncResult result)
179 {
180
181 try
182 {
183 //获取监听的socket
184 Socket clientSocket = result.AsyncState as Socket;
185 //与服务器通信的socket
186 Socket connSocket = clientSocket.EndAccept(result);
187
188 string ip = connSocket.RemoteEndPoint.ToString();
189 //连接成功。保存信息
190 if (!Common.connSocket.ContainsKey(ip))
191 Common.connSocket.Add(ip, connSocket);
192
193 //连接成功，更新服务器信息
194 changeList(connSocket);
195
196
197 //等待新的客户端连接 ，相当于循环调用
198 clientSocket.BeginAccept(new AsyncCallback(Listen), clientSocket);
199
200 byte[] buffer = new byte[1024 * 1024];
201
202
203 //接收来自客户端信息 ，相当于循环调用
204 connSocket.BeginReceive(Common.ReceiveBuffer, 0, Common.ReceiveBuffer.Length, 0, new AsyncCallback(Receive), connSocket);
205
206 //用户第一次登陆。获取所有在线用户 如果有好友功能。则获取他的好友
207 SendesClient(connSocket);
208 }
209 catch (Exception ex)
210 {
211
212 //MessageBox.Show(ex.Message);
213 }
214
215
216 }
217 /// <summary>
218 /// 接收来自客户端信息
219 /// </summary>
220 /// <param name="result"></param>
221 void Receive(IAsyncResult result)
222 {
223
224 //与客户端通信的socket
225 Socket clientSocket = result.AsyncState as Socket;
226
227 try
228 {
229 //获取实际的长度值
230 int num = clientSocket.EndReceive(result);
231 if (num > 0)
232 {
233 byte[] data = new byte[num];
234 //复制实际的长度到data字节数组中
235 Array.Copy(Common.ReceiveBuffer, 0, data, 0, num);
236
237 //判断协议位
238 int command = data[0];
239
240 //获取内容
241 string source = Encoding.UTF8.GetString(data, 1, num - 1);
242
243 //获取接收者的ip
244 string receiveIp = source.Split(‘,‘)[0];
245
246
247 if (command == 1) //说明发送的是文字
248 {
249 /*协议：
250 * //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
251 */
252 //获取接收者通信连接的socket
253 if (Common.connSocket.ContainsKey(receiveIp))
254 {
255 Common.connSocket[receiveIp].Send(data);
256 }
257 }
258 else if (command == 0) //说明是发送的文件
259 {
260 /*协议: 这里50位不知道是否理想。
261 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30位)|响应(文件内容) | ...]
262 */
263
264 //获取接收者通信连接的socket
265 if (Common.connSocket.ContainsKey(receiveIp))
266 {
267 Common.connSocket[receiveIp].Send(data);
268 }
269 }
270 else if (command == 2)//抖动一下
271 {
272 //协议
273 //震动
274 //[命令(2)| 对方的ip和自己的ip 50位| ...]
275
276 //获取接收者通信连接的socket
277 if (Common.connSocket.ContainsKey(receiveIp))
278 {
279 Common.connSocket[receiveIp].Send(data);
280 }
281 }
282
283 //string msg = Encoding.UTF8.GetString(data);
284 //MessageBox.Show(msg);
285
286
287 //接收其他信息
288 clientSocket.BeginReceive(Common.ReceiveBuffer, 0, Common.ReceiveBuffer.Length, 0, new AsyncCallback(Receive), clientSocket);
289
290 }
291 else //客户端断开
292 {
293 clientOff(clientSocket);
294 }
295 }
296 catch (Exception ex)
297 {
298 clientOff(clientSocket);
299 }
300
301 }
302
303 /// <summary>
304 /// 客户端关闭
305 /// </summary>
306 void clientOff(Socket clientSocket)
307 {
308 //从集合删除下线的ip
309 string outIp = clientSocket.RemoteEndPoint.ToString();
310 if (Common.connSocket.ContainsKey(outIp))
311 Common.connSocket.Remove(outIp);
312
313 //更新服务器在线人数
314 changOnlineCount(false);
315
316 this.Invoke(new Action(() =>
317 {
318 //更新列表
319 //删除退出的ip
320 for (int i = 0; i < dgvList.Rows.Count; i++)
321 {
322 if (dgvList.Rows[i].Tag.ToString() == outIp)
323 {
324 dgvList.Rows.RemoveAt(i);
325 break;
326 }
327 }
328 }));
329
330 clientSocket.Shutdown(SocketShutdown.Receive);
331 clientSocket.Close();
332
333 //通知所有在线用户。有人下线了。需要更新列表，如果是qq是通知我的好友。不知道是不是这样
334 /*这里有点疑问：
335 * 是客户端定时到服务器获取在线用户？
336 * 还是服务器通知客户端
337
338 */
339
340 //有人下线 协议
341 //[命令(11)| ip(下线的ip)| ...]
342
343 //我这里通知客户端吧
344 foreach (KeyValuePair<string, Socket> item in Common.connSocket)
345 {
346 Thread thread = new Thread(() =>
347 {
348 byte[] buffer = Encoding.UTF8.GetBytes(outIp);
349 List<byte> list = buffer.ToList();
350 list.Insert(0, 11);//添加协议位
351 item.Value.Send(list.ToArray());
352 });
353 thread.IsBackground = true;
354 thread.Start();
355
356
357 //多线程。通知每个在线用户。更新列表
358 //ThreadPool.QueueUserWorkItem(new WaitCallback(new Action<object>((o) =>
359 //{
360 // string result = string.Join(",", Common.connSocket.Keys);
361 // byte[] buffer = Encoding.UTF8.GetBytes(result);
362 // try
363 // {
364 // //客户端关闭，则发送报异常
365 // item.Value.Send(buffer);
366 // }
367 // catch (Exception ex)
368 // {
369
370 // }
371 //})));
372 //string result = string.Join(",", Common.connSocket.Keys);
373 //byte[] buffer = Encoding.UTF8.GetBytes(result);
374 //item.Value.Send(buffer);
375
376 }
377 }
378 /// <summary>
379 /// 把上线的人发送到客户端
380 /// </summary>
381 /// <param name="connSocket">当前连接的客户端</param>
382 void SendesClient(Socket connSocket)
383 {
384 //自定义协议：[命令 2位]
385 /*
386 * 第一位：10代表是首次登陆获取所有好友，把自己的ip放最后一位
387 * 好像这里默认已经是最后一位了？？
388 */
389 string key = connSocket.RemoteEndPoint.ToString();
390 //把自己的ip删除
391 if (Common.connSocket.ContainsKey(key))
392 Common.connSocket.Remove(key);
393
394 //把自己的key添加到最后一位
395 if (!Common.connSocket.ContainsKey(key))
396 Common.connSocket.Add(key, connSocket);
397
398 //发送到客户端
399 byte[] clientByte = Encoding.UTF8.GetBytes(string.Join(",", Common.connSocket.Keys));
400
401
402 //List<byte> bbb = new List<byte>();
403 //bbb.Add(1);
404 //bbb.AddRange(clientByte);
405
406 List<byte> li = clientByte.ToList();
407 li.Insert(0, 10);//第一位插入10 代表是获取好友
408
409 //把当前在线ip发送给自己
410 connSocket.Send(li.ToArray());
411
412 //告诉其他在线的用户。我上线啦，求勾搭
413 //var online = from onn in Common.connSocket
414 // where !onn.Key.Contains(connSocket.RemoteEndPoint.ToString()) //筛选，不包含自己的ip
415 // select onn;
416
417 //if (online.Count() <= 0) return; //当前没有上线的
418
419 foreach (KeyValuePair<string, Socket> item in Common.connSocket)
420 {
421 //不需要给自己发送。因为当自己上线的时候。就已经获取了在线的ip
422 if (item.Key == connSocket.RemoteEndPoint.ToString()) continue;
423 //多线程通知在线用户。
424 Thread thread = new Thread(() =>
425 {
426 byte[] buffer = Encoding.UTF8.GetBytes(connSocket.RemoteEndPoint.ToString());
427 List<byte> list = buffer.ToList();
428 //有人上线
429 //[命令(12)| ip(上线的ip)| ...]
430 list.Insert(0, 12);//说明有人上线
431 item.Value.Send(list.ToArray());
432 });
433 thread.IsBackground = true;
434 thread.Start();
435 }
436
437 //判断当前用户是否还处于连接状态
438 //if (Common.connSocket.ContainsKey(connSocket.RemoteEndPoint.ToString()))
439 //connSocket.Send(buffer);
440
441 //有人下线。就通知所有在线的人数
442 //如果是qq我想应该是通知我的好友。不是知道是不是
443
444 /*
445 * 如果在线有 A B C
446 * 那么A下线
447 * 是不是要通知B C
448 * 还是在B C 定时访问服务器来获取在线人数呢？
449 * 待解决
450 */
451 }
452
453 /// <summary>
454 /// 更新列表
455 /// </summary>
456 /// <param name="socket"></param>
457 void changeList(Socket socket)
458 {
459 //获取客户端信息 ip和端口号
460 string ip = socket.RemoteEndPoint.ToString();
461 //客户端登陆时间
462 string time = DateTime.Now.ToString();
463
464 //跨线程操作ui
465 this.Invoke(new Action(() =>
466 {
467 //新增一行
468 dgvList.Rows.Add();
469
470 //获取当前dgvList的行
471 int rows = dgvList.Rows.Count;
472
473 //赋值
474 dgvList.Rows[rows - 1].Cells[0].Value = ip;
475 dgvList.Rows[rows - 1].Cells[1].Value = time;
476
477 //把ip当作当前行的tag标记一下，为了删除行的时候可以找到该行
478 dgvList.Rows[rows - 1].Tag = ip;
479
480 //更新在线人数
481 //lbCount.Text = int.Parse(lbCount.Text) + 1 + "";//后面加空字符串。转为字符串
482 //或者
483 //lbCount.Text = (int.Parse(lbCount.Text) + 1).ToString();
484
485 //foreach (DataGridViewRow item in dgvList.Rows)
486 //{
487 // if(item.Tag==ip)item.
488
489 //}
490
491
492 //dgvList.DataSource = Common.connSocket;
493
494 //更新在线人数
495 changOnlineCount(true);
496 }));
497
498 }
499
500 /// <summary>
501 /// 更新在线人数
502 /// </summary>
503 /// <param name="tag">true=>+ false=>-</param>
504 void changOnlineCount(bool tag)
505 {
506 int num = 0;
507 if (tag) num = int.Parse(lbCount.Text) + 1;
508 else num = int.Parse(lbCount.Text) - 1;
509
510 this.Invoke(new Action(() =>
511 {
512 //更新在线人数
513 lbCount.Text = num.ToString();
514 if (num == 0) Common.connSocket.Clear();
515
516 }));
517 }
518 }
519
520 /// <summary>
521 /// 公共类
522 /// </summary>
523 public class Common
524 {
525 /// <summary>
526 /// 保存服务器来的消息
527 /// </summary>
528 public static byte[] ReceiveBuffer = new byte[1024 * 1024];
529
530 /// <summary>
531 /// 监听用的socket
532 /// </summary>
533 public static Socket ListenSocket;
534
535 /// <summary>
536 /// 保存所有负责通信用是socket
537 /// </summary>
538 public static Dictionary<string, Socket> connSocket = new Dictionary<string, Socket>();
539 }
540 }
客户端源码：
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 using System.IO;
13
14 namespace TopClient
15 {
16 public partial class UserList : Form
17 {
18 public UserList()
19 {
20 InitializeComponent();
21 Init();
22 }
23 public void Init()
24 {
25 //窗体加载
26 this.Load += new EventHandler(UserList_Load);
27
28 //发送文字
29 this.btnSender.Click += new EventHandler(btnSender_Click);
30
31 //选择文件
32 this.btnChangeFile.Click += new EventHandler(btnChangeFile_Click);
33
34 //发送文件
35 this.btnSendFile.Click += new EventHandler(btnSendFile_Click);
36
37 //抖动对方
38 this.btnDd.Click += new EventHandler(btnDd_Click);
39
40 //创建time
41 /*
42 * 用力监听服务器是否开启
43 */
44 //Common.time = new System.Windows.Forms.Timer();
45 //Common.time.Interval = 1000; //如果服务器未开启。则一秒访问一次
46 //Common.time.Tick += new EventHandler(time_Tick);
47 }
48 /// <summary>
49 /// 发送抖动
50 /// </summary>
51 /// <param name="sender"></param>
52 /// <param name="e"></param>
53 void btnDd_Click(object sender, EventArgs e)
54 {
55 //判断是否有选择用户
56 string sendUser = cbList.Text;
57
58 if (string.IsNullOrEmpty(sendUser))
59 {
60 //提示
61 tbHis.AppendText("请选择要抖动的用户...\n");
62 return;
63 }
64 //协议
65 //震动
66 //[命令(2)| 对方的ip和自己的ip 50位| ...]
67 string allIp = string.Format("{0},{1}", cbList.Text, myIp.Text);
68
69 byte[] sendIp = Encoding.UTF8.GetBytes(allIp);
70
71 List<byte> list = sendIp.ToList();
72 list.Insert(0, 2);//添加协议位
73
74 //sendIp 不够50位
75 if (sendIp.Length < 50)
76 {
77 for (int i = 0; i < 50 - sendIp.Length; i++)
78 {
79 list.Add(0);
80 }
81 }
82 //开始发送
83 Common.connSocket.Send(list.ToArray());
84 }
85
86 /// <summary>
87 /// 发送文件
88 /// </summary>
89 /// <param name="sender"></param>
90 /// <param name="e"></param>
91 void btnSendFile_Click(object sender, EventArgs e)
92 {
93 //判断是否有选择用户
94 string sendUser = cbList.Text;
95
96 if (string.IsNullOrEmpty(sendUser))
97 {
98 //提示
99 tbHis.AppendText("请选择要发送的用户...\n");
100 return;
101 }
102 //判断是否选择了文件
103 else if (string.IsNullOrEmpty(tbFile.Text))
104 {
105 tbHis.AppendText("请选择文件\n");
106 tbHis.AppendText("\n");
107 return;
108 }
109 //开始读取文件
110 using (FileStream fs = new FileStream(tbFile.Text, FileMode.Open, FileAccess.Read))
111 {
112 //大文件会内存溢出
113 //引发类型为“System.OutOfMemoryException”的异常。
114 //所以大文件只能 续传。像QQ一样在线接收的方式。
115 byte[] buffer = new byte[fs.Length];
116 //获取实际的字节数，如果有需要的话。
117 int num = fs.Read(buffer, 0, buffer.Length);
118
119 /*协议: 这里50位不知道是否理想？？
120 * 是不是可以修改为：第一位 协议 第二位标记ip的长度 第三位标记内容的长度？？
121 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30)|响应(文件内容) | ...]
122 */
123 string allIp = string.Format("{0},{1}", cbList.Text, myIp.Text);
124 byte[] sendIp = Encoding.UTF8.GetBytes(allIp);
125
126 List<byte> list = sendIp.ToList();
127
128 //sendIp 不够50位
129 if (sendIp.Length < 50)
130 {
131 for (int i = 0; i < 50 - sendIp.Length; i++)
132 {
133 list.Add(0);
134 }
135 }
136 list.Insert(0, 0); //添加协议位
137 //添加内容
138 byte[] fileByte = Encoding.UTF8.GetBytes(Common.SafeFileName);
139 list.AddRange(fileByte);
140 //内容是否够30
141 if (fileByte.Length < 30)
142 {
143 for (int i = 0; i < 30 - fileByte.Length; i++)
144 {
145 list.Add(0);
146 }
147 }
148 //添加响应
149 list.AddRange(buffer);
150
151 //开始发送
152 Common.connSocket.Send(list.ToArray());
153 }
154 }
155
156 /// <summary>
157 /// 选择文件
158 /// </summary>
159 /// <param name="sender"></param>
160 /// <param name="e"></param>
161 void btnChangeFile_Click(object sender, EventArgs e)
162 {
163 OpenFileDialog ofd = new OpenFileDialog();
164 if (ofd.ShowDialog() == DialogResult.OK)
165 {
166 tbFile.Text = ofd.FileName;
167 //保存文件名和扩展名
168 Common.SafeFileName = ofd.SafeFileName;
169 }
170 }
171 /// <summary>
172 ///
173 /// </summary>
174 /// <param name="sender"></param>
175 /// <param name="e"></param>
176 void time_Tick(object sender, EventArgs e)
177 {
178 connectServer();
179 }
180
181 /// <summary>
182 /// 发送
183 /// </summary>
184 /// <param name="sender"></param>
185 /// <param name="e"></param>
186 void btnSender_Click(object sender, EventArgs e)
187 {
188 //判断是否有选择用户
189 string sendUser = cbList.Text;
190 //获取聊天的内容
191 string content = tbContent.Text;
192
193 if (string.IsNullOrEmpty(sendUser))
194 {
195 //提示
196 tbHis.AppendText("请选择要发送的用户...\n");
197 return;
198 }
199 else if (string.IsNullOrEmpty(content))
200 {
201 //提示
202 tbHis.AppendText("你不打算输入点什么咯...\n");
203 return;
204 }
205
206 try
207 {
208 //文字： ip设置最大值为 50 位
209 //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
210 //这里把对方的ip放前面是为了在服务端好获取
211 //把自己的ip和对方的ip转为byte
212
213 //如果是独立电脑应该可以这样获取
214 //Common.connSocket.LocalEndPoint
215 //如果此处不发送自己的ip。那么也可以在服务端获取
216
217 string allIp = string.Format("{0},{1}", cbList.Text, myIp.Text);
218
219
220 byte[] sendIp = Encoding.UTF8.GetBytes(allIp);
221 byte[] buffer = Encoding.UTF8.GetBytes(content);
222
223 List<byte> list = sendIp.ToList();
224 list.Insert(0, 1);//添加协议位
225
226 //sendIp 不够50位
227 if (sendIp.Length < 50)
228 {
229 for (int i = 0; i < 50 - sendIp.Length; i++)
230 {
231 list.Add(0);
232 }
233 }
234
235 //把内容添加到末尾
236 list.AddRange(buffer);
237
238 //开始发送
239 Common.connSocket.Send(list.ToArray());
240 tbContent.Clear();
241
242 //把发送的内容显示在上面
243 tbHis.AppendText(string.Format("时间：{0}\n", DateTime.Now.ToString()));
244 tbHis.AppendText(string.Format("我对{0}说：\n", cbList.Text));
245 tbHis.AppendText(content + "\n");
246 tbHis.AppendText("\n");
247 //清空输入框
248 tbContent.Clear();
249 }
250 catch (Exception ex)
251 {
252 MessageBox.Show(ex.Message);
253 }
254
255 }
256 //保存服务器来的byte
257 byte[] buffer = new byte[1024 * 1024];
258 //保存ip
259 public static string ip;
260 void UserList_Load(object sender, EventArgs e)
261 {
262 connectServer();
263 }
264
265 void connectServer()
266 {
267 string ip = "192.168.1.2";
268 int _point = 8000;
269
270 try
271 {
272 Common.connSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
273 IPAddress address = IPAddress.Parse(ip);
274 IPEndPoint point = new IPEndPoint(address, _point);
275 Common.connSocket.Connect(point);
276
277 //连接成功，获取服务器发来的消息
278 Common.connSocket.BeginReceive(Common.buffer, 0, Common.buffer.Length, 0, new AsyncCallback(Receive), Common.connSocket);
279
280 //Thread t = new Thread(get);
281 //t.IsBackground = true;
282 //t.Start(Common.connSocket);
283
284 }
285 catch (Exception ex)
286 {
287 MessageBox.Show(ex.Message);
288 }
289 }
290
291 void get(object o)
292 {
293 while (true)
294 {
295 Socket clientSocket = o as Socket;
296
297 byte[] buffer = new byte[1024 * 1024];
298 try
299 {
300 //获取实际的长度
301 int num = clientSocket.Receive(buffer); //服务器关闭会报错
302 if (num > 0)
303 {
304 //获取口令
305 int command = buffer[0];
306 //说明是获取好友
307 if (command == 10)
308 {
309 //协议说明
310 //第一次登陆获取在线(好友)人数
311 //[命令(10)| ip(自己的ip和所有好友的ip)| ...]
312
313
314 //其实用户本地ip也可以这样获取
315 //string cy = clientSocket.LocalEndPoint;
316
317 string allIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
318 string[] temp = allIp.Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
319
320
321 //跨线程操作UI
322 this.Invoke(new Action(() =>
323 {
324 myIp.Text = temp.Length > 0 ? temp[temp.Length - 1] : "";
325
326 //排除自己的ip
327 var other = from i in temp where !i.Contains(myIp.Text) select i;
328
329 cbList.Items.Clear();//清空
330 cbList.Items.AddRange(other.ToArray()); //绑定列表
331 }));
332
333 }
334 else if (command == 11) //说明是有人下线
335 {
336 //协议说明
337 // 有人下线
338 //[命令(11)| ip(下线的ip)| ...]
339
340 //获取下线的ip
341 string outIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
342
343 this.Invoke(new Action(() =>
344 {
345 //删除下线的ip
346 cbList.Items.Remove(outIp);
347 }));
348 }
349 else if (command == 12) //有人上线了
350 {
351 //协议说明
352 // 有人上线
353 //[命令(12)| ip(上线的ip)| ...]
354
355 //获取上线的ip
356 string onlineIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
357 //添加上线的ip
358
359 this.Invoke(new Action(() =>
360 {
361 //添加上线的ip
362 cbList.Items.Add(onlineIp);
363 }));
364
365 }
366
367 this.Invoke(new Action(() =>
368 {
369 if (cbList.Items.Count > 0)
370 cbList.SelectedIndex = 0;//默认选中第一个
371
372 }));
373 }
374 }
375 catch (Exception ex)
376 {
377 MessageBox.Show(ex.Message);
378 clientSocket.Shutdown(SocketShutdown.Receive);
379 clientSocket.Close();
380 break;
381 }
382
383
384 //string ip = Encoding.UTF8.GetString(buffer, 0, num);
385 ////MessageBox.Show(ip);
386
387 ////第一个是自己的ip
388 //string[] userIp = ip.Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
389
390 //try
391 //{
392
393 // //cbList.Items.Clear();
394 // //MessageBox.Show(cbList.Items.Count.ToString());
395
396 // //var m0 = from m in userIp
397 // // where !m.Contains(userIp[0].ToString())
398 // // select m;
399 // //cbList.Items.AddRange(userIp.ToArray());
400
401 // //this.Invoke(new Action(() =>
402 // //{
403 // // cbList.Items.Clear();
404 // // //MessageBox.Show(cbList.Items.Count.ToString());
405
406 // // cbList.Items.AddRange(userIp.ToArray());
407
408
409 // //}));
410 //}
411 //catch (Exception ex)
412 //{
413 // MessageBox.Show(ex.Message);
414 //}
415
416
417 //MessageBox.Show(string.Join(",",userIp));
418
419 //cbList.DataSource = userIp.ToList();
420
421
422
423 }
424 }
425
426 /// <summary>
427 /// 接收来自服务器的消息
428 /// </summary>
429 /// <param name="result"></param>
430 void Receive(IAsyncResult result)
431 {
432 Socket clientSocket = result.AsyncState as Socket;
433
434 //byte[] b = new byte[1024 * 1024];
435 try
436 {
437 //获取实际的长度
438 int num = clientSocket.EndReceive(result);
439 if (num > 0)
440 {
441 //MessageBox.Show(num.ToString());
442 byte[] buffer = new byte[num];
443 Array.Copy(Common.buffer, 0, buffer, 0, num); //复制数据到data
444 //string ip = Encoding.UTF8.GetString(data);
445
446
447 //以下是客户端=》服务器==》服务器
448 /*
449 * 当if else 超过3个
450 *
451 * 建议用switch case语句
452 */
453
454 //获取口令
455 int command = buffer[0];
456 //说明是获取好友
457 if (command == 10)
458 {
459 //协议说明
460 //第一次登陆获取在线(好友)人数
461 //[命令(10)| ip(自己的ip和所有好友的ip)| ...]
462
463
464 //其实用户本地ip也可以这样获取
465 //string cy = clientSocket.LocalEndPoint;
466
467 string allIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
468 string[] temp = allIp.Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
469
470
471 //跨线程操作UI
472 this.Invoke(new Action(() =>
473 {
474 myIp.Text = temp.Length > 0 ? temp[temp.Length - 1] : "";
475
476 //排除自己的ip
477 var other = from i in temp where !i.Contains(myIp.Text) select i;
478
479 cbList.Items.Clear();//清空
480 cbList.Items.AddRange(other.ToArray()); //绑定列表
481
482 if (cbList.Items.Count > 0)
483 cbList.SelectedIndex = 0;//默认选中第一个
484 }));
485
486 }
487 else if (command == 11) //说明是有人下线
488 {
489 //协议说明
490 // 有人下线
491 //[命令(11)| ip(下线的ip)| ...]
492
493 //获取下线的ip
494 string outIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
495
496 this.Invoke(new Action(() =>
497 {
498 //删除下线的ip
499 cbList.Items.Remove(outIp);
500 if (cbList.Items.Count > 0)
501 cbList.SelectedIndex = 0;//默认选中第一个
502 }));
503 }
504 else if (command == 12) //有人上线了
505 {
506 //协议说明
507 // 有人上线
508 //[命令(12)| ip(上线的ip)| ...]
509
510 //获取上线的ip
511 string onlineIp = Encoding.UTF8.GetString(buffer, 1, num - 1);
512 //添加上线的ip
513
514 this.Invoke(new Action(() =>
515 {
516 //添加上线的ip
517 cbList.Items.Add(onlineIp);
518 if (cbList.Items.Count > 0)
519 cbList.SelectedIndex = 0;//默认选中第一个
520 }));
521 }
522
523 //以下是客户端=》服务器==》客户端
524
525 else if (command == 1)
526 {
527 //协议：
528 //[命令(1)|对方的ip和自己的ip 50位)| 内容(文字) | ...]
529
530 //获取ip段
531 string[] sourceIp = Encoding.UTF8.GetString(buffer, 1, 50).Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
532
533 //发消息来的ip
534 string fromIp = sourceIp[1];
535
536
537
538 //获取内容
539 string content = Encoding.UTF8.GetString(buffer, 50 + 1, num - 50 - 1);
540
541 this.Invoke(new Action(() =>
542 {
543 //列表框中选择当前的ip
544 cbList.Text = fromIp.ToString();
545
546 //显示内容
547 tbHis.AppendText(string.Format("时间：{0}\n", DateTime.Now.ToString()));
548 //tbHis.AppendText(string.Format("提示{0}对我说：", fromIp)); //我操。这样怎么就不行
549 tbHis.AppendText(fromIp + "\n");
550 tbHis.AppendText("对你说：\n");
551 tbHis.AppendText(content + "\n");
552 tbHis.AppendText("\n");
553 }));
554 }
555 else if (command == 0) //发送的文件
556 {
557 /*协议: 这里50位不知道是否理想。
558 * [命令(0)| ip(对方的ip和自己的ip 50位)| 内容(文件大小和文件全名 30位)|响应(文件内容) | ...]
559 */
560
561 //这里有冗余代码
562
563 //获取ip段
564 string[] sourceIp = Encoding.UTF8.GetString(buffer, 1, 50).Split(new char[] { ‘,‘ }, StringSplitOptions.RemoveEmptyEntries);
565
566 //发消息来的ip
567 string fromIp = sourceIp[1];
568
569 this.Invoke(new Action(() =>
570 {
571 //列表框中选择当前的ip
572 cbList.Text = fromIp.ToString();
573 }));
574
575
576 //获取内容
577 string content = Encoding.UTF8.GetString(buffer, 50 + 1, 30);
578
579 //获取响应
580 //string pass = Encoding.UTF8.GetString(buffer, 50 + 30 + 1, num - 50 - 30 - 1);
581
582 //显示
583 //tbHis.AppendText(string.Format("{0}给你发了一个文件：{1}\n", fromIp, content));
584 tbHis.AppendText(fromIp);
585 tbHis.AppendText("给你发了一个文件");
586 tbHis.AppendText(content + "\n");
587 tbHis.AppendText("\n");
588
589
590 //提示用户是否接收文件
591 if (MessageBox.Show("是否接受文件\n" + content, "接收文件", MessageBoxButtons.YesNo) == DialogResult.Yes)
592 {
593 //开始保存
594 SaveFileDialog sfd = new SaveFileDialog();
595 sfd.FileName = content;
596
597 //获取文件类型
598 string ex = content.Split(‘.‘)[1];
599
600 //保存文件类型
601 sfd.Filter = "|*." + ex;
602 if (sfd.ShowDialog(this) == DialogResult.OK)
603 {
604 using (FileStream fs = new FileStream(sfd.FileName, FileMode.Create))
605 {
606 fs.Write(buffer, 50 + 30 + 1, num - 50 - 30 - 1);
607 }
608 }
609
610 }
611
612 }
613 else if (command == 2) //发送抖动
614 {
615 //如果窗口在任务栏。则显示
616 this.Show();
617 this.WindowState = FormWindowState.Normal;
618 this.Activate();
619
620 int n = -1;
621
622 for (int i = 0; i < 10; i++)
623 {
624 n = -n;
625 this.Location = new Point(this.Location.X + 10 * n, this.Location.Y + 10 * n);
626 this.TopMost = true;//在所有窗口的顶部
627 System.Threading.Thread.Sleep(50);
628 }
629
630 //抖动完成。结束顶层显示
631 this.TopMost = false;
632 }
633
634 //连接成功，再一次获取服务器发来的消息
635 clientSocket.BeginReceive(Common.buffer, 0, Common.buffer.Length, 0, new AsyncCallback(Receive), clientSocket);
636
637 }
638 }
639 catch (Exception ex) //服务器端口
640 {
641 MessageBox.Show(ex.Message);
642 clientSocket.Shutdown(SocketShutdown.Receive);
643 clientSocket.Close();
644 }
645 }
646 }
647 }
客户端的一个公共类 Common.cs
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Net;
6 using System.Net.Sockets;
7
8 namespace TopClient
9 {
10 /****************************************
11 * 与服务器通信的类
12 ****************************************/
13 public class Common
14 {
15 /// <summary>
16 /// 与服务器通信的socket
17 /// </summary>
18 public static Socket connSocket;
19
20 /// <summary>
21 /// 保存服务器来的byte
22 /// </summary>
23 public static byte[] buffer = new byte[1024 * 1024];
24
25 /// <summary>
26 /// 保存当登陆成功后。从服务器获取的所有用ip
27 /// </summary>
28 public static string ip;
29
30 /// <summary>
31 /// time计时器
32 /// </summary>
33 public static System.Windows.Forms.Timer time;
34
35 /// <summary>
36 /// 当前是否连接到服务器
37 /// </summary>
38 public static bool isConnect = false;
39
40 /// <summary>
41 /// 保存文件的文件名和扩展名 xxx.png
42 /// </summary>
43 public static string SafeFileName;
44 }
45 }
时间： 2024-08-16 10:38:16