下面是我写的一些代码:
服务器端;namespace QQServer
{
    public partial class ServerMain : Form
    {
        public ServerMain()
        {
            InitializeComponent();
        }        private void ServerMain_Load(object sender, EventArgs e)
         {
             this.CmdStar.Enabled = true;
             this.CmdStop.Enabled = false;
         }
 
         //private void 配置参数ToolStripMenuItem_Click(object sender, EventArgs e)
         //{
          //   Set TSet = new Set();
          //   TSet.ShowDialog();
         //}
 
         //private void 关于ToolStripMenuItem_Click(object sender, EventArgs e)
         //{
          //   About TAbout = new About();
          //   TAbout.Show();
        // }
         /// <summary>
         /// 获得XML文件中的端口号
         /// </summary>
         /// <returns></returns>
        private int GetPort()
        {
            try
            {
               
                XmlDocument TDoc = new XmlDocument();
                TDoc.Load("Settings.xml");
                string TPort = TDoc.GetElementsByTagName("ServerPort")[0].InnerXml;
                return Convert.ToInt32(TPort);            }
            catch { return 6600; }//默认是6600
        }
 
         //声明将要用到的类
         private IPEndPoint ServerInfo;//存放服务器的IP和端口信息
         private Socket ServerSocket;//服务端运行的SOCKET
         private Thread ServerThread;//服务端运行的线程
         private Socket[] ClientSocket;//为客户端建立的SOCKET连接
         private int ClientNumb;//存放客户端数量
         private byte[] MsgBuffer;//存放消息数据
 
         private void CmdStar_Click(object sender, EventArgs e)
         {
             ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
             ServerInfo=new IPEndPoint(IPAddress.Any,this.GetPort());
             ServerSocket.Bind(ServerInfo);//将SOCKET接口和IP端口绑定
             ServerSocket.Listen(10);//开始监听,并且挂起数为10
 
             ClientSocket = new Socket[65535];//为客户端提供连接个数
             MsgBuffer = new byte[65535];//消息数据大小
             ClientNumb = 0;//数量从0开始统计
 
             ServerThread = new Thread(RecieveAccept);//将接受客户端连接的方法委托给线程
             ServerThread.Start();//线程开始运行
 
             CheckForIllegalCrossThreadCalls = false;//不捕获对错误线程的调用
 
             this.CmdStar.Enabled = false;
             this.CmdStop.Enabled = true;
             this.StateMsg.Text = "服务正在运行 "+"  运行端口:"+this.GetPort().ToString();
             this.ClientList.Items.Add("服务于 " + DateTime.Now.ToString() + " 开始运行.");
             //Console.Write("hhh");
             
         }
         
         //接受客户端连接的方法
         private void RecieveAccept()
         {
             while (true)
             {
                 ClientSocket[ClientNumb] = ServerSocket.Accept();
                 ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack),ClientSocket[ClientNumb]);
                 this.ClientList.Items.Add(ClientSocket[ClientNumb].RemoteEndPoint.ToString()+" 成功连接服务器.");
                 ClientNumb++;
            }
         }
 
         //回发数据给客户端
         private void RecieveCallBack(IAsyncResult AR)
         {
             try
             {
                 Socket RSocket = (Socket)AR.AsyncState;
                 int REnd = RSocket.EndReceive(AR);
                 //for (int i = 0; i < ClientNumb; i++)
                 //{
                 //    if (ClientSocket[i].Connected)
                  //   {
                         RSocket.Send(MsgBuffer, 0, REnd, 0);
                  //   }
                     RSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack), RSocket);                 
             }
             catch
             {
                
             }         }
 
         private void CmdStop_Click(object sender, EventArgs e)
         {
             ServerThread.Abort();//线程终止
             ServerSocket.Close();//关闭SOCKET
 
             this.CmdStar.Enabled = true;
             this.CmdStop.Enabled = false;
             this.StateMsg.Text = "等待运行 ";
             this.ClientList.Items.Add("服务于 " + DateTime.Now.ToString() + " 停止运行.");
         }    }
}客户端:
  namespace QQClient
{
    public partial class ClientMain : Form
    {
        
        public ClientMain()
        {
            InitializeComponent();
        }
         private IPEndPoint ServerInfo;
         private Socket ClientSocket;
         private Byte[] MsgBuffer;
         private Byte[] MsgSend;
         private void ClientMain_Load(object sender, EventArgs e)
         {
             this.CmdSend.Enabled = false;
             this.CmdExit.Enabled = false;             ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
             MsgBuffer = new Byte[65535];
             MsgSend = new Byte[65535];
             CheckForIllegalCrossThreadCalls = false;             Random TRand = new Random();
             
             this.textBox3.Text = "用户" + TRand.Next(10000).ToString();
         }         private void CmdEnter_Click(object sender, EventArgs e)
         {
             
             try
             {
                 ServerInfo = new IPEndPoint(IPAddress.Parse(this.textBox1.Text), Convert.ToInt32(this.textBox2.Text));                 ClientSocket.Connect(ServerInfo);                 ClientSocket.Send(Encoding.Unicode.GetBytes("用户: " + this.textBox3.Text + " 进入系统!\n"));                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);                 this.SysMsg.Text += "登录服务器成功!\n";
                 this.CmdSend.Enabled = true;
                 this.CmdEnter.Enabled = false;
                 this.CmdExit.Enabled = true;             }
             catch
             {
                 MessageBox.Show("登录服务器失败,请确认服务器是否正常工作!");
             }
         }         private void ReceiveCallBack(IAsyncResult AR)
         {
             try
             {
                 int REnd = ClientSocket.EndReceive(AR);
                 this.RecieveMsg.AppendText(Encoding.Unicode.GetString(MsgBuffer, 0, REnd));
                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null);             }
             catch
             {
                 MessageBox.Show("已经与服务器断开连接!");
                 //this.Close();
             }         }         private void CmdSend_Click(object sender, EventArgs e)
         {
             MsgSend = Encoding.Unicode.GetBytes(this.textBox3.Text + "说:\n" + this.SendMsg.Text + "\n");
             if (ClientSocket.Connected)
             {
                 ClientSocket.Send(MsgSend);
                 this.SendMsg.Text = "";
             }
             else
             {
                 MessageBox.Show("当前与服务器断开连接,无法发送信息!");
             }
         }         private void CmdExit_Click(object sender, EventArgs e)
         {
             if (ClientSocket.Connected)
             {
                 ClientSocket.Send(Encoding.Unicode.GetBytes(this.textBox1.Text + "离开了房间!\n"));
                 ClientSocket.Shutdown(SocketShutdown.Both);
                 ClientSocket.Disconnect(false);
             }
             ClientSocket.Close();             this.CmdSend.Enabled = false;
             this.CmdEnter.Enabled = true;
             this.CmdExit.Enabled = false;
         }         private void RecieveMsg_TextChanged(object sender, EventArgs e)
         {
             this.RecieveMsg.ScrollToCaret();
         }         private void SendMsg_KeyDown(object sender, KeyEventArgs e)
         {
             if (e.Control && e.KeyValue == 13)
             {
                 e.Handled = true;
                 this.CmdSend_Click(this, null);
             }
         }    }
}
现在我要的效果是客户端一断开连接,服务器端知道后,就从socket数组这边释放客户端连接,否则private Socket[] ClientSocket迟早会填满的。求解决方案

解决方案 »

  1.   

    private void RecieveCallBack(IAsyncResult AR)
      {
      try
      {
      Socket RSocket = (Socket)AR.AsyncState;
      int REnd = RSocket.EndReceive(AR);
      //for (int i = 0; i < ClientNumb; i++)
      //{
      // if (ClientSocket[i].Connected)
      // {
      RSocket.Send(MsgBuffer, 0, REnd, 0);
      // }
      RSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(RecieveCallBack), RSocket);    
      }
      catch (SocketException exp)
      {
        if(10054==ex.ErrorCode)//如果客户端已经断开连接
         {
           这里可以处理客户端断开连接后的事情
         }
      }大概看了下代码,应该这样改下,如有错误请见谅!主要方法在于:
    catch (SocketException exp)
      {
        if(10054==ex.ErrorCode)//如果客户端已经断开连接
         {
           这里可以处理客户端断开连接后的事情
         }
      }
    这些代码!
      

  2.   

    太长了,没看。在服务端写个close方法,关闭客户端传过来的关闭请求。另外就是对超出一定时间没有运作的客户端也一律关闭