Socket Server/Client. Падение клиента при коннекте к серверу - C#

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

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

В общем есть сервер:
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Net.Sockets;
  6. using System.Net;
  7.  
  8. namespace Server
  9. {
  10.     class Program
  11.     {
  12.         static List<EndPoint> sockets = new List<EndPoint>();
  13.         static string textToSend = null;
  14.         static void Main()
  15.         {
  16.             
  17.             Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  18.             server.Bind(new IPEndPoint(IPAddress.Any, 5080));
  19.             server.Listen(100);
  20.  
  21.             server.BeginAccept(ConnectCallback, server);
  22.  
  23.             string input;
  24.             Console.WriteLine("Type 'exit' to quit");
  25.             while ((input = Console.ReadLine().ToLower()) != "exit") ;
  26.         }
  27.  
  28.         static void ConnectCallback(IAsyncResult iar)
  29.         {
  30.  
  31.             Socket server = (Socket)iar.AsyncState;
  32.             
  33.             try
  34.             {
  35.                 
  36.                 Socket client = server.EndAccept(iar);
  37.                 sockets.Add (client.RemoteEndPoint);
  38.                 Console.WriteLine("Новый клиент: {0}", client.RemoteEndPoint);
  39.                 AsyncState state = new AsyncState { socket = client, buffer = new byte[client.ReceiveBufferSize] };
  40.                 byte[] data = Encoding.UTF8.GetBytes("Здравствуйте");
  41.                 client.BeginReceive(state.buffer, 0, state.buffer.Length, SocketFlags.None, ReceiveCallback, state);
  42.                 client.BeginSend(data, 0, data.Length, SocketFlags.None, SendCallback, state);
  43.             }
  44.             catch (SocketException e)
  45.             {
  46.                 Console.WriteLine("Error accepting connection: {0}", e.Message);
  47.             }
  48.             server.BeginAccept(ConnectCallback, server);
  49.         }
  50.  
  51.         static void ReceiveCallback(IAsyncResult iar)
  52.         {
  53.             AsyncState state = (AsyncState)iar.AsyncState;
  54.             try
  55.             {
  56.                 int recv = state.socket.EndReceive(iar);
  57.                 if (recv == 0)
  58.                 {
  59.                     Console.WriteLine("Client {0} has closed connection", state.socket.RemoteEndPoint);
  60.                     state.socket.Close();
  61.                 }
  62.                 else
  63.                 {
  64.                     string text = Encoding.UTF8.GetString(state.buffer, 0, recv);
  65.                     textToSend = state.socket.RemoteEndPoint.ToString() +"  "+ text;
  66.  
  67.                     Console.WriteLine("{0}: {1}", state.socket.RemoteEndPoint, text);
  68.                     byte[] answer = Encoding.UTF8.GetBytes(textToSend);
  69.                     for (int i = 0; i < sockets.ToArray().Length; i++)
  70.                     {
  71.                         System.Threading.Thread.Sleep(100);
  72.                         state.socket.BeginSendTo(answer, 0, answer.Length, SocketFlags.None, sockets[i], SendCallback, state);
  73.                     }
  74.                 }
  75.             }
  76.             catch (SocketException e)
  77.             {
  78.                 Console.WriteLine("Error receiving from {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  79.                 state.socket.Close();
  80.             }
  81.         }
  82.  
  83.         static void SendCallback(IAsyncResult iar)
  84.         {
  85.             AsyncState state = (AsyncState)iar.AsyncState;
  86.             try
  87.             {
  88.                 int sent = state.socket.EndSend(iar);
  89.  
  90.                 state.socket.BeginReceive(state.buffer, 0, state.buffer.Length, SocketFlags.None, ReceiveCallback, state);
  91.                 
  92.             }
  93.             catch (SocketException e)
  94.             {
  95.                 Console.WriteLine("Error sending to {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  96.                 state.socket.Close();
  97.             }
  98.         }
  99.     }
  100.  
  101.     struct AsyncState
  102.     {
  103.         public Socket socket;
  104.         public byte[] buffer;
  105.     }
  106. }
и клиент
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Net.Sockets;
  6. using System.Net;
  7.  
  8. namespace Client
  9. {
  10.     class Program
  11.     {
  12.         static Socket sck;
  13.         static byte[] buffer;
  14.  
  15.         static void Main(string[] args)
  16.         {
  17.             Socket accept = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  18.  
  19.             sck = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  20.             IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5080);
  21.  
  22.                 sck.BeginConnect(endpoint,ReceiveCallback,sck);
  23.                 Console.WriteLine("Connectin Succes");
  24.  
  25.         }
  26.  
  27.         static void ReceiveCallback(IAsyncResult iar)
  28.         {
  29.             AsyncState state = (AsyncState)iar.AsyncState;
  30.  
  31.             byte[] data = state.buffer;
  32.             state.socket.Receive(data);
  33.  
  34.             try
  35.             {
  36.                 int recv = state.socket.EndReceive(iar);
  37.                 
  38.                 string text = Encoding.UTF8.GetString(state.buffer, 0, recv);
  39.                 Console.WriteLine(text);
  40.  
  41.             }
  42.             
  43.             catch (SocketException e)
  44.             {
  45.                 Console.WriteLine("Error receiving from {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  46.                 state.socket.Close();
  47.             }
  48.         }
  49.  
  50.         static void SendCallback(IAsyncResult iar)
  51.         {
  52.             AsyncState state = (AsyncState)iar.AsyncState;
  53.             try
  54.             {
  55.                 int sent = state.socket.EndSend(iar);
  56.  
  57.                 state.socket.BeginReceive(state.buffer, 0, state.buffer.Length, SocketFlags.None, ReceiveCallback, state);
  58.  
  59.             }
  60.             catch (SocketException e)
  61.             {
  62.                 Console.WriteLine("Error sending to {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  63.                 state.socket.Close();
  64.             }
  65.         }
  66.     }
  67.  
  68.  struct AsyncState
  69.     {
  70.         public Socket socket;
  71.         public byte[] buffer;
  72.     }
  73. }
При конекте клиента к серверу консоль сразу же закрывается (в логе сервера клиент подсоединяется и сразу же закрывается). Что я не так делаю?

Решение задачи: «Socket Server/Client. Падение клиента при коннекте к серверу»

textual
Листинг программы 
  1. using System;
  2. using System.Net;
  3. using System.Net.Sockets;
  4. using System.Threading;
  5. using System.Text;
  6.  
  7. // State object for receiving data from remote device.
  8. public class StateObject
  9. {
  10.     // Client socket.
  11.     public Socket workSocket = null;
  12.     // Size of receive buffer.
  13.     public const int BufferSize = 256;
  14.     // Receive buffer.
  15.     public byte[] buffer = new byte[BufferSize];
  16.     // Received data string.
  17.     public StringBuilder sb = new StringBuilder();
  18. }
  19.  
  20. public class Client
  21. {
  22.     // The port number for the remote device.
  23.     private const int port = 5080;
  24.  
  25.     // ManualResetEvent instances signal completion.
  26.     private static ManualResetEvent connectDone =
  27.         new ManualResetEvent(false);
  28.     private static ManualResetEvent sendDone =
  29.         new ManualResetEvent(false);
  30.     private static ManualResetEvent receiveDone =
  31.         new ManualResetEvent(false);
  32.  
  33.     static byte[] data;
  34.     static Socket sck;
  35.  
  36.  
  37.  
  38.     public static void Main()
  39.     {
  40.         sck = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  41.         IPEndPoint end = new IPEndPoint(IPAddress.Parse("127.0.0.1"),5080);
  42.  
  43.         sck.BeginConnect(end, ConnectCallBack, sck);
  44.  
  45.     }
  46.  
  47.     static void ConnectCallBack(IAsyncResult iar){
  48.         
  49.         Socket client = (Socket)iar.AsyncState;
  50.         AsyncState state = new AsyncState { socket = client, buffer = new byte[client.ReceiveBufferSize] };
  51.  
  52.         String textdata = "привет";
  53.         byte[] data = Encoding.UTF8.GetBytes(textdata) ;
  54.         try
  55.         {
  56.             client.EndConnect(iar);
  57.             state.socket.BeginSend(data, 0, data.Length, SocketFlags.None, SendCallback, state);
  58.             connectDone.Set();
  59.         }
  60.         catch (Exception ex)
  61.         {
  62.             Console.WriteLine(ex);
  63.         }
  64.     }
  65.  
  66.    static void SendCallback(IAsyncResult iar)
  67.         {
  68.             AsyncState state = (AsyncState)iar.AsyncState;
  69.             try
  70.             {
  71.                 int sent = state.socket.EndSend(iar);
  72.  
  73.                
  74.                 state.socket.BeginReceive(state.buffer, 0, state.buffer.Length, SocketFlags.None, ReceiveCallback, state);
  75.                 
  76.             }
  77.             catch (SocketException e)
  78.             {
  79.                 Console.WriteLine("Error sending to {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  80.                 state.socket.Close();
  81.             }
  82.         }
  83.     
  84.  
  85.     static void ReceiveCallback(IAsyncResult iar)
  86.     {
  87.         AsyncState state = (AsyncState)iar.AsyncState;
  88.         try
  89.         {
  90.             int recv = state.socket.EndReceive(iar);
  91.             if (recv == 0)
  92.             {
  93.                 Console.WriteLine("Client {0} has closed connection", state.socket.RemoteEndPoint);
  94.                 state.socket.Close();
  95.             }
  96.             else
  97.             {
  98.                 string text = Encoding.UTF8.GetString(state.buffer, 0, recv);
  99.                 
  100.  
  101.  
  102.                 Console.WriteLine("{0}: {1}", state.socket.RemoteEndPoint, text);
  103.                 byte[] answer = Encoding.UTF8.GetBytes(text);
  104.                
  105.                 state.socket.BeginSend(answer, 0, answer.Length, SocketFlags.None, SendCallback, state);
  106.                 
  107.             }
  108.         }
  109.         catch (SocketException e)
  110.         {
  111.             Console.WriteLine("Error receiving from {0}: {1}", state.socket.RemoteEndPoint, e.Message);
  112.             state.socket.Close();
  113.         }
  114.     }
  115.  
  116.     struct AsyncState
  117.     {
  118.         public Socket socket;
  119.         public byte[] buffer;
  120.     }
  121. }

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

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

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

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

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

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

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