CS聊天模型

【实例简介】

先运行server端
再运行client端
client端可以同时打开多个窗口 可以建立聊天室

【实例截图】

【核心代码】

private void StartListening()
{
    listener = new TcpListener(listenport);
    listener.Start();
    while (true)
    {
        try
        {
            Socket s = listener.AcceptSocket();
            clientsocket = s;
            clientservice = new Thread(new ThreadStart(ServiceClient));
            clientservice.Start();
        }
        catch(Exception e)
        {
            Console.WriteLine(e.ToString() );
        }
    }
}

private void ServiceClient()
{
    Socket client = clientsocket;
    bool keepalive = true;

    while (keepalive)
    {
        Byte[] buffer = new Byte[1024];
        client.Receive(buffer);
        string clientcommand = System.Text.Encoding.ASCII.GetString(buffer);

        string[] tokens = clientcommand.Split(new Char[]{'|'});
        Console.WriteLine(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);
            clients.Add(c);
            string message = "LIST|" GetChatterList() "\r\n";
            SendToClient(c, message);

            lbClients.Items.Add(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<c; 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 void SendToClient(Client cl, string message)
{
    try
    {
        byte[] buffer = System.Text.Encoding.ASCII.GetBytes(message.ToCharArray());
        cl.Sock.Send(buffer,buffer.Length,0);
    }
    catch(Exception)
    {
        cl.Sock.Close();
        cl.CLThread.Abort();
        clients.Remove(cl);
        lbClients.Items.Remove(cl.Name " : " cl.Host.ToString());
    }
}