Реализовать клиент-серверный чат (консольная версия)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
 
namespace Server
{
    class Program
    {
        public static ManualResetEvent tcpClientConnected = new ManualResetEvent(false);
        public static void DoBeginAcceptTcpClient(TcpListener listener)
        {
            // Set the event to nonsignaled state.
            tcpClientConnected.Reset();
            while (true)
            {
                // Start to listen for connections from a client.
                Console.Write("Ожидание соединения... ");
 
                // Accept the connection. 
                // BeginAcceptSocket() creates the accepted socket.
                listener.BeginAcceptTcpClient(
                    new AsyncCallback(DoAcceptTcpClientCallback),
                    listener);
 
                // Wait until a connection is made and processed before 
                // continuing.
                tcpClientConnected.WaitOne();
            }
        }
 
        // Process the client connection.
        public static void DoAcceptTcpClientCallback(IAsyncResult ar)
        {
            // Get the listener that handles the client request.
            TcpListener listener = (TcpListener)ar.AsyncState;
 
            // End the operation and display the received data on 
            // the console.
            TcpClient client = listener.EndAcceptTcpClient(ar);
 
            // Process the connection here. (Add the client to a
            // server table, read data, etc.)
            Console.WriteLine("Соеденение установлено!");
 
            // Signal the calling thread to continue.
            tcpClientConnected.Set();
 
            //  Буфер для чтения данных
            Byte[] bytes = new Byte[256];
            String data = null;
 
            // Получаем информацию от клиента
            NetworkStream stream = client.GetStream();
 
            int i;
            // Принимаем данные от клиента в цикле пока не дойдём до конца.
            while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
            {
                // Преобразуем данные в Windows-1251 string.
                data = Encoding.GetEncoding(1251).GetString(bytes, 0, i);
 
                // Преобразуем полученную строку в массив Байт.
                byte[] msg = Encoding.GetEncoding(1251).GetBytes(data);
 
                // Отправляем данные обратно клиенту (ответ).
                stream.Write(msg, 0, msg.Length);
            }
 
        }
        static void Main(string[] args)
        {
            TcpListener server = null;
            try
            {
                // Устанавливаем порт для TcpListener 
                Int32 port = 1990;
 
                IPAddress localAddr = IPAddress.Parse("127.0.0.1");
                server = new TcpListener(localAddr, port);
                server.Start();
                DoBeginAcceptTcpClient(server);             
 
           
 
 
            Console.WriteLine("\nНажмите клавишу для продолжения...");
            Console.ReadKey();
 
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
 
namespace Client
{
    class Program
    {
 
        public static bool isClientRunning;
        static void Main(string[] args)
        {
            isClientRunning = true;
            while (isClientRunning)
            {
                String message = Console.ReadLine();
                Connect("127.0.0.1", message);
            }
            Console.WriteLine("\n Press Enter to continue...");
            Console.Read();
        }
 
        static void Connect(String server, String message)
        {
            try
            {
                // Создаём TcpClient.
                // Для созданного в предыдущем проекте TcpListener 
                // Настраиваем его на IP нашего сервера и тот же порт.
 
                Int32 port = 1990;
                TcpClient client = new TcpClient(server, port);
                Console.WriteLine("Соедение с сервером установлено!");
                // Переводим наше сообщение в Windows-1251, а затем в массив Byte.
                Byte[] data = Encoding.GetEncoding(1251).GetBytes(message);
 
                // Получаем поток для чтения и записи данных.
                NetworkStream stream = client.GetStream();
 
                // Отправляем сообщение нашему серверу. 
                stream.Write(data, 0, data.Length);
                Console.WriteLine("Отправлено: {0}", message);
 
                // Получаем ответ от сервера.
 
                // Буфер для хранения принятого массива bytes.
                data = new Byte[256];
 
                // Строка для хранения полученных Windows-1251 данных.
                String responseData = String.Empty;
 
                // Читаем первый пакет ответа сервера. 
                // Можно читать всё сообщение.
                // Для этого надо организовать чтение в цикле как на сервере.
                Int32 bytes = stream.Read(data, 0, data.Length);
                responseData = Encoding.GetEncoding(1251).GetString(data, 0, bytes);
                Console.WriteLine("["+DateTime.Now.ToString("HH:mm:ss") +"] " + responseData);
 
                // Закрываем всё.
                stream.Close();
                client.Close();
            }
            catch (ArgumentNullException e)
            {
                Console.WriteLine("ArgumentNullException: {0}", e);
            }
            catch (SocketException e)
            {
                Console.WriteLine("SocketException: {0}", e);
            }
 
 
        }
    }
}