[GH-ISSUE #556] redis: discarding bad PubSub connection: read tcp 127.0.0.1:52914->127.0.0.1:63791: i/o timeout[BUG] Description of the bug

kerem commented

2026-03-02 05:20:03 +03:00

Owner

Originally created by @yun36524 on GitHub (Oct 13, 2022).
Original GitHub issue: https://github.com/hibiken/asynq/issues/556

Originally assigned to: @hibiken on GitHub.

redis: discarding bad PubSub connection: read tcp 127.0.0.1:52914->127.0.0.1:63791: i/o timeout
I can't run it, my redis is working fine

Originally created by @yun36524 on GitHub (Oct 13, 2022). Original GitHub issue: https://github.com/hibiken/asynq/issues/556 Originally assigned to: @hibiken on GitHub. redis: discarding bad PubSub connection: read tcp 127.0.0.1:52914->127.0.0.1:63791: i/o timeout I can't run it, my redis is working fine

kerem added the

bug

label

2026-03-02 05:20:03 +03:00

kerem commented

2026-03-02 05:20:03 +03:00

Author

Owner

@huizhang001 commented on GitHub (Oct 13, 2022):

Can you paste the code? Let me have a look？ @yun36524

@huizhang001 commented on GitHub (Oct 13, 2022): Can you paste the code? Let me have a look？ @yun36524

kerem commented

2026-03-02 05:20:03 +03:00

Author

Owner

@huizhang001 commented on GitHub (Oct 13, 2022):

I think there is a problem with your Redis port
port:6379 ?

@huizhang001 commented on GitHub (Oct 13, 2022): I think there is a problem with your Redis port port:6379 ?

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@yun36524 commented on GitHub (Oct 13, 2022):

I think there is a problem with your Redis port port:6379 ?

I'm sure there's nothing wrong with redis because my application is using it properly.
I am copying the official code and it does not work.

func InitServer() {
	srv := asynq.NewServer(
		asynq.RedisClientOpt{Addr: "127.0.0.1:63791", Password: "***", ReadTimeout: 10 * time.Second, WriteTimeout: 0},
		asynq.Config{
			// Specify how many concurrent workers to use
			Concurrency: 10,
			// Optionally specify multiple queues with different priority.
			Queues: map[string]int{
				"critical": 6,
				"default":  3,
				"low":      1,
			},
			// See the godoc for other configuration options
		},
	)

	// mux maps a type to a handler
	mux := asynq.NewServeMux()
	mux.HandleFunc("msg", HandleEmailDeliveryTask)
	// ...register other handlers...

	if err := srv.Run(mux); err != nil {
		log.Fatalf("could not run server: %v", err)
	}
}
func HandleEmailDeliveryTask(ctx context.Context, t *asynq.Task) error {

	fmt.Println("----------------")
	// Email delivery code ...
	return nil
}

@yun36524 commented on GitHub (Oct 13, 2022): > I think there is a problem with your Redis port port:6379 ? I'm sure there's nothing wrong with redis because my application is using it properly. I am copying the official code and it does not work. ```golang func InitServer() { srv := asynq.NewServer( asynq.RedisClientOpt{Addr: "127.0.0.1:63791", Password: "***", ReadTimeout: 10 * time.Second, WriteTimeout: 0}, asynq.Config{ // Specify how many concurrent workers to use Concurrency: 10, // Optionally specify multiple queues with different priority. Queues: map[string]int{ "critical": 6, "default": 3, "low": 1, }, // See the godoc for other configuration options }, ) // mux maps a type to a handler mux := asynq.NewServeMux() mux.HandleFunc("msg", HandleEmailDeliveryTask) // ...register other handlers... if err := srv.Run(mux); err != nil { log.Fatalf("could not run server: %v", err) } } func HandleEmailDeliveryTask(ctx context.Context, t *asynq.Task) error { fmt.Println("----------------") // Email delivery code ... return nil } ```

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@yun36524 commented on GitHub (Oct 13, 2022):

Anybody here?

@yun36524 commented on GitHub (Oct 13, 2022): Anybody here?

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@huizhang001 commented on GitHub (Oct 13, 2022):

I used your code, but it didn't reproduce. The suspicion is still related to Redis....

@huizhang001 commented on GitHub (Oct 13, 2022): I used your code, but it didn't reproduce. The suspicion is still related to Redis....

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@yun36524 commented on GitHub (Oct 13, 2022):

I used your code, but it didn't reproduce. The suspicion is still related to Redis....

I can run this code normally.
Is there any configuration to pay attention to in redis?

import(
    "github.com/go-redis/redis/v8"
    "fmt"
)
func main(){
	client := redis.NewClient(&redis.Options{
		Addr:     "127.0.0.1:63791",
		Password: "***",
	})
	client.SetNX(context.Background(), "msg", "hello", 10*time.Second)
	fmt.Println(client.Get(context.Background(), "msg"))
}

@yun36524 commented on GitHub (Oct 13, 2022): > I used your code, but it didn't reproduce. The suspicion is still related to Redis.... I can run this code normally. Is there any configuration to pay attention to in redis? ```golang import( "github.com/go-redis/redis/v8" "fmt" ) func main(){ client := redis.NewClient(&redis.Options{ Addr: "127.0.0.1:63791", Password: "***", }) client.SetNX(context.Background(), "msg", "hello", 10*time.Second) fmt.Println(client.Get(context.Background(), "msg")) } ```

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@yun36524 commented on GitHub (Oct 18, 2022):

Can someone help me

@yun36524 commented on GitHub (Oct 18, 2022): Can someone help me

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@xuyang2 commented on GitHub (Oct 18, 2022):

@yun36524
This is how I manage redis client, don't know if this will work for you:

import (
	"github.com/go-redis/redis/v8"
	"github.com/hibiken/asynq"
)

type CloseNopClient struct {
	redis.UniversalClient
}

// Close do nothing
// asynq.Scheduler Shutdown() will call client.Close()
func (c *CloseNopClient) Close() error {
	return nil
}

type clientHolder struct {
	client redis.UniversalClient
}

var _ asynq.RedisConnOpt = (*clientHolder)(nil)

func (opt clientHolder) MakeRedisClient() interface{} {
	return opt.client
}

func NewRedisConnOpt(client redis.UniversalClient) asynq.RedisConnOpt {
	return &clientHolder{
		client: &CloseNopClient{
			UniversalClient: client,
		},
	}
}

func Example() {
	client := redis.NewClient(&redis.Options{
		Addr:     "127.0.0.1:63791",
		Password: "***",
	})

	srv := asynq.NewServer(
		NewRedisConnOpt(client),
		asynq.Config{
			// Specify how many concurrent workers to use
			Concurrency: 10,
			// Optionally specify multiple queues with different priority.
			Queues: map[string]int{
				"critical": 6,
				"default":  3,
				"low":      1,
			},
			// See the godoc for other configuration options
		},
	)
}

@xuyang2 commented on GitHub (Oct 18, 2022): @yun36524 This is how I manage redis client, don't know if this will work for you: ``` import ( "github.com/go-redis/redis/v8" "github.com/hibiken/asynq" ) type CloseNopClient struct { redis.UniversalClient } // Close do nothing // asynq.Scheduler Shutdown() will call client.Close() func (c *CloseNopClient) Close() error { return nil } type clientHolder struct { client redis.UniversalClient } var _ asynq.RedisConnOpt = (*clientHolder)(nil) func (opt clientHolder) MakeRedisClient() interface{} { return opt.client } func NewRedisConnOpt(client redis.UniversalClient) asynq.RedisConnOpt { return &clientHolder{ client: &CloseNopClient{ UniversalClient: client, }, } } func Example() { client := redis.NewClient(&redis.Options{ Addr: "127.0.0.1:63791", Password: "***", }) srv := asynq.NewServer( NewRedisConnOpt(client), asynq.Config{ // Specify how many concurrent workers to use Concurrency: 10, // Optionally specify multiple queues with different priority. Queues: map[string]int{ "critical": 6, "default": 3, "low": 1, }, // See the godoc for other configuration options }, ) } ```

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@huizhang001 commented on GitHub (Oct 20, 2022):

If you use a mac, I suggest you re install redis with brew！！！！！

@huizhang001 commented on GitHub (Oct 20, 2022): If you use a mac, I suggest you re install redis with brew！！！！！

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@Crystalplan commented on GitHub (Nov 7, 2022):

I have the same problem and hope to get help. Redis is installed with Docker. Redis is normally in use

@Crystalplan commented on GitHub (Nov 7, 2022): I have the same problem and hope to get help. Redis is installed with Docker. Redis is normally in use

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@larryclean commented on GitHub (Nov 25, 2022):

@hibiken Hi,about the problem.I found that it is related to the redis option.
when
db>0 log print "discarding bad PubSub connection"
db=0 ,password="" don't print.
db=0 password="xxxx" log print "discarding bad PubSub connection"

@larryclean commented on GitHub (Nov 25, 2022): @hibiken Hi,about the problem.I found that it is related to the redis option. when db>0 log print "discarding bad PubSub connection" db=0 ,password="" don't print. db=0 password="xxxx" log print "discarding bad PubSub connection"

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@Crystalplan commented on GitHub (Dec 16, 2022):

Can someone help me

My solution is：
asynq.NewServer(
asynq.RedisClientOpt{Addr: "127.0.0.1:63791", Password: "***", ReadTimeout: -1, WriteTimeout: 0}............................

ReadTimeout set -1，won't print anymore

@Crystalplan commented on GitHub (Dec 16, 2022): > Can someone help me My solution is： asynq.NewServer( asynq.RedisClientOpt{Addr: "127.0.0.1:63791", Password: "***", ReadTimeout: -1, WriteTimeout: 0}............................ ReadTimeout set -1，won't print anymore

kerem commented

2026-03-02 05:20:04 +03:00

Author

Owner

@fzpixzj90h7baqieoop5hg commented on GitHub (Oct 31, 2023):

use localhost,,,

@fzpixzj90h7baqieoop5hg commented on GitHub (Oct 31, 2023): use localhost,,,

kerem referenced this issue

2026-03-02 06:05:18 +03:00

[PR #333] [MERGED] Introduce Task Results #714

kerem referenced this issue

2026-03-07 22:05:56 +03:00