从 gRPC 服务器到 http 服务器的 http.Post() 在 docker-compose 设置上返回 EOF 错误

一分耕耘，一分收获！既然打开了这篇文章《从 gRPC 服务器到 http 服务器的 http.Post() 在 docker-compose 设置上返回 EOF 错误》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我有一个用 go 编写的 grpc 服务器 (server)，python grpc 客户端 (client) 与之通信。服务器偶尔会向基于 go 的 http 服务器 (sigsvc) 发送 http post 请求。所有这些实例都作为通过 docker-compose 启动的 docker 实例运行，共享相同的 docker 网络。

这是 server 上创建和发送 http 请求的代码部分：

b := new(bytes.buffer)
txbytes, err := json.marshal(tx)
if err != nil {
    log.witherror(err).error("failed to marshal transaction")
    return nil, err
}
b.write(txbytes)

resp, err := http.post(sigsvc.signerurl, "application/json; charset=utf-8", b)
if err != nil {
    log.witherror(err).errorf("error signing transaction with signer %s", sigsvc.signerurl)
    return nil, err
}
defer resp.body.close()

var signedtx types.transaction
err = json.newdecoder(resp.body).decode(&signedtx)
if err != nil {
    log.witherror(err).error("couldn't decode signed transaction")
    return nil, err
}

sigsvc.signerurl 映射到类似 http://signer:6666/sign 的内容，它是处理请求的 http 签名者服务上的端点。 signer 是指 docker-compose.yml 规范中列出的服务名称。

这是处理程序在 sigsvc 上的样子：

func (sv *signersv) handlesigntx() http.handlerfunc {
    return func(w http.responsewriter, r *http.request) {
        log.info("request received to sign transaction")
        dump, err := httputil.dumprequest(r, true)
        if err != nil {
            http.error(w, fmt.sprint(err), http.statusinternalservererror)
        }
        log.debugf("%q", dump)

        if r.body == nil {
            log.error("request body missing")
            http.error(w, "please send a request body", 400)
            return
        }

        log.debugf("request body: %v", r.body)

        var tx types.transaction
        err = json.newdecoder(r.body).decode(&tx)
        if err != nil {
            log.witherror(err).error("failed to unmarshal transaction")
            http.error(w, err.error(), 400)
            return
        }

        log.withfields(log.fields{
            "txhash":   tx.hash().hex(),
            "nonce":    tx.nonce(),
            "to":       tx.to().hex(),
            "data":     tx.data(),
            "gaslimit": tx.gas(),
            "gasprice": tx.gasprice(),
            "value":    tx.value(),
        }).debug("decoded transaction from request body")

调试日志已成功转储请求和请求正文。但是，显然，将请求正文解码为 transaction 类型的行永远不会执行，因为没有记录错误或解码的事务日志。

在 server 上，我不断收到以下错误： error="发布http://signer:6666/sign:eof"

这是在 sigsvc 上记录请求的方式：

msg="\"POST /sign HTTP/1.1\\r\\nHost: signer:6666\\r\\nConnection: close\\r\\nAccept-Encoding: gzip\\r\\nConnection: close\\r\\nContent-Length: 10708\\r\\nUser-Agent: Go-http-client/1.1\\r\\n\\r\\n{\\\"nonce\\\":\\\"0x0\\\",\\\"gasPrice\\\":\\\"0x2540be400\\\",\\\"gas\\\":\\\"0x15c285\\\",\\\"to\\\":null,\\\"value\\\":\\\"0x0\\\",\\\"input\\\":\\\"0x6080604055",\\\"v\\\":\\\"0x0\\\",\\\"r\\\":\\\"0x0\\\",\\\"s\\\":\\\"0x0\\\",\\\"hash\\\":\\\"0xab55920fb3d490fc55ccd76a29dfb380f4f8a9e5d0bda4155a3b114fca26da0a\\\"}\"

我尝试在类似但简化的 docker 设置上重现此错误，但失败了。

我试图理解以下内容：

1. 如果这段代码有任何问题而被暴露 docker 上的特定设置？
2. 或者，我是否需要查看一些 docker 设置细节来调试实例。

解决方案

问题在于 http 处理程序代码在此 logrus 调用中记录 to 字段的方式。

log.WithFields(log.Fields{
    "txhash":   tx.Hash().Hex(),
    "nonce":    tx.Nonce(),
    "to":       tx.To().Hex(),
    "data":     tx.Data(),
    "gasLimit": tx.Gas(),
    "gasPrice": tx.GasPrice(),
    "value":    tx.Value(),
}).Debug("Decoded transaction from request body")

在特定情况下，tx.to() 调用返回 nil，这意味着调用 tx.to().hex() 会因尝试对 nil 指针进行方法调用而导致错误。从表面上看，人们预计 log.withfields() 调用会出错或出现恐慌，但处理程序会默默地关闭与客户端的连接以获得 eof 响应。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《从 gRPC 服务器到 http 服务器的 http.Post() 在 docker-compose 设置上返回 EOF 错误》文章吧，也可关注golang学习网公众号了解相关技术文章。