using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace CSharpSocketServer
{
    class Program
    {
        static void Main(string[] args)
        {
            ChatServer server = new ChatServer();
            server.Do();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace CSharpSocketServer
{
    class ChatServer
    {
        private TcpListener serverSocket;
        static private List<ChatClient> ClientList;
        public ChatServer()
        {
            serverSocket = new TcpListener(5555);
            ClientList = new List<ChatClient>();
        }
        public void Do()
        {
            Thread t1 = new Thread(new ThreadStart(manageConnection));
            Thread t3 = new Thread(new ThreadStart(ManageChat));

            serverSocket.Start();
            Console.WriteLine(TimeStamp() + "[]Server started");

            t1.Start();
            t3.Start();

            t1.Join();
            t3.Join();

            serverSocket.Stop();

            Console.WriteLine(TimeStamp() + "[]End");
            Console.ReadLine();
        }
        static public void broadcast(string s)
        {
            Queue<int> toRemove = new Queue<int>();

            int count = 0;
            foreach (ChatClient cc in ClientList)
            {
                count++;
                try
                {
                    string dataSend = s;
                    NetworkStream stream = cc.socket.GetStream();
                    byte[] byteSend = Encoding.ASCII.GetBytes(dataSend);
                    stream.Write(byteSend, 0, byteSend.Length);
                    byteSend = null;
                }
                catch(Exception e)
                {
                    toRemove.Enqueue(count);
                    Console.WriteLine(TimeStamp() + "!! " + e.Message);
                }
            }
            count = 0;
            while (!(toRemove.Count == 0))
            {
                count++;
                ClientList.RemoveAt(toRemove.Dequeue()-count);
            }
            Console.WriteLine(TimeStamp() + s);
        }
        private void manageConnection()
        {
            while (true)
            {
                ChatClient tempClient = new ChatClient(serverSocket.AcceptTcpClient());
                ClientList.Add(tempClient);
                tempClient.start();
                
            }
        }
        private void ManageChat()
        {
            while (true)
            {
                string s = Console.ReadLine();
                if (s == "exit") break;
                broadcast("SERVER : " + s);
            }

        }
        static public string TimeStamp()
        {
            return DateTime.Now.ToShortTimeString() + ":" + DateTime.Now.Second + "." + DateTime.Now.Millisecond + " ";
        }

    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace CSharpSocketServer
{
    class ChatClient
    {
        public string name;
        public TcpClient socket;
        private NetworkStream stream;
        private byte[] byteGet;

        public ChatClient(TcpClient c)
        {
            Console.WriteLine(ChatServer.TimeStamp() + "[]Connection established");
            socket = c;
            socket.ReceiveBufferSize = 1024;
            
        }
        public void start()
        {
            stream = socket.GetStream();
            byteGet = new byte[1024];
            Thread t = new Thread(new ThreadStart(doChat));
            t.Start();
            /*
            t.Join();
            
            socket.Close();
            stream.Close();
            */

            
        }
        private void doChat()
        {
            string dataGet;
            try
            {
                byteGet = new byte[1024];
                stream.Read(byteGet, 0, socket.ReceiveBufferSize);
                dataGet = Encoding.ASCII.GetString(byteGet).TrimEnd('\0');
                name = dataGet;
                ChatServer.broadcast(name + " joined");
                
            }
            catch(Exception e)
            {
                Console.WriteLine(ChatServer.TimeStamp() + "!! " + e.Message);
                return;
            }
            while (true)
            {
                try
                {
                    byteGet = new byte[1024];
                    stream.Read(byteGet, 0, socket.ReceiveBufferSize);
                    dataGet = Encoding.ASCII.GetString(byteGet).TrimEnd('\0');
                    ChatServer.broadcast(name + " : " + dataGet);
                }
                catch (Exception e)
                {
                    Console.WriteLine(ChatServer.TimeStamp() + "!! " + e.Message);
                    break;
                }
            }
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace CSharpSocketClient
{
    class Program
    {
        static private TcpClient clientSocket;
        static private NetworkStream networkStream;
        static void Main(string[] args)
        {
            Thread t1 = new Thread(new ThreadStart(read));
            Thread t2 = new Thread(new ThreadStart(write));
            try
            {
                clientSocket = new TcpClient();
                clientSocket.ReceiveBufferSize = 1024;
                clientSocket.SendBufferSize = 1024;
                clientSocket.Connect("127.0.0.1", 5555);
                Console.WriteLine(TimeStamp() + "[] Connection established");

                networkStream = clientSocket.GetStream();

                t1.Start();
                t2.Start();                
            }
            catch (Exception e)
            {
                Console.WriteLine(TimeStamp() + "!! " + e.Message);
            }

            
            t1.Join();
            t2.Join();
            networkStream.Close();
            clientSocket.Close();
            Console.WriteLine(TimeStamp() + "[] End");
            Console.ReadLine();
        }

        static void read()
        {
            byte[] byteGet = new byte[1024];
            string dataGet;
            while (true)
            {
                try
                {
                    byteGet = new byte[1024];
                    networkStream.Read(byteGet, 0, clientSocket.ReceiveBufferSize);
                    dataGet = Encoding.ASCII.GetString(byteGet).TrimEnd('\0');
                    Console.WriteLine(TimeStamp() + dataGet);
                }
                catch(Exception e)
                {
                    Console.WriteLine(TimeStamp() + "!! " + e.Message);
                    return;
                }
            }
        }
        static void write()
        {
            string s;
            byte[] byteSend = new byte[1026];
            while (true)
            {
                s = Console.ReadLine();
                byteSend=Encoding.ASCII.GetBytes(s);
                networkStream.Write(byteSend, 0, byteSend.Length);
            }
        }

        static string TimeStamp()
        {
            return DateTime.Now.ToShortTimeString() + ":" + DateTime.Now.Second + "." + DateTime.Now.Millisecond + " ";
        }
    }
}