黄聪：C#下如何实现服务器+客户端的聊天程序

最近也在接触SOCKET编程&＃xff0c;在当今这样一个网络时代&＃xff0c;很多技术都以网络为中心在诞生&＃xff0c;至少我认为是这样的&＃xff0c;而SOCKET套接字接口&＃xff0c;在实现网络通讯上处于关键地位&＃xff0c;所以不会SOCKET是不行的。

首先&＃xff0c;本文主要是针对那些刚接触SOCKET编程的朋友&＃xff0c;如果是高手&＃xff0c;就可以不看此文啦&＃xff0c;可以去陪陪老婆&＃xff0c;比如逛街或看电视...

在开始之前&＃xff0c;我们需要预习一些基础知识&＃xff1a;
什么是SOCKET套接字&＃xff1f;
SOCKET通常有那几种数据格式&＃xff1f;
线程的概念&＃xff1f;
&＃xff08;以上基本知识我就不讲了&＃xff0c;网上这方面资料很多的&＃xff0c;大家找资料看下吧&＃xff09;

我要介绍的是一个服务器端&＃43;客户端的聊天系统&＃xff0c;程序比较简单&＃xff0c;我先把程序运行的界面给大家看下&＃xff1a;


上面是服务器端运行界面&＃xff1b;下面把客户端界面贴给大家看下&＃xff1a;



功能比较简单&＃xff0c;服务器的端口号可以在“系统菜单”里面的参数配置进行修改的。

看了上面的图&＃xff0c;下面我们就给大家把代码贴出来&＃xff1a;&＃xff08;因为程序比较简单&＃xff0c;所以本人就没有去分层啦&＃xff09;

服务器端代码&＃xff1a;

  1 using System;
  2 using System.Collections.Generic;
  3 using System.ComponentModel;
  4 using System.Data;
  5 using System.Drawing;
  6 using System.Text;
  7 using System.Windows.Forms;
  8 
  9 using System.Net;
 10 using System.Net.Sockets;
 11 using System.Threading;
 12 using System.Xml;
 13 
 14 namespace Server
 15 {
 16     public partial class ServerMain : Form
 17     {
 18         public ServerMain()
 19         {
 20             InitializeComponent();
 21         }
 22 
 23         private void ServerMain_Load(object sender, EventArgs e)
 24         {
 25             this.CmdStar.Enabled &＃61; true;
 26             this.CmdStop.Enabled &＃61; false;
 27         }
 28 
 29         private void 配置参数ToolStripMenuItem_Click(object sender, EventArgs e)
 30         {
 31             Set TSet &＃61; new Set();
 32             TSet.ShowDialog();
 33         }
 34 
 35         private void 关于ToolStripMenuItem_Click(object sender, EventArgs e)
 36         {
 37             About TAbout &＃61; new About();
 38             TAbout.Show();
 39         }
 40         /// 

 41         /// 获得XML文件中的端口号
 42         /// 

 43         /// 
 44         private int GetPort()
 45         {
 46             try
 47             {
 48                 XmlDocument TDoc &＃61; new XmlDocument();
 49                 TDoc.Load("Settings.xml");
 50                 string TPort &＃61; TDoc.GetElementsByTagName("ServerPort")[0].InnerXml;
 51                 return Convert.ToInt32(TPort);
 52 
 53             }
 54             catch { return 6600; }//默认是6600
 55         }
 56 
 57         //声明将要用到的类
 58         private IPEndPoint ServerInfo;//存放服务器的IP和端口信息
 59         private Socket ServerSocket;//服务端运行的SOCKET
 60         private Thread ServerThread;//服务端运行的线程
 61         private Socket[] ClientSocket;//为客户端建立的SOCKET连接
 62         private int ClientNumb;//存放客户端数量
 63         private byte[] MsgBuffer;//存放消息数据
 64 
 65         private void CmdStar_Click(object sender, EventArgs e)
 66         {
 67             ServerSocket &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 68             ServerInfo&＃61;new IPEndPoint(IPAddress.Any,this.GetPort());
 69             ServerSocket.Bind(ServerInfo);//将SOCKET接口和IP端口绑定
 70             ServerSocket.Listen(10);//开始监听&＃xff0c;并且挂起数为10
 71 
 72             ClientSocket &＃61; new Socket[65535];//为客户端提供连接个数
 73             MsgBuffer &＃61; new byte[65535];//消息数据大小
 74             ClientNumb &＃61; 0;//数量从0开始统计
 75 
 76             ServerThread &＃61; new Thread(RecieveAccept);//将接受客户端连接的方法委托给线程
 77             ServerThread.Start();//线程开始运行
 78 
 79             CheckForIllegalCrossThreadCalls &＃61; false;//不捕获对错误线程的调用
 80 
 81             this.CmdStar.Enabled &＃61; false;
 82             this.CmdStop.Enabled &＃61; true;
 83             this.StateMsg.Text &＃61; "服务正在运行"&＃43;"  运行端口&＃xff1a;"&＃43;this.GetPort().ToString();
 84             this.ClientList.Items.Add("服务于 " &＃43; DateTime.Now.ToString() &＃43; " 开始运行.");
 85         }
 86         
 87         //接受客户端连接的方法
 88         private void RecieveAccept()
 89         {
 90             while (true)
 91             {
 92                 ClientSocket[ClientNumb] &＃61; ServerSocket.Accept();
 93                 ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack),ClientSocket[ClientNumb]);
 94                 this.ClientList.Items.Add(ClientSocket[ClientNumb].RemoteEndPoint.ToString()&＃43;" 成功连接服务器.");
 95                 ClientNumb&＃43;&＃43;;
 96             }
 97         }
 98 
 99         //回发数据给客户端
100         private void RecieveCallBack(IAsyncResult AR)
101         {
102             try
103             {
104                 Socket RSocket &＃61; (Socket)AR.AsyncState;
105                 int REnd &＃61; RSocket.EndReceive(AR);
106                 for (int i &＃61; 0; i < ClientNumb; i&＃43;&＃43;)
107                 {
108                     if (ClientSocket[i].Connected)
109                     {
110                         ClientSocket[i].Send(MsgBuffer, 0, REnd,0);
111                     }
112                     RSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack), RSocket);
113 
114                 }
115             }
116             catch { }
117 
118         }
119 
120         private void CmdStop_Click(object sender, EventArgs e)
121         {
122             ServerThread.Abort();//线程终止
123             ServerSocket.Close();//关闭SOCKET
124 
125             this.CmdStar.Enabled &＃61; true;
126             this.CmdStop.Enabled &＃61; false;
127             this.StateMsg.Text &＃61; "等待运行";
128             this.ClientList.Items.Add("服务于 " &＃43; DateTime.Now.ToString() &＃43; " 停止运行.");
129         }
130 
131 
132 
133     }
134 }

客户端代码&＃xff1a;

我只对服务器端的代码做了注释&＃xff0c;客户端就没有写注释了&＃xff0c;因为代码是差不多的。区别在于客户端不需要监听&＃xff0c;也不需要启用线程进行委托。
关于 ServerSocket &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
这句代码&＃xff0c;我想给初学者解释一下&＃xff0c;这里“AddressFamily.InterNetwork”表示的是使用IPV4地址&＃xff0c;“SocketType.Stream”表示使用的是流格式&＃xff08;另外还有数据包格式和原始套接字格式&＃xff09;&＃xff0c;“ProtocolType.Tcp”表示使用TCP协议&＃xff08;另外还有很多其它协议&＃xff0c;例如大家常看到的UDP协议&＃xff09;。

另外关于SOCKET类中的BeginReceive方法&＃xff0c;请大家参考MSDN&＃xff0c;里面有详细说明。

希望本人给的这个程序可以起到一个抛砖引玉的作用&＃xff0c;不明白之处可以加QQ&＃xff08;17020415&＃xff09;或留言。

备注&＃xff1a;

完整的源码我已经放在CSDN上面共享了&＃xff0c;地址&＃xff1a;http://download.csdn.net/user/lixyvip