using System;using System.Drawing;using System.Collections;using System.ComponentModel;using System.Windows.Forms;using System.Data; using System.Threading;using System.Net.Sockets;using System.Net;namespace Chat_Server{/// /// Form1 的摘要说明。/// public class Form1 : System.Windows.Forms.Form{/// /// 必需的设计器变量。/// private System.ComponentModel.Container components = null;
static int listenport=6666;Socket clientsocket;private System.Windows.Forms.ListBox lbClients;ArrayList clients;private System.Windows.Forms.Button button1;Thread clientservice;private System.Windows.Forms.Label label1;Thread threadListen;
public Form1(){InitializeComponent();
}
/// /// 清理所有正在使用的资源。/// protected override void Dispose( bool disposing ){if( disposing ){if(clientservice != null){clientservice.Abort();}if(threadListen != null){try{threadListen.Abort();}catch(Exception ex){threadListen = null;}}
if (components != null) {components.Dispose();}}base.Dispose( disposing );}
#region Windows 窗体设计器生成的代码/// /// 设计器支持所需的方法 - 不要使用代码编辑器修改/// 此方法的内容。/// private void InitializeComponent(){this.lbClients = new System.Windows.Forms.ListBox();this.button1 = new System.Windows.Forms.Button();this.label1 = new System.Windows.Forms.Label();this.SuspendLayout();// // lbClients// this.lbClients.ItemHeight = 12;this.lbClients.Location = new System.Drawing.Point(16, 24);this.lbClients.Name = "lbClients";this.lbClients.Size = new System.Drawing.Size(184, 268);this.lbClients.TabIndex = 0;// // button1// this.button1.Location = new System.Drawing.Point(272, 56);this.button1.Name = "button1";this.button1.TabIndex = 1;this.button1.Text = "button1";this.button1.Click += new System.EventHandler(this.button1_Click);// // label1// this.label1.Location = new System.Drawing.Point(240, 136);this.label1.Name = "label1";this.label1.Size = new System.Drawing.Size(120, 32);this.label1.TabIndex = 2;this.label1.Text = "label1";// // Form1// this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);this.ClientSize = new System.Drawing.Size(368, 309);this.Controls.Add(this.label1);this.Controls.Add(this.button1);this.Controls.Add(this.lbClients);this.Name = "Form1";this.Text = "Form1";this.Load += new System.EventHandler(this.Form1_Load);this.ResumeLayout(false);
}#endregion
/// /// 应用程序的主入口点。/// [STAThread]static void Main() {Application.Run(new Form1());}
private void StartListening() { TcpListener listener = new TcpListener(listenport); listener.Start();label1.Text = "listening....";while (true) {try{Socket s = listener.AcceptSocket(); clientsocket = s; clientservice = new Thread(new ThreadStart(ServiceClient)); clientservice.Start(); }catch(Exception ex){MessageBox.Show("listening Error: "+ex.Message);}} }private void ServiceClient() { Socket client = clientsocket; bool keepalive = true;
while (keepalive) { Byte[] buffer = new Byte[1024]; int bufLen = 0;try{bufLen = client.Available ;client.Receive(buffer,0,bufLen,SocketFlags.None); if(bufLen==0)continue; }catch(Exception ex){MessageBox.Show("Receive Error:"+ex.Message);return;}string clientcommand = System.Text.Encoding.ASCII.GetString(buffer).Substring(0,bufLen);
string[] tokens = clientcommand.Split(new Char[]{'|'}); Console.WriteLine(clientcommand);
if (tokens[0] == "CONN") { for(int n=0; n { Client cl = (Client)clients[n]; SendToClient(cl, "JOIN|" + tokens[1]); }EndPoint ep = client.RemoteEndPoint; Client c = new Client(tokens[1], ep, clientservice, client); string message = "LIST|" + GetChatterList() +"\r\n"; SendToClient(c, message);
clients.Add(c);
lbClients.Items.Add(c);
}if (tokens[0] == "CHAT") { for(int n=0; n { Client cl = (Client)clients[n]; SendToClient(cl, clientcommand); }}if (tokens[0] == "PRIV") { string destclient = tokens[3]; for(int n=0; n { Client cl = (Client)clients[n]; if(cl.Name.CompareTo(tokens[3]) == 0) SendToClient(cl, clientcommand); if(cl.Name.CompareTo(tokens[1]) == 0) SendToClient(cl, clientcommand); } } if (tokens[0] == "GONE") { int remove = 0; bool found = false; int c = clients.Count; for(int n=0; n { Client cl = (Client)clients[n]; SendToClient(cl, clientcommand); if(cl.Name.CompareTo(tokens[1]) == 0) { remove = n; found = true; lbClients.Items.Remove(cl); } } if(found) clients.RemoveAt(remove); client.Close(); keepalive = false; } } }
private string GetChatterList(){string result = "";
for(int i=0;i {result += ((Client)clients[i]).Name+"|";}return result;
}
private void SendToClient(Client cl,string clientCommand){Byte[] message = System.Text.Encoding.ASCII.GetBytes(clientCommand);Socket s = cl.Sock;if(s.Connected){s.Send(message,message.Length,0);}}
private void Form1_Load(object sender, System.EventArgs e){clients = new ArrayList();}
private void button1_Click(object sender, System.EventArgs e){threadListen = new Thread(new ThreadStart(StartListening));threadListen.Start(); } } }
/***************************** client类 ********************/
/************************** 放于 chatServer 项目中 *********/
using System; using System.Threading;
namespace Chat_Server { using System.Net.Sockets; using System.Net;
/// /// Client 的摘要说明。 /// public class Client { private Thread clthread; private EndPoint endpoint; private string name; private Socket sock;
public Client(string _name, EndPoint _endpoint, Thread _thread, Socket _sock) { // TODO: 在此处添加构造函数逻辑 clthread = _thread; endpoint = _endpoint; name = _name; sock = _sock; }
public override string ToString() { return endpoint.ToString()+ " : " + name; }
public Thread CLThread { get{return clthread;} set{clthread = value;} }
public EndPoint Host { get{return endpoint;} set{endpoint = value;} }
public string Name { get{return name;} set{name = value;} }
public Socket Sock { get{return sock;} set{sock = value;} } } }
/***************************** chatClient ************************************/
using System;using System.Drawing;using System.Collections;using System.ComponentModel;using System.Windows.Forms;using System.Data;
using System.IO;using System.Net;using System.Net.Sockets;using System.Threading;
namespace Chat_Client{/// /// Form1 的摘要说明。/// public class Form1 : System.Windows.Forms.Form{private System.Windows.Forms.CheckBox checkBox1;private System.Windows.Forms.StatusBar statusBar1;
NetworkStream ns;StreamReader sr;TcpClient clientsocket;bool connected;Thread receive;string serveraddress = "219.228.231.85";int serverport = 6666;
private System.Windows.Forms.RichTextBox rtbChatIn;private System.Windows.Forms.ListBox lbChatters;private System.Windows.Forms.TextBox ChatOut;private System.Windows.Forms.Button btnDisconnect;private System.Windows.Forms.Button btnSend;private System.Windows.Forms.TextBox clientName;
string clientname;private System.Windows.Forms.Button btnConnect;
private System.ComponentModel.Container components = null;
public Form1(){InitializeComponent();
}
/// /// 清理所有正在使用的资源。/// protected override void Dispose( bool disposing ){if( disposing ){if(receive != null){QuitChat();}if (components != null) {components.Dispose();}}base.Dispose( disposing );}
#region Windows 窗体设计器生成的代码/// /// 设计器支持所需的方法 - 不要使用代码编辑器修改/// 此方法的内容。/// private void InitializeComponent(){this.lbChatters = new System.Windows.Forms.ListBox();this.rtbChatIn = new System.Windows.Forms.RichTextBox();this.checkBox1 = new System.Windows.Forms.CheckBox();this.ChatOut = new System.Windows.Forms.TextBox();this.btnSend = new System.Windows.Forms.Button();this.statusBar1 = new System.Windows.Forms.StatusBar();this.btnDisconnect = new System.Windows.Forms.Button();this.clientName = new System.Windows.Forms.TextBox();this.btnConnect = new System.Windows.Forms.Button();this.SuspendLayout();// // lbChatters// this.lbChatters.ItemHeight = 12;this.lbChatters.Location = new System.Drawing.Point(32, 40);this.lbChatters.Name = "lbChatters";this.lbChatters.Size = new System.Drawing.Size(112, 172);this.lbChatters.TabIndex = 0;// // rtbChatIn// this.rtbChatIn.Location = new System.Drawing.Point(160, 40);this.rtbChatIn.Name = "rtbChatIn";this.rtbChatIn.Size = new System.Drawing.Size(208, 176);this.rtbChatIn.TabIndex = 2;this.rtbChatIn.Text = "";// // checkBox1// this.checkBox1.Location = new System.Drawing.Point(16, 248);this.checkBox1.Name = "checkBox1";this.checkBox1.TabIndex = 3;this.checkBox1.Text = "checkBox1";// // ChatOut// this.ChatOut.Location = new System.Drawing.Point(136, 248);this.ChatOut.Name = "ChatOut";this.ChatOut.Size = new System.Drawing.Size(136, 21);this.ChatOut.TabIndex = 4;this.ChatOut.Text = "message";// // btnSend// this.btnSend.Location = new System.Drawing.Point(336, 248);this.btnSend.Name = "btnSend";this.btnSend.TabIndex = 5;this.btnSend.Text = "send";this.btnSend.Click += new System.EventHandler(this.btnSend_Click);// // statusBar1// this.statusBar1.Location = new System.Drawing.Point(0, 287);this.statusBar1.Name = "statusBar1";this.statusBar1.Size = new System.Drawing.Size(464, 22);this.statusBar1.TabIndex = 6;this.statusBar1.Text = "statusBar1";// // btnDisconnect// this.btnDisconnect.Enabled = false;this.btnDisconnect.Location = new System.Drawing.Point(392, 112);this.btnDisconnect.Name = "btnDisconnect";this.btnDisconnect.Size = new System.Drawing.Size(64, 32);this.btnDisconnect.TabIndex = 7;this.btnDisconnect.Text = "断开";this.btnDisconnect.Click += new System.EventHandler(this.btnDisconnect_Click);// // clientName// this.clientName.Location = new System.Drawing.Point(96, 8);this.clientName.Name = "clientName";this.clientName.TabIndex = 8;this.clientName.Text = "name";// // btnConnect// this.btnConnect.Location = new System.Drawing.Point(392, 56);this.btnConnect.Name = "btnConnect";this.btnConnect.Size = new System.Drawing.Size(64, 32);this.btnConnect.TabIndex = 9;this.btnConnect.Text = "连接";this.btnConnect.Click += new System.EventHandler(this.btnConnect_Click);// // Form1// this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);this.ClientSize = new System.Drawing.Size(464, 309);this.Controls.Add(this.btnConnect);this.Controls.Add(this.clientName);this.Controls.Add(this.btnDisconnect);this.Controls.Add(this.statusBar1);this.Controls.Add(this.btnSend);this.Controls.Add(this.ChatOut);this.Controls.Add(this.checkBox1);this.Controls.Add(this.rtbChatIn);this.Controls.Add(this.lbChatters);this.Name = "Form1";this.Text = "Form1";this.ResumeLayout(false);
}#endregion
/// /// 应用程序的主入口点。/// [STAThread]static void Main() {Application.Run(new Form1());}
private void EstablishConnection() { statusBar1.Text = "正在连接到服务器"; try { clientsocket = new TcpClient(serveraddress,serverport); ns = clientsocket.GetStream(); sr = new StreamReader(ns); connected = true; } catch (Exception) { MessageBox.Show("不能连接到服务器！","错误", MessageBoxButtons.OK, MessageBoxIcon.Exclamation); statusBar1.Text = "已断开连接"; } }
private void RegisterWithServer() { lbChatters.Items.Clear();
clientname = clientName.Text;try { string command = "CONN|" + clientname; //+"\r\n"; Byte[] outbytes = System.Text.Encoding.ASCII.GetBytes(command.ToCharArray()); ns.Write(outbytes,0,outbytes.Length);
string serverresponse = sr.ReadLine(); serverresponse.Trim(); string[] tokens = serverresponse.Split('|'); if(tokens[0] == "LIST") { statusBar1.Text = "已连接"; btnDisconnect.Enabled = true; }if(tokens[1] != ""){for(int n=1; n lbChatters.Items.Add(tokens[n].Trim(new char[]{'\r','\n'})); }this.Text = clientname + "：已连接到服务器";
} catch (Exception ex) { MessageBox.Show("注册时发生错误！"+ex.Message,"错误", MessageBoxButtons.OK, MessageBoxIcon.Exclamation); connected = false;} }
private void ReceiveChat() { bool keepalive = true; while (keepalive) { try { Byte[] buffer = new Byte[1024]; // 2048???ns.Read(buffer,0,buffer.Length); string chatter = System.Text.Encoding.ASCII.GetString(buffer); string[] tokens = chatter.Split(new Char[]{'|'});
if (tokens[0] == "CHAT") { rtbChatIn.AppendText(tokens[1]); // if(logging) // logwriter.WriteLine(tokens[1]); } if (tokens[0] == "PRIV") { rtbChatIn.AppendText("Private from "); rtbChatIn.AppendText(tokens[1].Trim() ); rtbChatIn.AppendText(tokens[2] + "\r\n"); // if(logging) // { // logwriter.Write("Private from "); // logwriter.Write(tokens[1].Trim() ); // logwriter.WriteLine(tokens[2] + "\r\n"); // } } if (tokens[0] == "JOIN") { rtbChatIn.AppendText(tokens[1].Trim() ); rtbChatIn.AppendText(" has joined the Chat\r\n"); // if(logging) // { // logwriter.WriteLine(tokens[1]+" has joined the Chat"); // } string newguy = tokens[1].Trim(new char[]{'\r','\n'}); lbChatters.Items.Add(newguy); } if (tokens[0] == "GONE") { rtbChatIn.AppendText(tokens[1].Trim() ); rtbChatIn.AppendText(" has left the Chat\r\n"); // if(logging) // { // logwriter.WriteLine(tokens[1]+" has left the Chat"); // } lbChatters.Items.Remove(tokens[1].Trim(new char[]{'\r','\n'})); } if (tokens[0] == "QUIT") { ns.Close(); clientsocket.Close(); keepalive = false; statusBar1.Text = "服务器端已停止"; connected= false; btnSend.Enabled = false; btnDisconnect.Enabled = false; } } catch(Exception){} } }
private void QuitChat() { if(connected) { try { string command = "GONE|" + clientname; Byte[] outbytes = System.Text.Encoding.ASCII.GetBytes(command.ToCharArray()); ns.Write(outbytes,0,outbytes.Length); clientsocket.Close(); } catch(Exception ex) { MessageBox.Show(ex.Message);} } // if(logging) // logwriter.Close(); if(receive != null && receive.IsAlive) receive.Abort(); this.Text = "客户端"; connected = false;
}
private void btnSend_Click(object sender, System.EventArgs e){if(connected) { try { string command = "CHAT|" + clientname+": "+ChatOut.Text+"\r\n"; Byte[] outbytes = System.Text.Encoding.ASCII.GetBytes(command.ToCharArray()); ns.Write(outbytes,0,outbytes.Length); //clientsocket.Close(); } catch(Exception ex) { MessageBox.Show(ex.Message);} } }
private void btnConnect_Click(object sender, System.EventArgs e){EstablishConnection();RegisterWithServer();if(connected){ receive = new Thread(new ThreadStart(ReceiveChat));receive.Start();}}
private void btnDisconnect_Click(object sender, System.EventArgs e){QuitChat();}}}
转载于:https://www.cnblogs.com/tuyile006/archive/2006/08/30/490106.html
相关资源：C# Udp多人聊天程序（源码）