Talk Online Program

参考了一些网上的例子，感觉挺有意思，于是自己也尝试了一下，如下：

代码如下：

Code
  1using System;
  2using System.Collections.Generic;
  3using System.ComponentModel;
  4using System.Data;
  5using System.Drawing;
  6using System.Text;
  7using System.Windows.Forms;
  8
  9using System.Threading;
 10using System.Net.Sockets;
 11using System.Net;
 12using System.Collections;
 13
 14namespace TcpSocketServer
 15{
 16    public partial class Form1 : Form
 17    {
 18        public Form1()
 19        {
 20            InitializeComponent();
 21        }
 22
 23        define Variable#region define Variable
 24
 25        private static int listenport = 6666;
 26
 27        private Socket clientsocket;
 28
 29        private ArrayList clients;
 30
 31        private Thread clientservice;
 32
 33        private Thread threadListen;
 34
 35        #endregion
 36
 37        /**//// <summary>
 38        /// Button Event
 39        /// </summary>
 40        /// <param name="sender"></param>
 41        /// <param name="e"></param>
 42        private void button1_Click(object sender, EventArgs e)
 43        {
 44            //开始监听 
 45            try
 46            { 
 47                threadListen = new Thread(new ThreadStart(StartListening));
 48                label1.Text = "listening.";
 49                threadListen.Start();  
 50            }
 51            catch (System.Exception er)
 52            {
 53                MessageBox.Show(er.Message, "完成", MessageBoxButtons.OK, MessageBoxIcon.Stop);
 54            }
 55        }
 56
 57        /**//// <summary>
 58        /// Start Listen
 59        /// </summary>
 60        private void StartListening()
 61        {
 62            TcpListener listener = new TcpListener(listenport);
 63            listener.Start();
 64            //label1.Text = "listening.";
 65            while (true)
 66            {
 67                try
 68                {
 69                    Socket s = listener.AcceptSocket();
 70                    clientsocket = s;
 71                    clientservice = new Thread(new ThreadStart(ServiceClient));
 72                    clientservice.Start();
 73                }
 74                catch (Exception ex)
 75                {
 76                    MessageBox.Show("listening Error: " + ex.Message);
 77                }
 78            }
 79        }
 80
 81        delegate event#region delegate event
 82        /**//// <summary>
 83        /// 添加子项代理
 84        /// </summary>
 85        /// <param name="cc"></param>
 86        private delegate void _deleAdditems(Client cc);
 87        /**//// <summary>
 88        /// 去除元素代理
 89        /// </summary>
 90        /// <param name="x"></param>
 91        private delegate void moveElement(int x);
 92        /**//// <summary>
 93        /// 去除列表元素代理
 94        /// </summary>
 95        /// <param name="x"></param>
 96        private delegate void movelist(Client x);
 97        /**//// <summary>
 98        /// 添加串代理
 99        /// </summary>
        /// <param name="str"></param>
        private delegate void deleAddStr(string str);

        private void Additems(Client cc)
        {
            try
            {
                //判断与创建textBox_ID控件的线程（这里是主线程）是否在同一个线程中
                if (this.lbClients.InvokeRequired)
                {
                    _deleAdditems changer = new _deleAdditems(Additems);
                    //在拥有控件的基础窗口句柄的线程上，用指定的参数列表执行指定委托                
                    this.Invoke(changer, new object[] { cc });
                }
                else
                {
                    #region
                    //lock (lockObject)
                    //{
                    //    Monitor.PulseAll(lockObject);
                    //}
                    #endregion
                    lbClients.Items.Add(cc);
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }        

        private void AddStr(string str)
        {
            try
            {
                if (this.textBox1.InvokeRequired)
                {
                    deleAddStr changer = new deleAddStr(AddStr);             
                    this.Invoke(changer, new object[] { str });
                }
                else
                    this.textBox1.Text = str;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }

        private void movel(Client x)
        {
            try
            {
                if (this.lbClients.InvokeRequired)
                {
                    movelist changer = new movelist(movel);
                    this.Invoke(changer, new object[] { x });
                }
                else
                    lbClients.Items.Remove(x);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }       

        private void MoveEle(int x)
        {
            try
            {
                if (this.clients.IsSynchronized)
                {
                    moveElement changer = new moveElement(MoveEle);              
                    this.Invoke(changer, new object[] { x });
                }
                else
                    this.clients.RemoveAt(x);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }
        #endregion

        /**//// <summary>
        /// ServiceClient
        /// </summary>
        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);
                //this.textBox1.Text = clientcommand;
                AddStr(clientcommand);

                if (tokens[0] == "CONN")
                {
                    for (int n = 0; n < clients.Count; 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);
                    Additems(c);

                }
                if (tokens[0] == "CHAT")
                {
                    for (int n = 0; n < clients.Count; n++)
                    {
                        Client cl = (Client)clients[n];
                        SendToClient(cl, clientcommand);
                    }
                }
                if (tokens[0] == "PRIV")
                {
                    string destclient = tokens[3];
                    for (int n = 0; n < clients.Count; 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 < clients.Count; n++)
                    {
                        Client cl = (Client)clients[n];
                        SendToClient(cl, clientcommand);
                        if (cl.Name.CompareTo(tokens[1]) == 0)
                        {
                            remove = n;
                            found = true;
                            movel(cl);
                            //lbClients.Items.Remove(cl);
                        }
                    }
                    if (found)
                    {
                        clients.RemoveAt(remove);
                    }
                    client.Close();
                    keepalive = false;
                }
            }
        }

        /**//// <summary>
        /// 获取列表元素
        /// </summary>
        /// <returns></returns>
        private string GetChatterList()
        {
            string result = "";

            for (int i = 0; i < clients.Count; i++)
            {
                result += ((Client)clients[i]).Name + "|";
            }
            return result;
        }

        /**//// <summary>
        /// 发送到客户端
        /// </summary>
        /// <param name="cl"></param>
        /// <param name="clientCommand"></param>
        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);
            }
        }

        /**//// <summary>
        /// Form Load Event
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_Load(object sender, EventArgs e)
        {
            clients = new ArrayList();
        }

    }
}

服务器端还有一个类Client.cs

Code
 1using System;
 2using System.Collections.Generic;
 3using System.Text;
 4using System.Net;
 5using System.Net.Sockets;
 6using System.Threading;
 7
 8
 9namespace TcpSocketServer
{
    public class Client
    {
        private Thread clthread;
        private EndPoint endpoint;
        private string name;
        private Socket sock;

        /**//// <summary>
        /// 客户端类
        /// </summary>
        /// <param name="_name">名称</param>
        /// <param name="_endpoint"></param>
        /// <param name="_thread"></param>
        /// <param name="_sock"></param>
        public Client(string _name, EndPoint _endpoint, Thread _thread, Socket _sock)
        {
            // TODO: 在此处添加构造函数逻辑 
            clthread = _thread;
            endpoint = _endpoint;
            name = _name;
            sock = _sock;
        }

        /**//// <summary>
        /// 重写ToString() 方法
        /// </summary>
        /// <returns></returns>
        public override string ToString()
        {
            return endpoint.ToString() + " : " + name;
        }
        /**//// <summary>
        /// 客户端线程
        /// </summary>
        public Thread CLThread
        {
            get { return clthread; }
            set { clthread = value; }
        }
        /**//// <summary>
        /// 客户端地址
        /// </summary>
        public EndPoint Host
        {
            get { return endpoint; }
            set { endpoint = value; }
        }
        /**//// <summary>
        /// 客户端姓名
        /// </summary>
        public string Name
        {
            get { return name; }
            set { name = value; }
        }
        /**//// <summary>
        /// 客户端套接字
        /// </summary>
        public Socket Sock
        {
            get { return sock; }
            set { sock = value; }
        }
    }
}

客户端

Code
  1using System;
  2using System.Collections.Generic;
  3using System.ComponentModel;
  4using System.Data;
  5using System.Drawing;
  6using System.Text;
  7using System.Windows.Forms;
  8using System.Net;
  9using System.Net.Sockets;
 10using System.Threading;
 11using System.IO;
 12
 13namespace TcpSocketClient
 14{
 15    public partial class Form1 : Form
 16    {
 17        public Form1()
 18        {
 19            InitializeComponent();
 20        }
 21        /**//// <summary>
 22        /// Form Load Event
 23        /// </summary>
 24        /// <param name="sender"></param>
 25        /// <param name="e"></param>
 26        private void Form1_Load(object sender, EventArgs e)
 27        {
 28            // to do?
 29        }
 30
 31        Define Variable#region Define Variable
 32
 33        /**//// <summary>
 34        /// 数据流
 35        /// </summary>
 36        private NetworkStream ns;
 37        /**//// <summary>
 38        /// 读取流
 39        /// </summary>
 40        private StreamReader sr;
 41        /**//// <summary>
 42        /// TCP连接
 43        /// </summary>
 44        private TcpClient clientsocket;
 45        /**//// <summary>
 46        /// 连接与否
 47        /// </summary>
 48        private bool connected;
 49        /**//// <summary>
 50        /// 接收线程
 51        /// </summary>
 52        private Thread receive;
 53        /**//// <summary>
 54        /// 服务器地址
 55        /// </summary>
 56        private string serveraddress = "192.168.1.40";
 57        /**//// <summary>
 58        /// 服务器端口
 59        /// </summary>
 60        private int serverport = 6666;
 61        /**//// <summary>
 62        /// 客户端名称
 63        /// </summary>
 64        private string clientname;
 65
 66        #endregion
 67
 68        /**//// <summary>
 69        /// EstablishConnection
 70        /// </summary>
 71        private void EstablishConnection()
 72        {
 73            statusBar1.Text = "正在连接到服务器";
 74
 75            try
 76            {
 77                clientsocket = new TcpClient(serveraddress, serverport);
 78                ns = clientsocket.GetStream();
 79                sr = new StreamReader(ns);
 80                connected = true;
 81            }
 82            catch (Exception)
 83            {
 84                MessageBox.Show("不能连接到服务器！", "错误",
 85                    MessageBoxButtons.OK, MessageBoxIcon.Exclamation);
 86                statusBar1.Text = "已断开连接";
 87            }
 88        }
 89        /**//// <summary>
 90        /// Register With Server
 91        /// </summary>
 92        private void RegisterWithServer()
 93        {
 94            lbChatters.Items.Clear();
 95
 96            clientname = clientName.Text;
 97            try
 98            {
 99                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 < tokens.Length; 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;
            }
        }
        /**//// <summary>
        /// Receive Chat Content
        /// </summary>
        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) { }
            }
        }
        /**//// <summary>
        /// Quit Chat 
        /// </summary>
        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;

        }
        /**//// <summary>
        /// Send Button
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnSend_Click(object sender, 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);
                }
            } 

        }
        /**//// <summary>
        /// Connect Button
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnConnect_Click(object sender, EventArgs e)
        {
            EstablishConnection();
            RegisterWithServer();
            if (connected)
            {
                receive = new Thread(new ThreadStart(ReceiveChat));
                receive.Start();
            }
        }
        /**//// <summary>
        /// Disconnect Button
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnDisconnect_Click(object sender, EventArgs e)
        {
            QuitChat();
        }
    }
}

如图：