美文网首页
thrift client 报 EOF 的错误

thrift client 报 EOF 的错误

作者: zippera | 来源:发表于2018-01-09 19:13 被阅读661次

    最近同事有个变更上线,暂且称为服务B,它的上游是服务A。服务B是thrift server,上线后,服务A报EOF错误。据此怀疑以下几点:

    1. C/S端协议不一致。CR 代码,发现 S 端协议中增加了新的 required 字段。改为 optional 重新上线,还是有 EOF 错误。如果协议错误,应该每个请求都失败,但发现只是部分失败,应该还有其他问题。(注:有文章说协议不一致会出现EOF,不过我用go测试了下,如果S端req增加 required 字段,s端会提示error processing request: Not enought frame size,s端的新字段是个随机值,c端一切正常。如果C端req增加 required 字段,S端收不到请求,C端提示 read io timeout)
    2. S 端关闭连接后,C 端继续 read,就会读到 EOF。服务B在什么情况下会主动关闭连接呢,检查了超时,没问题。检查了进程启动时间,并没有挂掉重启。结合 thrift 源码,剩下一种可能,就是 B 在处理某个请求的时候 panic 了,但整个 server 并未 panic,这样才会出现部分失败。检查 B 的handler,看到一开始便有一个 defer func,主要是为了打印请求和响应,并接住该协程栈下层的 panic。但是写法有点问题,大致如下:
    defer func() {
            breq, _ := json.Marshal(*request)
            bresp, _ := json.Marshal(*response)
            logger.Info("inout||req=%+v||resp=%+v||trace_id=%v", string(req), string(resp), traceId)
            if err := recover(); err != nil {
                // log
            }
    }()
    

    看日志,并未发现有panic记录。这里看到有指针取对象的操作,这个操作有风险,就是指针为空时就会panic。request可以保证不空,但response是后面的操作生成的,是否为空不敢保证。因此怀疑点落在这里。加日志上线,发现确有为空的情况。其实 go 里面的 Marshal 参数用指针就可以,没必要取对象,去掉取对象操作再上线,问题得到了修复。

    这里的panic,是怎么导致连接关闭但server保活的呢?看一下这几段代码:

    Server 的 AcceptLoop中,会为新建连接单独开协程处理

    go func() {
            if err := p.processRequests(client); err != nil {
                log.Println("error processing request:", err)
            }
    }()
    

    processRequests 函数中,最终调用 handler 函数。后者 panic,会往上抛,直到这里的 Process()。此处遇到panic会return,在此之前先依次退出defer栈函数并执行。可以看到,这里实际是把 transport 也就是 socket 关闭了。由于栈顶有 recover 接住 panic,因此 server 不会挂掉,只会影响当前的连接。服务A就会收到 EOF。

    defer func() {
            if e := recover(); e != nil {
                log.Printf("panic in processor: %s: %s", e, debug.Stack())
            }
    }()
    if inputTransport != nil {
        defer inputTransport.Close()
    }
    if outputTransport != nil {
        defer outputTransport.Close()
    }
    for {
        ok, err := processor.Process(inputProtocol, outputProtocol)
        //...
    }
    

    此外用 go 中的 tcp 编程也很好验证, server 收到请求后直接 conn.Close(),client 就会读到 EOF了,在此不赘述。

    相关文章

      网友评论

          本文标题:thrift client 报 EOF 的错误

          本文链接:https://www.haomeiwen.com/subject/cpzvnxtx.html