Grpc-10-连接

客户端

1. 构建链接阶段设置超时时间

   构建链接阶段有单独的超时控制，也就是链接的超时控制与发送请求的超时控制是分开的

   conn, err := grpc.DialContext(context.Background(), *addr, grpc.WithTransportCredentials(insecure.NewCredentials()))
   if err != nil {
     log.Fatalf("did not connect: %v", err)
   }
   defer conn.Close()

   在构建链接的过程中，通过强制等待

   func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error) {
     //...
     defer func() { //等待最后的结果，要么ctx.Done()结束
        select {
        case <-ctx.Done():
           switch {
           case ctx.Err() == err:	//失败错误
              conn = nil
           case err == nil || !cc.dopts.returnLastError:	//将服务端的错误与错误信息一起返回给客户端而不是仅仅一个错误码
              conn, err = nil, ctx.Err()
           default:
              conn, err = nil, fmt.Errorf("%v: %v", ctx.Err(), err)	//返回其他错误
           }
        default:
        }
     }()
     //...
     if cc.dopts.block {	//如果是阻塞模式
   		for {
   			cc.Connect()
   			s := cc.GetState()
   			if s == connectivity.Ready {	//连接状态，健康检查的时候也会更新
   				break
   			} else if cc.dopts.copts.FailOnNonTempDialError && s == connectivity.TransientFailure {
   				if err = cc.connectionError(); err != nil {
   					terr, ok := err.(interface {
   						Temporary() bool
   					})
   					if ok && !terr.Temporary() {
   						return nil, err
   					}
   				}
   			}
   			if !cc.WaitForStateChange(ctx, s) {	//为什么是等待状态变化，因为构建链接的时候是每个都使用一个协程进行建立连接
   				// ctx got timeout or canceled.
   				if err = cc.connectionError(); err != nil && cc.dopts.returnLastError {
   					return nil, err
   				}
   				return nil, ctx.Err()
   			}
   		}
   	}
     return cc, nil
   }

   等待连接的状态其实就是等待结果后者超时的过程，通过隧道通知

   func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
      ch := cc.csMgr.getNotifyChan()
      if cc.csMgr.getState() != sourceState {
         return true
      }
      select {
      case <-ctx.Done():
         return false
      case <-ch:
         return true
      }
   }

2. Dfasdf