无穷大而循环只得到一个结果

Question

我正在编写一个P2P程序，该程序必须在它的多个实例之间发送和接收数据。 当我创建单独的线程来侦听无限循环中的传入数据时，我遇到了一个问题，但我只收到第一条消息，然后没有其他消息。 我做错了什么？ 法典：

Task t = new Task(() => {
try {
server = new TcpListener(IPAddress.Parse(STD_IP), STD_PORT);
server.Start();
odjemalec = server.AcceptTcpClient();
nwStream = odjemalec.GetStream();
}
catch (Exception ex) {
Console.WriteLine("Errorn" + ex.Message + "n" + ex.StackTrace);
}
while(true) {
listen();
}

});
t.Start();

Answer 1

如果你想使用任务(我强烈推荐这种方法(，你需要一个侦听器任务和一个TcpClient Responder 任务为每个传入连接。

下面是一个基本的 TCP 侦听器任务

static async Task StartTcpServerAsync()
{
var tcpListener = new TcpListener(new IPEndPoint(IPAddress.Any, 9999));
tcpListener.Start();
while (true)
{
var tcpClient = await tcpListener.AcceptTcpClientAsync();
_ = StartTcpClientAsync(tcpClient);
}
}

我们启动TcpListener并开始侦听连接。 每次获得连接时，我们都会将关联的TcpClient交给新任务。

这是一个服务器端TCP客户端任务- 它位于服务器上，由侦听器启动

static async Task StartTcpClientAsync(TcpClient tcpClient)
{
Console.WriteLine($"Connection from: [{tcpClient.Client.RemoteEndPoint}]");
var stream = tcpClient.GetStream();
var buffer = new byte[1024];
while (true)
{
int x = await stream.ReadAsync(buffer, 0, 1024);
Console.WriteLine($"[{tcpClient.Client.RemoteEndPoint}] _ " +
$"read {x} bytes {System.Text.Encoding.UTF8.GetString(buffer)}");
}
}

在这个例子中，我们只写出收到的字节。

最后

为了完整起见，这里有一个 Main 和一个 TCPSender - 通常发送者将在完全不同的计算机上，但为了显示任务的强大功能，我们将从相同的进程运行它。

static async Task Main(string[] args)
{
_ = StartTcpServerAsync();
await Task.Delay(2000);
await RunSenderAsync();
}
static async Task RunSenderAsync()
{
var tcpClient = new TcpClient("127.0.0.1", 9999);
var s = tcpClient.GetStream();
tcpClient.NoDelay = true;
for (var i = 65; i < 91; i++)
{
s.Write(BitConverter.GetBytes(i), 0, 1);
await Task.Delay(1000);
}
}

我发现很多人感到困惑的一个地方是，您收到的每个连接都需要服务器上的TcpClient。