当前我尝试向网络流读写Async。我的软件是客户端的一部分，服务器可以自己发送信息或响应我发送给他的命令。
所以我需要一个
- 一直读取(以防服务器发送状态信息(
- 当我想发送命令时停止读取(命令可以是具有多字节写入和读取操作的数据序列(
所以我认为创建一个信号量和一个后台任务是一个很好的方法，它处理服务器发送的消息，如果我想发送命令，我会阻止信号量，并可以完全访问套接字的读/写操作。
以下是我目前的工作。
private TcpClient _tcpClient = new TcpClient();
protected SemaphoreSlim ClientSemaphore { get; } = new SemaphoreSlim(1, 1);
public async Task ConnectAsync()
{
if (_tcpClient.Connected)
{
await DisconnectAsync();
}
await _tcpClient.ConnectAsync(Hostname, RemotePort);
//here the background Task is started
_ = AutoReceiveMessages();
}
private async Task AutoReceiveMessages()
{
while (_tcpClient.Connected)
{
//enter and lock semaphore
await ClientSemaphore.WaitAsync();
try
{
//read from socket until timeout (ms)
var msg = await ReadFromSocket(2000);
foreach (var cmd in SplitMessageInTelegrams(msg))
{
Console.WriteLine("MESSAGE --> " + cmd);
}
}
catch (Exception ex)
{
}
finally
{
//release semaphore
ClientSemaphore.Release();
}
}
}
private async Task<string> ReadFromSocket(double timeout = 0)
{
var buf = new byte[4096];
var stream = _tcpClient.GetStream();
//read from stream or timeout
var amountReadTask = stream.ReadAsync(buf, 0, buf.Length);
var timeoutTask = Task.Delay(TimeSpan.FromMilliseconds(timeout));
await Task.WhenAny(timeoutTask, amountReadTask)
.ConfigureAwait(false);
//timeout
if (!amountReadTask.IsCompleted)
{
throw new TimeoutException("Timeout");
}
//no timeout
return Encoding.ASCII.GetString(buf, 0, amountReadTask.Result);
}
但这并没有像我预期的那样奏效。。。我使用这种方法向服务器发送消息，在WireShark中，我看到服务器返回相同的消息
protected async Task SendTelegramAsync(ITelegram telegram)
{
await ClientSemaphore.WaitAsync();
try
{
_ = telegram ?? throw new ArgumentException($"{nameof(telegram)}");
if (!_tcpClient.Connected) throw new InvalidOperationException("Socket not connected!");
var buf = new byte[4096];
var stream = _tcpClient.GetStream();
var msg = Encoding.ASCII.GetBytes("x02" + telegram.GetCommandMessage() + "x03");
Console.WriteLine("WRITE --> " + msg);
await stream.WriteAsync(msg, 0, msg.Length);
//comment AutoReceiveMessage and remove comment from this
//and I get responses from the server
//var test = await ReadFromSocket(2000);
}
finally
{
ClientSemaphore.Release();
}
}
我知道在这种情况下，我不需要信号量，但后来我想创建序列，这样一个命令由多字节写入和读取组成，只要执行了该命令，我就不想使用AutoReceiveMessages方法。
现在的问题是
- 如果我这样使用它，我永远不会得到响应ReadFromSocket方法总是得到超时，即使wireshark告诉我服务器已经响应
- 但更好的是，如果我禁用AutoReceiveMessages(只是注释_=AutoReceiveMessages(((并直接在SendTelegramAsync((中使用ReadFromSocket，一切都会按预期工作
所以我认为问题与后台任务和ReadAsync有关，但我无法解决。。。
明白了！
stream.DataAvailable是您的朋友(或我的朋友：(。
如果我在ReadAsync之前检查DataIsAvailable，那么我就没有问题了。
if (_tcpClient.GetStream().DataAvailable)
var msg = await ReadFromSocket(DEFAULT_TIMEOUT);