Program.cs 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. using Newtonsoft.Json;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.IO;
  5. using System.Linq;
  6. using System.Net;
  7. using System.Net.Sockets;
  8. using System.Net.WebSockets;
  9. using System.Text;
  10. using System.Threading.Tasks;
  11. namespace WebSocketServerSrez
  12. {
  13. public class Program
  14. {
  15. static void Main(string[] args)
  16. {
  17. WebSocketServer(11000);
  18. }
  19. public static void WebSocketServer(int port)
  20. {
  21. IPHostEntry iPHostEntry = Dns.GetHostEntry("localhost");
  22. IPAddress iPAddress = iPHostEntry.AddressList[0];
  23. IPEndPoint iPEndPoint = new IPEndPoint(iPAddress, port);
  24. Socket socketListener = new Socket(iPAddress.AddressFamily, SocketType.Stream,ProtocolType.Tcp);
  25. try
  26. {
  27. socketListener.Bind(iPEndPoint);
  28. socketListener.Listen(10);
  29. while (true)
  30. {
  31. Socket handler = socketListener.Accept();
  32. string data = null;
  33. byte[] bytes = new byte[1024];
  34. int bytesRec = handler.Receive(bytes);
  35. // Tut
  36. data += Encoding.UTF8.GetString(bytes, 0, bytesRec);
  37. var dataR = data.Split(' ');
  38. if (dataR[0] == "SetUserSession")
  39. {
  40. Session.IdUser = Convert.ToInt32(dataR[1]);
  41. Session.DateStart = DateTime.Now;
  42. SetSessionUser setSessionUser = new SetSessionUser()
  43. {
  44. id_user = Convert.ToInt32(dataR[1]),
  45. date_start = DateTime.Now.ToString()
  46. };
  47. var dataSend = JsonConvert.SerializeObject(setSessionUser, Formatting.Indented);
  48. var request = WebRequest.Create("http://127.0.0.1:5000/set_session_user");
  49. request.ContentType = "application/json";
  50. request.Method = "POST";
  51. using (var sw = new StreamWriter(request.GetRequestStream()))
  52. {
  53. sw.Write(dataSend);
  54. }
  55. var response = request.GetResponse();
  56. using (var sr = new StreamReader(response.GetResponseStream()))
  57. {
  58. var jsonResp = JsonConvert.DeserializeObject<RespSetSessionUser>(sr.ReadToEnd());
  59. byte[] mes = Encoding.UTF8.GetBytes(jsonResp.id_user_session.ToString());
  60. handler.Send(mes);
  61. handler.Shutdown(SocketShutdown.Both);
  62. handler.Close();
  63. }
  64. }
  65. else if (dataR[0] == "UpdateUserSession")
  66. {
  67. Session.DateFinish = DateTime.Now;
  68. var request = WebRequest.Create("http://127.0.0.1:5000/update_session_user");
  69. request.ContentType = "application/json";
  70. request.Method = "POST";
  71. UpdateSessionUser updateSessionUser = new UpdateSessionUser()
  72. {
  73. Id = Convert.ToInt32(dataR[1]),
  74. date_finish = Session.DateFinish.ToString()
  75. };
  76. var dataSend = JsonConvert.SerializeObject(updateSessionUser, Formatting.Indented);
  77. using (var sw = new StreamWriter(request.GetRequestStream()))
  78. {
  79. sw.Write(dataSend);
  80. }
  81. request.GetResponse();
  82. }
  83. }
  84. }
  85. catch (Exception)
  86. {
  87. throw;
  88. }
  89. finally
  90. {
  91. }
  92. }
  93. public class SetSessionUser
  94. {
  95. public int id_user { get; set; }
  96. public string date_start { get; set; }
  97. }
  98. public class RespSetSessionUser
  99. {
  100. public int id_user_session { get; set; }
  101. }
  102. public class UpdateSessionUser
  103. {
  104. public int Id { get; set; }
  105. public string date_finish { get; set; }
  106. }
  107. }
  108. }