Redis 在 Docker 环境下无法连接

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《Redis 在 Docker 环境下无法连接》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

我正在使用 redigo 创建一个 pubsub，并且连接是由 redis 池创建的。

这是 redis 池代码：

package main

import (
    "os"
    "os/signal"
    "syscall"
    "time"

    "github.com/gomodule/redigo/redis"
)

type iredis interface {
    addr() string
    conn() redis.conn
    set(key string, body string) error
    close()
}

type redis struct {
    addr string
    pool *redis.pool
}

func newredis(addr string) *redis {
    r := &redis{
        addr,
        &redis.pool{
            maxidle:     50000,
            idletimeout: 240 * time.second,
            dial: func() (redis.conn, error) {
                c, err := redis.dial("tcp", addr)
                if err != nil {
                    return nil, err
                }
                return c, err
            },
            testonborrow: func(c redis.conn, t time.time) error {
                _, err := c.do("ping")
                return err
            },
        },
    }

    r.cleanuphook()
    return r
}

func (r *redis) cleanuphook() {
    c := make(chan os.signal, 1)
    signal.notify(c, os.interrupt)
    signal.notify(c, syscall.sigterm)
    signal.notify(c, syscall.sigkill)
    go func() {
        <-c
        r.pool.close()
        os.exit(0)
    }()
}

func (r *redis) addr() string {
    return r.addr
}

func (r *redis) conn() redis.conn {
    return r.pool.get()
}

func (r *redis) set(key string, body string) error {
    p := r.pool.get()
    defer p.close()

    _, err := p.do("set", key, body)
    return err
}

func (r *redis) close() {
    r.pool.close()
}

这是我的 pubsub 代码：

package main

import (
    "log"

    "github.com/gomodule/redigo/redis"
)

type PubSub struct {
    send chan string
    conn *redis.PubSubConn
}

func NewPubSub(s chan string, c *redis.PubSubConn) (*PubSub, error) {
    err := c.Subscribe("urls")
    if err != nil {
        return nil, err
    }

    return &PubSub{s, c}, nil
}

func (ps *PubSub) Start() {
    for {
        switch v := ps.conn.Receive().(type) {
        case redis.Message:
            data := string(v.Data)
            ps.send <- data

        case redis.Subscription:
            log.Printf("subscription message: %s: %s %d\n", v.Channel, v.Kind, v.Count)

        case error:
            log.Println("error:", v)
            return
        }
    }
}

func (ps *PubSub) Close() {
    ps.conn.Close()
}

当我在 pubsub 频道中收到 10k 条消息后，连接丢失，我收到一条 redis.error 消息为 eof

有什么想法为什么会发生这种情况吗？ 即使我在本地运行也会出现问题

解决方案

问题出在 redisconf 中名为 client-output-buffer-limit pubsub 的参数上，默认值为 32mb 8mb 60，当达到限制时，redis 会关闭与 pubsub 的连接。 为了解决这个问题，我增加了该值。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Redis 在 Docker 环境下无法连接》文章吧，也可关注golang学习网公众号了解相关技术文章。