C#编写Socket服务器

1.Socket介绍

所谓套接字(Socket)，就是对网络中差别主机上的应用进程之间进行双向通信的端点的抽象。一个套接字就是网络上进程通信的一端，提供了应用层进程利用网络协议交换数据的机制。从所处的职位来讲，套接字上联应用进程，下联网络协议栈，是应用程序通过网络协议进行通信的接口，是应用程序与网络协议栈进行交互的接口 



2.Socket一样平常应用模式(服务器端和客户端)

3.Socket的通讯过程

4.Socket通信基本流程图：

5.项目界面设计：

6.实现焦点代码

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.Threading.Tasks;
9. using System.Windows.Forms;
11. using System.Net;
12. using System.Net.Sockets;
14. namespace TCPProgect
15. {
16.     public partial class FrmServer : Form
17.     {
18.         public FrmServer()
19.         {
20.             InitializeComponent();
21.         }
23.       
24.         //第一步：调用socket()函数创建一个用于通信的套接字
25.         private Socket listenSocket;
27.         //字典集合：存储IP和Socket的集合
28.         private Dictionary<string, Socket> OnLineList = new Dictionary<string, Socket>();
30.         //当前时间
31.         private string CurrentTime
32.         {
33.             get { return DateTime.Now.ToString("HH:mm:ss") + Environment.NewLine; }
34.         }
36.         //编码格式
37.         Encoding econding = Encoding.Default;
40.         private void btn_StartService_Click(object sender, EventArgs e)
41.         {
42.             //第一步：调用socket()函数创建一个用于通信的套接字
43.             listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
45.             //第二步：给已经创建的套接字绑定一个端口号，这一般通过设置网络套接口地址和调用Bind()函数来实现
46.             IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(this.txt_IP.Text.Trim()), int.Parse(this.txt_Port.Text.Trim()));
48.             try
49.             {
50.                 listenSocket.Bind(endPoint);
51.             }
52.             catch (Exception ex)
53.             {
54.                 MessageBox.Show("服务器开启失败：" + ex.Message, "开启服务器");
55.                 return;
56.             }
58.             //第三步：调用listen()函数使套接字成为一个监听套接字
59.             listenSocket.Listen(10);
61.             ShowMessage("服务器开启成功");
63.             //开启一个线程监听
64.             Task.Run(new Action(() =>
65.                 {
66.                     ListenConnection();
67.                 }
68.                 ));
70.             this.btn_StartService.Enabled = false;
73.         }
75.         private void ListenConnection()
76.         {
77.             while (true)
78.             {
79.                 Socket clientSocket = listenSocket.Accept();
81.                 string ip = clientSocket.RemoteEndPoint.ToString();
83.                 //更新在线列表
84.                 AddOnLine(ip, true);
85.                 //更新在线列表集合
86.                 OnLineList.Add(ip, clientSocket);
88.                 ShowMessage(ip + "上线了");
90.                 Task.Run(() => ReceiveMsg(clientSocket));
92.             }
95.         }
98.         /// <summary>
99.         /// 接收方法
100.         /// </summary>
101.         /// <param name="clientSocket"></param>
102.         private void ReceiveMsg(Socket clientSocket)
103.         {
104.             while (true)
105.             {
106.                 //定义一个2M的缓冲区
107.                 byte[] buffer = new byte[1024 * 1024 * 2];
109.                 int length = -1;
110.                 try
111.                 {
112.                     length = clientSocket.Receive(buffer);
113.                 }
114.                 catch (Exception)
115.                 {
117.                     //客户端下线了
119.                     //更新在线列表
120.                     string ip = clientSocket.RemoteEndPoint.ToString();
122.                     AddOnLine(ip, false);
124.                     OnLineList.Remove(ip);
126.                     break;
127.                 }
129.                 if (length == 0)
130.                 {
131.                     //客户端下线了
133.                     //更新在线列表
134.                     string ip = clientSocket.RemoteEndPoint.ToString();
136.                     AddOnLine(ip, false);
138.                     OnLineList.Remove(ip);
140.                     break;
141.                 }
144.                 if (length > 0)
145.                 {
146.                     string info = econding.GetString(buffer, 0, length);
147.                     ShowMessage(info);
148.                 }
149.             }
150.         }
152.         /// <summary>
153.         /// 在线列表更新
154.         /// </summary>
155.         /// <param name="clientIp"></param>
156.         /// <param name="value"></param>
157.         private void AddOnLine(string clientIp, bool value)
158.         {
159.             Invoke(new Action(() =>
160.             {
161.                 if (value)
162.                 {
163.                     this.lst_Online.Items.Add(clientIp);
164.                 }
165.                 else
166.                 {
167.                     this.lst_Online.Items.Remove(clientIp);
168.                 }
170.             }));
172.         }
175.         /// <summary>
176.         /// 更新接收区
177.         /// </summary>
178.         /// <param name="info"></param>
179.         private void ShowMessage(string info)
180.         {
181.             Invoke(new Action(() =>
182.             {
183.                 this.txt_Rcv.AppendText(CurrentTime + info + Environment.NewLine);
184.             }));
186.         }
188.         /// <summary>
189.         /// 消息发送
190.         /// </summary>
191.         /// <param name="sender"></param>
192.         /// <param name="e"></param>
193.         private void btn_Send_Click(object sender, EventArgs e)
194.         {
195.             if (this.lst_Online.SelectedItem != null)
196.             {
197.                 foreach (string item in this.lst_Online.SelectedItems)
198.                 {
199.                     if (OnLineList.ContainsKey(item))
200.                     {
201.                         OnLineList[item].Send(econding.GetBytes(this.txt_Send.Text.Trim()));
202.                     }
203.                 }
204.             }
205.             else
206.             {
207.                 MessageBox.Show("请先选择要发送的对象", "发送消息");
208.             }
210.         }
212.         /// <summary>
213.         /// 群发功能
214.         /// </summary>
215.         /// <param name="sender"></param>
216.         /// <param name="e"></param>
217.         private void btn_SendAll_Click(object sender, EventArgs e)
218.         {
219.             foreach (string item in this.lst_Online.Items)
220.             {
221.                 if (OnLineList.ContainsKey(item))
222.                 {
223.                     OnLineList[item].Send(econding.GetBytes(this.txt_Send.Text.Trim()));
224.                 }
225.             }
226.         }
227.     }
228. }

复制代码

7.运行结果

        7.1 运行界面演示

         7.2 接收消息界面演示

         7.3 发送消息界面演示

         7.4 群发消息演示

源码地点：https://download.csdn.net/download/m0_73500215/89143273


如果你觉得我的分享有代价，那就请为我点赞收藏吧！你们的支持是我继续分享的动力。盼望大家可以或许积极批评，让我知道你们的想法和建议。谢谢！


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。