我的异步连接代码非常简陋,如下所示:
private Socket _socket;
public void Connect(IPEndPoint remoteEndPoint, bool persistentConnection)
{
_logger.Trace("Attempting To Connect To " + remoteEndPoint.Address);
_remoteEndPoint = remoteEndPoint;
_persistentConnection = persistentConnection;
_socket = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
_socket.BeginConnect(_remoteEndPoint, ConnectCallback, null);
}
该Connect()
方法伴随着ConnectCallback()
我将很快描述的问题发生的地方:
private void ConnectCallback(IAsyncResult asyncResult)
{
try
{
_socket.EndConnect(asyncResult);
_logger.Trace("Successfully Connected To " + _remoteEndPoint.Address);
}
catch (SocketException)
{
_logger.Trace("Failed To Connect To " + _remoteEndPoint.Address);
if (_persistentConnection)
{
Thread.Sleep(TimeSpan.FromSeconds(3));
Connect(_remoteEndPoint, true);
return;
}
}
_socketWriter.AssignSocket(_socket);
_socket.BeginReceive(..);
}
我的网络代码封装在一个程序集中。今天我决定从另一个应用程序中引用程序集,发现该ConnectCallback
方法的行为非常奇怪。
我在服务器应用程序未运行Connect()
时进行调用。这意味着连接在物理上不可能成功。因为远程端点不可用,我希望抛出异常。相反,它似乎成功了,因为即使套接字没有真正连接,我的代码也会继续调用,当然,由于套接字没有连接,所以会引发异常。EndConnect
EndConnect
_socket.BeginReceive
特别奇怪的是,如果我在左大括号上放置一个断点try
并单步执行回调代码,则会引发并处理异常。
这发生在本地主机上。
为什么我会遇到这种行为,我如何确保EndConnect
抛出SocketException
的连接无法始终如一地建立?