Клиент-серверное приложение

using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Timers;
 
class Program
{
    static Mutex mtx = new Mutex();
    static void Main(string[] args)
    {
        Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //Создаем основной сокет
        IPAddress ipAddress = null; //IP-адресс
        IPEndPoint Addr = null; //конечная точка(IP и порт)
 
        Console.WriteLine("1 - Server\n2 - Client");
        switch (Console.ReadKey(true).KeyChar)
        {
            case '1':
                Console.Title = "Server"; //Сервер
                //ipAddress = Dns.GetHostEntry("127.0.0.1").AddressList[0]; //Преобразовуем адрес или IP узла в массив IP и берем первый
                Addr = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 3128); //"localhost" = 127.0.0.1
                s.Bind(Addr); //"Адресуем" сокет
                s.Listen(10); //Обозначаем количество ожидающих в очереди на подключение
                Console.WriteLine("Ждем коннекта...");
                while(true)
                {
                    Socket cl_s = s.Accept(); //Ожидаем подключения
                    Thread ClientThread = new Thread(delegate() { ProcessClient(cl_s); });
                    ClientThread.Start();
                }
            break;
 
            case '2':
            s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            ipAddress = IPAddress.Parse("127.0.0.1");
            Addr = new IPEndPoint(ipAddress, Int32.Parse("3128")); //"localhost" = 127.0.0.1
            string msg = "";
            try
            {
                s.Connect(Addr); //Коннектимся к сeрверу
                sendMessage(s, "connect");
                msg = receiveMessage(s);
                ConsoleWrite("MESSAGE: " + msg);
            }
            catch
            {
                ConsoleWrite("Error1");
            }
            if (msg == "connected")
            {
                sendMessage(s, "name");
                ConsoleWrite("Connected!");
            }
            else
            {
                ConsoleWrite(msg);
            }
            break;
        }
        s.Close(); //Закрываем сокет
        Console.ReadKey();
    }
    static void ProcessClient(Socket cl_s)
    {
        string name = "default";
        int startFlag = 0;
        while (true) //Пока не нажата клавиша
        {
            if (cl_s.Available != 0)
            {
                string message = "";
                message = receiveMessage(cl_s);
                ConsoleWrite("MESSAGE:" + message);
                switch (message)
                {
                    case "connect":
                        sendMessage(cl_s, "connected");
                        name = receiveMessage(cl_s);
                        ConsoleWrite(name + " подключился к серверу!");
                    break;
                }
            }
 
        }
        cl_s.Close(); //Закрываем сокет
    }
    static void ConsoleWrite(string message)
    {
        mtx.WaitOne();
        Console.WriteLine(message);
        mtx.ReleaseMutex();
    }
    static void sendMessage(Socket s, string message)
    {
        if (s.Poll(10000, SelectMode.SelectWrite) == false)
        { }
        byte[] msgToSent = Encoding.UTF8.GetBytes(message);
        s.Send(msgToSent, 0, msgToSent.Length, SocketFlags.None);
    }
 
    static string receiveMessage(Socket s)
    {
        if (s.Poll(1000000, SelectMode.SelectRead) == false)
            return "ERROR";
        string result;
        int buffCnt = s.Available;
        int recCnt = 0;
        byte[] msg = new byte[buffCnt];
        while (recCnt != buffCnt)
            recCnt = s.Receive(msg, 0, buffCnt, SocketFlags.None);
        result = Encoding.UTF8.GetString(msg);
        return result;
    }
}