TheRyuzaki.Network v0.001 PreAlpha - Критика и оптимизация - C#

Узнай цену своей работы

Формулировка задачи:

Client.cs

Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Collections.Concurrent;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using System.Net;
  8. using System.Net.Sockets;
  9. using System.IO;
  10. using System.Threading;
  11.  
  12. namespace TheRyuzaki.Network
  13. {
  14.     public class Client
  15.     {
  16.         public int build = 1;
  17.         public Dictionary<string, object> Cl = new Dictionary<string, object>();
  18.         #region Обьявление  ссылок на функции
  19.         /// <summary>
  20.         /// Ссылка на функцию вызываемую при завершении действий по подключению к серверу.
  21.         /// </summary>
  22.         public Action ConnectToServer_Completed = null;
  23.         /// <summary>
  24.         /// Ссылка на функцию вызываемую при получении текста от сервера.
  25.         /// </summary>
  26.         public Action<string> ReadLineToServer = null;
  27.         /// <summary>
  28.         /// Ссылка на функцию вызываемую при завершении отключения от сервера.
  29.         /// </summary>
  30.         public Action DisconnectServer_Completed = null;
  31.         #endregion
  32.  
  33.         /// <summary>
  34.         /// Класс для клиента по работе с сервером работающиго на TheRyuzaki.Network
  35.         /// </summary>
  36.         /// <param name="ip">IP Адрес до сервера работающиго на TheRyuzaki.Network</param>
  37.         /// <param name="port">Порт до сервера работающиго на TheRyuzaki.Network</param>
  38.         public Client(string ip, int port)
  39.         {
  40.             Cl["connect_status"] = false;
  41.             Cl["client_ip"] = ip;
  42.             Cl["client_port"] = port;
  43.         }
  44.         public void ConnectToServer()
  45.         {
  46.             Cl["client_thread"] = new Thread(delegate ()
  47.             {
  48.                 if (!(bool)Cl["connect_status"])
  49.                     try
  50.                     {
  51.                         Cl["client_tcp"] = new TcpClient((string)Cl["client_ip"], (int)Cl["client_port"]);
  52.                         Cl["client_ns"] = (Cl["client_tcp"] as TcpClient).GetStream();
  53.                         Cl["client_sr"] = new StreamReader((Cl["client_ns"] as NetworkStream));
  54.                         Cl["client_sw"] = new StreamWriter((Cl["client_ns"] as NetworkStream));
  55.                         Cl["connect_status"] = true;
  56.                         
  57.                     }
  58.                     catch
  59.                     {
  60.                         Cl["connect_status"] = false;
  61.                     }
  62.                 if (ConnectToServer_Completed != null) ConnectToServer_Completed();
  63.                 Reading();
  64.             });
  65.             (Cl["client_thread"] as Thread).Start();
  66.         }
  67.         
  68.         /// <summary>
  69.         /// Функция потокового прослушивания запросов от сервера
  70.         /// </summary>
  71.         private void Reading()
  72.         {
  73.             if ((bool)Cl["connect_status"])
  74.                 try
  75.                 {
  76.                     while(true)
  77.                     {
  78.                         var request = (Cl["client_sr"] as StreamReader).ReadLine();
  79.                         if (request.Length == 0) break;
  80.                         var ex = request.Split(';');
  81.                         switch (ex[0])
  82.                         {
  83.                             case "version":
  84.                                 WriteForServer("version;" + build);
  85.                                 break;
  86.                             default:
  87.                                 if (ReadLineToServer != null) ReadLineToServer(request);
  88.                                 break;
  89.                         }
  90.                     }
  91.                     Disconnect();
  92.                 }
  93.                 catch {
  94.                     if ((Thread)Cl["client_thread"] != null) Disconnect();
  95.                 }
  96.         }
  97.  
  98.         /// <summary>
  99.         /// Функция отправки запроса на сервер
  100.         /// </summary>
  101.         /// <param name="request">Запрос</param>
  102.         /// <param name="WriteAllClients">Просто отправить всем клиентам</param>
  103.         public void WriteForServer(string request, bool WriteAllClients = false)
  104.         {
  105.             if (!(bool)Cl["connect_status"])
  106.                 return;
  107.             if (WriteAllClients)
  108.                 request = "WriteAllClients;" + request;
  109.             (Cl["client_sw"] as StreamWriter).WriteLine(request);
  110.             (Cl["client_sw"] as StreamWriter).Flush();
  111.         }
  112.  
  113.         /// <summary>
  114.         /// Функция разрыва соеденения с сервером
  115.         /// </summary>
  116.         public void Disconnect()
  117.         {
  118.             Cl["client_thread"] = null;
  119.             try { (Cl["client_sr"] as StreamReader).Close(); } catch { }
  120.             try { (Cl["client_sw"] as StreamWriter).Close(); } catch { }
  121.             try { (Cl["client_ns"] as NetworkStream).Close(); } catch { }
  122.             try { (Cl["client_tcp"] as TcpClient).Close(); } catch { }
  123.             Cl["connect_status"] = false;
  124.             if (DisconnectServer_Completed != null) DisconnectServer_Completed();
  125.         }
  126.  
  127.     }
  128. }

Server.cs

Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Collections.Concurrent;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using System.Net;
  8. using System.Net.Sockets;
  9. using System.IO;
  10. using System.Threading;
  11.  
  12. namespace TheRyuzaki.Network
  13. {
  14.     public class Server
  15.     {
  16.         private int build = 1;
  17.  
  18.         public Dictionary<string, object> Config = new Dictionary<string, object>();
  19.         public Dictionary<string, object> Srv = new Dictionary<string, object>();
  20.  
  21.         #region Ссылки на функции CallBack
  22.         /// <summary>
  23.         /// Ссылка на функцию которая вызывается при успешном запуске сервера
  24.         /// </summary>
  25.         public Action ServerStarted = null;
  26.         /// <summary>
  27.         /// Ссылка на функцию которая вызывается при остановке сервера
  28.         /// </summary>
  29.         public Action ServerStoped = null;
  30.         /// <summary>
  31.         /// Ссылка на функцию которая вызывается при подключении нового клиента
  32.         /// </summary>
  33.         public Action<int> ClientConnected = null;
  34.         /// <summary>
  35.         /// Ссылка на функцию которая вызывается при отключении клиента от сервера
  36.         /// </summary>
  37.         public Action<int, Dictionary<string, object>> ClientDisconnected = null;
  38.         /// <summary>
  39.         /// Ссылка на функцию которая вызывается при получении сообщения от клиента
  40.         /// </summary>
  41.         public Action<int, string> ClientSendedMessage = null;
  42.         #endregion
  43.  
  44.         /// <summary>
  45.         /// Класс по работе Сервер-Клиент по сердствам TheRyuzaki.Network
  46.         /// </summary>
  47.         /// <param name="IP">IP адрес прослушки в формате IPAddress</param>
  48.         /// <param name="Port">Порт прослушиваемый</param>
  49.         public Server(IPAddress IP, int Port)
  50.         {
  51.             Config["server_ip"] = IP;
  52.             Config["server_port"] = Port;
  53.             Config["last_session"] = 0;
  54.             Srv["server_thread"] = null;
  55.             Srv["Server"] = new Dictionary<string, object>();
  56.             Srv["Users"] = new Dictionary<int, object>();
  57.             (Srv["Server"] as Dictionary<string, object>)["Listener"] = new TcpListener(IP, Port);
  58.         }
  59.  
  60.         /// <summary>
  61.         /// Функция запуска сервера
  62.         /// </summary>
  63.         public void StartServer()
  64.         {
  65.             if ((Srv["server_thread"] as Thread) != null) return;
  66.             ((Srv["Server"] as Dictionary<string, object>)["Listener"] as TcpListener).Start();
  67.             Srv["server_thread"] = new Thread(delegate ()
  68.             {
  69.                 if (ServerStarted != null) ServerStarted();
  70.                 while (true)
  71.                 {
  72.                     Socket Soc = null;
  73.                     try { Soc = ((Srv["Server"] as Dictionary<string, object>)["Listener"] as TcpListener).AcceptSocket(); } catch { break; }
  74.                     if (Soc.Connected)
  75.                     {
  76.                         Config["last_session"] = (int)Config["last_session"] + 1;
  77.                         var id_session = (int)Config["last_session"];
  78.                         (Srv["Users"] as Dictionary<int, object>)[id_session] = new Dictionary<string, object>();
  79.                         ((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["Thread"] = new Thread(delegate ()
  80.                         {
  81.                             try
  82.                             {
  83.                                 ((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["Soc"] = Soc;
  84.                                 ((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["NS"] = new NetworkStream(Soc);
  85.                                 ((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SR"] = new StreamReader((((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["NS"] as NetworkStream));
  86.                                 ((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SW"] = new StreamWriter((((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["NS"] as NetworkStream));
  87.                                 if (ClientConnected != null) ClientConnected(id_session);
  88.                                 while (true)
  89.                                 {
  90.                                     var request = (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SR"] as StreamReader).ReadLine();
  91.                                     if (request.Length == 0) break;
  92.                                     request = "WriteAllClients;" + request;
  93.                                     var ex = request.Split(';');
  94.                                     switch (ex[0])
  95.                                     {
  96.                                         case "version":
  97.                                             if (build.ToString() != ex[1]) CloseSession(id_session);
  98.                                             break;
  99.                                         case "WriteAllClients":
  100.                                             request = request.Replace("WriteAllClients;", "");
  101.                                             (new Thread(delegate ()
  102.                                             {
  103.                                                 foreach (var r in GetUsers())
  104.                                                     if ((Srv["Users"] as Dictionary<int, object>).ContainsKey(r.Key))
  105.                                                         SendMessage(request, r.Key);
  106.                                             })).Start();
  107.                                             break;
  108.                                         default:
  109.                                             if (ClientSendedMessage != null) ClientSendedMessage(id_session, request);
  110.                                             break;
  111.                                     }
  112.                                 }
  113.                                 CloseSession(id_session);
  114.                             }
  115.                             catch
  116.                             {
  117.                                 CloseSession(id_session);
  118.                             }
  119.                         });
  120.                         (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["Thread"] as Thread).Start();
  121.                     }
  122.                 }
  123.             });
  124.             (Srv["server_thread"] as Thread).Start();
  125.  
  126.         }
  127.  
  128.         /// <summary>
  129.         /// Функция остановки сервера
  130.         /// </summary>
  131.         public void StopServer()
  132.         {
  133.             if ((Srv["server_thread"] as Thread) == null) return;
  134.             ((Srv["Server"] as Dictionary<string, object>)["Listener"] as TcpListener).Stop();
  135.             foreach(var r in GetUsers())
  136.                 if ((Srv["Users"] as Dictionary<int, object>).ContainsKey(r.Key))
  137.                     CloseSession(r.Key);
  138.             (Srv["server_thread"] as Thread).Abort();
  139.             Srv["server_thread"] = null;
  140.             if (ServerStoped != null) ServerStoped();
  141.  
  142.         }
  143.  
  144.         /// <summary>
  145.         /// Функция завершения сеанса сессии.
  146.         /// Возвращает ответ:
  147.         /// 0 = Закрыт успешно.
  148.         /// 1 = Такой сессии не существует.
  149.         /// 2 = Возникла ошибка при закрытии сесии.
  150.         /// </summary>
  151.         public int CloseSession(int id, bool NotRemove = false)
  152.         {
  153.             int i = 0;
  154.             if ((Srv["Users"] as Dictionary<int, object>).ContainsKey(id))
  155.                 try
  156.                 {
  157.  
  158.                     try { (((Srv["Users"] as Dictionary<int, object>)[id] as Dictionary<string, object>)["Soc"] as Socket).Close(); } catch { }
  159.                     if (ClientDisconnected != null) ClientDisconnected(id, ((Srv["Users"] as Dictionary<int, object>)[id] as Dictionary<string, object>));
  160.                     Thread tmp = (((Srv["Users"] as Dictionary<int, object>)[id] as Dictionary<string, object>)["Thread"] as Thread);
  161.                     if (!NotRemove) (Srv["Users"] as Dictionary<int, object>).Remove(id);
  162.                     tmp.Abort();
  163.                 }
  164.                 catch
  165.                 {
  166.                     i = 2; // Записываем про чтоизошла ошибка
  167.                 }
  168.             else
  169.                 i = 1;
  170.             return i;
  171.         }
  172.  
  173.         /// <summary>
  174.         /// Функция отправки сообщения на клиент
  175.         /// </summary>
  176.         /// <param name="message">Само сообщение</param>
  177.         /// <param name="id_session">ID сессии</param>
  178.         public void SendMessage(string message, int id_session)
  179.         {
  180.             (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SW"] as StreamWriter).WriteLine(message);
  181.             (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SW"] as StreamWriter).Flush();
  182.         }
  183.  
  184.         /// <summary>
  185.         /// Функция получения списка ID сессий активных пользователей. Желательно проверять при работе на достоверность  if ((Srv["Users"] as Dictionary<int, object>).ContainsKey(r.Key))
  186.         /// </summary>
  187.         /// <returns>Dictionary<int, bool> - массив содержащий ID в ключе</returns>
  188.         public Dictionary<int, bool> GetUsers()
  189.         {
  190.             var k =(Srv["Users"] as Dictionary<int, object>).Keys;
  191.             Dictionary<int, bool> keys = new Dictionary<int, bool>();
  192.             foreach(var r in k)
  193.                 keys.Add(r, true);
  194.             return keys;
  195.         }
  196.     }
  197. }
Welcome критика, оптимизация и предложения.

Решение задачи: «TheRyuzaki.Network v0.001 PreAlpha - Критика и оптимизация»

textual
Листинг программы 
  1.         public void SendMessage(string message, int id_session)
  2.         {
  3.             (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SW"] as StreamWriter).WriteLine(message);
  4.             (((Srv["Users"] as Dictionary<int, object>)[id_session] as Dictionary<string, object>)["SW"] as StreamWriter).Flush();
  5.         }

ИИ поможет Вам:

  • решить любую задачу по программированию
  • объяснить код
  • расставить комментарии в коде
  • и т.д
Попробуйте бесплатно

Оцени полезность:

5   голосов , оценка 3.6 из 5

Нужна аналогичная работа?

Оформи быстрый заказ и узнай стоимость

Бесплатно
Оформите заказ и авторы начнут откликаться уже через 10 минут
Похожие ответы