服务器+客户端的聊天程序

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

创新互联一直通过网站建设和网站营销帮助企业获得更多客户资源。 以"深度挖掘，量身打造，注重实效"的一站式服务，以网站设计制作、成都网站建设、移动互联产品、营销型网站建设服务为核心业务。10年网站制作的经验，使用新网站建设技术，全新开发出的标准网站，不但价格便宜而且实用、灵活，特别适合中小公司网站制作。网站管理系统简单易用，维护方便，您可以完全操作网站资料，是中小公司快速网站建设的选择。

首先，本文主要是针对那些刚接触SOCKET编程的朋友，如果是高手，就可以不看此文啦

在开始之前，我们需要预习一些基础知识：

什么是SOCKET套接字？

SOCKET通常有那几种数据格式？

线程的概念？

（以上基本知识我就不讲了，网上这方面资料很多的，大家找资料看下吧）

我要介绍的是一个服务器端+客户端的聊天系统，程序比较简单，我先把程序运行的界面给大家看下：

上面是服务器端运行界面；下面把客户端界面贴给大家看下：

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

看了上面的图，下面我们就给大家把代码贴出来：（因为程序比较简单，所以本人就没有去分层啦）

服务器端代码：

 
 
 
 
    
  
  
  
  
  1.  using System;  
    2.   
  
  
  
  2.  using System.Collections.Generic;  
    3.   
  
  
  
  3.  using System.ComponentModel;  
    4.   
  
  
  
  4.  using System.Data;  
    5.   
  
  
  
  5.  using System.Drawing;  
    6.   
  
  
  
  6.  using System.Text;  
    7.   
  
  
  
  7.  using System.Windows.Forms;  
    8.   
  
  
  
  8.    
    9.   
  
  
  
  9.  using System.Net;  
    10.   
  
  
  
  10.  using System.Net.Sockets;  
    11.   
  
  
  
  11.  using System.Threading;  
    12.   
  
  
  
  12.  using System.Xml;  
    13.   
  
  
  
  13.    
    14.   
  
  
  
  14.  namespace Server  
    15.   
  
  
  
  15.  {  
    16.   
  
  
  
  16.      public partial class ServerMain : Form  
    17.   
  
  
  
  17.      {  
    18.   
  
  
  
  18.          public ServerMain()  
    19.   
  
  
  
  19.          {  
    20.   
  
  
  
  20.              InitializeComponent();  
    21.   
  
  
  
  21.          }  
    22.   
  
  
  
  22.    
    23.   
  
  
  
  23.          private void ServerMain_Load(object sender, EventArgs e)  
    24.   
  
  
  
  24.          {  
    25.   
  
  
  
  25.              this.CmdStar.Enabled = true;  
    26.   
  
  
  
  26.              this.CmdStop.Enabled = false;  
    27.   
  
  
  
  27.          }  
    28.   
  
  
  
  28.    
    29.   
  
  
  
  29.          private void 配置参数ToolStripMenuItem_Click(object sender, EventArgs e)  
    30.   
  
  
  
  30.          {  
    31.   
  
  
  
  31.              Set TSet = new Set();  
    32.   
  
  
  
  32.              TSet.ShowDialog();  
    33.   
  
  
  
  33.          }  
    34.   
  
  
  
  34.  
    35.   
  
  
  
  35.          private void 关于ToolStripMenuItem_Click(object sender, EventArgs e)  
    36.   
  
  
  
  36.          {  
    37.   
  
  
  
  37.              About TAbout = new About();  
    38.   
  
  
  
  38.              TAbout.Show();  
    39.   
  
  
  
  39.          }  
    40.   
  
  
  
  40.          /// < summary>  
    41.   
  
  
  
  41.          /// 获得XML文件中的端口号  
    42.   
  
  
  
  42.          /// < /summary>  
    43.   
  
  
  
  43.          /// < returns>< /returns>  
    44.   
  
  
  
  44.          private int GetPort()  
    45.   
  
  
  
  45.          {  
    46.   
  
  
  
  46.              try 
    47.   
  
  
  
  47.              {  
    48.   
  
  
  
  48.                  XmlDocument TDoc = new XmlDocument();  
    49.   
  
  
  
  49.                  TDoc.Load("Settings.xml");  
    50.   
  
  
  
  50.                  string TPort = TDoc.GetElementsByTagName("ServerPort")[0].InnerXml;  
    51.   
  
  
  
  51.                  return Convert.ToInt32(TPort);  
    52.   
  
  
  
  52.    
    53.   
  
  
  
  53.              }  
    54.   
  
  
  
  54.              catch { return 6600; }//默认是6600  
    55.   
  
  
  
  55.          }  
    56.   
  
  
  
  56.    
    57.   
  
  
  
  57.          //声明将要用到的类  
    58.   
  
  
  
  58.          private IPEndPoint ServerInfo;//存放服务器的IP和端口信息  
    59.   
  
  
  
  59.          private Socket ServerSocket;//服务端运行的SOCKET  
    60.   
  
  
  
  60.          private Thread ServerThread;//服务端运行的线程  
    61.   
  
  
  
  61.          private Socket[] ClientSocket;//为客户端建立的SOCKET连接  
    62.   
  
  
  
  62.          private int ClientNumb;//存放客户端数量  
    63.   
  
  
  
  63.          private byte[] MsgBuffer;//存放消息数据  
    64.   
  
  
  
  64.    
    65.   
  
  
  
  65.          private void CmdStar_Click(object sender, EventArgs e)  
    66.   
  
  
  
  66.          {  
    67.   
  
  
  
  67.              ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  
    68.   
  
  
  
  68.              ServerInfo=new IPEndPoint(IPAddress.Any,this.GetPort());  
    69.   
  
  
  
  69.              ServerSocket.Bind(ServerInfo);//将SOCKET接口和IP端口绑定  
    70.   
  
  
  
  70.              ServerSocket.Listen(10);//开始监听，并且挂起数为10  
    71.   
  
  
  
  71.    
    72.   
  
  
  
  72.              ClientSocket = new Socket[65535];//为客户端提供连接个数  
    73.   
  
  
  
  73.              MsgBuffer = new byte[65535];//消息数据大小  
    74.   
  
  
  
  74.              ClientNumb = 0;//数量从0开始统计  
    75.   
  
  
  
  75.    
    76.   
  
  
  
  76.              ServerThread = new Thread(RecieveAccept);//将接受客户端连接的方法委托给线程  
    77.   
  
  
  
  77.              ServerThread.Start();//线程开始运行  
    78.   
  
  
  
  78.    
    79.   
  
  
  
  79.              CheckForIllegalCrossThreadCalls = false;//不捕获对错误线程的调用  
    80.   
  
  
  
  80.    
    81.   
  
  
  
  81.              this.CmdStar.Enabled = false;  
    82.   
  
  
  
  82.              this.CmdStop.Enabled = true;  
    83.   
  
  
  
  83.              this.StateMsg.Text = "服务正在运行"+"  运行端口："+this.GetPort().ToString();  
    84.   
  
  
  
  84.              this.ClientList.Items.Add("服务于 " + DateTime.Now.ToString() + " 开始运行.");  
    85.   
  
  
  
  85.          }  
    86.   
  
  
  
  86.            
    87.   
  
  
  
  87.          //接受客户端连接的方法  
    88.   
  
  
  
  88.          private void RecieveAccept()  
    89.   
  
  
  
  89.          {  
    90.   
  
  
  
  90.              while (true)  
    91.   
  
  
  
  91.              {  
    92.   
  
  
  
  92.                  ClientSocket[ClientNumb] = ServerSocket.Accept();  
    93.   
  
  
  
  93.                  ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack),ClientSocket[ClientNumb]);  
    94.   
  
  
  
  94.                  this.ClientList.Items.Add(ClientSocket[ClientNumb].RemoteEndPoint.ToString()+" 成功连接服务器.");  
    95.   
  
  
  
  95.                  ClientNumb++;  
    96.   
  
  
  
  96.              }  
    97.   
  
  
  
  97.          }  
    98.   
  
  
  
  98.    
    99.   
  
  
  
  99.          //回发数据给客户端  
    100.   
  
  
  
  100.         private void RecieveCallBack(IAsyncResult AR)  
    101.   
  
  
  
  101.         {  
    102.   
  
  
  
  102.             try 
    103.   
  
  
  
  103.             {  
    104.   
  
  
  
  104.                 Socket RSocket = (Socket)AR.AsyncState;  
    105.   
  
  
  
  105.                 int REnd = RSocket.EndReceive(AR);  
    106.   
  
  
  
  106.                 for (int i = 0; i <  ClientNumb; i++)  
    107.   
  
  
  
  107.                 {  
    108.   
  
  
  
  108.                     if (ClientSocket[i].Connected)  
    109.   
  
  
  
  109.                     {  
    110.   
  
  
  
  110.                         ClientSocket[i].Send(MsgBuffer, 0, REnd,0);  
    111.   
  
  
  
  111.                     }  
    112.   
  
  
  
  112.                     RSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack), RSocket);  
    113.   
  
  
  
  113.  
    114.   
  
  
  
  114.                 }  
    115.   
  
  
  
  115.             }  
    116.   
  
  
  
  116.             catch { }  
    117.   
  
  
  
  117.  
    118.   
  
  
  
  118.         }  
    119.   
  
  
  
  119.  
    120.   
  
  
  
  120.         private void CmdStop_Click(object sender, EventArgs e)  
    121.   
  
  
  
  121.         {  
    122.   
  
  
  
  122.             ServerThread.Abort();//线程终止  
    123.   
  
  
  
  123.             ServerSocket.Close();//关闭SOCKET  
    124.   
  
  
  
  124.  
    125.   
  
  
  
  125.             this.CmdStar.Enabled = true;  
    126.   
  
  
  
  126.             this.CmdStop.Enabled = false;  
    127.   
  
  
  
  127.             this.StateMsg.Text = "等待运行";  
    128.   
  
  
  
  128.             this.ClientList.Items.Add("服务于 " + DateTime.Now.ToString() + " 停止运行.");  
    129.   
  
  
  
  129.         }  
    130.   
  
  
  
  130.  
    131.   
  
  
  
  131.  
    132.   
  
  
  
  132.  
    133.   
  
  
  
  133.     }  
    134.   
  
  
  
  134. } 
    135.

客户端代码：

 
 
 
 
    
  
  
  
  
  1.  using System;  
    2.   
  
  
  
  2.  using System.Collections.Generic;  
    3.   
  
  
  
  3.  using System.ComponentModel;  
    4.   
  
  
  
  4.  using System.Data;  
    5.   
  
  
  
  5.  using System.Drawing;  
    6.   
  
  
  
  6.  using System.Text;  
    7.   
  
  
  
  7.  using System.Windows.Forms;  
    8.   
  
  
  
  8.    
    9.   
  
  
  
  9.  using System.Net;  
    10.   
  
  
  
  10.  using System.Net.Sockets;  
    11.   
  
  
  
  11.  
    12.   
  
  
  
  12. namespace Client  
    13.   
  
  
  
  13. {  
    14.   
  
  
  
  14.     public partial class ClientMain : Form  
    15.   
  
  
  
  15.     {  
    16.   
  
  
  
  16.         public ClientMain()  
    17.   
  
  
  
  17.         {  
    18.   
  
  
  
  18.             InitializeComponent();  
    19.   
  
  
  
  19.         }  
    20.   
  
  
  
  20.  
    21.   
  
  
  
  21.         private IPEndPoint ServerInfo;  
    22.   
  
  
  
  22.         private Socket ClientSocket;  
    23.   
  
  
  
  23.         private Byte[] MsgBuffer;  
    24.   
  
  
  
  24.         private Byte[] MsgSend;  
    25.   
  
  
  
  25.  
    26.   
  
  
  
  26.         private void ClientMain_Load(object sender, EventArgs e)  
    27.   
  
  
  
  27.         {  
    28.   
  
  
  
  28.             this.CmdSend.Enabled = false;  
    29.   
  
  
  
  29.             this.CmdExit.Enabled = false;  
    30.   
  
  
  
  30.  
    31.   
  
  
  
  31.             ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  
    32.   
  
  
  
  32.             MsgBuffer = new Byte[65535];  
    33.   
  
  
  
  33.             MsgSend = new Byte[65535];  
    34.   
  
  
  
  34.             CheckForIllegalCrossThreadCalls = false;  
    35.   
  
  
  
  35.  
    36.   
  
  
  
  36.             Random TRand=new Random();  
    37.   
  
  
  
  37.             this.UserName.Text = "用户" + TRand.Next(10000).ToString();  
    38.   
  
  
  
  38.         }  
    39.   
  
  
  
  39.  
    40.   
  
  
  
  40.         private void CmdEnter_Click(object sender, EventArgs e)  
    41.   
  
  
  
  41.         {  
    42.   
  
  
  
  42.             ServerInfo = new IPEndPoint(IPAddress.Parse(this.ServerIP.Text), Convert.ToInt32(this.ServerPort.Text));  
    43.   
  
  
  
  43.  
    44.   
  
  
  
  44.             try 
    45.   
  
  
  
  45.             {  
    46.   
  
  
  
  46.                 ClientSocket.Connect(ServerInfo);  
    47.   
  
  
  
  47.  
    48.   
  
  
  
  48.                 ClientSocket.Send(Encoding.Unicode.GetBytes("用户： " + this.UserName.Text + " 进入系统！\n"));  
    49.   
  
  
  
  49.  
    50.   
  
  
  
  50.                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);  
    51.   
  
  
  
  51.  
    52.   
  
  
  
  52.                 this.SysMsg.Text += "登录服务器成功！\n";  
    53.   
  
  
  
  53.                 this.CmdSend.Enabled = true;  
    54.   
  
  
  
  54.                 this.CmdEnter.Enabled = false;  
    55.   
  
  
  
  55.                 this.CmdExit.Enabled = true;  
    56.   
  
  
  
  56.             }  
    57.   
  
  
  
  57.             catch 
    58.   
  
  
  
  58.             {  
    59.   
  
  
  
  59.                 MessageBox.Show("登录服务器失败，请确认服务器是否正常工作！");  
    60.   
  
  
  
  60.             }  
    61.   
  
  
  
  61.         }  
    62.   
  
  
  
  62.  
    63.   
  
  
  
  63.         private void ReceiveCallBack(IAsyncResult AR)  
    64.   
  
  
  
  64.         {  
    65.   
  
  
  
  65.             try 
    66.   
  
  
  
  66.             {  
    67.   
  
  
  
  67.                 int REnd = ClientSocket.EndReceive(AR);  
    68.   
  
  
  
  68.                 this.RecieveMsg.AppendText(Encoding.Unicode.GetString(MsgBuffer, 0, REnd));  
    69.   
  
  
  
  69.                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);  
    70.   
  
  
  
  70.  
    71.   
  
  
  
  71.             }  
    72.   
  
  
  
  72.             catch 
    73.   
  
  
  
  73.             {  
    74.   
  
  
  
  74.                 MessageBox.Show("已经与服务器断开连接！");  
    75.   
  
  
  
  75.                 this.Close();  
    76.   
  
  
  
  76.            }  
    77.   
  
  
  
  77.  
    78.   
  
  
  
  78.         }  
    79.   
  
  
  
  79.  
    80.   
  
  
  
  80.         private void CmdSend_Click(object sender, EventArgs e)  
    81.   
  
  
  
  81.         {  
    82.   
  
  
  
  82.            MsgSend = Encoding.Unicode.GetBytes(this.UserName.Text + "说：\n" + this.SendMsg.Text + "\n");  
    83.   
  
  
  
  83.             if (ClientSocket.Connected)  
    84.   
  
  
  
  84.             {  
    85.   
  
  
  
  85.                 ClientSocket.Send(MsgSend);  
    86.   
  
  
  
  86.                 this.SendMsg.Text = "";  
    87.   
  
  
  
  87.             }  
    88.   
  
  
  
  88.             else 
    89.   
  
  
  
  89.             {  
    90.   
  
  
  
  90.                 MessageBox.Show("当前与服务器断开连接，无法发送信息！");  
    91.   
  
  
  
  91.             }  
    92.   
  
  
  
  92.         }  
    93.   
  
  
  
  93.  
    94.   
  
  
  
  94.         private void CmdExit_Click(object sender, EventArgs e)  
    95.   
  
  
  
  95.         {  
    96.   
  
  
  
  96.             if (ClientSocket.Connected)  
    97.   
  
  
  
  97.             {  
    98.   
  
  
  
  98.                 ClientSocket.Send(Encoding.Unicode.GetBytes(this.UserName.Text + "离开了房间！\n"));  
    99.   
  
  
  
  99.                 ClientSocket.Shutdown(SocketShutdown.Both);  
    100.   
  
  
  
  100.                ClientSocket.Disconnect(false);  
    101.   
  
  
  
  101.            }  
    102.   
  
  
  
  102.            ClientSocket.Close();  
    103.   
  
  
  
  103.  
    104.   
  
  
  
  104.            this.CmdSend.Enabled = false;  
    105.   
  
  
  
  105.            this.CmdEnter.Enabled = true;  
    106.   
  
  
  
  106.            this.CmdExit.Enabled = false;  
    107.   
  
  
  
  107.        }  
    108.   
  
  
  
  108.  
    109.   
  
  
  
  109.        private void RecieveMsg_TextChanged(object sender, EventArgs e)  
    110.   
  
  
  
  110.        {  
    111.   
  
  
  
  111.            this.RecieveMsg.ScrollToCaret();  
    112.   
  
  
  
  112.        }  
    113.   
  
  
  
  113.  
    114.   
  
  
  
  114.        private void SendMsg_KeyDown(object sender, KeyEventArgs e)  
    115.   
  
  
  
  115.        {  
    116.   
  
  
  
  116.            if (e.Control && e.KeyValue == 13)  
    117.   
  
  
  
  117.            {  
    118.   
  
  
  
  118.                e.Handled = true;  
    119.   
  
  
  
  119.                this.CmdSend_Click(this, null);  
    120.   
  
  
  
  120.            }  
    121.   
  
  
  
  121.        }  
    122.   
  
  
  
  122.  
    123.   
  
  
  
  123.  
    124.   
  
  
  
  124.  
    125.   
  
  
  
  125.  
    126.   
  
  
  
  126.    }  
    127.

我只对服务器端的代码做了注释，客户端就没有写注释了，因为代码是差不多的。区别在于客户端不需要监听，也不需要启用线程进行委托。

关于 ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

这句代码，我想给初学者解释一下，这里“AddressFamily.InterNetwork”表示的是使用IPV4地址，“SocketType.Stream”表示使用的是流格式（另外还有数据包格式和原始套接字格式），“ProtocolType.Tcp”表示使用TCP协议（另外还有很多其它协议，例如大家常看到的UDP协议）。

服务器端+客户端的聊天系统就介绍完了。另外关于SOCKET类中的BeginReceive方法，请大家参考MSDN，里面有详细说明。

本文标题：服务器+客户端的聊天程序
文章出自：http://www.csdahua.cn/qtweb/news30/112330.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

python知识

各行业网站

平山县网站建设　　 　造型师设计　　 　边坡防护网　　 　兴发搬家　　 　网站运营　　 　成都门户网站建设　　 　成都网站设计　　 　成都app开发　　 　网页改版　　 　重庆网站制作　　 　全网营销推广　　 　成都网站建设　　 　成都租用服务器　　 　自适应网站　　 　成都柴油发电机租赁　　 　成都SEO公司　　 　电信内江机房　　 　手机网站版本　　 　成都酒店服定制　　 　东电技服