Клиент-серверное приложение перстает работать при отправке/приеме 3-4 сообщений - C#

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

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

Здравствуйте! При создании сервера (пока он ещё на начальном этапе и я сделал только самое простое) у меня возникла проблема: сначала сервер получает сообщения от клиента и отправляет уведомление. Потом он начинает получать сообщения от клиента и отправлять уведомления о доставке. После двух или нескольких сообщений клиент перестает получать уведомления, а сервер перестает воспринимать окружающие подключения. Вот код сервера:
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel;
  4. using System.Data;
  5. using System.Drawing;
  6. using System.Text;
  7. using System.Windows.Forms;
  8. using System.Net;
  9. using System.Net.Sockets;
  10. using System.Diagnostics;
  11.  
  12. namespace SocketServer
  13. {
  14.     public partial class Form1 : Form
  15.     {
  16.         Socket server = null;
  17.         //Socket client = null;
  18.         bool RunChat = false;
  19.  
  20.         public Form1()
  21.         {
  22.             InitializeComponent();
  23.         }
  24.  
  25.         private void startServerButton_Click(object sender, EventArgs e)
  26.         {
  27.  
  28.             if (server != null && server.Connected)
  29.                 server.Disconnect(false);
  30.  
  31.             int port = 12345;
  32.             if (portTextBox.Text != "")
  33.                 port = Convert.ToInt32(portTextBox.Text);
  34.             else
  35.                 MessageBox.Show("используется порт по умолчанию: 12345");
  36.  
  37.             server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  38.             EndPoint endPoint = new IPEndPoint(IPAddress.Any, port);
  39.  
  40.             try
  41.             {
  42.                 server.Bind(endPoint);
  43.                 server.Listen(100);
  44.             }
  45.             catch (Exception exc)
  46.             {
  47.                 MessageBox.Show("Невозможно запустить сервер " + exc.Message);
  48.                 return;
  49.             }
  50.  
  51.             server.BeginAccept(new AsyncCallback(AsyncAcceptCallback_), server);
  52.         }
  53.  
  54.         void AsyncAcceptCallback(IAsyncResult result)
  55.         {
  56.             Socket serverSocket = (Socket)result.AsyncState;
  57.  
  58.             SocketData data = new SocketData();
  59.             data.ServerConnection = serverSocket.EndAccept(result);
  60.  
  61.             data.ServerConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
  62.                     new AsyncCallback(ReadCallback), data);
  63.         }
  64.  
  65.         void ReadCallback(IAsyncResult result)
  66.         {
  67.             SocketData data = (SocketData)result.AsyncState;
  68.             int bytes = data.ServerConnection.EndReceive(result);
  69.  
  70.             if (bytes > 0)
  71.             {
  72.                 string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
  73.  
  74.                 try
  75.                 {
  76.                     clientRichTextBox.AppendText(s + "\n");
  77.                 }
  78.                 catch (Exception exc) { }
  79.  
  80.                 data.ServerConnection.Send(Encoding.UTF8.GetBytes("Получено: " + s.Length + " символов"));
  81.                 RunChat = true;
  82.             }
  83.  
  84.         }
  85.  
  86.         void AsyncAcceptCallback_(IAsyncResult result)
  87.         {
  88.             Socket serverSocket = (Socket)result.AsyncState;
  89.  
  90.             SocketData data = new SocketData();
  91.             data.ServerConnection = serverSocket.EndAccept(result);
  92.  
  93.             data.ServerConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
  94.                     new AsyncCallback(ReadCallback_), data);
  95.             server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);   
  96.         }
  97.  
  98.         void ReadCallback_(IAsyncResult result)
  99.         {
  100.             SocketData data = (SocketData)result.AsyncState;
  101.             int bytes = data.ServerConnection.EndReceive(result);
  102.  
  103.             if (bytes > 0)
  104.             {
  105.                 string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
  106.  
  107.                 try
  108.                 {
  109.                     clientRichTextBox.AppendText(s + "\n");
  110.                 }
  111.                 catch (Exception exc) { }
  112.  
  113.                 data.ServerConnection.Send(Encoding.UTF8.GetBytes("Сервер: соединен"));
  114.                 RunChat = true;
  115.             }
  116.  
  117.         }
  118.  
  119.         public IPAddress GetAddress(string address)
  120.         {
  121.             IPAddress ipAddress = null;
  122.             try
  123.             {
  124.                 ipAddress = IPAddress.Parse(address);
  125.             }
  126.             catch (Exception)
  127.             {
  128.                 IPHostEntry heserver;
  129.  
  130.                 try
  131.                 {
  132.                     heserver = Dns.GetHostEntry(address);
  133.                     if (heserver.AddressList.Length == 0)
  134.                     {
  135.                         return null;
  136.                     }
  137.                     ipAddress = heserver.AddressList[0];
  138.                 }
  139.                 catch
  140.                 {
  141.                     return null;
  142.                 }
  143.             }
  144.  
  145.             return ipAddress;
  146.         }
  147.  
  148.         private void timerServer_Tick(object sender, EventArgs e)
  149.         {
  150.             if (RunChat)
  151.             {
  152.                 try
  153.                 {
  154.                     server.Listen(100);
  155.                 }
  156.                 catch (Exception exc)
  157.                 {
  158.                     MessageBox.Show("Ошибка прослушивания: " + exc.Message);
  159.                     RunChat = false;
  160.                     return;
  161.                 }
  162.  
  163.                 server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);
  164.  
  165.                 RunChat = false;
  166.             }
  167.         }
  168.     }
  169.  
  170.     class SocketData
  171.     {
  172.         public const int BufferSize = 1024;
  173.  
  174.         public Socket ServerConnection { get; set; }
  175.  
  176.         byte[] buffer = new byte[BufferSize];
  177.  
  178.         public byte[] Buffer 
  179.         {
  180.             get { return buffer; }
  181.             set { buffer = value; }
  182.         }
  183.     }
  184. }
Вот код клиента:
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel;
  4. using System.Data;
  5. using System.Drawing;
  6. using System.Text;
  7. using System.Windows.Forms;
  8. using System.Net;
  9. using System.Net.Sockets;
  10. using System.Diagnostics;
  11.  
  12. namespace SocketClient
  13. {
  14.     public partial class Form1 : Form
  15.     {
  16.         Socket client = null;
  17.         int id = 0;
  18.         public Form1()
  19.         {
  20.             InitializeComponent();
  21.         }
  22.  
  23.         private void connectButton_Click(object sender, EventArgs e)
  24.         {
  25.             if (client != null && client.Connected)
  26.                 client.Disconnect(false);
  27.  
  28.             IPAddress addr = GetAddress(serverAddressTextBox.Text);
  29.             if (addr == null)
  30.             {
  31.                 MessageBox.Show("Я в шоке, не смог разобрать адрес");
  32.                 return;
  33.             }
  34.  
  35.             int port = 12345;
  36.             if (portTextBox.Text != "")
  37.                 port = Convert.ToInt32(portTextBox.Text);
  38.             else
  39.                 MessageBox.Show("используется порт по умолчанию: 12345");
  40.  
  41.             client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  42.             EndPoint point = new IPEndPoint(addr, port);
  43.             try
  44.             {
  45.                 client.Connect(point);
  46.             }
  47.             catch (Exception exc)
  48.             {
  49.                 MessageBox.Show("Ошибка соединения: " + exc.Message);
  50.             }
  51.             if (client.Connected)
  52.             {
  53.                 MessageBox.Show("Подключен!");
  54.             }
  55.  
  56.             this.id = Convert.ToInt32(textBoxID.Text);
  57.  
  58.             client.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + " Password: " + textBoxPassword.Text + " - Подключен!"));
  59.  
  60.             byte[] buffer = new byte[1024];
  61.             int bytes = 0;
  62.  
  63.             try
  64.             {
  65.                 bytes = client.Receive(buffer);
  66.             }
  67.             catch (Exception exc)
  68.             {
  69.                 MessageBox.Show("Ошибка подключения: " + exc.Message);
  70.             }
  71.             
  72.             if (bytes > 0)
  73.             {
  74.                 string s = Encoding.UTF8.GetString(buffer, 0, bytes);
  75.                 clientRichTextBox.AppendText(s + "\n");
  76.             }
  77.         }
  78.  
  79.         void AsyncAcceptCallback(IAsyncResult result)
  80.         {
  81.             Socket serverSocket = (Socket)result.AsyncState;
  82.  
  83.             SocketData data = new SocketData();
  84.             data.ClientConnection = serverSocket.EndAccept(result);
  85.  
  86.             data.ClientConnection.BeginReceive(data.Buffer, 0, 1024, SocketFlags.None,
  87.                     new AsyncCallback(ReadCallback), data);
  88.         }
  89.  
  90.         void ReadCallback(IAsyncResult result)
  91.         {
  92.             SocketData data = (SocketData)result.AsyncState;
  93.             int bytes = data.ClientConnection.EndReceive(result);
  94.  
  95.             if (bytes > 0)
  96.             {
  97.                 string s = Encoding.UTF8.GetString(data.Buffer, 0, bytes);
  98.  
  99.                 try
  100.                 {
  101.                     clientRichTextBox.AppendText(s + "\n");
  102.                 }
  103.                 catch (Exception exc)
  104.                 { }
  105.                 data.ClientConnection.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + "Получено!"));
  106.             }
  107.  
  108.         }
  109.  
  110.         public IPAddress GetAddress(string address)
  111.         {
  112.             IPAddress ipAddress = null;
  113.             try
  114.             {
  115.                 ipAddress = IPAddress.Parse(address);
  116.             }
  117.             catch (Exception)
  118.             {
  119.                 IPHostEntry heserver;
  120.  
  121.                 try
  122.                 {
  123.                     heserver = Dns.GetHostEntry(address);
  124.                     if (heserver.AddressList.Length == 0)
  125.                     {
  126.                         return null;
  127.                     }
  128.                     ipAddress = heserver.AddressList[0];
  129.                 }
  130.                 catch
  131.                 {
  132.                     return null;
  133.                 }
  134.             }
  135.  
  136.             return ipAddress;
  137.         }
  138.  
  139.         private void sendButton_Click(object sender, EventArgs e)
  140.         {
  141.             if (client != null && client.Connected)
  142.                 client.Disconnect(false);
  143.  
  144.             IPAddress addr = GetAddress(serverAddressTextBox.Text);
  145.             if (addr == null)
  146.             {
  147.                 MessageBox.Show("Я в шоке, не смог разобрать адрес");
  148.                 return;
  149.             }
  150.  
  151.             int port = 12345;
  152.             if (portTextBox.Text != "")
  153.                 port = Convert.ToInt32(portTextBox.Text);
  154.  
  155.             client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  156.             EndPoint point = new IPEndPoint(addr, port);
  157.             try
  158.             {
  159.                 client.Connect(point);
  160.             }
  161.             catch (Exception exc)
  162.             {
  163.                 MessageBox.Show("Ошибка соединения: " + exc.Message);
  164.             }
  165.  
  166.             try
  167.             {
  168.                 client.Send(Encoding.UTF8.GetBytes("ID: " + this.id.ToString() + " Сообщение: " + commandTextBox.Text));
  169.             }
  170.             catch (Exception exc)
  171.             {
  172.                 MessageBox.Show("Ошибка отправки: " + exc.Message);
  173.             }
  174.  
  175.             byte[] buffer = new byte[1024];
  176.  
  177.             int bytes = 0;
  178.             try
  179.             {
  180.                 bytes = client.Receive(buffer);
  181.             }
  182.             catch (Exception exc)
  183.             {
  184.                 MessageBox.Show("Ошибка получения уведомления об отправке: " + exc.Message);
  185.             }
  186.  
  187.             if (bytes > 0)
  188.             {
  189.                 string s = Encoding.UTF8.GetString(buffer, 0, bytes);
  190.                 try
  191.                 {
  192.                     clientRichTextBox.AppendText(s + "\n");
  193.                 }
  194.                 catch (Exception exc)
  195.                 {}
  196.             }
  197.         }
  198.     }
  199.  
  200.     class SocketData
  201.     {
  202.         public const int BufferSize = 1024;
  203.  
  204.         public Socket ClientConnection { get; set; }
  205.  
  206.         byte[] buffer = new byte[BufferSize];
  207.  
  208.         public byte[] Buffer
  209.         {
  210.             get { return buffer; }
  211.             set { buffer = value; }
  212.         }
  213.     }
  214. }
иногда все работает, но иногда ...

Решение задачи: «Клиент-серверное приложение перстает работать при отправке/приеме 3-4 сообщений»

textual
Листинг программы 
  1. using System.Threading;
  2.  
  3.         void StartServer()
  4.         {
  5.             while (this.IsActive)
  6.             {
  7.                 if(this.IsEnable)
  8.                     if (this.RunChat)
  9.                     {
  10.                         try
  11.                         {
  12.                             server.Listen(100);
  13.                         }
  14.                         catch (Exception exc)
  15.                         {
  16.                             MessageBox.Show("Ошибка прослушивания: " + exc.Message);
  17.                             RunChat = false;
  18.                             return;
  19.                         }
  20.  
  21.                         server.BeginAccept(new AsyncCallback(AsyncAcceptCallback), server);
  22.                         RunChat = false;
  23.                     }
  24.                 Thread.Sleep(50);
  25.             }
  26.         }
  27.  
  28.         private void startServerButton_Click(object sender, EventArgs e)
  29.         {
  30.             if (!this.IsActive)
  31.             {
  32.                 if (server != null && server.Connected)
  33.                     server.Disconnect(false);
  34.  
  35.                 int port = 12345;
  36.                 if (portTextBox.Text != "")
  37.                     port = Convert.ToInt32(portTextBox.Text);
  38.                 else
  39.                     MessageBox.Show("используется порт по умолчанию: 12345");
  40.  
  41.  
  42.                 server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  43.                 EndPoint endPoint = new IPEndPoint(IPAddress.Any, port);
  44.  
  45.                 try
  46.                 {
  47.                     server.Bind(endPoint);
  48.                     //server.Listen(100);
  49.                 }
  50.                 catch (Exception exc)
  51.                 {
  52.                     MessageBox.Show("Невозможно запустить сервер " + exc.Message);
  53.                     return;
  54.                 }
  55.  
  56.                 this.RunChat = true;//для приема нового сообщения
  57.                 this.IsActive = true;//для работы потока
  58.                 this.IsEnable = true;//для временного прерывания\возобновления потока, при этом данные на сокете, ожидающие принятия программой не пропадают
  59.  
  60.                 myThread = new Thread(new ThreadStart(StartServer));
  61.                 myThread.Start();
  62.             }
  63.         }
  64. //...

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

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

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

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

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

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

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