Приват "комната" для чата, как это сделать на сервере?

namespace Server
{
    public partial class Form1 : Form
    {
        Form2 form2 = new Form2();
 
        private delegate void UpdateStatusCallback(string strMessage);
 
        public Form1()
        {
            InitializeComponent();
 
            form2.ShowDialog();
        }
 
        private void btnListen_Click(object sender, EventArgs e)
        {
            // Разбор IP-адрес сервера из TextBox
            IPAddress ipAddr = IPAddress.Parse(txtIp.Text);
            // Создайте новый экземпляр объекта Server
            Serverr mainServer = new Serverr(ipAddr);
            // Наденьте StatusChanged обработчик события mainServer_StatusChanged
            Serverr.StatusChanged += new StatusChangedEventHandler(mainServer_StatusChanged);
            // Начать прослушивание соединений
            mainServer.StartListening();
            // Показать, что мы начали ожидать соединения
            txtLog.AppendText("Идёт прослушивание соединений...\r\n");
        }
 
        public void mainServer_StatusChanged(object sender, StatusChangedEventArgs e)
        {
            // Вызовите метод, который обновляет форму
            this.Invoke(new UpdateStatusCallback(this.UpdateStatus), new object[] { e.EventMessage });
        }
 
        private void UpdateStatus(string strMessage)
        {
            // Обновления журнал с сообщением
            txtLog.AppendText(strMessage + "\r\n");
        }
 
      
    }
}
 
namespace Server
{
    
    public class StatusChangedEventArgs : EventArgs
    {
        
        private string EventMsg;
 
        // Недвижимость для извлечения и установки сообщения о событии
        public string EventMessage
        {
            get
            {
                return EventMsg;
            }
            set
            {
                EventMsg = value;
            }
        }
 
        // Конструктор для установки события сообщение
        public StatusChangedEventArgs(string strEventMsg)
        {
            EventMsg = strEventMsg;
        }
    }
 
    // Этот делегат нужно указать параметры мы передаем нашим события
    public delegate void StatusChangedEventHandler(object sender, StatusChangedEventArgs e);
 
    class Serverr
    {
        // Этот хэш-таблицы магазинах пользователей и подключений (доступный для просмотра пользователем)
        public static Hashtable htUsers = new Hashtable(300); // 300 пользователей одновременно предел
        // Этот хэш-таблицы магазинах соединений и пользователей (доступен просмотр на подключение)
        public static Hashtable htConnections = new Hashtable(300); // 300 users at one time limit
        // Будет хранить IP-адреса, переданные ему
        private IPAddress ipAddress;
        private TcpClient tcpClient;
        // События и его аргумент будет уведомлять форме, когда пользователь подключен, отключен, отправить сообщение и т.д.
        public static event StatusChangedEventHandler StatusChanged;
        private static StatusChangedEventArgs e;
 
        // Конструктор устанавливает IP-адрес одного извлекается экземпляр объекта
        public Serverr(IPAddress address)
        {
            ipAddress = address;
        }
 
        // Поток, который будет держать связь слушателя
        private Thread thrListener;
 
        // Объект, который прослушивает TCP соединений
        private TcpListener tlsClient;
 
        // Скажете то время как цикл сохранить контроль для соединения
        bool ServRunning = false;
 
        // Добавить пользователя в хэш-таблицы
        public static void AddUser(TcpClient tcpUser, string strUsername)
        {
            // Сначала добавьте имя пользователя и связанного связи как хэш-таблицы
            Serverr.htUsers.Add(strUsername, tcpUser);
            Serverr.htConnections.Add(tcpUser, strUsername);
 
            // Расскажите нового соединения с другими пользователями и сервером форме
            SendAdminMessage(htConnections[tcpUser] + " подключился");
        }
 
        // Удалить пользователя из хэш-таблицы
        public static void RemoveUser(TcpClient tcpUser)
        {
            // Если пользователь есть
            if (htConnections[tcpUser] != null)
            {
                // Первые показывают информацию и рассказать другим пользователям о отключением
                SendAdminMessage(htConnections[tcpUser] + " отключился");
 
                // Удалить пользователя из хеш-таблицы
                Serverr.htUsers.Remove(Serverr.htConnections[tcpUser]);
                Serverr.htConnections.Remove(tcpUser);
            }
        }
 
        // Это называется, когда мы хотим поднять StatusChanged события
        public static void OnStatusChanged(StatusChangedEventArgs e)
        {
            StatusChangedEventHandler statusHandler = StatusChanged;
            if (statusHandler != null)
            {
                // Вызов делегата
                statusHandler(null, e);
            }
        }
 
        // Отправить административных сообщений
        public static void SendAdminMessage(string Message)
        {
            StreamWriter swSenderSender;
 
            // Прежде всего, показать в нашем приложении, который говорит, что
            e = new StatusChangedEventArgs(Message);
            OnStatusChanged(e);
 
            // Создать массив клиентов TCP, размер количество пользователей у нас есть
            TcpClient[] tcpClients = new TcpClient[Serverr.htUsers.Count];
            // Скопируйте TcpClient объектов в массив
            Serverr.htUsers.Values.CopyTo(tcpClients, 0);
            // Цикл по списку клиентов TCP
            for (int i = 0; i < tcpClients.Length; i++)
            {
                // Попробуйте отправить сообщение для каждого
                try
                {
                    // Если сообщение пустое или нулевое соединение, вырваться из
                    if (Message.Trim() == "" || tcpClients[i] == null)
                    {
                        continue;
                    }
                    // Отправить сообщение для текущего пользователя в петлю
                    swSenderSender = new StreamWriter(tcpClients[i].GetStream());
                    swSenderSender.WriteLine(Message);
                    swSenderSender.Flush();
        //           swSenderSender = null;
                }
                catch // Если возникла проблема, пользователю больше не существует, удалите его
                {
                    RemoveUser(tcpClients[i]);
                }
            }
        }
 
        // Отправка сообщений от одного пользователя все остальные
        public static void SendMessage(string From, string Message)
        {
            StreamWriter swSenderSender;
 
            // Прежде всего, показать в нашем приложении, который говорит, что
            e = new StatusChangedEventArgs(From + " *** говорит: " + Message);
            OnStatusChanged(e);
 
            // Создать массив клиентов TCP, размер количество пользователей у нас есть
            TcpClient[] tcpClients = new TcpClient[Serverr.htUsers.Count];
            // Скопируйте TcpClient объектов в массив
            Serverr.htUsers.Values.CopyTo(tcpClients, 0);
            // Цикл по списку клиентов TCP
            for (int i = 0; i < tcpClients.Length; i++)
            {
                // Попробуйте отправить сообщение для каждого
                try
                {
                    // Если сообщение пустое или нулевое соединение, вырваться из
                    if (Message.Trim() == "" || tcpClients[i] == null)
                    {
                        continue;
                    }
                    // Отправить сообщение для текущего пользователя в петлю
                    swSenderSender = new StreamWriter(tcpClients[i].GetStream());
                    swSenderSender.WriteLine(Message);
                    swSenderSender.Flush();
         //           swSenderSender = null;
                }
                catch // Если возникла проблема, пользователю больше не существует, удалите его
                {
                    RemoveUser(tcpClients[i]);
                }
            }
        }
 
        public void StartListening()
        {
 
            // Получить IP первого сетевого устройства, однако это может оказаться ненадежной на некоторых конфигурациях
            IPAddress ipaLocal = ipAddress;
 
            // Создайте объект TCP слушатель использованием IP сервера, и указанный порт
            tlsClient = new TcpListener(ipAddress,1100);
 
            // Начало слушателя TCP и слушать соединений
            tlsClient.Start();
 
            // Время цикла будет проверять на истину в этом перед проверкой соединений
            ServRunning = true;
 
            // Начало нового протектора, который проводит слушателя
            thrListener = new Thread(KeepListening);
            thrListener.Start();
        }
 
        private void KeepListening()
        {
            // В то время как сервер работает
            while (ServRunning) // == true)
            {
                // Приму в ожидании соединения
                tcpClient = tlsClient.AcceptTcpClient();
                // Создать новый экземпляр подключения
                Connection newConnection = new Connection(tcpClient);
            }
        }
    }
 
    // Этот класс Handels соединений; там будет столько экземпляров его как будут подключены пользователи
    internal class Connection
    {
        private TcpClient tcpClient;
        // Поток, который будет передавать информацию клиенту
        private Thread thrSender;
        private StreamReader srReceiver;
        private StreamWriter swSender;
        private string currUser;
        private string strResponse;
 
        // Конструктор класса принимает в связи TCP
        public Connection(TcpClient tcpCon)
        {
            tcpClient = tcpCon;
            // Поток, который принимает клиент и ждет сообщений
            thrSender = new Thread(AcceptClient);
            // Поток вызывает AcceptClient () метод
            thrSender.Start();
        }
 
        private void CloseConnection()
        {
            // Закройте открытые объекты
            tcpClient.Close();
            srReceiver.Close();
            swSender.Close();
        }
 
        // Встречается, когда новый клиент принимаются
        private void AcceptClient()
        {
            srReceiver = new System.IO.StreamReader(tcpClient.GetStream());
            swSender = new System.IO.StreamWriter(tcpClient.GetStream());
 
            // Читайте счет информации от клиента
            currUser = srReceiver.ReadLine();
 
            // Мы получили ответ от клиента
            if (currUser != "")
            {
                // Храните имя пользователя в хэш-таблице
                if (Serverr.htUsers.Contains(currUser))
                {
                    // 0 означает, что не связано
                    swSender.WriteLine("0|Это имя пользователя уже существует.");
                    swSender.Flush();
                    CloseConnection();
                    return;
                }
                else if (currUser == "Администратор")
                {
                    // 0 означает, что не связано
                    swSender.WriteLine("0|Это имя пользователя защищено.");
                    swSender.Flush();
                    CloseConnection();
                    return;
                }
                else
                {
                    // 1 означает успешное подключение
                    swSender.WriteLine("1");
                    swSender.Flush();
 
                    // Добавить пользователя в хэш-таблиц и начать прослушивание сообщений от него
                   Serverr.AddUser(tcpClient, currUser);
                }
            }
            else
            {
                CloseConnection();
                return;
            }
 
            try
            {
                // Держите ждет сообщений от пользователей
                while ((strResponse = srReceiver.ReadLine()) != "")
                {
                    // Если оно недействительно, удалить пользователя
                    if (strResponse == null)
                    {
                        Serverr.RemoveUser(tcpClient);
                    }
                    else
                    {
                        // В противном случае отправить сообщение всем другим пользователям
                        Serverr.SendMessage(currUser, strResponse);
                    }
                }
            }
 
            catch
            {
                // Если что-то пошло не так с этим пользователем, отключить его
                Serverr.RemoveUser(tcpClient);
            }
        }
    }
}

//  public string[] peremennay;               
        // Будет хранить имя пользователя
        private string UserName = "еее";
        private StreamWriter swSender;
        private StreamReader srReceiver;
        private TcpClient tcpServer;
        // Необходимо обновить форму с сообщениями из другого потока
        private delegate void UpdateLogCallback(string strMessage);
 
        // Необходимо установить форму в "отключенном» состоянии из другого потока
        private delegate void CloseConnectionCallback(string strReason);
 
        private Thread thrMessaging;
        private IPAddress ipAddr;
        private bool Connected;
 
 
        public void Client()
        {
            // На выходе из приложения, не забудьте отключить первый
            Application.ApplicationExit += (OnApplicationExit);
            InitializeComponent();
        }
 
        //  для выхода из приложения
        public void OnApplicationExit(object sender, EventArgs e)
        {
            //  if (Connected == true)
            //   {
            // Закрывает соединения, потоки, и т.д.
            Connected = false;
            swSender.Close();
            srReceiver.Close();
            tcpServer.Close();
            //   }
        }
 
        public void ConnectedS1()
        {
            // Если мы сейчас не подключены, но в ожидании подключения
            if (Connected == false)
            {
                // Инициализация связи
                InitializeConnection();
            }
            else // Мы связаны, таким образом, отсоедините
            {
                CloseConnection("Disconnected at user's request.");
            }
        }
 
        private void InitializeConnection()
        {
            try
            {
                // Разбор IP-адреса из TextBox в IP-адрес объекта
                ipAddr = IPAddress.Parse(textBoxIPServera.Text);
                // Начало нового соединения TCP для чат-сервера
                tcpServer = new TcpClient();
                tcpServer.Connect(textBoxIPServera.Text, 1100);
 
                // Помогает нам отслеживать ли мы связаны или нет
                Connected = true;
                // Подготовьте форму
                UserName = textBoxNickNames.Text;
 
                // Отключить и включить в соответствующие поля
                textBoxIPServera.Enabled = false;
                textBoxNickNames.Enabled = false;
                textBoxVvodChat.Enabled = true;
                EnterSend.Enabled = true;
                ConnectedS.Text = "Disconnect";
 
                // Отправить желаемое имя пользователя на сервере
                swSender = new StreamWriter(tcpServer.GetStream());
                swSender.WriteLine(textBoxNickNames.Text);
                swSender.Flush();
 
                // Начало нити для получения сообщений и дальнейшее общение
 
                thrMessaging = new Thread(new ThreadStart(ReceiveMessages));
                thrMessaging.Start();
 
            }
            catch (Exception)
            {
                MessageBox.Show("Нет соединения с сервером");
            }
        }
 
 
        private void ReceiveMessages()
        {
            // Получить ответ от сервера
            srReceiver = new StreamReader(tcpServer.GetStream());
            // Если первый символ в ответ равен 1, соединение было успешным
            string ConResponse = srReceiver.ReadLine();
            // Если первый символ равен 1, соединение было успешным
            if (ConResponse[0] == '1')
            {
                // Обновите форму, чтобы сказать ему мы теперь связаны
                this.Invoke(new UpdateLogCallback(this.UpdateLog), new object[] {"Connected Successfully!"});
 
            }
            else // Если первый символ не является 1 (возможно, 0), связь была неудачной
            {
                string Reason = "Not Connected: ";
                // Извлечение причине из ответного сообщения.Причина начинается с 3-го символа
                Reason += ConResponse.Substring(2, ConResponse.Length - 2);
                // Обновление формы с причиной, почему мы не могли соединиться
                this.Invoke(new CloseConnectionCallback(this.CloseConnection), new object[] {Reason});
                // Выход из метода
                return;
            }
 
 
            // Пока мы успешно подключились, читать входящие линии с сервера
            while (Connected)
            {
                if (Connected)
                {
                    try
                    {
                        peremennay = srReceiver.ReadLine();
                        // Показать сообщения в журнале TextBox
                        this.Invoke(new UpdateLogCallback(this.UpdateLog), new object[] {peremennay});
                    }
                    catch (Exception) // ex)
                    {
                        swSender.Close();
                        srReceiver.Close();
                        tcpServer.Close();
                        //  MessageBox.Show("Нет соединения с сервером"); // или так - //(ex.Message);
                    }
                }
                else
                {
                    break;
                }
            }
        }
 
        // Этот метод вызывается из другого потока, чтобы обновить журнал TextBox
        private void UpdateLog(string strMessage)
        {
            // Добавить текст также свитки TextBox на дно каждый раз
            textBoxLogChat.AppendText(strMessage + "\r\n");
        }
 
        // Закрывает текущее соединение
        private void CloseConnection(string Reason)
        {
            // Показать причине соединение заканчивается
            textBoxLogChat.AppendText(Reason + "\r\n");
            // Включить и отключить соответствующие элементы управления на форму
            textBoxIPServera.Enabled = true;
            textBoxNickNames.Enabled = true;
            textBoxVvodChat.Enabled = false;
            EnterSend.Enabled = false;
            ConnectedS.Text = "Connect";
 
            // Close the objects
            Connected = false;
            swSender.Close();
            srReceiver.Close();
            tcpServer.Close();
        }
 
        // Отправка сообщения набрали на сервер
        private void SendMessage()
        {
            if (textBoxVvodChat.Lines.Length >= 1)
            {
                swSender.WriteLine(textBoxVvodChat.Text);
                swSender.Flush();
                textBoxVvodChat.Lines = null;
            }
            textBoxVvodChat.Text = "";
        }
 
        // Мы хотим, чтобы отправить сообщение, когда Send нажатии кнопки
        //   private void EnterSend_Click(object sender, EventArgs e)
        //   {
        //        SendMessage();
        //   }
 
        // Но мы также хотим, чтобы отправить сообщение один раз Enter нажат
        private void txtMessage_KeyPress(object sender, KeyPressEventArgs e)
        {
            // Если клавиша Enter
            if (e.KeyChar == (char) 13)
            {
                SendMessage();
            }
        }

InitializeConnection(string ipHost, int port)
{
//...
tcpServer.Connect(ipHost, port);
}

class Room
{
  public string ID { get; private set; }
  private List<Client> ClientList;
 
  public Room(string idRoom)
  {
    this.ID = idRoom;
    this.ClientList = new List<Client>();
  }
 
  public void AddClient(Client client);
}

List<Room> RoomList;
//... 
string id;
//... где-то тут мы получаем от пользователя id-комнаты
bool f = true;
foreach (Room room in RoomList)
{
  if (room.ID == id)
  {
    room.AddClient(client);
    f = false;
  }
}
if (f)
{
  Room room = new Room(id);
  room.AddClient(client);
  RoomList.Add(room);
}

class Room
{
  public void AddClient(Client client)
  {
    this.ClientList.Add(client);
    client.GetMessage += this.HandlerMessage;
  }
 
  private HandlerMessage(object sender, MessageEventArgs e)
  {
    foreach (Client client in ClientList)
    {
      client.Send(e.Message);
    }
  }
}