我有这个TcpClient代码,工作正常.它连接到Linux系统上的perl服务器并接收服务器发送给它的任何东西.很好地工作.
public static void Main() { foreach (ProtocolConnection tcpConnection in TcpConnectionsList) { ProtocolConnection connection = tcpConnection; ThreadPool.QueueUserWorkItem(_ => { ThreadTcpClient(connection); ManualResetEventTcp.Set(); }); } ... Some code... } public static void TcpConnect(ProtocolConnection varConnection) { int retryCountSeconds = varConnection.RetryEverySeconds*Program.MilisecondsMultiplier; int count = 0; while (true) { try { using (var client = new TcpClient(varConnection.IpAddress.ToString(), varConnection.Port) { NoDelay = true }) using (var stream = client.GetStream()) { var data = new Byte[256]; while (!Program.PrepareExit) { Int32 bytes = stream.Read(data, 0, data.Length); string varReadData = Encoding.ASCII.GetString(data, 0, bytes).Trim(); if (varReadData != "" && varReadData != "PONG") { VerificationQueue.EnqueueData(varReadData); Logging.AddToLog("[TCP][" + varConnection.Name + "][DATA ARRIVED]" + varReadData); } else { Logging.AddToLog("[TCP]" + varReadData); } } } } catch (Exception e) { if (e.ToString().Contains("No connection could be made because the target machine actively refused it")) { Logging.AddToLog("[TCP][ERROR] Can't connect to server (" + varConnection.Name + ") " + varConnection.IpAddress + ":" + varConnection.Port ); } else { Logging.AddToLog(e.ToString()); } } DateTime startTimeFunction = DateTime.Now; do { Thread.Sleep(1000); } while (((DateTime.Now - startTimeFunction).TotalSeconds < retryCountSeconds)); } }
但是在某些条件下我遇到了一些问题:
我的工作经常连接滴一些空闲时间,所以我在服务器已经实现,所以当它收到PING它PONG回应后连接.我可以用UDP发送PING服务器,它会与PONG回应的TCP但我宁愿内置的方式进入TCP客户端,以便它发送Ping每60秒左右.即使UDP的解决方案是可以接受我有没有超时string varReadData = Encoding.ASCII.GetString(data, 0, bytes).Trim();
,所以当PONG没有到达我的客户甚至不反正注意到它.它只是在等待...这让我...
我的另一个问题是,在某些时候,string varReadData = Encoding.ASCII.GetString(data, 0, bytes).Trim();
这一直在等待数据.当服务器崩溃或断开我的客户端时,我甚至都没有注意到.我希望服务器有某种timeout
或检查连接是否有效.如果它不活动,它应该尝试重新连接.
修复此TcpClient最简单的方法是什么?如何实现二者双向通信确保如果服务器断开连接,我的还是我的网络断开连接的客户端会注意到这一点,并重新建立连接?
这不是Encoding.ASCII.GetString(data, 0, bytes).Trim();
永远的阻塞,它是 stream.Read()
如果你正在阅读,你不能轻易区分服务器(或中间的任何NAT网关)丢弃你的连接,以及服务器根本没有任何东西发送你的情况.如果TCP FIN/RST数据包在发生故障时未到达您的客户端,或者NAT网关静默丢弃您的连接,则至少应该这样做.
你可以做什么;
设置发送/ 接收时间,并在发生超时时ping服务器,或通过TCP连接实现自己的心跳消息.如果您在合理的时间内没有收到心跳,请重新建立或采取其他措施.
设置TCP keepalive选项,并依赖它来告诉您服务器是否已经消失.见代码在这里.
最后一点将告诉你tcp连接是否失败,它不会告诉你服务器是否有一些失败 - 例如,如果你CTRL + Z你的perl服务器,它只会坐在那里没有做任何事情,因为tcp窗口关闭,因此,如果需要,您可能需要实施自己的热量消息来覆盖这种情况.