66 lines
1.8 KiB
C#
66 lines
1.8 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Net;
|
|
using System.Net.Sockets;
|
|
using System.Text;
|
|
using Newtonsoft;
|
|
using Newtonsoft.Json;
|
|
|
|
namespace Server
|
|
{
|
|
class Client
|
|
{
|
|
private Communication communication;
|
|
private TcpClient tcpClient;
|
|
private NetworkStream stream;
|
|
private byte[] buffer = new byte[1024];
|
|
private byte[] totalBuffer = new byte[1024];
|
|
|
|
public string Username { get; set; }
|
|
|
|
public Client(Communication communication, TcpClient tcpClient)
|
|
{
|
|
this.communication = communication;
|
|
this.tcpClient = tcpClient;
|
|
this.stream = this.tcpClient.GetStream();
|
|
stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
|
|
}
|
|
|
|
private void OnRead(IAsyncResult ar)
|
|
{
|
|
try
|
|
{
|
|
int receivedBytes = stream.EndRead(ar);
|
|
|
|
}
|
|
catch (IOException)
|
|
{
|
|
communication.Disconnect(this);
|
|
return;
|
|
}
|
|
|
|
int counter = 0;
|
|
|
|
while (buffer.Length > counter)
|
|
{
|
|
byte[] lenghtBytes = new byte[4];
|
|
Array.Copy(buffer, counter, lenghtBytes, 0, 4);
|
|
int length = Convert.ToInt32(lenghtBytes);
|
|
byte[] packet = new byte[length];
|
|
Array.Copy(buffer, counter + 4, packet, 0, length-4);
|
|
HandleData(Encoding.Default.GetString(packet));
|
|
counter += length;
|
|
}
|
|
|
|
stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
|
|
}
|
|
|
|
private void HandleData(string packet)
|
|
{
|
|
Console.WriteLine(packet);
|
|
JsonConvert.DeserializeObject(packet);
|
|
}
|
|
}
|
|
}
|