C# Странное поведение обратных вызовов делегатов

Question

Я написал класс, который должен обеспечивать базовое взаимодействие с сервером NodeJS. Этот класс также включает экземпляр TcpClient и работает асинхронно (такие методы, как BeginRead, BeginWrite, ...), поэтому многие функции принимают обратные вызовы (анонимную функцию с использованием lambda expr.) В качестве аргумента. Проблема начинается в этом сценарии (я пытаюсь проиллюстрировать в коде мира, подобном оригиналу).

this._nodeJS.Send("DATA_TO_SEND", (Response) => { 
    Console.WriteLine(Response); 

    // Section1 
    this._nodeJS.Send("ANOTHER_DATA", (Response1) => { 
     Console.WriteLine(Response1); 
    }); 
}); 

Проблема возникает в section1. Когда он закомментирован, программа ведет себя так, как ожидалось. Ответ получен в Консоли. Когда он не прокомментирован, он начинает вести себя очень странно. Write to Console в разделе 1 не работает (во многих случаях) и, что важно, код ниже Console.WriteLine в этом разделе не выполняется, «поток» просто останавливается прямо перед командой. Я попытался отлаживать его, шаг за шагом, переменные в Разделе 1 правильно установлены, и когда я перехожу к следующей команде, отладка просто прекращается. Что-то не так с этим подходом? Есть ли какие-то вещи, о которых я должен знать?

Для лучшего воображения здесь приведен пример. Я подключаюсь к серверу NodeJS, когда это делается, я отправляю запрос и жду ответа, содержащие данные, которые обрабатываются и снова отправляются на сервер NodeJS в следующем запросе (раздел 1). NodeJS дает мне окончательный ответ и работает программа ... Спасибо за любой совет!

Answer 1

Наконец, я понял, что происходит. Я знаю, я не показываю свой исходный код и вместо этого использовал какой-то псевдокод, но если кому-то интересно узнать, проблема, вероятно, вызывала неправильное преобразование полученных данных. У меня есть буфер размером 1024 и StringBuilder переменная, в которой были добавлены данные. Поэтому, когда я получил данные, преобразовал их так: Encoding.UTF8.GetString(state.Buffer) - это неправильно, вместо этого мне пришлось использовать Encoding.UTF8.GetString(state.Buffer, 0, bytesRead). Я не знаю, как, но эта часть кода вызывала проблемы и останавливала обратный вызов для выполнения.

Answer 2

Не зная подробностей реализации, я подозреваю, что второй звонок _nodeJS.Send(... блокируется ответом от первого вызова «Отправить».

В догадке, ваш код делает что-то вроде этого (сделанный до псевдокода!):

void Send(String data, Action<Response> callback) 
{ 
    _socket.BeginSend(Magic(data), r => { 
     callback.Invoke(r.ResponseData); 
     _socket.EndSend(r.Result); //you cannot call _socket.Send() again until you have done this! 
    }); 
} 

Благодаря порядку операций, он должен делать это:

void Send(String data, Action<Response> callback) 
{ 
    _socket.BeginSend(Magic(data), r => { 
     _socket.EndSend(r.Result); 
     callback.Invoke(r.ResponseData); 
    }); 
}