简单的多人聊天系统.doc

/*8ChatServer:*/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 Byte1024; 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 (tokens0 = CONN) for(int n=0; nclients.Count;n+) Client cl = (Client)clientsn; SendToClient(cl, JOIN| + tokens1); EndPoint ep = client.RemoteEndPoint; Client c = new Client(tokens1, ep, clientservice, client); string message = LIST| + GetChatterList() +rn; SendToClient(c, message); clients.Add(c); lbClients.Items.Add(c); if (tokens0 = CHAT) for(int n=0; nclients.Count;n+) Client cl = (Client)clientsn; SendToClient(cl, clientcommand); if (tokens0 = PRIV) string destclient = tokens3; for(int n=0; nclients.Count;n+) Client cl = (Client)clientsn; if(cl.Name.CompareTo(tokens3) = 0) SendToClient(cl, clientcommand); if(cl.Name.CompareTo(tokens1) = 0) SendToClient(cl, clientcommand); if (tokens0 = GONE) int remove = 0; bool found = false; int c = clients.Count; for(int n=0; nclients.Count;n+) Client cl = (Client)clientsn; SendToClient(cl, clientcommand); if(cl.Name.CompareTo(tokens1) = 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;iclients.Count;i+) result += (Client)clientsi).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 getreturn clthread; setclthread = value; public EndPoint Host getreturn endpoint; setendpoint = value; public string Name getreturn name; setname = value; public Socket Sock getreturn sock; setsock = 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 = 5; 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; /+rn; 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(tokens0 = LIST) statusBar1.Text = 已连接; btnDisconnect.Enabled = true; if(tokens1 != ) for(int n=1; ntokens.Length;n+) lbChatters.Items.Add(tokensn.Trim(new charr,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 Byte1024; / 2048? ns.Read(buffer,0,buffer.Length); string chatter = System.Text.Encoding.ASCII.GetString(buffer); string tokens = chatter.Split(new Char|); if (tokens0 = CHAT) rtbChatIn.AppendText(tokens1); / if(logging) / logwriter.WriteLine(tokens1); if (tokens0 = PRIV) rtbChatIn.AppendText(Private from ); rtbChatIn.AppendText(tokens1.Trim() ); rtbChatIn.AppendText(tokens2 + rn); / if(logging) / / logwriter.Write(Private from ); / logwriter.Write(tokens1.Trim() ); / logwriter.WriteLine(tokens2 + rn); / if (tokens0 = JOIN) rtbChatIn.AppendText(tokens1.Trim() ); rtbChatIn.AppendText( has joined the Chatrn); / if(logging) / / logwriter.WriteLine(tokens1+ has joined the Chat); / string newguy = tokens1.Trim(new charr,n); lbChatters.Items.Add(newguy); if (tokens0 = GONE) rtbChatIn.AppendText(tokens1.Trim() ); rtbChatIn.