微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

sql-server – 为什么在这种情况下忽略ConnectTimeout？

分类：MsSQL作者：编程之家
运行此代码时： 
static void Main(string[] args)
{
    sqlConnectionStringBuilder csb = new sqlConnectionStringBuilder();
    csb.DataSource = @"8.8.8.8"; // some inaccessible ip address
    csb.InitialCatalog = "Tempdb";
    csb.IntegratedSecurity = true;
    csb.ConnectTimeout = 1;
    DateTime start = DateTime.Now;
    try
    {
        new sqlConnection(csb.ToString()).open();
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
    }
    finally
    {
        Console.Write(string.Format("{0} seconds",DateTime.Now.Subtract(start).TotalSeconds));
    }
}

我得到这个结果：

A network-related or instance-specific error occurred while establishing a connection to sql Server. The server was not found or was not accessible. Verify that the instance name is correct and that sql Server is configured to allow remote connections. (provider: Named Pipes Provider,error: 40 - Could not open a connection to sql Server)
47.6097605 seconds

我希望ConnectTimeout属性有效.那么为什么在这种情况下会忽略ConnectTimeout属性？ (我也很好奇其他人看到的时间).

更新：我注意到以下额外的行将时间跨度缩短到26秒???

csb.FailoverPartner=@"9.9.9.9";

解决方法

编辑：虽然看起来很奇怪,但我在反编译代码中加入了一个断点并使用 – > VALID< - 服务器名称将超时设置为1,我让断点坐在那里然后继续,然后它按预期给出超时过期异常所以看起来ConnectTimeout仅在能够解析服务器并等待连接时才适用.它不会影响解析要连接的服务器.我认为现在经历的是服务器解析而不是实际的“连接”行为.至少这是我目前的假设. 我用反射器看看封面下发生了什么.也许微软的某些人可以帮助我们,因为我还发现ConnectTimeout似乎对初始连接没有影响. 无论如何在内部建立连接,调用以下方法,按此顺序我想： 
internal DbConnectionInternal CreatePooledConnection(DbConnection owningConnection,DbConnectionPool pool,DbConnectionoptions options)
    {
      DbConnectionPoolGroupProviderInfo providerInfo = pool.PoolGroup.ProviderInfo;
      DbConnectionInternal internal2 = this.CreateConnection(options,providerInfo,pool,owningConnection);
      if (internal2 != null)
      {
        this.PerformanceCounters.HardConnectsPerSecond.Increment();
        internal2.MakePooledConnection(pool);
      }
      Bid.Trace("<prov.DbConnectionFactory.CreatePooledConnection|RES|CPOOL> %d#,Pooled database connection created.\n",this.ObjectID);
      return internal2;
    }

然后：

protected override DbConnectionInternal CreateConnection(DbConnectionoptions options,object poolGroupProviderInfo,DbConnection owningConnection)
    {
      string instanceName;
      sqlConnectionString str = (sqlConnectionString) options;
      if (str.ContextConnection)
      {
        return this.GetContextConnection(str,poolGroupProviderInfo,owningConnection);
      }
      bool redirectedUserInstance = false;
      DbConnectionPoolIdentity current = null;
      if (str.IntegratedSecurity)
      {
        if (pool != null)
        {
          current = pool.Identity;
        }
        else
        {
          current = DbConnectionPoolIdentity.GetCurrent();
        }
      }
      if (!str.UserInstance)
      {
        goto Label_00F1;
      }
      redirectedUserInstance = true;
      if ((pool == null) || ((pool != null) && (pool.Count <= 0)))
      {
        using (sqlInternalConnectionTds tds = null)
        {
          sqlConnectionString connectionoptions = new sqlConnectionString(str,str.DataSource,true,false);
          tds = new sqlInternalConnectionTds(current,connectionoptions,null,"",false);
          instanceName = tds.InstanceName;
          if (!instanceName.StartsWith(@"\\.\",StringComparison.Ordinal))
          {
            throw sql.nonlocalSSEInstance();
          }
          if (pool != null)
          {
            sqlConnectionPoolProviderInfo info2 = (sqlConnectionPoolProviderInfo) pool.ProviderInfo;
            info2.InstanceName = instanceName;
          }
          goto Label_00DB;
        }
      }
      sqlConnectionPoolProviderInfo providerInfo = (sqlConnectionPoolProviderInfo) pool.ProviderInfo;
      instanceName = providerInfo.InstanceName;
    Label_00DB:
      str = new sqlConnectionString(str,instanceName,false,null);
      poolGroupProviderInfo = null;
    Label_00F1:
      return new sqlInternalConnectionTds(current,str,(sqlConnection) owningConnection,redirectedUserInstance);
    }

然后：

internal sqlInternalConnectionTds(DbConnectionPoolIdentity identity,sqlConnectionString connectionoptions,object providerInfo,string newPassword,sqlConnection owningObject,bool redirectedUserInstance) : base(connectionoptions)
    {
      this._instanceName = string.Empty;
      if (connectionoptions.UserInstance && InOutOfProcHelper.InProc)
      {
        throw sql.UserInstanceNotAvailableInProc();
      }
      this._identity = identity;
      this._poolGroupProviderInfo = (sqlConnectionPoolGroupProviderInfo) providerInfo;
      this._fResetConnection = connectionoptions.ConnectionReset;
      if (this._fResetConnection)
      {
        this._originalDatabase = connectionoptions.InitialCatalog;
        this._originalLanguage = connectionoptions.CurrentLanguage;
      }
      RuntimeHelpers.PrepareConstrainedRegions();
      try
      {
        TimeoutTimer timeout = TimeoutTimer.StartSecondsTimeout(connectionoptions.ConnectTimeout);
        this.OpenLoginEnlist(owningObject,timeout,newPassword,redirectedUserInstance);
      }
      catch (OutOfMemoryException)
      {
        base.DoomThisConnection();
        throw;
      }
      catch (StackOverflowException)
      {
        base.DoomThisConnection();
        throw;
      }
      catch (ThreadAbortException)
      {
        base.DoomThisConnection();
        throw;
      }
      if (Bid.AdvancedOn)
      {
        Bid.Trace("<sc.sqlInternalConnectionTds.ctor|ADV> %d#,constructed new TDS internal connection\n",base.ObjectID);
      }
    }

然后,默认情况下(没有故障转移伙伴)：

private void LoginNoFailover(ServerInfo serverInfo,bool redirectedUserInstance,TimeoutTimer timeout)
    {
      if (Bid.AdvancedOn)
      {
        Bid.Trace("<sc.sqlInternalConnectionTds.LoginNoFailover|ADV> %d#,host=%ls\n",base.ObjectID,serverInfo.UserServerName);
      }
      int num = 100;
      this.ResolveExtendedServerName(serverInfo,!redirectedUserInstance,owningObject);
      while (true)
      {
        if (this._parser != null)
        {
          this._parser.disconnect();
        }
        this._parser = new TdsParser(base.Connectionoptions.MARS,base.Connectionoptions.Asynchronous);
        try
        {
          this.AttemptOneLogin(serverInfo,owningObject);
          break;
        }
        catch (sqlException exception)
        {
          if (((this._parser == null) || (this._parser.State != TdsParserState.Closed)) || (this.IsDoNotRetryConnectError(exception.Number) || timeout.IsExpired))
          {
            throw;
          }
          if (timeout.MillisecondsRemaining <= num)
          {
            throw;
          }
        }
        if (this.ServerProvidedFailoverPartner != null)
        {
          this.LoginWithFailover(true,serverInfo,this.ServerProvidedFailoverPartner,redirectedUserInstance,owningObject,timeout);
          return;
        }
        if (Bid.AdvancedOn)
        {
          Bid.Trace("<sc.sqlInternalConnectionTds.LoginNoFailover|ADV> %d#,sleeping %d{milisec}\n",num);
        }
        Thread.Sleep(num);
        num = (num < 500) ? (num * 2) : 0x3e8;
      }
      if (this.PoolGroupProviderInfo != null)
      {
        this.PoolGroupProviderInfo.FailoverCheck(this,this.ServerProvidedFailoverPartner);
      }
      base.CurrentDataSource = serverInfo.UserServerName;
    }

然后：

internal void Connect(ServerInfo serverInfo,sqlInternalConnectionTds connHandler,bool ignoreSniOpenTimeout,long timerExpire,bool encrypt,bool trustServerCert,bool integratedSecurity)
    {
      if (this._state == TdsParserState.Closed)
      {
        this._connHandler = connHandler;
        if (SNILoadHandle.SingletonInstance.SNIStatus != 0)
        {
          this.Errors.Add(this.ProcessSNIError(this._physicalStateObj));
          this._physicalStateObj.dispose();
          this.ThrowExceptionAndWarning();
        }
        if (integratedSecurity)
        {
          this.LoadsspILibrary();
          this._sniServerUserName = new byte[s_maxsspILength];
          Bid.Trace("<sc.TdsParser.Connect|SEC> sspI authentication\n");
        }
        else
        {
          Bid.Trace("<sc.TdsParser.Connect|SEC> sql authentication\n");
        }
        byte[] instanceName = null;
        this._physicalStateObj.CreatePhysicalSNIHandle(serverInfo.ExtendedServerName,ignoreSniOpenTimeout,timerExpire,out instanceName,integratedSecurity,this._sniServerUserName,this._fAsync);
        if (this._physicalStateObj.Status != 0)
        {
          this.Errors.Add(this.ProcessSNIError(this._physicalStateObj));
          this._physicalStateObj.dispose();
          Bid.Trace("<sc.TdsParser.Connect|ERR|SEC> Login failure\n");
          this.ThrowExceptionAndWarning();
        }
        this._server = serverInfo.ResolvedServerName;
        if (connHandler.PoolGroupProviderInfo != null)
        {
          connHandler.PoolGroupProviderInfo.AliasCheck(serverInfo.ResolvedServerName);
        }
        this._state = TdsParserState.OpenNotLoggedIn;
        this._physicalStateObj.SniContext = SniContext.Snix_PreLoginBeforeSuccessfullWrite;
        this._physicalStateObj.TimeoutTime = timerExpire;
        bool marsCapable = false;
        this.SendPreLoginHandshake(instanceName,encrypt);
        this._physicalStateObj.SniContext = SniContext.Snix_PreLogin;
        switch (this.ConsumePreLoginHandshake(encrypt,trustServerCert,out marsCapable))
        {
          case PreLoginHandshakeStatus.SphinxFailure:
            this._fMARS = false;
            this._physicalStateObj._sniPacket = null;
            this._physicalStateObj.SniContext = SniContext.Snix_Connect;
            this._physicalStateObj.CreatePhysicalSNIHandle(serverInfo.ExtendedServerName,this._fAsync);
            if (this._physicalStateObj.Status != 0)
            {
              this.Errors.Add(this.ProcessSNIError(this._physicalStateObj));
              Bid.Trace("<sc.TdsParser.Connect|ERR|SEC> Login failure\n");
              this.ThrowExceptionAndWarning();
            }
            break;

          case PreLoginHandshakeStatus.InstanceFailure:
            this._physicalStateObj.dispose();
            this._physicalStateObj.SniContext = SniContext.Snix_Connect;
            this._physicalStateObj.CreatePhysicalSNIHandle(serverInfo.ExtendedServerName,this._fAsync);
            if (this._physicalStateObj.Status != 0)
            {
              this.Errors.Add(this.ProcessSNIError(this._physicalStateObj));
              Bid.Trace("<sc.TdsParser.Connect|ERR|SEC> Login failure\n");
              this.ThrowExceptionAndWarning();
            }
            this.SendPreLoginHandshake(instanceName,encrypt);
            if (this.ConsumePreLoginHandshake(encrypt,out marsCapable) == PreLoginHandshakeStatus.InstanceFailure)
            {
              Bid.Trace("<sc.TdsParser.Connect|ERR|SEC> Login failure\n");
              throw sql.InstanceFailure();
            }
            break;
        }
        if (this._fMARS && marsCapable)
        {
          this._sessionPool = new TdsParserSessionPool(this);
        }
        else
        {
          this._fMARS = false;
        }
      }
    }

我不确定这一切是如何组合在一起的,但是infiniteTimeout似乎是真的.

不确定这是否有帮助,但我认为值得挖掘

原文地址：https://www.jb51.cc/mssql/76980.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

SQL Server CASE WHEN ... THEN ... ELSE ... END
SELECT a.*,b.dp_name,c.pa_name,fm_name=(CASE WHEN a.fm_no=&#39;LJCG001H&#39; THEN dbo.ELTPNAME(a.fw_nu) ELSE d.fm_name END),e.fw_state_nm,f.fw_rmk_nm
SQL Server 数据表栏位新增
if not exists(select name from syscolumns where name=&#39;tod_no&#39; and id=object_id(&#39;iebo09d12&#39;)) alter table iebo09d12 add tod_no varchar(
SQL Server Left join
select a.*,pano=a.pa_no,b.pa_name,f.dp_name,e.fw_state_nm,g.fa_name from LJSS007H a (nolock) Left join LJPA002H b (nolock) On a.pa_no =b.pa_no Left jo
SQL Server 2019 中设置定时自动重启
要在 SQL Server 2019 中设置定时自动重启，可以使用 Windows 任务计划程序。下面是详细的步骤： 步骤一：创建批处理文件 打开记事本。 输入以下内容： net stop &quot;SQL Server (MSSQLSERVER)&quot; net start &quot;SQ
SQL Server 事务日志已满
您收到的错误消息表明数据库 &#39;EastRiver&#39; 的事务日志已满，导致数据库操作失败。要解决这个问题，可以按照以下步骤操作： 1. 备份事务日志首先，备份事务日志以释放空间： BACKUP LOG [EastRiver] TO DISK = N&#39;C:\Backup\East
SQL SERVER PROFILER
首先我需要查询出需要使用SQL Server Profiler跟踪的数据库标识ID，若不知道怎么查询数据库的标识ID, 打开SQL Server management studio，点击工具。选择SQL Server Profiler。 登录，登录成功后，如果有个默认弹窗，先取消 新建追踪 命名
SQL Server:User, group, or role 'iemis' already exists in the current database.
--最新的解决方法 --先创建用户帐户，不进行授权，然后通过下面的SQL语句将该用户帐户关联至对应的数据库用户。优点是避免了重新授权的操作。 USE tempdbEXEC sp_change_users_login &#39;Update_One&#39;, &#39;iemis&#39;, &#3
SQL Server2019 新增字段并设置默认值
命令： ALTER TABLE 表名 add 列名 数据类型 default 默认值 not null 例如： ALTER TABLE LJEL005H add el_req int default 15 not null
SQL 尚未定义空闲 CPU 条件
     
sql 流水号的递增
declare @i int set @i=340 while @i&lt;415 begin set @i=@iʱ insert into LJWK007H select &#39;2024&#39;,&#39;28&#39;,&#39;9110&#39;,&#39;3PTSD621000000
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot