Estou desenvolvendo uma Dll C# que trabalha com Socket TCP Asynchronous para o desenvolvimento de algumas ferramentas que estou trabalhando, o problema aparece quando o cliente recebe muitas mensagem em um curto período, neste caso as mensagens são em JSON, sendo assim, o servidor me envia somente uma mensagem JSON por ver, mas o cliente recebe 2 ou 3 juntas, causando uma Exception ao tentar transformar o JSON em Objeto. Sendo que, se eu mandar o servidor mandar uma mensagem a cada segundo, tudo ocorre bem, mas meu sistema depende de mais mensagens por segundo.
OBS: O Servidor é feito em C++ com QT.
CLIENTE:
public void connect(Action<Message> callback, string ip, int porta){
this.callback = callback;
this.ip = ip;
this.porta = porta;
try{
this.ipadress = new IPEndPoint (IPAddress.Parse (this.ip), this.porta);
this.client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
this.client.BeginConnect (this.ipadress, new AsyncCallback (ConectCallback), null);
}catch(Exception ex){
this.conected = false;
lastExeception = ex;
}
}
void ReceiveCallback(IAsyncResult IA){
String json_string = "";
if (isConnected ()) {
try {
int received = client.EndReceive (IA);
Array.Resize (ref _buffer, received);
json_string = Encoding.UTF8.GetString (_buffer);
Console.WriteLine(json_string);
Message msg = JsonConvert.DeserializeObject<Message> (json_string);
callback_sender (msg);
Array.Resize (ref _buffer, client.ReceiveBufferSize);
if (isConnected ())
client.BeginReceive (_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback (ReceiveCallback), null);
} catch (JsonException erro) {
lastExeception = erro;
} catch (Exception ex) {
lastExeception = ex;
}
}
}
SERVIDOR:
void MyClient::readyRead() {
qDebug() << "MyClient::readyRead()";
QString msg = socket->readAll();
qDebug() << msg;
socket->write(msg.toUtf8());
}