http.Post () с сервера gRPC на сервер http возвращает ошибку EOF при настройке docker-compose - PullRequest
Новая
       29

http.Post () с сервера gRPC на сервер http возвращает ошибку EOF при настройке docker-compose

1 голос
/ 24 октября 2019

У меня есть сервер gRPC (server), написанный на Go, с которым общается клиент Python gRPC (client). Сервер иногда отправляет http-запросы на http-сервер Go (sigsvc). Все эти экземпляры запускаются, когда экземпляры докера запускаются через docker-compose, разделяющие одну и ту же сеть докеров.

Это раздел кода на 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="Post 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\\\"}\"

Я пытался воспроизвести эту ошибку на аналогичных, но упрощенных настройках докера, но мне это не удалось.

Я пытаюсь понять следующее:

  1. Если что-то не так с этим кодом, который открывается из-за определенной настройки в Docker?
  2. Или сделатьМне нужно взглянуть на некоторые особенности настройки докера для отладки экземпляров.

1 Ответ

0 голосов
/ 25 октября 2019

Проблема заключалась в том, что код обработчика http регистрировал поле to в этом вызове logrus. 

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.

...