89 lines
2.9 KiB
C#
89 lines
2.9 KiB
C#
using System;
|
|
using System.Linq;
|
|
using System.Net.Sockets;
|
|
using System.Text;
|
|
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];
|
|
private int totalBufferReceived = 0;
|
|
|
|
|
|
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)
|
|
{
|
|
int receivedBytes = this.stream.EndRead(ar);
|
|
|
|
if (totalBufferReceived + receivedBytes > 1024)
|
|
{
|
|
throw new OutOfMemoryException("buffer too small");
|
|
}
|
|
Array.Copy(buffer, 0, totalBuffer, totalBufferReceived, receivedBytes);
|
|
totalBufferReceived += receivedBytes;
|
|
|
|
int expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
|
while (totalBufferReceived >= expectedMessageLength)
|
|
{
|
|
//volledig packet binnen
|
|
byte[] messageBytes = new byte[expectedMessageLength];
|
|
Array.Copy(totalBuffer, 0, messageBytes, 0, expectedMessageLength);
|
|
HandleData(messageBytes);
|
|
|
|
Array.Copy(totalBuffer, expectedMessageLength, totalBuffer, 0, (totalBufferReceived - expectedMessageLength)); //maybe unsafe idk
|
|
|
|
totalBufferReceived -= expectedMessageLength;
|
|
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
|
if (expectedMessageLength <= 5)
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
|
|
this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null);
|
|
|
|
}
|
|
/// <summary>
|
|
/// TODO
|
|
/// </summary>
|
|
/// <param name="message">including message length and messageId (can be changed)</param>
|
|
private void HandleData(byte[] message)
|
|
{
|
|
//Console.WriteLine("Data " + packet);
|
|
//JsonConvert.DeserializeObject(packet);
|
|
//0x01 Json
|
|
//0x01 Raw data
|
|
|
|
if (message[4] == 0x01)
|
|
{
|
|
byte[] jsonArray = new byte[message.Length - 5];
|
|
Array.Copy(message, 5, jsonArray, 0, message.Length - 5);
|
|
dynamic json = JsonConvert.DeserializeObject(Encoding.ASCII.GetString(jsonArray));
|
|
Console.WriteLine(json);
|
|
|
|
}
|
|
else if (message[4] == 0x02)
|
|
{
|
|
|
|
}
|
|
|
|
|
|
}
|
|
}
|
|
}
|