下面是我写的一些代码:
服务器端;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迟早会填满的。求解决方案
服务器端;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迟早会填满的。求解决方案
{
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)//如果客户端已经断开连接
{
这里可以处理客户端断开连接后的事情
}
}
这些代码!