Блог

На стороне клиента:

Что-то вроде моего кода:

 var socket = Connect();
var reader = new BinaryReader(socket.GetStream());
var writer = new BinaryWriter(socket.GetStream());

// In other thread
writer.Write((byte) 5);
writer.Write("C:\no-file.exe");
var exists = reader.ReadBoolean();
 

Застрял в System.Net.Sockets.Socket.Receive :

 // Decompiled with JetBrains decompiler
UnsafeNclNativeMethods.OSSOCK.recv(this.m_Handle.DangerousGetHandle(), numPtr   offset, size, socketFlags);
 

Я вижу пакет с моим логическим значением в WireShark, но ReadBoolean он все еще выполняется и socket.Available равен нулю.

Прототип сервера:

Минимальный код, который действует как настоящий сервер и вызывает ту же проблему.

 var server = new TcpListener(IPAddress.Any, 2386);
server.Start();

var socket = server.AcceptTcpClient();
socket.NoDelay = true;
Console.WriteLine("Connected: "   socket.Client.RemoteEndPoint);

var stream = socket.GetStream();
var reader = new BinaryReader(stream);
var writer = new BinaryWriter(stream);

while (socket.Connected) {
    while (!stream.DataAvailable);

    if (stream.ReadByte() != 5) {
        break;
    }

    var path = reader.ReadString();
    Console.WriteLine("Requested file "   path);

    var exists = File.Exists(path);
    writer.Write(exists);

    writer.Flush();
    Console.WriteLine(exists ? "File exists" : "Not found");
}

Console.WriteLine("Disconnected: "   socket.Client.RemoteEndPoint);
 

Я обнаружил в своем коде, что у меня есть другой поток, который украл мое логическое значение.

 // TcpClient thread inside Connect method
while (client.Connected) {
    DispatchPacketType(stream.ReadByte());
}

// Thread that calls Connect
reader.ReadBoolean(); // stuck!
 

Редактировать:

Поэтому я создал WaitPacket метод, чтобы исправить эту проблему. Не лучшее решение, но это работает.

Создание специального метода ожидания было совершенно неправильным, потому что это вызвало много проблем. Единственное нормальное решение — рефакторинг проекта.

В том же случае вы можете попробовать:

1. Отказ от цикла while для чтения пакетов ( DispatchPacketType ). Теперь клиент отправляет байт типа пакета, его содержимое и считывает ответ сервера тем же методом (например FetchSomeData ), потому что сервер (в моей ситуации) отвечает последовательно.
2. Избегайте взаимодействия с одним и тем же TCPClient из нескольких потоков или используйте lockers, как указано @500-Внутренняя ошибка сервера в его комментарии. Я переписал много строк кода, и теперь он работает более безопасно и производительно.