Bonjour à toutes et tous,
Je travaille actuellement sur les sockets avec Windows 10 en utilisant donc la classe StreamSocket.
J'arrive donc à me connecter puis envoyer des données, et même recevoir une réponse.
Mon problème est lorsque je veux répéter cette action plusieurs fois, au bout d'un moment un Stream se retrouve fermé et cela ne fonctionne plus. Je vous mets mon code :
Le seveur :
private async void _listener_ConnectionReceived(StreamSocketListener sender, StreamSocketListenerConnectionReceivedEventArgs args)
{
DataReader reader = new DataReader(args.Socket.InputStream);
DataWriter writer = new DataWriter(args.Socket.OutputStream);
try
{
while (_run)
{
// Read first 4 bytes (length of the subsequent string).
uint sizeFieldCount = await reader.LoadAsync(sizeof(uint));
if (sizeFieldCount != sizeof(uint))
{
// The underlying socket was closed before we were able to read the whole data.
return;
}
// Read the string.
uint stringLength = reader.ReadUInt32();
uint actualStringLength = await reader.LoadAsync(stringLength);
if (stringLength != actualStringLength)
{
// The underlying socket was closed before we were able to read the whole data.
return;
}
string data = reader.ReadString(actualStringLength);
ParseData(data);
writer.WriteUInt32(writer.MeasureString("received!"));
writer.WriteString("received!");
try
{
busy = true;
await writer.StoreAsync();
}
catch (Exception e)
{
Log(e.Message);
}
}
//reader.DetachStream();
//reader.Dispose();
//writer.DetachStream();
//writer.Dispose();
}
catch (Exception exception)
{
// If this is an unknown status it means that the error is fatal and retry will likely fail.
if (SocketError.GetStatus(exception.HResult) == SocketErrorStatus.Unknown)
{
Log("Unknown socket error: " + exception.Message);
}
else
{
Log(exception.Message);
}
}
}
Et le client :
public async Task<string> Send(string data)
{
DataWriter writer = new DataWriter(_socket.OutputStream);
writer.WriteUInt32(writer.MeasureString(data));
writer.WriteString(data);
DataReader reader = new DataReader(_socket.InputStream);
string response = null;
try
{
await writer.StoreAsync();
Log("datas sent: " + data);
uint sizeFieldCount = await reader.LoadAsync(sizeof(uint));
if (sizeFieldCount != sizeof(uint))
{
// The underlying socket was closed before we were able to read the whole data.
return null;
}
// Read the string.
uint stringLength = reader.ReadUInt32();
uint actualStringLength = await reader.LoadAsync(stringLength);
if (stringLength != actualStringLength)
{
// The underlying socket was closed before we were able to read the whole data.
return null;
}
string datar = reader.ReadString(actualStringLength);
Log("response: " + datar);
response = datar;
}
catch (Exception e)
{
Log("send failed with message: " + e.Message);
}
return response;
}
Merci,
Samuel
