获取 Elasticsearch 响应

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《获取 Elasticsearch 响应》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我正在使用 gin 框架构建一个 api 以从 elastic 获取数据。 问题是，当我运行应用程序时，我在第一个请求中成功获得响应，但此后在任何后续请求中我都会收到错误：

error parsing the response body: eof

弹性配置：

var cfg = elasticsearch.config{
    password:  getconnectconfig().espassword,
    username:  getconnectconfig().esusername,
    addresses: getconnectconfig().eshost,
    logger: &estransport.colorlogger{
        output:             os.stdout,
    }

我的请求处理函数如下所示：

func search() gin.handlerfunc {

    client, err := elasticsearch.newclient(cfg)
    if err != nil {
        log.fatalf("elastic configuration failed %s", err)
    }

    res, err := client.search(
        client.search.withindex(index_name),
        client.search.withsize(10),
        client.search.withpretty(),
        )
    if err != nil {
        log.fatalf("elastic failed to respond %s", err)
    }

    return func(c *gin.context) {
        r := map[string]interface{}{}
        if err := json.newdecoder(res.body).decode(&r); err != nil {
            c.json(http.statusinternalservererror, gin.h{"error": err})
            log.fatalf("error parsing the response body: %s", err)            // error 
        } else {
            for _, hit := range r["hits"].(map[string]interface{})["hits"].([]interface{}) {
                log.printf(" * id=%s, %s", hit.(map[string]interface{})["_id"], hit.(map[string]interface{})["_source"])
            }
            c.json(http.statusok, "success")
        }
    }
}

正如我所说，每次运行应用程序时，我只能在第一个请求中获得响应。 我不确定这里的错误原因是什么。

我还尝试通过添加以下内容在搜索后关闭响应正文：

defer res.body.close()

但现在我收到以下错误：

Error parsing the response body: http2: response body closed

解决方案

defer res.body.close() 应该在 func(c *gin.context){} 内哟。可以将您的搜索初始化移到 func 内并在其中执行类似的操作，并且可以在此处将客户端作为依赖项注入。

return func(c *gin.Context) {
          res, err := client.Search(
           client.Search.WithIndex(Index_Name),
           client.Search.WithSize(10),
           client.Search.WithPretty(),
          )
          defer res.Body.Close()
   }
}

今天关于《获取 Elasticsearch 响应》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！