TCP 侦听器在负载平衡器后面时不起作用

Question

我在 Windows 服务中有一个 TCP 侦听器，它侦听特定端口上的任何传入 TCP 请求并处理消息。直接访问时效果很好。但是一旦它在负载均衡器后面运行（在 Intranet 中），那么它就不会接受任何请求。我收到诸如“无法连接到远程服务器”或“操作超时”之类的错误。一段时间后，服务因“内存不足”异常而终止。请让我知道这可能是什么原因。粘贴下面的代码。我什至也尝试过异步模式（以避免显式线程启动）。但这没有帮助。

public class SampleListener: IDisposable
{
    public delegate void JobRecieved(HttpMessage msg);
    public event JobRecieved OnJobRecieved;

    #region Property

    private TcpListener _tcpListener;
    private Thread _listenerThread;

    public int Port { get; private set; }

    public string Url
    {
        get
        {
            return new UriBuilder { Scheme = "http", Port = Port, Host = Dns.GetHostName() }.ToString();
        }
    }

    #endregion

    public SampleListener(int port)
    {
        Port = port;
    }

    ~SampleListener()
    {
        DisposeImpl(false);
    }

    public void Start()
    {
        _tcpListener = new TcpListener(IPAddress.Any, Port);
        _tcpListener.Start();

        _listenerThread = new Thread(ListenCallback);
        _listenerThread.Start();
    }

    public void ListenCallback()
    {
        try
        {
            while (true)
            {
                using (TcpClient client = _tcpListener.AcceptTcpClient())
                using (var clientStream = client.GetStream())
                {
                    var msg = new HttpMessage();
                    msg.Receive(clientStream);
                    SendOKResponse(client, "");
                    OnJobRecieved(msg);
                    client.Close();
                }
            }
        }
        catch (System.Net.Sockets.SocketException e)
        {
            // Expected, TcpClient.Stop called                
        }
        catch (System.Threading.ThreadAbortException)
        {
            // Expected, thread going away
        }
        catch (System.IO.IOException)
        {
            // Expected, shutdown while reading
        }
    }

    private void SendOKResponse(TcpClient tcpClient, String responseBody)
    {
        var response = new HttpMessage
        {
            Status = "200",
            Reason = "OK",
            Version = "HTTP/1.1"
        };
        response.Send(tcpClient.GetStream(), responseBody);
    }

    public void Shutdown()
    {
        lock (this)
        {
            if (_listenerThread != null)
            {
                _listenerThread.Abort();
                _listenerThread = null;
            }

            if (_tcpListener != null)
            {
                _tcpListener.Stop();
                _tcpListener.Server.Close();
                _tcpListener = null;
            }                
        }
    }

    #region IDisposable Members

    private void DisposeImpl(Boolean bDisposing)
    {
        lock (this)
        {
            Shutdown();
        }
    }

    public void Dispose()
    {
        GC.SuppressFinalize(this);
        DisposeImpl(true);
    }

    #endregion

}

Answer 1

这是因为 Windows 上的 NLB 默认情况下需要您的应用程序是一个集群应用程序。如果不是（这是您的情况），您必须使用粘性会话。显然您的 NLB 没有使用粘性会话，因此请求可能会在每次传递时传送到不同的服务器。这就是你得到这些异常的原因（看看this）。

这发生在我自己的一个项目中（高性能 TCP 服务器 - 与您正在做的相反）。