pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:42144->127.0.0.1:6379: i/o timeout

[poembro]

Is this the best solution ？

• reference Answer
• I don't If this is right approach but when creating new Redis client setting ReadTimeout property to -1 fixed the problem for me.

redisClient := redis.NewClient(&redis.Options{
    Addr:        addr,
    Password:    redisConf.Password,
    DB:          0,  
    ReadTimeout: -1, // 
})

My code

func (s *Service) Consume() {
	ctx := context.TODO()

	pubsub := redis.RDSCli.Subscribe(ctx, "topic_a", "topic_b")
	defer pubsub.Close()
 
	if _, err := pubsub.Receive(ctx); err != nil {
		panic(err)
	}

	ch := pubsub.Channel()
	for {
		select {
		case msg, ok := <-ch:
			if !ok {
				logger.Logger.Debug("Consume", zap.String("desc", "redis err ;  chan close "))
				return
			}

			if len(msg.Payload) <= 0 {
				continue
			}
			if msg.Channel == "topic_a" {
				// ... more 
			}
			if msg.Channel == "topic_b" {
				// ... more 
			}
		}
	}

}

My log file

• Yes, consistent with the document, timed out every 3 seconds, and then output the log

redis: 2023/02/27 17:27:19 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:56204->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:22 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:60700->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:25 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:37804->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:28 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:42078->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:31 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:45328->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:34 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:48224->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:37 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:50910->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:40 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:53630->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:43 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:56444->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:46 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:59182->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:49 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:33778->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:52 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:36230->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:55 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:39122->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:27:58 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:42144->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:01 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:45390->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:04 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:48780->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:07 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:52200->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:10 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:56108->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:13 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:59588->127.0.0.1:6379: i/o timeout
redis: 2023/02/27 17:28:16 pubsub.go:159: redis: discarding bad PubSub connection: read tcp 127.0.0.1:34700->127.0.0.1:6379: i/o timeout

[monkey92t]

I think this has been resolved in #2175, you need to update the go-redis version.

[poembro]

Thanks, it has been resolved, this will be an upgrade from V8 to V9