解决golang使用elastic连接elasticsearch

使用olivere/elastic连接elasticsearch时，发现连接地址明明输入的时候是公网地址，但是连接时会自动转换成内网地址或者docker中的ip地址，导致服务连接不上。

// 自动转换成docker中的ip导致无法连接服务
time="2019-02-15T20:04:26+08:00" level=error msg="Head http://172.17.0.2:9200: context deadline exceeded"

解决方法

client, _ := elastic.NewClient(
  // ...
  // 将sniff设置为false后，便不会自动转换地址
   elastic.SetSniff(false),
)

源码解析

// sniff 会请求http://ip:port/_nodes/http，将其返回的url list作为新的url list。
// 如果snifferEnabled被设置为false，那么则不启动该功能。
func (c *Client) sniff(parentCtx context.Context, timeout time.Duration) error {
    c.mu.RLock()
    if !c.snifferEnabled {
        c.mu.RUnlock()
        return nil
    }

    // Use all available URLs provided to sniff the cluster.
    var urls []string
    urlsMap := make(map[string]bool)

    // Add all URLs provided on startup
    for _, url := range c.urls {
        urlsMap[url] = true
        urls = append(urls, url)
    }
    c.mu.RUnlock()

    // Add all URLs found by sniffing
    c.connsMu.RLock()
    for _, conn := range c.conns {
        if !conn.IsDead() {
            url := conn.URL()
            if _, found := urlsMap[url]; !found {
                urls = append(urls, url)
            }
        }
    }
    c.connsMu.RUnlock()

    if len(urls) == 0 {
        return errors.Wrap(ErrNoClient, "no URLs found")
    }

    // Start sniffing on all found URLs
    ch := make(chan []*conn, len(urls))

    ctx, cancel := context.WithTimeout(parentCtx, timeout)
    defer cancel()

    for _, url := range urls {
        // sniffNode 方法使用http，请求了对应的url，将结果封装后返回
        go func(url string) { ch <- c.sniffNode(ctx, url) }(url)
    }

    // Wait for the results to come back, or the process times out.
    for {
        select {
        case conns := <-ch:
            if len(conns) > 0 {
                c.updateConns(conns)
                return nil
            }
        case <-ctx.Done():
            if err := ctx.Err(); err != nil {
                switch {
                case IsContextErr(err):
                    return err
                }
                return errors.Wrapf(ErrNoClient, "sniff timeout: %v", err)
            }
            // We get here if no cluster responds in time
            return errors.Wrap(ErrNoClient, "sniff timeout")
        }
    }
}