У меня есть инфраструктура клиент / сервер. В настоящее время они используют TcpClient и TcpListener для отправки данных приема между всеми клиентами и сервером.
Что я сейчас делаю, так это когда данные получены (в собственном потоке), они помещаются в очередь для обработки другим потоком, чтобы освободить сокет, чтобы он был готов и открылся для приема новых данных.
// Enter the listening loop.
while (true)
{
Debug.WriteLine("Waiting for a connection... ");
// Perform a blocking call to accept requests.
using (client = server.AcceptTcpClient())
{
data = new List<byte>();
// Get a stream object for reading and writing
using (NetworkStream stream = client.GetStream())
{
// Loop to receive all the data sent by the client.
int length;
while ((length = stream.Read(bytes, 0, bytes.Length)) != 0)
{
var copy = new byte[length];
Array.Copy(bytes, 0, copy, 0, length);
data.AddRange(copy);
}
}
}
receivedQueue.Add(data);
}
Однако я хотел чтобы узнать, есть ли лучший способ сделать это. Например, если есть 10 клиентов, и все они хотят отправлять данные на сервер одновременно, один из них пройдет, а все остальные потерпят неудачу. Или если один клиент имеет медленное соединение и перегружает сокет, все остальные коммуникации будут остановлены.
Нет ли способа получить данные от всех клиентов одновременно и добавить полученные данные в очередь для обработки после завершения загрузки ?